Home
last modified time | relevance | path

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

12345678910>>...13

/f-stack/app/redis-5.0.5/src/
H A Dae_epoll.c36 struct epoll_event *events; member
44 if (!state->events) { in aeApiCreate()
50 zfree(state->events); in aeApiCreate()
61 state->events = zrealloc(state->events, sizeof(struct epoll_event)*setsize); in aeApiResize()
69 zfree(state->events); in aeApiFree()
81 ee.events = 0; in aeApiAddEvent()
83 if (mask & AE_READABLE) ee.events |= EPOLLIN; in aeApiAddEvent()
84 if (mask & AE_WRITABLE) ee.events |= EPOLLOUT; in aeApiAddEvent()
95 ee.events = 0; in aeApiDelEvent()
96 if (mask & AE_READABLE) ee.events |= EPOLLIN; in aeApiDelEvent()
[all …]
H A Dae_ff_kqueue.c40 struct kevent *events; member
47 state->events = zmalloc(sizeof(struct kevent)*eventLoop->setsize); in aeApiCreate()
48 if (!state->events) { in aeApiCreate()
54 zfree(state->events); in aeApiCreate()
65 state->events = zrealloc(state->events, sizeof(struct kevent)*setsize); in aeApiResize()
73 zfree(state->events); in aeApiFree()
114 retval = ff_kevent(state->kqfd, NULL, 0, state->events, eventLoop->setsize, in aeApiPoll()
117 retval = ff_kevent(state->kqfd, NULL, 0, state->events, eventLoop->setsize, in aeApiPoll()
127 struct kevent *e = state->events+j; in aeApiPoll()
H A Dae_kqueue.c38 struct kevent *events; member
45 state->events = zmalloc(sizeof(struct kevent)*eventLoop->setsize); in aeApiCreate()
46 if (!state->events) { in aeApiCreate()
52 zfree(state->events); in aeApiCreate()
63 state->events = zrealloc(state->events, sizeof(struct kevent)*setsize); in aeApiResize()
71 zfree(state->events); in aeApiFree()
112 retval = kevent(state->kqfd, NULL, 0, state->events, eventLoop->setsize, in aeApiPoll()
115 retval = kevent(state->kqfd, NULL, 0, state->events, eventLoop->setsize, in aeApiPoll()
125 struct kevent *e = state->events+j; in aeApiPoll()
H A Dae.c72 eventLoop->events = zmalloc(sizeof(aeFileEvent)*setsize); in aeCreateEventLoop()
87 eventLoop->events[i].mask = AE_NONE; in aeCreateEventLoop()
92 zfree(eventLoop->events); in aeCreateEventLoop()
118 eventLoop->events = zrealloc(eventLoop->events,sizeof(aeFileEvent)*setsize); in aeResizeSetSize()
125 eventLoop->events[i].mask = AE_NONE; in aeResizeSetSize()
131 zfree(eventLoop->events); in aeDeleteEventLoop()
147 aeFileEvent *fe = &eventLoop->events[fd]; in aeCreateFileEvent()
163 aeFileEvent *fe = &eventLoop->events[fd]; in aeDeleteFileEvent()
184 aeFileEvent *fe = &eventLoop->events[fd]; in aeGetFileEvents()
490 if (mask & AE_READABLE) pfd.events |= POLLIN; in aeWait()
[all …]
/f-stack/example/
H A Dmain_epoll.c21 struct epoll_event events[MAX_EVENTS]; variable
62 int nevents = ff_epoll_wait(epfd, events, MAX_EVENTS, 0); in loop()
67 if (events[i].data.fd == sockfd) { in loop()
76 ev.events = EPOLLIN; in loop()
84 if (events[i].events & EPOLLERR ) { in loop()
87 ff_close(events[i].data.fd); in loop()
88 } else if (events[i].events & EPOLLIN) { in loop()
92 ff_write( events[i].data.fd, html, sizeof(html) - 1); in loop()
95 ff_close( events[i].data.fd); in loop()
98 printf("unknown event: %8.8X\n", events[i].events); in loop()
[all …]
/f-stack/app/redis-5.0.5/deps/hiredis/adapters/
H A Dlibuv.h12 int events; member
23 if (p->context != NULL && (events & UV_READABLE)) { in redisLibuvPoll()
26 if (p->context != NULL && (events & UV_WRITABLE)) { in redisLibuvPoll()
35 p->events |= UV_READABLE; in redisLibuvAddRead()
37 uv_poll_start(&p->handle, p->events, redisLibuvPoll); in redisLibuvAddRead()
44 p->events &= ~UV_READABLE; in redisLibuvDelRead()
46 if (p->events) { in redisLibuvDelRead()
57 p->events |= UV_WRITABLE; in redisLibuvAddWrite()
59 uv_poll_start(&p->handle, p->events, redisLibuvPoll); in redisLibuvAddWrite()
66 p->events &= ~UV_WRITABLE; in redisLibuvDelWrite()
[all …]
H A Dglib.h21 source->poll_fd.events |= G_IO_IN; in redis_source_add_read()
30 source->poll_fd.events &= ~G_IO_IN; in redis_source_del_read()
39 source->poll_fd.events |= G_IO_OUT; in redis_source_add_write()
48 source->poll_fd.events &= ~G_IO_OUT; in redis_source_del_write()
77 return !!(redis->poll_fd.events & redis->poll_fd.revents); in redis_source_prepare()
84 return !!(redis->poll_fd.events & redis->poll_fd.revents); in redis_source_check()
139 source->poll_fd.events = 0; in redis_source_new()
/f-stack/freebsd/contrib/openzfs/tests/zfs-tests/tests/functional/deadman/
H A Ddeadman_zio.ksh79 log_must zpool events -c
91 events=$(zpool events | grep -c ereport.fs.zfs.deadman)
92 if [ "$events" -lt 1 ]; then
93 log_fail "Expect >=1 deadman events, $events found"
98 log_must zpool events -c
108 events=$(zpool events | grep -c ereport.fs.zfs.deadman)
109 if [ "$events" -ne 0 ]; then
110 log_fail "Expect 0 deadman events, $events found"
113 log_pass "Verify zio deadman detected a hung zio and $events deadman events"
H A Ddeadman_sync.ksh63 log_must zpool events -c
77 log_must zpool events
81 events=$(zpool events | grep -c ereport.fs.zfs.deadman)
82 if [ "$events" -lt 5 ]; then
83 log_fail "Expect >=5 deadman events, $events found"
86 log_pass "Verify spa deadman detected a hung txg and $events deadman events"
/f-stack/freebsd/contrib/openzfs/tests/zfs-tests/tests/functional/cli_root/zpool_events/
H A Dzpool_events_cliargs.ksh67 log_mustnot zpool events $opt "/tmp/"
68 log_mustnot zpool events $opt "$TESTPOOL/fs"
69 log_mustnot zpool events $opt "$TESTPOOL@snap"
70 log_mustnot zpool events $opt "$TESTPOOL#bm"
71 log_mustnot zpool events $opt "$TESTPOOL" "$TESTPOOL"
76 log_mustnot zpool events -c "$TESTPOOL"
79 log_mustnot zpool events -c $opt
85 log_mustnot zpool events $opt
86 log_mustnot zpool events $opt "$TESTPOOL"
H A Dzpool_events_errors.ksh57 log_must zpool events -c
88 log_must zpool events -c
117 events=$(zpool events | grep checksum | wc -l)
121 allevents=$(zpool events | grep io)
122 events=$(echo "$allevents" | wc -l)
132 if [ -z "$val" -o $val -eq 0 -o -z "$events" -o $events -eq 0 ] ; then
133 log_fail "Didn't see any errors or events ($val/$events)"
136 if [ $val -ne $events ] ; then
137 log_fail "$val $POOLTYPE $str errors != $events events"
139 log_note "$val $POOLTYPE $str errors == $events events"
H A Dzpool_events_clear.ksh38 log_must zpool events -c
46 EVENTS_NUM=$(zpool events -H | wc -l | xargs)
49 CLEAR_OUTPUT=$(zpool events -c)
53 EVENTS_NUM=$(zpool events -H | wc -l)
/f-stack/app/nginx-1.16.1/src/event/modules/
H A Dngx_epoll_module.c46 uint32_t events; member
99 ngx_uint_t events; member
495 if (events == -1) { in ngx_epoll_test_rdhup()
501 if (events) { in ngx_epoll_test_rdhup()
602 events = EPOLLOUT; in ngx_epoll_add_event()
608 events |= prev; in ngx_epoll_add_event()
620 ee.events = events | (uint32_t) flags; in ngx_epoll_add_event()
680 ee.events = 0; in ngx_epoll_del_event()
746 ee.events = 0; in ngx_epoll_del_connection()
826 if (events == 0) { in ngx_epoll_process_events()
[all …]
H A Dngx_ff_host_event_module.c52 ngx_uint_t events; member
89 cf->events = NGX_CONF_UNSET; in ngx_ff_host_event_create_conf()
97 cf->events = 8; in ngx_ff_host_event_init_conf()
158 events = (uint32_t) event; in ngx_ff_epoll_add_event()
171 events = EPOLLOUT; in ngx_ff_epoll_add_event()
177 events |= prev; in ngx_ff_epoll_add_event()
183 ee.events = events | (uint32_t) flags; in ngx_ff_epoll_add_event()
243 ee.events = 0; in ngx_ff_epoll_del_event()
308 ee.events = 0; in ngx_ff_epoll_del_connection()
327 int events; in ngx_ff_epoll_process_events() local
[all …]
H A Dngx_eventport_module.c135 ngx_uint_t events; member
233 if (nevents < epcf->events) { in ngx_eventport_init()
275 nevents = epcf->events; in ngx_eventport_init()
320 events = event; in ngx_eventport_add_event()
326 events = POLLIN; in ngx_eventport_add_event()
333 events = POLLOUT; in ngx_eventport_add_event()
338 events |= prev; in ngx_eventport_add_event()
440 u_int events; in ngx_eventport_process_events() local
461 events = 1; in ngx_eventport_process_events()
487 if (events == 0) { in ngx_eventport_process_events()
[all …]
H A Dngx_devpoll_module.c34 ngx_uint_t events; member
74 offsetof(ngx_devpoll_conf_t, events),
170 if (nevents < dpcf->events) { in ngx_devpoll_init()
182 nevents = dpcf->events; in ngx_devpoll_init()
374 events = ioctl(dp, DP_POLL, &dvp); in ngx_devpoll_process_events()
376 err = (events == -1) ? ngx_errno : 0; in ngx_devpoll_process_events()
400 if (events == 0) { in ngx_devpoll_process_events()
410 for (i = 0; i < events; i++) { in ngx_devpoll_process_events()
420 pfd.events = 0; in ngx_devpoll_process_events()
446 pfd.events = POLLREMOVE; in ngx_devpoll_process_events()
[all …]
/f-stack/freebsd/contrib/openzfs/tests/zfs-tests/tests/functional/events/
H A Devents_common.kshlib30 . $STF_SUITE/tests/functional/events/events.cfg
81 set -A events
86 events+=("$OPTARG")
106 log_must zpool events -c
124 for event in ${events[*]}; do
144 for event in ${events[*]}; do
/f-stack/lib/
H A Dff_epoll.c75 if (event->events & EPOLLET) { in ff_epoll_ctl()
79 if (event->events & EPOLLONESHOT) { in ff_epoll_ctl()
89 if (event->events & EPOLLIN) { in ff_epoll_ctl()
94 if (event->events & EPOLLOUT) { in ff_epoll_ctl()
138 (*ppev)->events = event_one; in ff_event_to_epoll()
148 ff_epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout) in ff_epoll_wait() argument
151 if (!events || maxevents < 1) { in ff_epoll_wait()
156 return ff_kevent_do_each(epfd, NULL, 0, events, maxevents, NULL, ff_event_to_epoll); in ff_epoll_wait()
/f-stack/app/redis-5.0.5/tests/unit/type/
H A Dstream-cgroups.tcl97 r del events
98 r xadd events * f1 v1
99 r xadd events * f1 v1
100 r xadd events * f1 v1
101 r xadd events * f1 v1
103 r xadd events * f1 v1
106 r xgroup setid events g1 -
112 r del events
113 r xadd events * a 1
114 r xadd events * b 2
[all …]
/f-stack/app/micro_thread/
H A Dkqueue_proxy.cpp179 item->AttachEvents(events); in KqueueCtrlAdd()
182 int new_events = old_events | events; in KqueueCtrlAdd()
195 item->DetachEvents(events); in KqueueCtrlAdd()
205 item->DetachEvents(events); in KqueueCtrlAdd()
210 if (events & KQ_EVENT_WRITE) { in KqueueCtrlAdd()
215 item->DetachEvents(events); in KqueueCtrlAdd()
220 if (events & KQ_EVENT_READ) { in KqueueCtrlAdd()
225 item->DetachEvents(events); in KqueueCtrlAdd()
254 item->DetachEvents(events); in KqueueCtrlDelRef()
256 int new_events = old_events &~ events; in KqueueCtrlDelRef()
[all …]
/f-stack/freebsd/contrib/device-tree/Bindings/goldfish/
H A Devents.txt3 Android goldfish events keypad device generated by android emulator.
7 - compatible : should contain "google,goldfish-events-keypad" to match emulator
13 goldfish-events@9040000 {
14 compatible = "google,goldfish-events-keypad";
/f-stack/freebsd/contrib/device-tree/src/arm/
H A Dexynos4412-ppmu-common.dtsi12 events {
22 events {
32 events {
42 events {
/f-stack/dpdk/lib/librte_eventdev/
H A Drte_event_ring.h90 const struct rte_event *events, in rte_event_ring_enqueue_burst() argument
96 num = rte_ring_enqueue_burst_elem(&r->r, events, in rte_event_ring_enqueue_burst()
126 struct rte_event *events, in rte_event_ring_dequeue_burst() argument
132 num = rte_ring_dequeue_burst_elem(&r->r, events, in rte_event_ring_dequeue_burst()
/f-stack/dpdk/doc/guides/eventdevs/
H A Ddsw.rst8 distributes the task of scheduling events among all the eventdev ports
51 Producer-only ports which currently have no events to enqueue should
62 send enqueued events immediately to the destination port, but instead
65 In case no more events are enqueued on a port with buffered events,
66 these events will be sent after the application has performed a number
89 parallel events on the same queue.
/f-stack/dpdk/drivers/event/sw/
H A Diq_chunk.h15 struct rte_event events[SW_EVS_PER_Q_CHUNK]; member
71 iq->tail->events[iq->tail_idx++] = *ev; in iq_enqueue()
103 return &iq->head->events[iq->head_idx]; in iq_peek()
126 ev[total++] = current->events[index++]; in iq_dequeue_burst()
173 iq->head->events[idx + i] = ev[i]; in iq_put_back()
182 iq->head->events[i] = ev[remaining + i]; in iq_put_back()
190 iq->head->events[iq->head_idx + i] = ev[i]; in iq_put_back()

12345678910>>...13