Home
last modified time | relevance | path

Searched refs:events (Results 1 – 25 of 505) sorted by relevance

12345678910>>...21

/packages/modules/Connectivity/service-t/native/libs/libnetworkstats/
DNetworkTraceHandlerTest.cpp121 std::vector<TracePacket> events; in TEST_F() local
122 ASSERT_TRUE(TraceAndSortPackets(input, &events)); in TEST_F()
124 ASSERT_EQ(events.size(), 1); in TEST_F()
125 EXPECT_THAT(events[0].timestamp(), 1000); in TEST_F()
126 EXPECT_THAT(events[0].network_packet().uid(), 10); in TEST_F()
127 EXPECT_THAT(events[0].network_packet().tag(), 123); in TEST_F()
128 EXPECT_THAT(events[0].network_packet().ip_proto(), 6); in TEST_F()
129 EXPECT_THAT(events[0].network_packet().tcp_flags(), 1); in TEST_F()
130 EXPECT_THAT(events[0].network_packet().length(), 100); in TEST_F()
131 EXPECT_THAT(events[0].has_sequence_flags(), false); in TEST_F()
[all …]
/packages/modules/StatsD/statsd/benchmark/
Dduration_metric_benchmark.cpp140 std::vector<std::unique_ptr<LogEvent>> events; in BM_DurationMetricNoLink() local
142 events.push_back(CreateScreenStateChangedEvent(bucketStartTimeNs + 11, in BM_DurationMetricNoLink()
144 events.push_back( in BM_DurationMetricNoLink()
147 events.push_back(CreateScreenStateChangedEvent(bucketStartTimeNs + 102, in BM_DurationMetricNoLink()
149 events.push_back(CreateScreenStateChangedEvent(bucketStartTimeNs + 450, in BM_DurationMetricNoLink()
152 events.push_back(CreateScreenStateChangedEvent(bucketStartTimeNs + 650, in BM_DurationMetricNoLink()
154 events.push_back(CreateScreenStateChangedEvent(bucketStartTimeNs + bucketSizeNs + 100, in BM_DurationMetricNoLink()
157 events.push_back(CreateScreenStateChangedEvent(bucketStartTimeNs + bucketSizeNs + 640, in BM_DurationMetricNoLink()
159 events.push_back(CreateScreenStateChangedEvent(bucketStartTimeNs + bucketSizeNs + 650, in BM_DurationMetricNoLink()
164 events.push_back(CreateStartScheduledJobEvent(bucketStartTimeNs + 2, attributionUids1, in BM_DurationMetricNoLink()
[all …]
/packages/modules/Telephony/services/QualifiedNetworksService/tests/src/com/android/telephony/qns/
DQnsEventDispatcherTest.java138 List<Integer> events = new ArrayList<Integer>(); in testOnReceivedCarrierConfigChangedIntent() local
139 events.add(QnsEventDispatcher.QNS_EVENT_CARRIER_CONFIG_CHANGED); in testOnReceivedCarrierConfigChangedIntent()
140 events.add(QnsEventDispatcher.QNS_EVENT_CARRIER_CONFIG_UNKNOWN_CARRIER); in testOnReceivedCarrierConfigChangedIntent()
141 mQnsEventDispatcher.registerEvent(events, mMockHandler); in testOnReceivedCarrierConfigChangedIntent()
169 List<Integer> events = new ArrayList<Integer>(); in testOnReceivedCarrierConfigChangedIntentWithInvalidSlot() local
170 events.add(QnsEventDispatcher.QNS_EVENT_CARRIER_CONFIG_CHANGED); in testOnReceivedCarrierConfigChangedIntentWithInvalidSlot()
171 events.add(QnsEventDispatcher.QNS_EVENT_CARRIER_CONFIG_UNKNOWN_CARRIER); in testOnReceivedCarrierConfigChangedIntentWithInvalidSlot()
172 mQnsEventDispatcher.registerEvent(events, mMockHandler); in testOnReceivedCarrierConfigChangedIntentWithInvalidSlot()
197 List<Integer> events = new ArrayList<Integer>(); in testOnSimLoadedStateEvent() local
198 events.add(QnsEventDispatcher.QNS_EVENT_SIM_LOADED); in testOnSimLoadedStateEvent()
[all …]
/packages/modules/StatsD/statsd/tests/e2e/
DMetricConditionLink_e2e_test.cpp171 std::vector<std::unique_ptr<LogEvent>> events; in TEST() local
172 events.push_back(std::move(crashEvent1)); in TEST()
173 events.push_back(std::move(crashEvent2)); in TEST()
174 events.push_back(std::move(crashEvent3)); in TEST()
175 events.push_back(std::move(crashEvent4)); in TEST()
176 events.push_back(std::move(crashEvent5)); in TEST()
177 events.push_back(std::move(crashEvent6)); in TEST()
178 events.push_back(std::move(crashEvent7)); in TEST()
179 events.push_back(std::move(crashEvent8)); in TEST()
180 events.push_back(std::move(crashEvent9)); in TEST()
[all …]
DCountMetric_e2e_test.cpp171 std::vector<std::unique_ptr<LogEvent>> events; in TEST() local
173 events.push_back(CreateScreenStateChangedEvent( in TEST()
177 events.push_back(CreateSyncStartEvent(bucketStartTimeNs + 60 * NS_PER_SEC, attributionUids1, in TEST()
180 events.push_back(CreateAppCrashEvent(activationStart1Ns, 111)); // 1:20 in TEST()
181 events.push_back(CreateSyncStartEvent(bucketStartTimeNs + 75 * NS_PER_SEC, attributionUids1, in TEST()
185 events.push_back(CreateSyncStartEvent(bucket2StartTimeNs + 20 * NS_PER_SEC, attributionUids1, in TEST()
188 events.push_back(CreateScreenStateChangedEvent( in TEST()
192 events.push_back(CreateSyncStartEvent(bucket2StartTimeNs + 50 * NS_PER_SEC, attributionUids1, in TEST()
195 events.push_back(CreateScreenStateChangedEvent( in TEST()
198 events.push_back(CreateSyncStartEvent(bucket2StartTimeNs + 110 * NS_PER_SEC, attributionUids1, in TEST()
[all …]
DAttribution_e2e_test.cpp116 std::vector<std::unique_ptr<LogEvent>> events; in TEST() local
118 events.push_back(CreateAcquireWakelockEvent(bucketStartTimeNs + 2, attributionUids1, in TEST()
120 events.push_back(CreateAcquireWakelockEvent(bucketStartTimeNs + 200, attributionUids2, in TEST()
122 events.push_back(CreateAcquireWakelockEvent(bucketStartTimeNs + bucketSizeNs - 1, in TEST()
124 events.push_back(CreateAcquireWakelockEvent(bucketStartTimeNs + bucketSizeNs, attributionUids4, in TEST()
128 events.push_back(CreateAcquireWakelockEvent(bucketStartTimeNs + 2 * bucketSizeNs + 1, in TEST()
130 events.push_back(CreateAcquireWakelockEvent(bucketStartTimeNs + 2 * bucketSizeNs + 100, in TEST()
132 events.push_back(CreateAcquireWakelockEvent(bucketStartTimeNs + 3 * bucketSizeNs - 2, in TEST()
134 events.push_back(CreateAcquireWakelockEvent(bucketStartTimeNs + 3 * bucketSizeNs, in TEST()
136 events.push_back(CreateAcquireWakelockEvent(bucketStartTimeNs + 3 * bucketSizeNs + 1, in TEST()
[all …]
DRestrictedEventMetric_e2e_test.cpp141 std::vector<std::unique_ptr<LogEvent>> events; in TEST_F() local
143 events.push_back(CreateRestrictedLogEvent(atomTag, configAddedTimeNs + 100)); in TEST_F()
144 events.push_back(CreateRestrictedLogEvent(atomTag, configAddedTimeNs + 200)); in TEST_F()
145 events.push_back(CreateRestrictedLogEvent(atomTag, configAddedTimeNs + 300)); in TEST_F()
148 for (auto& event : events) { in TEST_F()
179 std::vector<std::unique_ptr<LogEvent>> events; in TEST_F() local
193 events.push_back(CreateRestrictedLogEvent(atomTag, configAddedTimeNs + 100)); in TEST_F()
194 events.push_back(std::move(logEvent)); in TEST_F()
197 for (auto& event : events) { in TEST_F()
226 std::vector<std::unique_ptr<LogEvent>> events; in TEST_F() local
[all …]
DKllMetric_e2e_test.cpp58 events.push_back(CreateScreenBrightnessChangedEvent(bucketStartTimeNs + 5 * NS_PER_SEC, 5)); in SetUp()
59 events.push_back( in SetUp()
61 events.push_back( in SetUp()
71 vector<unique_ptr<LogEvent>> events; member in android::os::statsd::KllMetricE2eTest
78 for (auto& event : events) { in TEST_F()
122 events.clear(); in TEST_F()
123 events.push_back(CreateTestAtomReportedEvent(bucketStartTimeNs + 5 * NS_PER_SEC, 5l, "dim_1")); in TEST_F()
124 events.push_back(CreateTestAtomReportedEvent(bucketStartTimeNs + 15 * NS_PER_SEC, 6l, "dim_2")); in TEST_F()
125 events.push_back(CreateTestAtomReportedEvent(bucketStartTimeNs + 25 * NS_PER_SEC, 7l, "dim_1")); in TEST_F()
130 for (auto& event : events) { in TEST_F()
[all …]
DWakelockDuration_e2e_test.cpp98 std::vector<std::unique_ptr<LogEvent>> events; in FeedEvents() local
100 events.push_back(std::move(screenTurnedOnEvent)); in FeedEvents()
101 events.push_back(std::move(screenTurnedOffEvent)); in FeedEvents()
102 events.push_back(std::move(screenTurnedOnEvent2)); in FeedEvents()
103 events.push_back(std::move(acquireEvent1)); in FeedEvents()
104 events.push_back(std::move(acquireEvent2)); in FeedEvents()
105 events.push_back(std::move(releaseEvent1)); in FeedEvents()
106 events.push_back(std::move(releaseEvent2)); in FeedEvents()
108 sortLogEventsByTimestamp(&events); in FeedEvents()
110 for (const auto& event : events) { in FeedEvents()
[all …]
DGaugeMetric_e2e_push_test.cpp145 std::vector<std::unique_ptr<LogEvent>> events; in TEST_F() local
146 events.push_back(CreateMoveToBackgroundEvent(bucketStartTimeNs + 15, appUid1)); in TEST_F()
147 events.push_back( in TEST_F()
149 events.push_back( in TEST_F()
151 events.push_back( in TEST_F()
154 events.push_back(CreateAppStartOccurredEvent( in TEST_F()
157 events.push_back(CreateAppStartOccurredEvent( in TEST_F()
160 events.push_back(CreateAppStartOccurredEvent( in TEST_F()
163 events.push_back(CreateAppStartOccurredEvent( in TEST_F()
167 events.push_back(CreateAppStartOccurredEvent( in TEST_F()
[all …]
DConfigUpdate_e2e_test.cpp142 std::vector<std::unique_ptr<LogEvent>> events; in TEST_P() local
143 events.push_back(CreateAcquireWakelockEvent(bucketStartTimeNs + 5 * NS_PER_SEC, in TEST_P()
146 events.push_back(CreateScreenStateChangedEvent( in TEST_P()
149 events.push_back(CreateSyncStartEvent(bucketStartTimeNs + 15 * NS_PER_SEC, attributionUids1, in TEST_P()
152 events.push_back(CreateBatteryStateChangedEvent( in TEST_P()
155 events.push_back(CreateAcquireWakelockEvent(bucketStartTimeNs + 25 * NS_PER_SEC, in TEST_P()
158 events.push_back(CreateScreenStateChangedEvent( in TEST_P()
161 events.push_back(CreateSyncStartEvent(bucketStartTimeNs + 35 * NS_PER_SEC, attributionUids1, in TEST_P()
164 events.push_back(CreateAcquireWakelockEvent(bucketStartTimeNs + 40 * NS_PER_SEC, in TEST_P()
169 for (auto& event : events) { in TEST_P()
[all …]
/packages/modules/adb/fdevent/
Dfdevent_epoll.cpp64 result.events = 0; in calculate_epoll_event()
66 result.events |= EPOLLIN; in calculate_epoll_event()
69 result.events |= EPOLLOUT; in calculate_epoll_event()
72 result.events |= EPOLLERR; in calculate_epoll_event()
74 result.events |= EPOLLRDHUP; in calculate_epoll_event()
92 void fdevent_context_epoll::Set(fdevent* fde, unsigned events) { in Set() argument
94 fde->state = events; in Set()
97 if ((previous_state & ~FDE_TIMEOUT) == (events & ~FDE_TIMEOUT)) { in Set()
147 unsigned events = 0; in Loop() local
148 if (epoll_events[i].events & EPOLLIN) { in Loop()
[all …]
Dfdevent_poll.cpp82 void fdevent_context_poll::Set(fdevent* fde, unsigned events) { in Set() argument
84 fde->state = events; in Set()
85 D("fdevent_set: %s, events = %u", dump_fde(fde).c_str(), events); in Set()
92 if (pollfd.events & POLLIN) { in dump_pollfds()
95 if (pollfd.events & POLLOUT) { in dump_pollfds()
119 pfd.events = 0; in Loop()
121 pfd.events |= POLLIN; in Loop()
124 pfd.events |= POLLOUT; in Loop()
127 pfd.events |= POLLERR; in Loop()
130 pfd.events |= POLLRDHUP; in Loop()
[all …]
Dfdevent_test.cpp57 static void FdEventCallback(int fd, unsigned events, void* userdata) { in FdEventCallback() argument
59 ASSERT_EQ(0u, (events & ~(FDE_READ | FDE_WRITE))) << "unexpected events: " << events; in FdEventCallback()
60 if (events & FDE_READ) { in FdEventCallback()
67 if (events & FDE_WRITE) { in FdEventCallback()
79 static void FdEventNewCallback(fdevent* fde, unsigned events, void* userdata) { in FdEventNewCallback() argument
82 ASSERT_EQ(0u, (events & ~(FDE_READ | FDE_WRITE))) << "unexpected events: " << events; in FdEventNewCallback()
83 if (events & FDE_READ) { in FdEventNewCallback()
90 if (events & FDE_WRITE) { in FdEventNewCallback()
233 std::vector<std::pair<TimeoutEvent, std::chrono::steady_clock::time_point>> events; in TEST_F() member
242 test.fde = fdevent_create(fds[0], [](fdevent* fde, unsigned events, void* arg) { in TEST_F() argument
[all …]
Dfdevent.cpp38 void invoke_fde(struct fdevent* fde, unsigned events) { in invoke_fde() argument
40 (*f)(fde->fd.get(), events, fde->arg); in invoke_fde()
42 (*f)(fde, events, fde->arg); in invoke_fde()
110 void fdevent_context::Add(fdevent* fde, unsigned events) { in Add() argument
111 CHECK(!(events & FDE_TIMEOUT)); in Add()
112 Set(fde, fde->state | events); in Add()
115 void fdevent_context::Del(fdevent* fde, unsigned events) { in Del() argument
116 CHECK(!(events & FDE_TIMEOUT)); in Del()
117 Set(fde, fde->state & ~events); in Del()
154 void fdevent_context::HandleEvents(const std::vector<fdevent_event>& events) { in HandleEvents() argument
[all …]
Dfdevent.h45 typedef void (*fd_func)(int fd, unsigned events, void *userdata);
46 typedef void (*fd_func2)(struct fdevent* fde, unsigned events, void* userdata);
48 void invoke_fde(struct fdevent* fde, unsigned events);
53 unsigned events; member
87 virtual void Set(fdevent* fde, unsigned events) = 0;
88 void Add(fdevent* fde, unsigned events);
89 void Del(fdevent* fde, unsigned events);
99 void HandleEvents(const std::vector<fdevent_event>& events);
146 void fdevent_set(fdevent *fde, unsigned events);
147 void fdevent_add(fdevent *fde, unsigned events);
[all …]
/packages/services/Iwlan/test/com/google/android/iwlan/
DIwlanEventListenerTest.java74 private List<Integer> events; field in IwlanEventListenerTest
130 events = new ArrayList<Integer>(); in testWifiApChanged()
131 events.add(IwlanEventListener.WIFI_AP_CHANGED_EVENT); in testWifiApChanged()
132 mIwlanEventListener.addEventListener(events, mMockHandler); in testWifiApChanged()
152 events = new ArrayList<Integer>(); in testCrossSimCallingSettingEnableChanged()
153 events.add(IwlanEventListener.CROSS_SIM_CALLING_ENABLE_EVENT); in testCrossSimCallingSettingEnableChanged()
154 mIwlanEventListener.addEventListener(events, mMockHandler); in testCrossSimCallingSettingEnableChanged()
176 events = new ArrayList<Integer>(); in testCrossSimCallingSettingDisableChanged()
177 events.add(IwlanEventListener.CROSS_SIM_CALLING_DISABLE_EVENT); in testCrossSimCallingSettingDisableChanged()
178 mIwlanEventListener.addEventListener(events, mMockHandler); in testCrossSimCallingSettingDisableChanged()
[all …]
/packages/modules/Wifi/service/
Dwifi.rc42 # Enable cfg80211 events for connection and key management events.
46 write /sys/kernel/debug/tracing/instances/wifi/events/cfg80211/cfg80211_gtk_rekey_notify/enable 1
47 write /sys/kernel/debug/tracing/instances/wifi/events/cfg80211/rdev_add_key/enable 1
48 write /sys/kernel/debug/tracing/instances/wifi/events/cfg80211/rdev_assoc/enable 1
49 write /sys/kernel/debug/tracing/instances/wifi/events/cfg80211/rdev_auth/enable 1
50 write /sys/kernel/debug/tracing/instances/wifi/events/cfg80211/rdev_connect/enable 1
51 write /sys/kernel/debug/tracing/instances/wifi/events/cfg80211/rdev_set_default_key/enable 1
52 write /sys/kernel/debug/tracing/instances/wifi/events/cfg80211/rdev_set_default_mgmt_key/enable 1
53 write /sys/kernel/debug/tracing/instances/wifi/events/cfg80211/rdev_set_rekey_data/enable 1
55 write /sys/kernel/tracing/instances/wifi/events/cfg80211/cfg80211_gtk_rekey_notify/enable 1
[all …]
/packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/latin/
DInputLogicTestsDeadKeys.java54 final EventList events = new EventList() in testDeadCircumflexSimple() local
58 for (final Event event : events) { in testDeadCircumflexSimple()
67 final EventList events = new EventList() in testDeadCircumflexBackspace() local
72 for (final Event event : events) { in testDeadCircumflexBackspace()
81 final EventList events = new EventList() in testDeadCircumflexFeedback() local
84 for (final Event event : events) { in testDeadCircumflexFeedback()
94 final EventList events = new EventList() in testDeadDiaeresisSpace() local
102 for (final Event event : events) { in testDeadDiaeresisSpace()
113 final EventList events = new EventList() in testDeadAcuteLetterBackspace() local
117 for (final Event event : events) { in testDeadAcuteLetterBackspace()
[all …]
/packages/services/Car/tests/carservice_unit_test/src/com/android/car/testapi/
DBlockingUserLifecycleListenerTest.java111 List<UserLifecycleEvent> events = listener.waitForEvents(); in testForSpecificEvents_receivedOnlyExpected() local
112 assertEvents(events, 10, in testForSpecificEvents_receivedOnlyExpected()
117 assertThat(allReceivedEvents).containsAtLeastElementsIn(events).inOrder(); in testForSpecificEvents_receivedOnlyExpected()
133 List<UserLifecycleEvent> events = listener.waitForEvents(); in testForSpecificEvents_receivedExtraEvents() local
134 assertEvents(events, 10, in testForSpecificEvents_receivedExtraEvents()
162 List<UserLifecycleEvent> events = listener.waitForEvents(); in testForSpecificEvents_filterByUser() local
163 assertThat(events).containsExactly(right1, right2).inOrder(); in testForSpecificEvents_filterByUser()
190 List<UserLifecycleEvent> events = listener.waitForEvents(); in testForSpecificEvents_filterByUserDuplicatedEventTypes() local
191 assertThat(events).containsExactly(right1, right2, right3).inOrder(); in testForSpecificEvents_filterByUserDuplicatedEventTypes()
221 List<UserLifecycleEvent> events = listener.waitForEvents(); in testForSpecificEvents_filterByPreviousUser() local
[all …]
/packages/apps/Settings/tests/unit/src/com/android/settings/core/codeinspection/
DLifecycleObserverCodeInspector.java24 import com.android.settingslib.core.lifecycle.events.OnAttach;
25 import com.android.settingslib.core.lifecycle.events.OnCreate;
26 import com.android.settingslib.core.lifecycle.events.OnCreateOptionsMenu;
27 import com.android.settingslib.core.lifecycle.events.OnDestroy;
28 import com.android.settingslib.core.lifecycle.events.OnOptionsItemSelected;
29 import com.android.settingslib.core.lifecycle.events.OnPause;
30 import com.android.settingslib.core.lifecycle.events.OnPrepareOptionsMenu;
31 import com.android.settingslib.core.lifecycle.events.OnResume;
32 import com.android.settingslib.core.lifecycle.events.OnSaveInstanceState;
33 import com.android.settingslib.core.lifecycle.events.OnStart;
[all …]
/packages/apps/Settings/tests/robotests/src/com/android/settings/core/codeinspection/
DLifecycleObserverCodeInspector.java24 import com.android.settingslib.core.lifecycle.events.OnAttach;
25 import com.android.settingslib.core.lifecycle.events.OnCreate;
26 import com.android.settingslib.core.lifecycle.events.OnCreateOptionsMenu;
27 import com.android.settingslib.core.lifecycle.events.OnDestroy;
28 import com.android.settingslib.core.lifecycle.events.OnOptionsItemSelected;
29 import com.android.settingslib.core.lifecycle.events.OnPause;
30 import com.android.settingslib.core.lifecycle.events.OnPrepareOptionsMenu;
31 import com.android.settingslib.core.lifecycle.events.OnResume;
32 import com.android.settingslib.core.lifecycle.events.OnSaveInstanceState;
33 import com.android.settingslib.core.lifecycle.events.OnStart;
[all …]
/packages/modules/Bluetooth/system/stack/rfcomm/
Dport_rfc.cc150 uint32_t events = 0; in port_start_close() local
160 events |= port_get_signal_changes(p_port, old_signals, in port_start_close()
163 if (p_port->ev_mask & PORT_EV_CONNECT_ERR) events |= PORT_EV_CONNECT_ERR; in port_start_close()
165 if (p_port->ev_mask & PORT_EV_ERR) events |= PORT_EV_ERR; in port_start_close()
167 if ((p_port->p_callback != NULL) && events) in port_start_close()
168 p_port->p_callback(events, p_port->handle); in port_start_close()
791 uint32_t events = 0; in PORT_DataInd() local
839 events |= PORT_EV_RXFLAG; in PORT_DataInd()
857 if (events & PORT_EV_RXFLAG) { in PORT_DataInd()
863 events |= PORT_EV_RXCHAR; in PORT_DataInd()
[all …]
/packages/apps/ThemePicker/src/com/android/customization/picker/clock/ui/view/
DClockViewFactory.kt106 clockControllers.values.forEach { it.events.onSeedColorChanged(seedColor = seedColor) } in <lambda>()
110 clockControllers[clockId]?.events?.onSeedColorChanged(seedColor) in <lambda>()
116 it.largeClock.events.onRegionDarknessChanged(isRegionDark) in <lambda>()
117 it.smallClock.events.onRegionDarknessChanged(isRegionDark) in <lambda>()
128 .events in <lambda>()
150 it.largeClock.events.onTimeTick() in <lambda>()
151 it.smallClock.events.onTimeTick() in <lambda>()
170 controller.largeClock.events.onRegionDarknessChanged(isWallpaperDark) in <lambda>()
171 controller.largeClock.events.onFontSettingChanged( in <lambda>()
174 controller.largeClock.events.onTargetRegionChanged(getLargeClockRegion()) in <lambda>()
[all …]
/packages/modules/Bluetooth/system/osi/src/
Dreactor.cc98 event.events = EPOLLIN; in reactor_new()
156 if (read_ready) event.events |= (EPOLLIN | EPOLLRDHUP); in reactor_register()
157 if (write_ready) event.events |= EPOLLOUT; in reactor_register()
178 if (read_ready) event.events |= (EPOLLIN | EPOLLRDHUP); in reactor_change_registration()
179 if (write_ready) event.events |= EPOLLOUT; in reactor_change_registration()
239 struct epoll_event events[MAX_EVENTS]; in run_reactor() local
247 OSI_NO_INTR(ret = epoll_wait(reactor->epoll_fd, events, MAX_EVENTS, -1)); in run_reactor()
258 if (events[j].data.ptr == NULL) { in run_reactor()
265 reactor_object_t* object = (reactor_object_t*)events[j].data.ptr; in run_reactor()
278 if (events[j].events & (EPOLLIN | EPOLLHUP | EPOLLRDHUP | EPOLLERR) && in run_reactor()
[all …]

12345678910>>...21