| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ObjectReference/ |
| InvokeMethodDefaultTest.java | 76 int events = event.getNextValueAsInt(); local
78 " events=" + events);
79 for (int i = 0; i < events; i++) {
|
| InvokeMethodTest.java | 86 int events = event.getNextValueAsInt(); local
88 + " events=" + events);
89 for (int i = 0; i < events; i++) {
|
| /external/autotest/client/site_tests/hardware_Keyboard/src/ |
| evtest.c | 42 char *events[EV_MAX + 1] = {
variable
295 [EV_SYN] = events, [EV_KEY] = keys,
412 printf("Supported events:\n");
416 events[i] ? events[i] : "?");
465 events[ev[i].type] ? events[ev[i].type] : "?",
476 events[ev[i].type] ? events[ev[i].type] : "?",
|
| /external/curl/include/curl/ |
| multi.h | 112 short events; member in struct:curl_waitfd
281 * (to allow libcurl's timed events to take place).
313 * called (to allow libcurl's timed events to take place).
|
| /external/fio/engines/ |
| binject.c | 24 struct io_u **events; member in struct:binject_data
66 int i, ret, events; local
69 events = 0;
82 events += ret / sizeof(struct b_user_cmd);
86 if (*err || events)
87 return events;
100 unsigned int i, events; local
110 * don't block for min events == 0
118 bd->pfds[i].events = POLLIN;
139 events = binject_read_commands(td, buf, left, &r)
[all...] |
| libaio.c | 113 struct io_event events[0]; member in struct:aio_ring
119 struct io_event *events)
133 events[i] = ring->events[head];
150 int r, events = 0; local
163 ld->aio_events + events);
166 max, ld->aio_events + events, lt);
169 events += r;
175 } while (events < min);
177 return r < 0 ? r : events;
[all...] |
| rbd.c | 206 unsigned int *events)
212 rbd->aio_events[*events] = io_u;
213 (*events)++;
253 static int rbd_iter_events(struct thread_data *td, unsigned int *events,
268 if (fri_check_complete(rbd, io_u, events))
278 * Sort events, oldest issue first, then wait on as many as we
279 * need in order of age. If we have enough events, stop waiting,
288 if (fri_check_complete(rbd, io_u, events)) {
297 if (*events >= min_evts)
302 if (fri_check_complete(rbd, io_u, events))
312 unsigned int this_events, events = 0; local
[all...] |
| sg.c | 25 struct io_u **events; member in struct:sgio_data
71 unsigned int i, events; local
79 * don't block for min events == 0
87 sd->pfds[i].events = POLLIN;
115 events = 0;
126 events += ret / sizeof(struct sg_io_hdr);
132 if (!events) {
137 left -= events;
138 r += events;
140 for (i = 0; i < events; i++)
[all...] |
| /external/guava/guava/src/com/google/common/eventbus/ |
| EventBus.java | 45 * Dispatches events to listeners, and provides ways for listeners to register
55 * <h2>Receiving Events</h2>
56 * <p>To receive events, an object should:
65 * <h2>Posting Events</h2>
70 * <p>Events are routed based on their type — an event will be delivered
94 * <h2>Dead Events</h2>
96 * considered "dead." To give the system a second chance to handle dead events,
99 * <p>If a subscriber for a supertype of all events (such as Object) is registered,
149 /** queues of events for the current thread to dispatch */
195 * Registers all subscriber methods on {@code object} to receive events
301 Queue<EventWithSubscriber> events = eventsToDispatch.get(); local
[all...] |
| /external/icu/icu4c/source/tools/ctestfw/ |
| uperf.cpp | 412 long events = -1; local
434 events = testFunction->getEventsPerIteration();
437 if(events == -1){
440 fprintf(stdout, "= %s end: %f loops: %i operations: %li events: %li\n", name, t, (int)loops, ops, events);
443 if(events == -1){
446 fprintf(stdout,"= %s end %f %i %li %li\n", name, t, (int)loops, ops, events);
455 else if(events == -1) {
463 name, avg_t, (int)loops, (avg_t*1E9)/(loops*ops), (avg_t*1E9)/(loops*events));
465 name, min_t, (int)loops, (min_t*1E9)/(loops*ops), (min_t*1E9)/(loops*events));
[all...] |
| /external/ltp/testcases/kernel/fs/dmapi/ |
| disp.c | 63 dm_eventset_t events, maxEvents, minEvents; local
71 DMEV_ZERO(events);
72 DMEV_SET(DM_EVENT_MOUNT, events);
89 &events, DM_EVENT_MAX)) == -1) {
3916 dm_eventset_t events; local
[all...] |
| event_am.c | 24 * EVENTS TESTED: DM_EVENT_ATTRIBUTE
67 dm_eventset_t events; local
76 DMEV_ZERO(events);
77 DMEV_SET(DM_EVENT_MOUNT, events);
94 &events, DM_EVENT_MAX)) == -1) {
124 * First batch of tests will be with events enabled on file system,
125 * so set up events on fs accordingly
136 DMEV_ZERO(events);
137 DMEV_SET(DM_EVENT_PREUNMOUNT, events);
138 DMEV_SET(DM_EVENT_UNMOUNT, events);
2274 dm_eventset_t events; local
[all...] |
| event_an.c | 24 * EVENTS TESTED: DM_EVENT_POSTCREATE
75 dm_eventset_t events; local
82 DMEV_ZERO(events);
83 DMEV_SET(DM_EVENT_MOUNT, events);
100 &events, DM_EVENT_MAX)) == -1) {
141 * First batch of tests will be with events enabled on file system,
142 * so set up events on fs accordingly
153 DMEV_ZERO(events);
154 DMEV_SET(DM_EVENT_PREUNMOUNT, events);
155 DMEV_SET(DM_EVENT_UNMOUNT, events);
3007 dm_eventset_t events; local
[all...] |
| event_sd.c | 24 * EVENTS TESTED: DM_EVENT_READ
31 * call will generate DM_EVENT_WRITE events that can interfere
78 dm_eventset_t events; local
83 DMEV_ZERO(events);
84 DMEV_SET(DM_EVENT_MOUNT, events);
101 &events, DM_EVENT_MAX)) == -1) {
7000 dm_eventset_t events; local
[all...] |
| event_sn.c | 24 * EVENTS TESTED: DM_EVENT_CREATE
71 dm_eventset_t events; local
76 DMEV_ZERO(events);
77 DMEV_SET(DM_EVENT_MOUNT, events);
94 &events, DM_EVENT_MAX)) == -1) {
1508 dm_eventset_t events; local
[all...] |
| invis.c | 116 dm_eventset_t events, maxFileEvents, minFileEvents; local
121 DMEV_ZERO(events);
122 DMEV_SET(DM_EVENT_MOUNT, events);
139 &events, DM_EVENT_MAX)) == -1) {
2422 dm_eventset_t events; local
[all...] |
| mmap.c | 24 * EVENTS TESTED: DM_EVENT_READ
68 dm_eventset_t events; local
73 DMEV_ZERO(events);
74 DMEV_SET(DM_EVENT_MOUNT, events);
91 &events, DM_EVENT_MAX)) == -1) {
1420 dm_eventset_t events; local
[all...] |
| pmr_post.c | 74 dm_eventset_t events; local
80 DMEV_ZERO(events);
81 DMEV_SET(DM_EVENT_MOUNT, events);
98 &events, DM_EVENT_MAX)) == -1) {
1252 dm_eventset_t events; local
[all...] |
| /external/ltp/testcases/kernel/io/ltp-aiodio/ |
| aiocp.c | 178 struct io_event events[aio_maxio]; local
183 * get up to aio_maxio events at a time.
185 ret = n = io_getevents(ctx, 1, aio_maxio, events, to);
190 for (ep = events; n-- > 0; ep++) {
|
| /external/sl4a/Common/src/com/googlecode/android_scripting/facade/ |
| EventFacade.java | 58 * Events are automatically entered into the Event Queue following API calls such as startSensing()
60 * The Event Facade provides control over how events are entered into (and removed from) the Event
62 * The Event Queue provides a useful means of recording background events (such as sensor data) when
68 * The maximum length of the event queue. Old events will be discarded when this limit is
93 @Rpc(description = "Clears all events from the event buffer.")
105 description = "Should this events be added to the event queue or only dispatched") @RpcDefault(value = "true") Boolean enqueue) {
159 @Rpc(description = "Returns and removes the oldest n events (i.e. location or sensor update, etc.) from the event buffer.",
163 List<Event> events = Lists.newArrayList(); local
169 events.add(event);
171 return events;
[all...] |
| /external/webrtc/webrtc/base/ |
| event_tracer.cc | 110 std::vector<TraceEvent> events; local
113 trace_events_.swap(events);
115 for (const TraceEvent& e : events) {
148 // Since the atomic fast-path for adding events to the queue can be
150 // stale events in the queue, hence the vector needs to be cleared to not
151 // log events from a previous logging session (which may be days old).
|
| httpbase_unittest.cc | 69 events.push_back(e);
78 events.push_back(e);
83 events.push_back(e);
108 // The source of http data, and source events
110 std::vector<Event> events; member in class:rtc::HttpBaseTest
112 // Document stream, and stream events
126 EXPECT_TRUE(events.empty());
129 ASSERT_EQ(1U, events.size());
130 EXPECT_EQ(E_COMPLETE, events[0].event);
131 EXPECT_EQ(HM_CONNECT, events[0].mode)
[all...] |
| macsocketserver.cc | 103 // Used to disable socket events from waking our message queue when
171 // No way to listen to common modes and not get socket events, unless
250 // Listen to all events if we're processing I/O.
253 const EventTypeSpec* events = NULL; local
256 events = kEventWakeUpSpec;
267 OSStatus result = ReceiveNextEvent(num_types, events, timeout, true,
359 // No way to listen to common modes and not get socket events, unless
|
| /external/webrtc/webrtc/examples/androidapp/src/org/appspot/apprtc/ |
| RoomParametersFetcher.java | 40 private final RoomParametersFetcherEvents events; field in class:RoomParametersFetcher
62 final RoomParametersFetcherEvents events) {
65 this.events = events;
76 events.onSignalingParametersError(errorMessage);
96 events.onSignalingParametersError("Room response error: " + result);
159 events.onSignalingParametersReady(params);
161 events.onSignalingParametersError(
164 events.onSignalingParametersError("Room IO error: " + e.toString());
|
| /frameworks/base/cmds/input/src/com/android/commands/input/ |
| Input.java | 32 * Command that sends key events to the device, either by their keycode, or by
186 KeyEvent[] events = kcm.getEvents(chars); local
187 for(int i = 0; i < events.length; i++) {
188 KeyEvent e = events[i];
|
