/dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/ndb/src/common/util/ |
H A D | socket_io.cpp | 35 int timeout_millis, int* total_elapsed_millis) in poll_socket() argument 39 timeout_millis -= *total_elapsed_millis; in poll_socket() 41 if (timeout_millis <= 0) in poll_socket() 45 ndb_poll(socket, read, write, false, timeout_millis); in poll_socket() 60 read_socket(NDB_SOCKET_TYPE socket, int timeout_millis, in read_socket() argument 67 timeout_millis, &elapsed_millis); in read_socket() 76 readln_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in readln_socket() argument 85 timeout_millis, time); in readln_socket() 168 write_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in write_socket() argument 171 if (poll_socket(socket, false, true, timeout_millis, time) != 1) in write_socket() [all …]
|
/dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/ndb/src/common/util/ |
H A D | socket_io.cpp | 35 int timeout_millis, int* total_elapsed_millis) in poll_socket() argument 39 timeout_millis -= *total_elapsed_millis; in poll_socket() 41 if (timeout_millis <= 0) in poll_socket() 45 ndb_poll(socket, read, write, false, timeout_millis); in poll_socket() 60 read_socket(NDB_SOCKET_TYPE socket, int timeout_millis, in read_socket() argument 67 timeout_millis, &elapsed_millis); in read_socket() 76 readln_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in readln_socket() argument 85 timeout_millis, time); in readln_socket() 168 write_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in write_socket() argument 171 if (poll_socket(socket, false, true, timeout_millis, time) != 1) in write_socket() [all …]
|
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/storage/ndb/src/common/util/ |
H A D | socket_io.cpp | 35 int timeout_millis, int* total_elapsed_millis) in poll_socket() argument 39 timeout_millis -= *total_elapsed_millis; in poll_socket() 41 if (timeout_millis <= 0) in poll_socket() 45 ndb_poll(socket, read, write, false, timeout_millis); in poll_socket() 60 read_socket(NDB_SOCKET_TYPE socket, int timeout_millis, in read_socket() argument 67 timeout_millis, &elapsed_millis); in read_socket() 76 readln_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in readln_socket() argument 85 timeout_millis, time); in readln_socket() 168 write_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in write_socket() argument 171 if (poll_socket(socket, false, true, timeout_millis, time) != 1) in write_socket() [all …]
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/src/common/util/ |
H A D | socket_io.cpp | 35 int timeout_millis, int* total_elapsed_millis) in poll_socket() argument 39 timeout_millis -= *total_elapsed_millis; in poll_socket() 41 if (timeout_millis <= 0) in poll_socket() 45 ndb_poll(socket, read, write, false, timeout_millis); in poll_socket() 60 read_socket(NDB_SOCKET_TYPE socket, int timeout_millis, in read_socket() argument 67 timeout_millis, &elapsed_millis); in read_socket() 76 readln_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in readln_socket() argument 85 timeout_millis, time); in readln_socket() 168 write_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in write_socket() argument 171 if (poll_socket(socket, false, true, timeout_millis, time) != 1) in write_socket() [all …]
|
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/src/common/util/ |
H A D | socket_io.cpp | 35 int timeout_millis, int* total_elapsed_millis) in poll_socket() argument 39 timeout_millis -= *total_elapsed_millis; in poll_socket() 41 if (timeout_millis <= 0) in poll_socket() 45 ndb_poll(socket, read, write, false, timeout_millis); in poll_socket() 60 read_socket(NDB_SOCKET_TYPE socket, int timeout_millis, in read_socket() argument 67 timeout_millis, &elapsed_millis); in read_socket() 76 readln_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in readln_socket() argument 85 timeout_millis, time); in readln_socket() 168 write_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in write_socket() argument 171 if (poll_socket(socket, false, true, timeout_millis, time) != 1) in write_socket() [all …]
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/src/common/util/ |
H A D | socket_io.cpp | 35 int timeout_millis, int* total_elapsed_millis) in poll_socket() argument 39 timeout_millis -= *total_elapsed_millis; in poll_socket() 41 if (timeout_millis <= 0) in poll_socket() 45 ndb_poll(socket, read, write, false, timeout_millis); in poll_socket() 60 read_socket(NDB_SOCKET_TYPE socket, int timeout_millis, in read_socket() argument 67 timeout_millis, &elapsed_millis); in read_socket() 76 readln_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in readln_socket() argument 85 timeout_millis, time); in readln_socket() 168 write_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in write_socket() argument 171 if (poll_socket(socket, false, true, timeout_millis, time) != 1) in write_socket() [all …]
|
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/src/common/util/ |
H A D | socket_io.cpp | 35 int timeout_millis, int* total_elapsed_millis) in poll_socket() argument 39 timeout_millis -= *total_elapsed_millis; in poll_socket() 41 if (timeout_millis <= 0) in poll_socket() 45 ndb_poll(socket, read, write, false, timeout_millis); in poll_socket() 60 read_socket(NDB_SOCKET_TYPE socket, int timeout_millis, in read_socket() argument 67 timeout_millis, &elapsed_millis); in read_socket() 76 readln_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in readln_socket() argument 85 timeout_millis, time); in readln_socket() 168 write_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in write_socket() argument 171 if (poll_socket(socket, false, true, timeout_millis, time) != 1) in write_socket() [all …]
|
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/src/common/util/ |
H A D | socket_io.cpp | 35 int timeout_millis, int* total_elapsed_millis) in poll_socket() argument 39 timeout_millis -= *total_elapsed_millis; in poll_socket() 41 if (timeout_millis <= 0) in poll_socket() 45 ndb_poll(socket, read, write, false, timeout_millis); in poll_socket() 60 read_socket(NDB_SOCKET_TYPE socket, int timeout_millis, in read_socket() argument 67 timeout_millis, &elapsed_millis); in read_socket() 76 readln_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in readln_socket() argument 85 timeout_millis, time); in readln_socket() 168 write_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in write_socket() argument 171 if (poll_socket(socket, false, true, timeout_millis, time) != 1) in write_socket() [all …]
|
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/src/common/util/ |
H A D | socket_io.cpp | 35 int timeout_millis, int* total_elapsed_millis) in poll_socket() argument 39 timeout_millis -= *total_elapsed_millis; in poll_socket() 41 if (timeout_millis <= 0) in poll_socket() 45 ndb_poll(socket, read, write, false, timeout_millis); in poll_socket() 60 read_socket(NDB_SOCKET_TYPE socket, int timeout_millis, in read_socket() argument 67 timeout_millis, &elapsed_millis); in read_socket() 76 readln_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in readln_socket() argument 85 timeout_millis, time); in readln_socket() 168 write_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in write_socket() argument 171 if (poll_socket(socket, false, true, timeout_millis, time) != 1) in write_socket() [all …]
|
/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/storage/ndb/src/common/util/ |
H A D | socket_io.cpp | 35 int timeout_millis, int* total_elapsed_millis) in poll_socket() argument 39 timeout_millis -= *total_elapsed_millis; in poll_socket() 41 if (timeout_millis <= 0) in poll_socket() 45 ndb_poll(socket, read, write, false, timeout_millis); in poll_socket() 60 read_socket(NDB_SOCKET_TYPE socket, int timeout_millis, in read_socket() argument 67 timeout_millis, &elapsed_millis); in read_socket() 76 readln_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in readln_socket() argument 85 timeout_millis, time); in readln_socket() 168 write_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in write_socket() argument 171 if (poll_socket(socket, false, true, timeout_millis, time) != 1) in write_socket() [all …]
|
/dports/databases/mysql56-client/mysql-5.6.51/storage/ndb/src/common/util/ |
H A D | socket_io.cpp | 35 int timeout_millis, int* total_elapsed_millis) in poll_socket() argument 39 timeout_millis -= *total_elapsed_millis; in poll_socket() 41 if (timeout_millis <= 0) in poll_socket() 45 ndb_poll(socket, read, write, false, timeout_millis); in poll_socket() 60 read_socket(NDB_SOCKET_TYPE socket, int timeout_millis, in read_socket() argument 67 timeout_millis, &elapsed_millis); in read_socket() 76 readln_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in readln_socket() argument 85 timeout_millis, time); in readln_socket() 168 write_socket(NDB_SOCKET_TYPE socket, int timeout_millis, int *time, in write_socket() argument 171 if (poll_socket(socket, false, true, timeout_millis, time) != 1) in write_socket() [all …]
|
/dports/databases/mysql55-client/mysql-5.5.62/storage/ndb/src/common/util/ |
H A D | socket_io.cpp | 26 read_socket(NDB_SOCKET_TYPE socket, int timeout_millis, in read_socket() argument 36 timeout.tv_sec = (timeout_millis / 1000); in read_socket() 37 timeout.tv_usec = (timeout_millis % 1000) * 1000; in read_socket() 62 timeout.tv_sec = (timeout_millis / 1000); in readln_socket() 63 timeout.tv_usec = (timeout_millis % 1000) * 1000; in readln_socket() 134 timeout.tv_sec = ((timeout_millis - *time) / 1000); in readln_socket() 135 timeout.tv_usec = ((timeout_millis - *time) % 1000) * 1000; in readln_socket() 157 timeout.tv_sec = (timeout_millis / 1000); in write_socket() 158 timeout.tv_usec = (timeout_millis % 1000) * 1000; in write_socket() 183 timeout.tv_sec = ((timeout_millis - *time) / 1000); in write_socket() [all …]
|
/dports/net/seda/seda-release-20020712/seda/src/seda/sandStorm/core/ |
H A D | FiniteQueue.java | 229 if ((rets != null) || (timeout_millis == 0)) { in blocking_dequeue_all() 234 if (timeout_millis == -1) { in blocking_dequeue_all() 242 blocker.wait(timeout_millis); in blocking_dequeue_all() 255 if (timeout_millis != -1) { in blocking_dequeue_all() 276 if ((rets != null) || (timeout_millis == 0)) { in blocking_dequeue() 280 if (timeout_millis == -1) { in blocking_dequeue() 287 blocker.wait(timeout_millis); in blocking_dequeue() 297 if (timeout_millis != -1) { in blocking_dequeue() 326 if (timeout_millis == -1) { in blocking_dequeue() 333 blocker.wait(timeout_millis); in blocking_dequeue() [all …]
|
/dports/biology/seqan1/seqan-1.3.1/seqan/system/ |
H A D | system_event.h | 101 inline bool wait(DWORD timeout_millis = Infinite) { 103 return WaitForSingleObject(hEvent, timeout_millis) != WAIT_TIMEOUT; 127 inline bool waitForAll(Event eventList[], DWORD count, DWORD timeout_millis) in waitForAll() argument 137 inline int waitForAny(Event eventList[], DWORD count, DWORD timeout_millis) in waitForAny() argument 219 inline bool wait(long timeout_millis) { 220 if (timeout_millis != Infinite) { 222 ts.tv_sec = timeout_millis / 1000; 223 ts.tv_nsec = (timeout_millis % 1000) * 1000; 262 inline bool waitFor(Event &e, TTime timeout_millis) { in waitFor() argument 265 bool b = e.wait(timeout_millis); in waitFor() [all …]
|
/dports/net/seda/seda-release-20020712/seda/src/seda/sandStorm/lib/aSocket/nbio/ |
H A D | SelectSource.java | 261 if (timeout_millis == 0) return null; in blocking_dequeue() 264 if (timeout_millis == -1) { in blocking_dequeue() 271 blocker.wait(timeout_millis); in blocking_dequeue() 279 doPoll(timeout_millis); in blocking_dequeue() 293 if (timeout_millis == 0) return null; in blocking_dequeue_all() 296 if (timeout_millis == -1) { in blocking_dequeue_all() 303 blocker.wait(timeout_millis); in blocking_dequeue_all() 311 doPoll(timeout_millis); in blocking_dequeue_all() 332 if (timeout_millis == -1) { in blocking_dequeue() 339 blocker.wait(timeout_millis); in blocking_dequeue() [all …]
|
/dports/net/seda/seda-release-20020712/seda/src/seda/sandStorm/lib/aSocket/nio/ |
H A D | NIOSelectSource.java | 303 if (timeout_millis == 0) return null; in blocking_dequeue() 306 if (timeout_millis == -1) { in blocking_dequeue() 313 blocker.wait(timeout_millis); in blocking_dequeue() 321 doPoll(timeout_millis); in blocking_dequeue() 344 if (timeout_millis == 0) return null; in blocking_dequeue_all() 346 if (timeout_millis == -1) { in blocking_dequeue_all() 353 blocker.wait(timeout_millis); in blocking_dequeue_all() 361 doPoll(timeout_millis); in blocking_dequeue_all() 387 if (timeout_millis == -1) { in blocking_dequeue() 394 blocker.wait(timeout_millis); in blocking_dequeue() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/blink/renderer/core/dom/ |
H A D | scripted_idle_task_controller.cc | 125 uint32_t timeout_millis = options->timeout(); in RegisterCallback() local 127 idle_task, queue_timestamp, timeout_millis)); in RegisterCallback() 134 ScheduleCallback(std::move(callback_wrapper), timeout_millis); in RegisterCallback() 138 GetExecutionContext(), id, timeout_millis)); in RegisterCallback() 144 uint32_t timeout_millis) { in ScheduleCallback() argument 148 if (timeout_millis > 0) { in ScheduleCallback() 155 base::TimeDelta::FromMilliseconds(timeout_millis)); in ScheduleCallback() 277 queued_idle_task->timeout_millis()); in RecordIdleTaskMetrics() 287 queued_idle_task->timeout_millis()); in RecordIdleTaskMetrics() 294 uint32_t timeout_millis) in QueuedIdleTask() argument [all …]
|
/dports/net-p2p/vuze/vuze-5.7.4.0_2/org/gudy/azureus2/pluginsimpl/local/utils/resourcedownloader/ |
H A D | ResourceDownloaderTimeoutImpl.java | 39 protected int timeout_millis; field in ResourceDownloaderTimeoutImpl 61 timeout_millis = _timeout_millis; in ResourceDownloaderTimeoutImpl() 67 return( delegate.getName() + ": timeout=" + timeout_millis ); in getName() 81 …pl x = new ResourceDownloaderTimeoutImpl( getParent(), delegate.getClone( this ), timeout_millis ); in getSize() 130 … c = new ResourceDownloaderTimeoutImpl( getParent(), delegate.getClone( parent ), timeout_millis ); in getClone() 178 Thread.sleep( timeout_millis ); in asyncDownload() 257 Thread.sleep( timeout_millis ); in asyncGetSize()
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/src/ndbapi/ |
H A D | WakeupHandler.cpp | 125 int timeout_millis, in waitForInput() argument 178 const int maxTime = timeout_millis; in waitForInput() 199 pg.wait_for_input(timeout_millis > 10 ? 10 : timeout_millis); in waitForInput() 210 timeout_millis = (maxTime - (int)NdbTick_Elapsed(start,now).milliSec()); in waitForInput() 211 if (timeout_millis <= 0) in waitForInput()
|
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/src/ndbapi/ |
H A D | WakeupHandler.cpp | 125 int timeout_millis, in waitForInput() argument 178 const int maxTime = timeout_millis; in waitForInput() 199 pg.wait_for_input(timeout_millis > 10 ? 10 : timeout_millis); in waitForInput() 210 timeout_millis = (maxTime - (int)NdbTick_Elapsed(start,now).milliSec()); in waitForInput() 211 if (timeout_millis <= 0) in waitForInput()
|
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/src/ndbapi/ |
H A D | WakeupHandler.cpp | 125 int timeout_millis, in waitForInput() argument 178 const int maxTime = timeout_millis; in waitForInput() 199 pg.wait_for_input(timeout_millis > 10 ? 10 : timeout_millis); in waitForInput() 210 timeout_millis = (maxTime - (int)NdbTick_Elapsed(start,now).milliSec()); in waitForInput() 211 if (timeout_millis <= 0) in waitForInput()
|
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/src/ndbapi/ |
H A D | WakeupHandler.cpp | 125 int timeout_millis, in waitForInput() argument 178 const int maxTime = timeout_millis; in waitForInput() 199 pg.wait_for_input(timeout_millis > 10 ? 10 : timeout_millis); in waitForInput() 210 timeout_millis = (maxTime - (int)NdbTick_Elapsed(start,now).milliSec()); in waitForInput() 211 if (timeout_millis <= 0) in waitForInput()
|
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/src/ndbapi/ |
H A D | WakeupHandler.cpp | 125 int timeout_millis, in waitForInput() argument 178 const int maxTime = timeout_millis; in waitForInput() 199 pg.wait_for_input(timeout_millis > 10 ? 10 : timeout_millis); in waitForInput() 210 timeout_millis = (maxTime - (int)NdbTick_Elapsed(start,now).milliSec()); in waitForInput() 211 if (timeout_millis <= 0) in waitForInput()
|
/dports/net/seda/seda-release-20020712/seda/src/seda/sandStorm/api/ |
H A D | SourceIF.java | 63 public QueueElementIF blocking_dequeue(int timeout_millis); in blocking_dequeue() argument 81 public QueueElementIF[] blocking_dequeue_all(int timeout_millis); in blocking_dequeue_all() argument 88 public QueueElementIF[] blocking_dequeue(int timeout_millis, int num); in blocking_dequeue() argument
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/core/dom/ |
H A D | scripted_idle_task_controller.cc | 122 uint32_t timeout_millis = options->timeout(); in RegisterCallback() local 129 ScheduleCallback(std::move(callback_wrapper), timeout_millis); in RegisterCallback() 133 GetExecutionContext(), id, timeout_millis)); in RegisterCallback() 139 uint32_t timeout_millis) { in ScheduleCallback() argument 143 if (timeout_millis > 0) { in ScheduleCallback() 150 base::TimeDelta::FromMilliseconds(timeout_millis)); in ScheduleCallback()
|