Skip to content

Commit fbd4a04

Browse files
author
Mikael Ronström
committed
BUG#25334193: Fix a timing issue in flexAsynch
1 parent 4a0450a commit fbd4a04

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

storage/ndb/test/ndbapi/flexAsynch.cpp

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
Copyright (c) 2003, 2015, Oracle and/or its affiliates. All rights reserved.
2+
Copyright (c) 2003, 2016, Oracle and/or its affiliates. All rights reserved.
33
44
This program is free software; you can redistribute it and/or modify
55
it under the terms of the GNU General Public License as published by
@@ -1758,13 +1758,13 @@ receive_operations(THREAD_DATA *my_thread_data,
17581758
}
17591759
NdbMutex_Unlock(my_thread_data->transport_mutex);
17601760
if (first && wait &&
1761-
thread_list_header->num_in_list < ((tNoOfParallelTrans + 1) / 2))
1761+
list_header->num_in_list < ((tNoOfParallelTrans + 1) / 2))
17621762
{
17631763
/**
1764-
* We will wait for at least 2 milliseconds extra if we haven't yet
1764+
* We will wait for at least 1 milliseconds extra if we haven't yet
17651765
* received at least half of the number of records we desire to execute.
17661766
*/
1767-
NdbSleep_MicroSleep(2000);
1767+
NdbSleep_MicroSleep(1000);
17681768
first = false;
17691769
goto recheck;
17701770
}

0 commit comments

Comments
 (0)