Home
last modified time | relevance | path

Searched refs:evb (Results 1 – 25 of 2188) sorted by relevance

12345678910>>...88

/dports/databases/twemproxy/twemproxy-0.5.0/src/event/
H A Dnc_kqueue.c58 evb = nc_alloc(sizeof(*evb)); in event_base_create()
114 ASSERT(evb->nchange < evb->nevent); in event_add_in()
120 event = &evb->change[evb->nchange++]; in event_add_in()
136 ASSERT(evb->nchange < evb->nevent); in event_del_in()
142 event = &evb->change[evb->nchange++]; in event_del_in()
159 ASSERT(evb->nchange < evb->nevent); in event_add_out()
182 ASSERT(evb->nchange < evb->nevent); in event_del_out()
204 ASSERT(evb->nchange < evb->nevent); in event_add_conn()
220 ASSERT(evb->nchange < evb->nevent); in event_del_conn()
273 evb->nreturned = kevent(kq, evb->change, evb->nchange, evb->event, in event_wait()
[all …]
H A Dnc_evport.c49 evb = nc_alloc(sizeof(*evb)); in event_base_create()
50 if (evb == NULL) { in event_base_create()
59 evb->evp = evp; in event_base_create()
60 evb->event = event; in event_base_create()
62 evb->cb = cb; in event_base_create()
64 log_debug(LOG_INFO, "evp %d with nevent %d", evb->evp, evb->nevent); in event_base_create()
66 return evb; in event_base_create()
74 if (evb == NULL) { in event_base_destroy()
86 evb->evp = -1; in event_base_destroy()
88 nc_free(evb); in event_base_destroy()
[all …]
H A Dnc_epoll.c48 evb = nc_alloc(sizeof(*evb)); in event_base_create()
49 if (evb == NULL) { in event_base_create()
58 evb->ep = ep; in event_base_create()
61 evb->cb = cb; in event_base_create()
63 log_debug(LOG_INFO, "e %d with nevent %d", evb->ep, evb->nevent); in event_base_create()
65 return evb; in event_base_create()
73 if (evb == NULL) { in event_base_destroy()
85 evb->ep = -1; in event_base_destroy()
87 nc_free(evb); in event_base_destroy()
95 int ep = evb->ep; in event_add_in()
[all …]
/dports/www/varnish6/varnish-cache-varnish-6.6.2/lib/libvarnish/
H A Dvev.c133 if (evb->lpfd + 1 < evb->npfd) in vev_get_pfd()
143 evb->pfd = realloc(evb->pfd, sizeof(*evb->pfd) * u); in vev_get_pfd()
144 AN(evb->pfd); in vev_get_pfd()
145 evb->pev = realloc(evb->pev, sizeof(*evb->pev) * u); in vev_get_pfd()
196 evb = calloc(1, sizeof *evb); in VEV_New()
201 free(evb); in VEV_New()
205 evb->binheap = VBH_new(evb, vev_bh_cmp, vev_bh_update); in VEV_New()
288 evb->lpfd++; in VEV_Start()
410 assert(evb->lpfd < evb->npfd); in VEV_Once()
432 i = poll(evb->pfd + 1, evb->lpfd - 1, tmo); in VEV_Once()
[all …]
/dports/devel/libphk/Libphk/
H A Dphk_event.c104 if (evb->lpfd < evb->npfd) in ev_get_pfd()
166 evb = calloc(sizeof *evb, 1); in PhkEvNewBase()
235 es->evb = evb; in PhkEvAdd()
243 assert(evb->lpfd < evb->npfd); in PhkEvAdd()
244 evb->pfd[evb->lpfd].fd = e->fd; in PhkEvAdd()
245 evb->pfd[evb->lpfd].events = in PhkEvAdd()
263 E->evb = evb; in PhkEvAdd()
290 assert(evb == E->evb); in PhkEvDel()
393 if (!es->happened || es->evb != evb) in ev_sched_signal()
438 assert(evb->lpfd < evb->npfd);
[all …]
/dports/net/grpcui/grpcui-1.1.0/vendor/github.com/jhump/protoreflect/desc/builder/
H A Denum.go195 Unlink(evb)
196 evb.setParent(eb)
343 return evb, nil
356 return evb, nil
366 return evb
373 return evb.baseBuilder.setName(evb, newName)
380 return evb
408 return evb
428 evb.number = 0
430 return evb
[all …]
/dports/net/evans/evans-0.9.1/vendor/github.com/jhump/protoreflect/desc/builder/
H A Denum.go195 Unlink(evb)
196 evb.setParent(eb)
343 return evb, nil
356 return evb, nil
366 return evb
373 return evb.baseBuilder.setName(evb, newName)
380 return evb
408 return evb
428 evb.number = 0
430 return evb
[all …]
/dports/net/grpcox/grpcox-1.0.0/vendor/github.com/jhump/protoreflect/desc/builder/
H A Denum.go195 Unlink(evb)
196 evb.setParent(eb)
343 return evb, nil
356 return evb, nil
366 return evb
373 return evb.baseBuilder.setName(evb, newName)
380 return evb
408 return evb
428 evb.number = 0
430 return evb
[all …]
/dports/net/grpcurl/grpcurl-1.8.5/vendor/github.com/jhump/protoreflect/desc/builder/
H A Denum.go195 Unlink(evb)
196 evb.setParent(eb)
343 return evb, nil
356 return evb, nil
366 return evb
373 return evb.baseBuilder.setName(evb, newName)
380 return evb
408 return evb
428 evb.number = 0
430 return evb
[all …]
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/common/test/
H A DFunctionLooperTest.cpp23 EventBase evb; in TEST() local
28 evb.loopOnce(); in TEST()
30 evb.loopOnce(); in TEST()
36 EventBase evb; in TEST() local
43 evb.loopOnce(); in TEST()
46 evb.loopOnce(); in TEST()
51 EventBase evb; in TEST() local
57 evb.loopOnce(); in TEST()
62 evb.loopOnce(); in TEST()
67 EventBase evb; in TEST() local
[all …]
/dports/devel/folly/folly-2021.12.27.00/folly/io/async/
H A DEventBaseLocal.cpp39 auto* evb = *locked->begin(); in ~EventBaseLocalBase() local
40 if (evb->tryDeregister(*this)) { in ~EventBaseLocalBase()
41 locked->erase(evb); in ~EventBaseLocalBase()
47 evb.dcheckIsInEventBaseThread(); in getVoid()
54 evb.dcheckIsInEventBaseThread(); in erase()
56 evb.localStorage_.erase(key_); in erase()
59 eventBases_.wlock()->erase(&evb); in erase()
63 evb.dcheckIsInEventBaseThread(); in tryDeregister()
66 locked->erase(&evb); in tryDeregister()
78 evb.dcheckIsInEventBaseThread(); in setVoid()
[all …]
H A DEventBaseLocal.h43 void erase(EventBase& evb);
46 bool tryDeregister(EventBase& evb);
50 void* getVoid(EventBase& evb);
91 T& store(EventBase& evb, T* const ptr) { in store() argument
99 T* get(EventBase& evb) { return static_cast<T*>(getVoid(evb)); } in get() argument
102 T& emplace(EventBase& evb, A&&... a) { in emplace() argument
112 T& emplace_with(EventBase& evb, F f) { in emplace_with() argument
113 return store(evb, new T(f())); in emplace_with()
118 auto const ptr = get(evb); in try_emplace()
124 auto const ptr = get(evb); in try_emplace()
[all …]
/dports/net-p2p/libswift/libswift-dc0cbcc/
H A Dsendrecv.cpp521 evbuffer_free(evb); in Send()
806 SendIfTooBig(evb); in AddData()
1151 evbuffer_drain(evb, evbuffer_get_length(evb)); in OnHash()
1284 evbuffer_drain(evb, evbuffer_get_length(evb)); in OnData()
1443 evbuffer_drain(evb, evbuffer_get_length(evb)); in OnAck()
1574 evbuffer_drain(evb, evbuffer_get_length(evb)); in OnHave()
1654 evbuffer_drain(evb, evbuffer_get_length(evb)); in OnHint()
1880 evbuffer_drain(evb, evbuffer_get_length(evb)); in OnCancel()
1999 evbuffer_drain(evb, evbuffer_get_length(evb)); in OnSignedHash()
2008 evbuffer_drain(evb, evbuffer_get_length(evb)); in OnSignedHash()
[all …]
H A Dexttrack.cpp216 evb = evbuffer_new(); in ExternalTrackerClientHTTPResponseCallback()
233 evbuffer_free(evb); in ExternalTrackerClientHTTPResponseCallback()
238 evbuffer_free(evb); in ExternalTrackerClientHTTPResponseCallback()
243 evb = evbuffer_new(); in ExternalTrackerClientHTTPResponseCallback()
274 evbuffer_free(evb); in ExternalTrackerClientHTTPResponseCallback()
281 evb = evbuffer_new(); in ExternalTrackerClientHTTPResponseCallback()
286 evbuffer_free(evb); in ExternalTrackerClientHTTPResponseCallback()
292 evbuffer_free(evb); in ExternalTrackerClientHTTPResponseCallback()
299 evb = evbuffer_new(); in ExternalTrackerClientHTTPResponseCallback()
304 evbuffer_free(evb); in ExternalTrackerClientHTTPResponseCallback()
[all …]
H A Dchannel.cpp303 int length = evbuffer_get_length(evb);
311 evbuffer_drain(evb,r);
475 return evbuffer_add(evb, &b, 1);
481 return evbuffer_add(evb, &wbe, 2);
487 return evbuffer_add(evb, &ibe, 4);
495 return evbuffer_add(evb, lbe, 8);
521 ret = evbuffer_add_32be(evb, a.ipv4());
538 if (evbuffer_remove(evb, &b, 1) < 1)
546 if (evbuffer_remove(evb, &wbe, 2) < 2)
554 if (evbuffer_remove(evb, &ibe, 4) < 4)
[all …]
H A Dlivesig.cpp188 evbuffer_add_8(evb,alg_); in GetSwarmPubKey()
196 evbuffer_free(evb); in GetSwarmPubKey()
200 uint8_t *bindata = (uint8_t *)evbuffer_pullup(evb,evbuffer_get_length(evb)); in GetSwarmPubKey()
202 evbuffer_free(evb); in GetSwarmPubKey()
206 evbuffer_free(evb); in GetSwarmPubKey()
228 evbuffer_free(evb); in Sign()
234 uint8_t *sigdata = (uint8_t *)evbuffer_pullup(evb,evbuffer_get_length(evb)); in Sign()
238 evbuffer_free(evb); in Sign()
254 evbuffer_free(evb); in Sign()
260 uint8_t *sigdata = (uint8_t *)evbuffer_pullup(evb,evbuffer_get_length(evb)); in Sign()
[all …]
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/transport/rocket/test/
H A DRocketClientChannelTest.cpp125 folly::EventBase evb; in TEST_F() local
134 folly::EventBase evb; in TEST_F() local
151 evb.loopOnce(); in TEST_F()
157 folly::EventBase evb; in TEST_F() local
175 evb.loopOnce(); in TEST_F()
224 evb.loopOnce(); in TEST_F()
340 .via(&evb) in TEST_F()
395 .via(&evb) in TEST_F()
613 .via(&evb) in TEST_F()
668 evb.loopOnce(); in TEST_F()
[all …]
/dports/net/netatalk3/netatalk-3.1.12/libevent/test/
H A Dregress_buffer.c177 evbuffer_validate(evb); in test_evbuffer()
179 evbuffer_validate(evb); in test_evbuffer()
185 evbuffer_validate(evb); in test_evbuffer()
188 evbuffer_validate(evb); in test_evbuffer()
193 evbuffer_validate(evb); in test_evbuffer()
195 evbuffer_validate(evb); in test_evbuffer()
203 evbuffer_validate(evb); in test_evbuffer()
210 evbuffer_validate(evb); in test_evbuffer()
283 evbuffer_free(evb); in test_evbuffer()
754 evbuffer_drain(evb, evbuffer_get_length(evb)); in test_evbuffer_readln()
[all …]
/dports/www/firefox-legacy/firefox-52.8.0esr/ipc/chromium/src/third_party/libevent/test/
H A Dregress_buffer.c177 evbuffer_validate(evb); in test_evbuffer()
179 evbuffer_validate(evb); in test_evbuffer()
185 evbuffer_validate(evb); in test_evbuffer()
188 evbuffer_validate(evb); in test_evbuffer()
193 evbuffer_validate(evb); in test_evbuffer()
195 evbuffer_validate(evb); in test_evbuffer()
203 evbuffer_validate(evb); in test_evbuffer()
210 evbuffer_validate(evb); in test_evbuffer()
283 evbuffer_free(evb); in test_evbuffer()
754 evbuffer_drain(evb, evbuffer_get_length(evb)); in test_evbuffer_readln()
[all …]
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp/async/
H A DTAsyncSSLSocket.h36 : folly::AsyncSSLSocket(ctx, evb) {} in TAsyncSSLSocket()
45 folly::EventBase* evb,
55 folly::EventBase* evb, in TAsyncSSLSocket() argument
66 folly::EventBase* evb,
70 new TAsyncSSLSocket(ctx, evb, fd, server));
76 folly::EventBase* evb, in TAsyncSSLSocket() argument
78 : folly::AsyncSSLSocket(ctx, evb, serverName) {} in TAsyncSSLSocket()
82 folly::EventBase* evb, in TAsyncSSLSocket() argument
85 : folly::AsyncSSLSocket(ctx, evb, fd, serverName) {} in TAsyncSSLSocket()
89 folly::EventBase* evb, in newSocket() argument
[all …]
/dports/net/ntp/ntp-4.2.8p15/sntp/libevent/test/
H A Dregress_buffer.c179 evbuffer_validate(evb); in test_evbuffer()
181 evbuffer_validate(evb); in test_evbuffer()
187 evbuffer_validate(evb); in test_evbuffer()
190 evbuffer_validate(evb); in test_evbuffer()
285 evbuffer_free(evb); in test_evbuffer()
902 tt_assert(evb); in test_evbuffer_file_segment_add_cleanup_cb()
921 evbuffer_free(evb); in test_evbuffer_file_segment_add_cleanup_cb()
930 if (evb) in test_evbuffer_file_segment_add_cleanup_cb()
931 evbuffer_free(evb); in test_evbuffer_file_segment_add_cleanup_cb()
989 evbuffer_drain(evb, evbuffer_get_length(evb)); in test_evbuffer_readln()
[all …]
/dports/devel/folly/folly-2021.12.27.00/folly/fibers/async/
H A DWaitUtils.h31 F&& func, folly::EventBase& evb, FiberManager& fm) { in executeOnFiberAndWait() argument
33 return addFiberFuture(std::forward<F>(func), fm).getVia(&evb); in executeOnFiberAndWait()
49 folly::EventBase evb; variable
51 std::forward<F>(func), evb, getFiberManager(evb, opts));
57 folly::EventBase evb; in executeOnFiberAndWait() local
59 std::forward<F>(func), evb, getFiberManager(evb, opts)); in executeOnFiberAndWait()
65 folly::EventBase& evb,
68 std::forward<F>(func), evb, getFiberManager(evb, opts));
73 F&& func, folly::EventBase& evb, const FiberManager::FrozenOptions& opts) { in executeOnFiberAndWait() argument
75 std::forward<F>(func), evb, getFiberManager(evb, opts)); in executeOnFiberAndWait()
/dports/www/firefox-esr/firefox-91.8.0/ipc/chromium/src/third_party/libevent/test/
H A Dregress_buffer.c179 evbuffer_validate(evb); in test_evbuffer()
181 evbuffer_validate(evb); in test_evbuffer()
187 evbuffer_validate(evb); in test_evbuffer()
190 evbuffer_validate(evb); in test_evbuffer()
285 evbuffer_free(evb); in test_evbuffer()
1149 tt_assert(evb); in test_evbuffer_file_segment_add_cleanup_cb()
1168 evbuffer_free(evb); in test_evbuffer_file_segment_add_cleanup_cb()
1177 if (evb) in test_evbuffer_file_segment_add_cleanup_cb()
1178 evbuffer_free(evb); in test_evbuffer_file_segment_add_cleanup_cb()
1236 evbuffer_drain(evb, evbuffer_get_length(evb)); in test_evbuffer_readln()
[all …]
/dports/lang/spidermonkey78/firefox-78.9.0/ipc/chromium/src/third_party/libevent/test/
H A Dregress_buffer.c179 evbuffer_validate(evb); in test_evbuffer()
181 evbuffer_validate(evb); in test_evbuffer()
187 evbuffer_validate(evb); in test_evbuffer()
190 evbuffer_validate(evb); in test_evbuffer()
285 evbuffer_free(evb); in test_evbuffer()
1149 tt_assert(evb); in test_evbuffer_file_segment_add_cleanup_cb()
1168 evbuffer_free(evb); in test_evbuffer_file_segment_add_cleanup_cb()
1177 if (evb) in test_evbuffer_file_segment_add_cleanup_cb()
1178 evbuffer_free(evb); in test_evbuffer_file_segment_add_cleanup_cb()
1236 evbuffer_drain(evb, evbuffer_get_length(evb)); in test_evbuffer_readln()
[all …]
/dports/www/firefox/firefox-99.0/ipc/chromium/src/third_party/libevent/test/
H A Dregress_buffer.c179 evbuffer_validate(evb); in test_evbuffer()
181 evbuffer_validate(evb); in test_evbuffer()
187 evbuffer_validate(evb); in test_evbuffer()
190 evbuffer_validate(evb); in test_evbuffer()
285 evbuffer_free(evb); in test_evbuffer()
1149 tt_assert(evb); in test_evbuffer_file_segment_add_cleanup_cb()
1168 evbuffer_free(evb); in test_evbuffer_file_segment_add_cleanup_cb()
1177 if (evb) in test_evbuffer_file_segment_add_cleanup_cb()
1178 evbuffer_free(evb); in test_evbuffer_file_segment_add_cleanup_cb()
1236 evbuffer_drain(evb, evbuffer_get_length(evb)); in test_evbuffer_readln()
[all …]

12345678910>>...88