/haiku/src/servers/package/ |
H A D | Volume.cpp | 157 fPendingNodeMonitorEventsLock("pending node monitor events"), 730 // get the events 731 NodeMonitorEventList events; local 734 events.MoveFrom(&fPendingNodeMonitorEvents); 738 while (NodeMonitorEvent* event = events.RemoveHead()) { 876 // make sure for a move the two events cannot get split
|
/haiku/src/system/kernel/events/ |
H A D | event_queue.cpp | 39 #define EVENT_BEHAVIOR(events) ((events) & (B_EVENT_LEVEL_TRIGGERED | B_EVENT_ONE_SHOT)) 40 #define USER_EVENTS(events) ((events) & ~B_EVENT_PRIVATE_MASK) 100 status_t Select(int32 object, uint16 type, uint32 events, void* userData); 104 status_t Notify(select_info* info, uint16 events); 110 void _Notify(select_event* event, uint16 events); 141 * Notified when events are available on the queue. 173 event->events |= B_EVENT_DELETING; 180 if ((event->events 212 Select(int32 object, uint16 type, uint32 events, void* userData) argument 330 Notify(select_info* info, uint16 events) argument 339 _Notify(select_event* event, uint16 events) argument 437 int32 events = atomic_and(&event->events, local [all...] |
H A D | wait_for_objects.cpp | 56 uint16 events; member in struct:select_sync_pool_entry 72 virtual status_t Notify(select_info* info, uint16 events); 217 if (resultEvents ? fds[i].revents : fds[i].events) 228 uint16 events = resultEvents ? fds->revents : fds->events; local 229 if (events != 0) { 231 fEntries[i].events = events; 268 if ((fEntries[i].events & kEventNames[k].event) != 0) { 284 uint16 events; member in struct:WaitForObjectsTracing::PollTraceEntry::FDEntry 422 Notify(select_info* info, uint16 events) argument 731 notify_select_events(select_info* info, uint16 events) argument 744 notify_select_events_list(select_info* list, uint16 events) argument [all...] |
H A D | select_sync.h | 15 virtual status_t Notify(select_info* info, uint16 events) = 0;
|
/haiku/src/kits/network/libnetapi/ |
H A D | AbstractSocket.cpp | 311 entry.events = flags;
|
/haiku/src/system/kernel/ |
H A D | sem.cpp | 297 notify_sem_select_events(struct sem_entry* sem, uint16 events) argument 300 notify_select_events_list(sem->u.used.select_infos, events);
|
H A D | port.cpp | 615 /*! Notifies the port's select events. 619 notify_port_select_events(Port* port, uint16 events) argument 622 notify_select_events_list(port->select_infos, events); 1165 uint16 events = 0; local 1170 // check for events 1173 events |= B_EVENT_READ; 1177 events |= B_EVENT_WRITE; 1179 if (events != 0) 1180 notify_select_events(info, events);
|
/haiku/src/apps/debuganalyzer/model_loader/ |
H A D | ModelLoader.cpp | 27 // add a scheduling state snapshot every x events 203 system_profiler_event_header** events = fEvents; local 205 return events; 432 system_profiler_event_header** events; local 434 error = _CreateDebugEventArray(eventData, eventDataSize, events, 438 ArrayDeleter<system_profiler_event_header*> eventsDeleter(events); 446 eventDataSize, events, eventCount); 464 // process the events 603 // count the events 625 system_profiler_event_header** events local 746 system_profiler_event_header** events = fModel->Events(); local [all...] |
/haiku/src/system/libnetwork/netresolv/resolv/ |
H A D | res_send.c | 997 pollfd.events = POLLRDNORM;
|
/haiku/src/servers/launch/ |
H A D | LaunchDaemon.cpp | 93 /*! This class is the connection between the external events that are part of 462 // Jobs will be re-scanned later for unregistered external events. 546 // Launch run targets (ignores events) 1013 // Send registration messages for all already-known events. 1131 // Trigger events 1155 // Reset sticky events 1682 queue, except those that are triggered by events that haven't been 1685 Unless \a forceNow is true, the target is only launched if its events, 1768 queue, except those that are triggered by events. 1770 Unless \c FORCE_NOW is set, the target is only launched if its events, 1895 BMessage events; local [all...] |
/haiku/src/libs/bsd/ |
H A D | kqueue.cpp | 31 if (info.events > 0 && (info.events & B_EVENT_WRITE) != 0) 56 waitInfo->events = 0; 59 int32 events = 0, behavior = 0; local 63 events = B_EVENT_READ; 68 events = B_EVENT_WRITE; 74 events |= B_EVENT_INVALID; 122 waitInfo->events |= otherEvents; 124 waitInfo->events &= ~otherEvents; 131 info.events 191 ssize_t events = _kern_event_queue_wait(kq, waitInfos, local [all...] |
/haiku/headers/private/kernel/ |
H A D | wait_for_objects.h | 20 int32 events; member in struct:select_info 41 extern status_t notify_select_events(select_info* info, uint16 events); 42 extern void notify_select_events_list(select_info* list, uint16 events);
|
/haiku/headers/private/system/ |
H A D | event_queue_defs.h | 21 int32 events; /* select(): > 0 to select, -1 to get selection, 0 to deselect */ member in struct:event_wait_info
|
/haiku/headers/os/kernel/ |
H A D | OS.h | 647 uint16 events; /* events mask */ member in struct:object_wait_info 650 /* wait_for_objects[_etc]() waits until at least one of the specified events or, 652 object_wait_info::events field specifies the events for each object the 654 events that actually occurred. The events B_EVENT_INVALID, B_EVENT_ERROR,
|
/haiku/src/tools/fs_shell/ |
H A D | block_cache.cpp | 94 int32_t events; member in struct:FSShell::cache_notification 252 cache_notification ¬ification, int32_t events, 257 notification.events = events; 322 bool remove = (isClosing && !is_written_event(listener->events)) 323 || (isWritten && is_written_event(listener->events)); 327 if ((listener->events & event) != 0) 334 // most transaction events, we can do it here. 357 int32_t events, fssh_transaction_notification_hook hookFunction, void* data) 365 listener->events | 251 set_notification(cache_transaction* transaction, cache_notification ¬ification, int32_t events, fssh_transaction_notification_hook hook, void* data) argument 356 add_transaction_listener(block_cache* cache, cache_transaction* transaction, int32_t events, fssh_transaction_notification_hook hookFunction, void* data) argument 1365 fssh_cache_add_transaction_listener(void* _cache, int32_t id, int32_t events, fssh_transaction_notification_hook hookFunction, void* data) argument [all...] |
/haiku/src/system/kernel/vm/ |
H A D | VMCache.cpp | 72 uint32 events; member in struct:VMCache::PageEventWaiter 935 /*! Waits until one or more events happened for a given page which belongs to 940 \param events The mask of events the caller is interested in. 945 VMCache::WaitForPageEvents(vm_page* page, uint32 events, bool relock) argument 951 waiter.events = events; 1498 /*! Wakes up threads waiting for page events. 1499 \param page The page for which events occurred. 1500 \param events Th 1503 _NotifyPageEvents(vm_page* page, uint32 events) argument [all...] |
/haiku/src/tests/system/kernel/ |
H A D | fifo_poll_test.cpp | 8 * We should get these events (preferrably in this exact order): 22 pfd.events = POLLIN | POLLRDBAND; 40 printf("events=%08x revents=%08x\n", pfd.events, pfd.revents); 41 if ((pfd.events & pfd.revents) == 0)
|
/haiku/src/kits/device/ |
H A D | SerialPort.cpp | 476 info[0].events = B_EVENT_READ | B_EVENT_ERROR | B_EVENT_DISCONNECTED;
|
/haiku/src/bin/debug/strace/ |
H A D | NetworkTypes.cpp | 211 r += ", events="; 213 if ((tmp[i].events & POLLIN) != 0) { 219 if ((tmp[i].events & POLLOUT) != 0) {
|
/haiku/src/apps/poorman/ |
H A D | PoorManServer.cpp | 223 fds[0].events = POLLIN; 225 fds[1].events = POLLIN;
|
/haiku/src/apps/debuganalyzer/model/ |
H A D | Model.cpp | 342 Model::Thread::SetEvents(system_profiler_event_header** events, argument 345 fEvents = events; 623 system_profiler_event_header** events, size_t eventCount) 627 fEvents(events), 663 // The events themselves are unmodified and use an absolute time. 666 // Binary search the event. Since not all events have a timestamp, we have 622 Model(const char* dataSourceName, void* eventData, size_t eventDataSize, system_profiler_event_header** events, size_t eventCount) argument
|
/haiku/src/apps/debuganalyzer/gui/main_window/ |
H A D | SchedulingPage.cpp | 785 const Array<SchedulingEvent>& events local 787 int32 eventCount = events.Size(); 793 const SchedulingEvent& event = events[mid]; 801 threadState = events[lower].state; 802 threadStateTime = events[lower].time; 803 threadWaitObject = events[lower].waitObject; 805 threadStateEndTime = events[lower + 1].time; 816 system_profiler_event_header** events = fModel->Events(); local 828 system_profiler_event_header* header = events[eventIndex]; 922 // draw the events 951 const Array<SchedulingEvent>& events local 1259 const Array<IOSchedulingEvent>& events local [all...] |
/haiku/src/system/kernel/cache/ |
H A D | block_cache.cpp | 127 int32 events; member in struct:__anon39::cache_notification 877 cache_notification ¬ification, int32 events, 882 notification.events = events; 953 bool remove = (isClosing && !is_written_event(listener->events)) 954 || (isWritten && is_written_event(listener->events)); 958 if ((listener->events & event) != 0) 984 int32 events, transaction_notification_hook hookFunction, void* data) 992 listener->events |= events; 876 set_notification(cache_transaction* transaction, cache_notification ¬ification, int32 events, transaction_notification_hook hook, void* data) argument 983 add_transaction_listener(block_cache* cache, cache_transaction* transaction, int32 events, transaction_notification_hook hookFunction, void* data) argument 3251 cache_add_transaction_listener(void* _cache, int32 id, int32 events, transaction_notification_hook hook, void* data) argument [all...] |
/haiku/src/kits/network/libnetservices2/ |
H A D | HttpSession.cpp | 95 // Request state/events 369 if (data->objectList[0].events == B_EVENT_ACQUIRE_SEMAPHORE) { 403 data->objectList[offset].events = EVENT_CANCELLED; 410 } else if ((data->objectList[0].events & B_EVENT_INVALID) == B_EVENT_INVALID) { 420 if ((item.events & B_EVENT_WRITE) == B_EVENT_WRITE) { 438 } else if ((item.events & B_EVENT_READ) == B_EVENT_READ) { 467 } else if ((item.events & B_EVENT_DISCONNECTED) == B_EVENT_DISCONNECTED) { 477 } else if ((item.events & EVENT_CANCELLED) == EVENT_CANCELLED) { 489 } else if (item.events == 0) { 490 // No events fo [all...] |
/haiku/src/servers/input/ |
H A D | InputServer.cpp | 1462 fEventLooperPort = create_port(100, "input server events"); 1520 EventList events; local 1524 events.AddList(&fEventQueue); 1539 events.AddItem(event); 1544 if (_SanitizeEvents(events) 1545 && _MethodizeEvents(events) 1546 && _FilterEvents(events)) { 1547 _UpdateMouseAndKeys(events); 1548 _DispatchEvents(events); 1556 InputServer::_UpdateMouseAndKeys(EventList& events) argument 1620 _SanitizeEvents(EventList& events) argument 1708 _MethodizeEvents(EventList& events) argument 1802 _FilterEvents(EventList& events) argument 1825 _DispatchEvents(EventList& events) argument 1848 _FilterEvent(BInputServerFilter* filter, EventList& events, int32& index, int32& count) argument [all...] |