/haiku/src/system/libnetwork/netresolv/resolv/ |
H A D | res_send.c | 864 struct timespec now, timeout, finish; local 971 timeout = evConsTime((time_t)seconds, 0L); 972 finish = evAddTime(now, timeout); 979 timeout = evSubTime(finish, now); 981 timeout = evConsTime(0L, 0L); 984 n = kevent(kq, &kv, 1, &kv, 1, &timeout); 988 n = pselect(s + 1, &dsmask, NULL, NULL, &timeout, NULL); 991 timeout = evSubTime(finish, now); 992 if (timeout.tv_sec < 0) 993 timeout [all...] |
/haiku/headers/posix/ |
H A D | signal.h | 169 #define SI_TIMER 2 /* signal sent on timer_settime() timeout */ 254 const struct timespec* timeout);
|
/haiku/src/system/kernel/ |
H A D | thread.cpp | 1394 common_snooze_etc(bigtime_t timeout, clockid_t clockID, uint32 flags, 1399 panic("common_snooze_etc(): called with interrupts disabled, timeout " 1400 "%" B_PRIdBIGTIME, timeout); 1422 status_t status = thread_block_with_timeout(flags, timeout); 1431 startTime + timeout - system_time(), (bigtime_t)0); 1435 *_remainingTime = std::max(timeout - now, (bigtime_t)0); 2504 wait_for_thread_etc(thread_id id, uint32 flags, bigtime_t timeout, 2572 status_t status = acquire_sem_etc(exitSem, 1, flags, timeout); 2581 // We were probably interrupted or the timeout occurred; we need to 2925 /*! Blocks the current thread with a timeout [all...] |
/haiku/headers/private/system/ |
H A D | syscalls.h | 76 uint32 flags, bigtime_t timeout); 82 int numInfos, uint32 flags, bigtime_t timeout); 86 uint32 flags, bigtime_t timeout); 90 bigtime_t timeout); 92 uint32 flags, bigtime_t timeout); 100 uint32 count, uint32 flags, bigtime_t timeout); 103 bigtime_t timeout); 124 bigtime_t timeout); 179 bigtime_t timeout, status_t *_returnCode); 206 extern status_t _kern_block_thread(uint32 flags, bigtime_t timeout); [all...] |
/haiku/headers/private/kernel/ |
H A D | thread.h | 137 status_t thread_block_with_timeout(uint32 timeoutFlags, bigtime_t timeout); 148 status_t _user_wait_for_thread_etc(thread_id id, uint32 flags, bigtime_t timeout, 150 status_t _user_snooze_etc(bigtime_t timeout, int timebase, uint32 flags, 164 status_t _user_block_thread(uint32 flags, bigtime_t timeout); 248 lock: 1. When thread_block_with_timeout() had been used and the timeout 253 unblocking code. A timeout can only happen after 287 decide whether a concurrent timeout/interruption can be ignored, or
|
H A D | wait_for_objects.h | 45 int numInfos, uint32 flags, bigtime_t timeout);
|
H A D | event_queue.h | 22 int numInfos, uint32 flags, bigtime_t timeout);
|
H A D | user_mutex.h | 22 bigtime_t timeout); 25 int32* toMutex, const char* name, uint32 toFlags, bigtime_t timeout); 27 bigtime_t timeout);
|
/haiku/src/apps/cortex/NodeManager/ |
H A D | NodeRef.cpp | 1408 bigtime_t timeout) { 1416 if(!m_manager->lock(type, timeout)) 1424 bool ret = m_group->lock(type, timeout); 1406 lock( lock_t type, bigtime_t timeout) argument
|
H A D | NodeManager.cpp | 975 bigtime_t timeout, 989 info, &node, timeout); 1005 info, &node, timeout); 1056 bigtime_t timeout, 1082 err = instantiate(info, outRef, timeout, nodeFlags); 1567 bigtime_t timeout) { 1571 status_t err = LockWithTimeout(timeout); 972 instantiate( const dormant_node_info& info, NodeRef** outRef, bigtime_t timeout, uint32 nodeFlags) argument 1052 instantiate( const entry_ref& file, uint64 requireNodeKinds, NodeRef** outRef, bigtime_t timeout, uint32 nodeFlags, bigtime_t* outDuration) argument 1565 lock( lock_t type, bigtime_t timeout) argument
|
H A D | NodeGroup.cpp | 872 bigtime_t timeout) { 877 status_t err = m_lock.LockWithTimeout(timeout); 1613 bigtime_t timeout = wakeUpAt - m_timeSourceObj->RealTime(); local 1615 if(timeout <= 0) { 1620 " by %" B_PRIdBIGTIME "\n", -timeout)); 1623 // +++++ if timeout is very short, spin until the target time arrives 1634 timeout); 870 lock( lock_t type, bigtime_t timeout) argument
|
/haiku/src/system/kernel/util/ |
H A D | ring_buffer.cpp | 353 uint32 flags, bigtime_t timeout) 364 flags, timeout); 376 status = writev_port_etc(port, code, vecs, 2, length, flags, timeout);
|
/haiku/src/add-ons/kernel/network/protocols/unix/ |
H A D | UnixFifo.cpp | 387 struct sockaddr_storage* address, bigtime_t timeout) 390 find_thread(NULL), this, vecs, vecCount, timeout); 399 status_t error = _Read(request, timeout); 433 const struct sockaddr_storage* address, bigtime_t timeout) 437 timeout); 450 status_t error = _Write(request, timeout); 522 UnixFifo::_Read(UnixRequest& request, bigtime_t timeout) argument 525 if (fReaders.Head() != &request && timeout == 0) 535 timeout); 549 if (timeout 385 Read(const iovec* vecs, size_t vecCount, ancillary_data_container** _ancillaryData, struct sockaddr_storage* address, bigtime_t timeout) argument 431 Write(const iovec* vecs, size_t vecCount, ancillary_data_container* ancillaryData, const struct sockaddr_storage* address, bigtime_t timeout) argument 581 _Write(UnixRequest& request, bigtime_t timeout) argument [all...] |
H A D | UnixEndpoint.h | 96 absolute_timeout(bigtime_t timeout) argument 98 if (timeout == 0 || timeout == B_INFINITE_TIMEOUT) 99 return timeout; 102 return timeout + system_time();
|
H A D | UnixFifo.h | 137 struct sockaddr_storage* address, bigtime_t timeout); 140 const struct sockaddr_storage* address, bigtime_t timeout); 151 status_t _Read(UnixRequest& request, bigtime_t timeout); 152 status_t _Write(UnixRequest& request, bigtime_t timeout);
|
/haiku/src/system/kernel/locks/ |
H A D | user_mutex.cpp | 330 uint32 flags, bigtime_t timeout, ReadLocker& locker) 336 return waiter.Wait(flags, timeout); 367 uint32 flags, bigtime_t timeout, ReadLocker& locker, bool isWired) 372 status_t error = user_mutex_wait_locked(entry, flags, timeout, locker); 419 uint32 flags, bigtime_t timeout, ReadLocker& locker, bool isWired) 432 timeout, locker); 520 user_mutex_lock(int32* mutex, const char* name, uint32 flags, bigtime_t timeout) 535 flags, timeout, entryLocker, contextFetcher.IsWired()); 545 int32* toMutex, const char* name, uint32 toFlags, bigtime_t timeout) 585 error = waiter.Wait(toFlags, timeout); [all...] |
/haiku/src/system/kernel/events/ |
H A D | wait_for_objects.cpp | 164 fd_set* errorSet, bigtime_t timeout) 167 fTimeout(timeout) 175 out.Print(", timeout: %" B_PRIdBIGTIME, fTimeout); 294 PollBegin(pollfd* fds, int count, bigtime_t timeout) argument 297 fTimeout(timeout) 306 out.Print(", timeout: %" B_PRIdBIGTIME, fTimeout); 440 bigtime_t timeout, const sigset_t *sigMask, bool kernel) 446 find_thread(NULL), numFDs, readSet, writeSet, errorSet, timeout, 465 T(SelectBegin(numFDs, readSet, writeSet, errorSet, timeout)); 503 B_CAN_INTERRUPT | (timeout > 163 SelectBegin(int count, fd_set* readSet, fd_set* writeSet, fd_set* errorSet, bigtime_t timeout) argument 439 common_select(int numFDs, fd_set *readSet, fd_set *writeSet, fd_set *errorSet, bigtime_t timeout, const sigset_t *sigMask, bool kernel) argument 569 common_poll(struct pollfd *fds, nfds_t numFDs, bigtime_t timeout, const sigset_t *sigMask, bool kernel) argument 660 common_wait_for_objects(object_wait_info* infos, int numInfos, uint32 flags, bigtime_t timeout, bool kernel) argument 906 _kern_select(int numFDs, fd_set *readSet, fd_set *writeSet, fd_set *errorSet, bigtime_t timeout, const sigset_t *sigMask) argument 918 _kern_poll(struct pollfd *fds, int numFDs, bigtime_t timeout, const sigset_t *sigMask) argument 929 _kern_wait_for_objects(object_wait_info* infos, int numInfos, uint32 flags, bigtime_t timeout) argument 952 _user_select(int numFDs, fd_set *userReadSet, fd_set *userWriteSet, fd_set *userErrorSet, bigtime_t timeout, const sigset_t *userSigMask) argument 1035 _user_poll(struct pollfd *userfds, int numFDs, bigtime_t timeout, const sigset_t *userSigMask) argument 1082 _user_wait_for_objects(object_wait_info* userInfos, int numInfos, uint32 flags, bigtime_t timeout) argument [all...] |
/haiku/src/libs/bsd/ |
H A D | kqueue.cpp | 184 bigtime_t timeout = 0; local 187 timeout = (tspec->tv_sec * 1000000LL) + (tspec->tv_nsec / 1000LL); 192 max_c(1, nevents / 2), waitFlags, timeout);
|
/haiku/headers/os/kernel/ |
H A D | OS.h | 30 B_TIMEOUT = 0x8, /* relative timeout */ 31 B_RELATIVE_TIMEOUT = 0x8, /* fails after a relative timeout 33 B_ABSOLUTE_TIMEOUT = 0x10, /* fails after an absolute timeout 135 size_t bufferSize, uint32 flags, bigtime_t timeout); 139 size_t bufferSize, uint32 flags, bigtime_t timeout); 145 bigtime_t timeout); 174 bigtime_t timeout); 176 #define get_port_message_info_etc(port, info, flags, timeout) \ 177 _get_port_message_info_etc((port), (info), sizeof(*(info)), flags, timeout) 213 bigtime_t timeout); [all...] |
/haiku/headers/compatibility/bsd/sys/ |
H A D | event.h | 109 const struct timespec *timeout);
|
/haiku/src/tests/add-ons/kernel/kernelland_emu/ |
H A D | condition_variable.cpp | 93 ConditionVariableEntry::Wait(uint32 flags, bigtime_t timeout) argument 108 while ((error = _kern_block_thread(flags, timeout)) == B_INTERRUPTED) { 118 bigtime_t timeout) 121 return Wait(flags, timeout); 203 ConditionVariable::Wait(uint32 flags, bigtime_t timeout) argument 207 return entry.Wait(flags, timeout); 117 Wait(const void* object, uint32 flags, bigtime_t timeout) argument
|
/haiku/src/system/libroot/posix/ |
H A D | semaphore.cpp | 164 const struct timespec* timeout) 172 if (timeout != NULL) { 173 timeoutMicros = ((bigtime_t)timeout->tv_sec) * 1000000 174 + timeout->tv_nsec / 1000; 210 const struct timespec* timeout) 212 if (timeout != NULL 213 && (timeout->tv_nsec < 0 || timeout->tv_nsec >= 1000000000)) { 224 if (timeout != NULL) { 225 timeoutMicros = ((bigtime_t)timeout 163 unnamed_sem_timedwait(sem_t* semaphore, clockid_t clock_id, const struct timespec* timeout) argument 209 named_sem_timedwait(sem_t* semaphore, clockid_t clock_id, const struct timespec* timeout) argument [all...] |
/haiku/src/kits/tracker/ |
H A D | TaskLoop.cpp | 193 bigtime_t period, bigtime_t timeout) 196 fTimeoutAfter(system_time() + timeout) 212 // if call didn't terminate the task yet, check if timeout is due 363 bigtime_t period, bigtime_t timeout) 366 timeout)); 506 for (int32 timeout = 10000; ; timeout--) { 507 // use a 10 sec timeout value in case the spawned 510 if (!timeout) { 191 PeriodicDelayedTaskWithTimeout( FunctionObjectWithResult<bool>* functor, bigtime_t initialDelay, bigtime_t period, bigtime_t timeout) argument 362 RunLater(FunctionObjectWithResult<bool>* functor, bigtime_t delay, bigtime_t period, bigtime_t timeout) argument
|
/haiku/src/kits/media/ |
H A D | MediaRoster.cpp | 1511 bigtime_t timeout) 1514 ", at timeout %" B_PRId64 "\n", node.node, atTime, timeout); 1532 sizeof(status), B_TIMEOUT, timeout); 1510 SyncToNode(const media_node& node, bigtime_t atTime, bigtime_t timeout) argument
|
/haiku/src/kits/app/ |
H A D | Message.cpp | 70 bigtime_t timeout, BMessage* reply); 113 handle_reply(port_id replyPort, int32* _code, bigtime_t timeout, argument 119 size = port_buffer_size_etc(replyPort, B_RELATIVE_TIMEOUT, timeout); 915 BMessage::SendReply(BMessage* reply, BHandler* replyTo, bigtime_t timeout) argument 919 return SendReply(reply, messenger, timeout); 924 BMessage::SendReply(BMessage* reply, BMessenger replyTo, bigtime_t timeout) argument 943 status_t result = messenger.SendMessage(reply, replyTo, timeout); 960 status_t result = messenger.SendMessage(reply, replyTo, timeout); 2127 bigtime_t timeout, bool replyRequired, BMessenger& replyTo) const 2237 size, B_RELATIVE_TIMEOUT, timeout); 2126 _SendMessage(port_id port, team_id portOwner, int32 token, bigtime_t timeout, bool replyRequired, BMessenger& replyTo) const argument 2389 _SendFlattenedMessage(void* data, int32 size, port_id port, int32 token, bigtime_t timeout) argument [all...] |