/dports/databases/twemproxy/twemproxy-0.5.0/src/event/ |
H A D | nc_kqueue.c | 58 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 D | nc_evport.c | 49 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 D | nc_epoll.c | 48 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 D | vev.c | 133 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 D | phk_event.c | 104 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 D | enum.go | 195 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 D | enum.go | 195 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 D | enum.go | 195 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 D | enum.go | 195 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 D | FunctionLooperTest.cpp | 23 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 D | EventBaseLocal.cpp | 39 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 D | EventBaseLocal.h | 43 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 D | sendrecv.cpp | 521 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 D | exttrack.cpp | 216 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 D | channel.cpp | 303 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 D | livesig.cpp | 188 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 D | RocketClientChannelTest.cpp | 125 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 D | regress_buffer.c | 177 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 D | regress_buffer.c | 177 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 D | TAsyncSSLSocket.h | 36 : 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 D | regress_buffer.c | 179 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 D | WaitUtils.h | 31 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 D | regress_buffer.c | 179 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 D | regress_buffer.c | 179 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 D | regress_buffer.c | 179 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 …]
|