/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_queue.h | 670 return replyq; in rd_kafka_replyq_make() 738 memset(replyq, 0, sizeof(*replyq)); in rd_kafka_replyq_clear() 764 if (replyq->q) in rd_kafka_replyq_destroy() 767 if (replyq->_id) { in rd_kafka_replyq_destroy() 769 replyq->_id = NULL; in rd_kafka_replyq_destroy() 801 if (replyq->_id) { in rd_kafka_replyq_enq() 803 replyq->_id = NULL; in rd_kafka_replyq_enq() 914 eonce->replyq = replyq; /* struct copy */ in rd_kafka_enq_once_new() 932 eonce->replyq = replyq; /* struct copy */ in rd_kafka_enq_once_reenable() 1073 replyq = eonce->replyq; in rd_kafka_enq_once_trigger() [all …]
|
H A D | rdkafka_request.h | 78 rd_kafka_replyq_t replyq, 134 rd_kafka_replyq_t replyq, 144 rd_kafka_replyq_t replyq, 155 rd_kafka_replyq_t replyq, 229 rd_kafka_replyq_t replyq, 235 rd_kafka_replyq_t replyq, 261 rd_kafka_replyq_t replyq, 270 rd_kafka_replyq_t replyq, 288 rd_kafka_replyq_t replyq, 306 rd_kafka_replyq_t replyq, [all …]
|
H A D | rdkafka_request.c | 1035 rkbuf->rkbuf_replyq = replyq; in rd_kafka_OffsetFetchRequest() 1360 rd_kafka_replyq_destroy(&replyq); in rd_kafka_OffsetCommitRequest() 1422 rd_kafka_replyq_destroy(&replyq); in rd_kafka_OffsetDeleteRequest() 2201 rd_kafka_replyq_t replyq, in rd_kafka_ApiVersionRequest() argument 2243 if (replyq.q) in rd_kafka_ApiVersionRequest() 2256 rd_kafka_replyq_t replyq, in rd_kafka_SaslHandshakeRequest() argument 2292 if (replyq.q) in rd_kafka_SaslHandshakeRequest() 2395 if (replyq.q) in rd_kafka_SaslAuthenticateRequest() 3530 rd_kafka_replyq_destroy(&replyq); in rd_kafka_CreateTopicsRequest() 3540 rd_kafka_replyq_destroy(&replyq); in rd_kafka_CreateTopicsRequest() [all …]
|
H A D | rdkafka_coord.c | 224 rd_kafka_replyq_t replyq, in rd_kafka_coord_req() argument 235 creq->creq_replyq = replyq; in rd_kafka_coord_req() 460 rd_kafka_replyq_t replyq; in rd_kafka_coord_req_fsm() local 462 rd_kafka_replyq_copy(&replyq, &creq->creq_replyq); in rd_kafka_coord_req_fsm() 464 replyq, creq->creq_resp_cb, in rd_kafka_coord_req_fsm() 470 rd_kafka_replyq_destroy(&replyq); in rd_kafka_coord_req_fsm()
|
H A D | rdkafka_partition.h | 499 rd_kafka_replyq_t replyq); 502 rd_kafka_replyq_t replyq); 506 rd_kafka_replyq_t replyq); 527 rd_kafka_replyq_t replyq); 547 rd_kafka_replyq_t replyq); 672 rd_kafka_replyq_t replyq,
|
H A D | rdkafka_cgrp.h | 316 rd_kafka_replyq_t replyq, rd_kafka_op_type_t type, 319 void rd_kafka_cgrp_terminate (rd_kafka_cgrp_t *rkcg, rd_kafka_replyq_t replyq);
|
H A D | rdkafka_partition.c | 1301 rko->rko_replyq = replyq; in rd_kafka_toppar_offset_fetch() 2307 rd_kafka_replyq_t replyq) { in rd_kafka_toppar_op0() argument 2309 rko->rko_replyq = replyq; in rd_kafka_toppar_op0() 2323 rd_kafka_replyq_t replyq) { in rd_kafka_toppar_op() argument 2335 rd_kafka_toppar_op0(rktp, rko, replyq); in rd_kafka_toppar_op() 2398 0, NULL, replyq); in rd_kafka_toppar_op_fetch_stop() 2427 offset, NULL, replyq); in rd_kafka_toppar_op_seek() 3682 if (rko->rko_u.leaders.replyq.q) { in rd_kafka_topic_partition_list_query_leaders_async_worker() 3731 rd_kafka_replyq_t replyq, in rd_kafka_topic_partition_list_query_leaders_async() argument 3737 rd_assert(replyq.q); in rd_kafka_topic_partition_list_query_leaders_async() [all …]
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_queue.h | 670 return replyq; in rd_kafka_replyq_make() 738 memset(replyq, 0, sizeof(*replyq)); in rd_kafka_replyq_clear() 764 if (replyq->q) in rd_kafka_replyq_destroy() 767 if (replyq->_id) { in rd_kafka_replyq_destroy() 769 replyq->_id = NULL; in rd_kafka_replyq_destroy() 801 if (replyq->_id) { in rd_kafka_replyq_enq() 803 replyq->_id = NULL; in rd_kafka_replyq_enq() 914 eonce->replyq = replyq; /* struct copy */ in rd_kafka_enq_once_new() 932 eonce->replyq = replyq; /* struct copy */ in rd_kafka_enq_once_reenable() 1073 replyq = eonce->replyq; in rd_kafka_enq_once_trigger() [all …]
|
H A D | rdkafka_request.h | 76 rd_kafka_replyq_t replyq, 91 rd_kafka_replyq_t replyq, 132 rd_kafka_replyq_t replyq, 142 rd_kafka_replyq_t replyq, 227 rd_kafka_replyq_t replyq, 233 rd_kafka_replyq_t replyq, 259 rd_kafka_replyq_t replyq, 268 rd_kafka_replyq_t replyq, 286 rd_kafka_replyq_t replyq, 304 rd_kafka_replyq_t replyq, [all …]
|
H A D | rdkafka_request.c | 960 rkbuf->rkbuf_replyq = replyq; in rd_kafka_OffsetFetchRequest() 1285 rd_kafka_replyq_destroy(&replyq); in rd_kafka_OffsetCommitRequest() 1347 rd_kafka_replyq_destroy(&replyq); in rd_kafka_OffsetDeleteRequest() 2196 rd_kafka_replyq_t replyq, in rd_kafka_ApiVersionRequest() argument 2238 if (replyq.q) in rd_kafka_ApiVersionRequest() 2251 rd_kafka_replyq_t replyq, in rd_kafka_SaslHandshakeRequest() argument 2287 if (replyq.q) in rd_kafka_SaslHandshakeRequest() 2390 if (replyq.q) in rd_kafka_SaslAuthenticateRequest() 3525 rd_kafka_replyq_destroy(&replyq); in rd_kafka_CreateTopicsRequest() 3535 rd_kafka_replyq_destroy(&replyq); in rd_kafka_CreateTopicsRequest() [all …]
|
H A D | rdkafka_coord.c | 224 rd_kafka_replyq_t replyq, in rd_kafka_coord_req() argument 235 creq->creq_replyq = replyq; in rd_kafka_coord_req() 460 rd_kafka_replyq_t replyq; in rd_kafka_coord_req_fsm() local 462 rd_kafka_replyq_copy(&replyq, &creq->creq_replyq); in rd_kafka_coord_req_fsm() 464 replyq, creq->creq_resp_cb, in rd_kafka_coord_req_fsm() 470 rd_kafka_replyq_destroy(&replyq); in rd_kafka_coord_req_fsm()
|
H A D | rdkafka_partition.h | 499 rd_kafka_replyq_t replyq); 502 rd_kafka_replyq_t replyq); 506 rd_kafka_replyq_t replyq); 527 rd_kafka_replyq_t replyq); 547 rd_kafka_replyq_t replyq); 672 rd_kafka_replyq_t replyq,
|
H A D | rdkafka_cgrp.h | 309 rd_kafka_replyq_t replyq, rd_kafka_op_type_t type, 312 void rd_kafka_cgrp_terminate (rd_kafka_cgrp_t *rkcg, rd_kafka_replyq_t replyq);
|
H A D | rdkafka_partition.c | 1301 rko->rko_replyq = replyq; in rd_kafka_toppar_offset_fetch() 2292 rd_kafka_replyq_t replyq) { in rd_kafka_toppar_op0() argument 2294 rko->rko_replyq = replyq; in rd_kafka_toppar_op0() 2308 rd_kafka_replyq_t replyq) { in rd_kafka_toppar_op() argument 2320 rd_kafka_toppar_op0(rktp, rko, replyq); in rd_kafka_toppar_op() 2383 0, NULL, replyq); in rd_kafka_toppar_op_fetch_stop() 2412 offset, NULL, replyq); in rd_kafka_toppar_op_seek() 3667 if (rko->rko_u.leaders.replyq.q) { in rd_kafka_topic_partition_list_query_leaders_async_worker() 3716 rd_kafka_replyq_t replyq, in rd_kafka_topic_partition_list_query_leaders_async() argument 3722 rd_assert(replyq.q); in rd_kafka_topic_partition_list_query_leaders_async() [all …]
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
H A D | rdkafka_request.h | 72 rd_kafka_replyq_t replyq, 87 rd_kafka_replyq_t replyq, 126 rd_kafka_replyq_t replyq, 138 rd_kafka_replyq_t replyq, 165 rd_kafka_replyq_t replyq, 211 rd_kafka_replyq_t replyq, 217 rd_kafka_replyq_t replyq, 242 rd_kafka_replyq_t replyq, 251 rd_kafka_replyq_t replyq, 269 rd_kafka_replyq_t replyq, [all …]
|
H A D | rdkafka_queue.h | 641 return replyq; in rd_kafka_replyq_make() 689 memset(replyq, 0, sizeof(*replyq)); in rd_kafka_replyq_clear() 715 if (replyq->q) in rd_kafka_replyq_destroy() 718 if (replyq->_id) { in rd_kafka_replyq_destroy() 720 replyq->_id = NULL; in rd_kafka_replyq_destroy() 752 if (replyq->_id) { in rd_kafka_replyq_enq() 754 replyq->_id = NULL; in rd_kafka_replyq_enq() 865 eonce->replyq = replyq; /* struct copy */ in rd_kafka_enq_once_new() 883 eonce->replyq = replyq; /* struct copy */ in rd_kafka_enq_once_reenable() 989 replyq = eonce->replyq; in rd_kafka_enq_once_trigger() [all …]
|
H A D | rdkafka_request.c | 787 rd_kafka_replyq_t replyq, in rd_kafka_OffsetFetchRequest() argument 868 rkbuf->rkbuf_replyq = replyq; in rd_kafka_OffsetFetchRequest() 1141 rd_kafka_replyq_destroy(&replyq); in rd_kafka_OffsetCommitRequest() 1985 rd_kafka_replyq_t replyq, in rd_kafka_ApiVersionRequest() argument 2038 if (replyq.q) in rd_kafka_ApiVersionRequest() 2051 rd_kafka_replyq_t replyq, in rd_kafka_SaslHandshakeRequest() argument 2087 if (replyq.q) in rd_kafka_SaslHandshakeRequest() 2190 if (replyq.q) in rd_kafka_SaslAuthenticateRequest() 3313 rd_kafka_replyq_destroy(&replyq); in rd_kafka_CreateTopicsRequest() 3323 rd_kafka_replyq_destroy(&replyq); in rd_kafka_CreateTopicsRequest() [all …]
|
H A D | rdkafka_coord.c | 224 rd_kafka_replyq_t replyq, in rd_kafka_coord_req() argument 235 creq->creq_replyq = replyq; in rd_kafka_coord_req() 402 rd_kafka_replyq_t replyq; in rd_kafka_coord_req_fsm() local 404 rd_kafka_replyq_copy(&replyq, &creq->creq_replyq); in rd_kafka_coord_req_fsm() 406 replyq, creq->creq_resp_cb, in rd_kafka_coord_req_fsm()
|
H A D | rdkafka_cgrp.h | 282 rd_kafka_replyq_t replyq, rd_kafka_op_type_t type, 285 void rd_kafka_cgrp_terminate (rd_kafka_cgrp_t *rkcg, rd_kafka_replyq_t replyq);
|
/dports/net/radsecproxy/radsecproxy-1.8.2/ |
H A D | tcp.c | 240 struct gqueue *replyq; in tcpserverwr() local 245 replyq = client->replyq; in tcpserverwr() 247 pthread_mutex_lock(&replyq->mutex); in tcpserverwr() 248 while (!list_first(replyq->entries)) { in tcpserverwr() 251 pthread_cond_wait(&replyq->cond, &replyq->mutex); in tcpserverwr() 256 pthread_mutex_unlock(&replyq->mutex); in tcpserverwr() 261 reply = (struct request *)list_shift(replyq->entries); in tcpserverwr() 262 pthread_mutex_unlock(&replyq->mutex); in tcpserverwr() 308 pthread_mutex_lock(&client->replyq->mutex); in tcpserverrd() 309 pthread_cond_signal(&client->replyq->cond); in tcpserverrd() [all …]
|
H A D | udp.c | 95 pthread_mutex_lock(&c->replyq->mutex); in removeudpclientfromreplyq() 96 for (n = list_first(c->replyq->entries); n; n = list_next(n)) { in removeudpclientfromreplyq() 101 pthread_mutex_unlock(&c->replyq->mutex); in removeudpclientfromreplyq() 212 c->replyq = NULL; /* stop removeclient() from removing common udp replyq */ in radudpget() 291 struct gqueue *replyq = (struct gqueue *)arg; in udpserverwr() local 296 pthread_mutex_lock(&replyq->mutex); in udpserverwr() 297 while (!(reply = (struct request *)list_shift(replyq->entries))) { in udpserverwr() 299 pthread_cond_wait(&replyq->cond, &replyq->mutex); in udpserverwr() 305 pthread_mutex_unlock(&replyq->mutex); in udpserverwr() 316 client->replyq = server_replyq; in addclientudp()
|
H A D | tls.c | 389 struct gqueue *replyq; in tlsserverwr() local 394 replyq = client->replyq; in tlsserverwr() 396 pthread_mutex_lock(&replyq->mutex); in tlsserverwr() 397 while (!list_first(replyq->entries)) { in tlsserverwr() 400 pthread_cond_wait(&replyq->cond, &replyq->mutex); in tlsserverwr() 406 reply = (struct request *)list_shift(replyq->entries); in tlsserverwr() 407 pthread_mutex_unlock(&replyq->mutex); in tlsserverwr() 465 pthread_mutex_lock(&client->replyq->mutex); in tlsserverrd() 466 pthread_cond_signal(&client->replyq->cond); in tlsserverrd() 467 pthread_mutex_unlock(&client->replyq->mutex); in tlsserverrd()
|
H A D | dtls.c | 200 struct gqueue *replyq; in dtlsserverwr() local 205 replyq = client->replyq; in dtlsserverwr() 207 pthread_mutex_lock(&replyq->mutex); in dtlsserverwr() 208 while (!list_first(replyq->entries)) { in dtlsserverwr() 211 pthread_cond_wait(&replyq->cond, &replyq->mutex); in dtlsserverwr() 217 reply = (struct request *)list_shift(replyq->entries); in dtlsserverwr() 218 pthread_mutex_unlock(&replyq->mutex); in dtlsserverwr() 288 pthread_mutex_lock(&client->replyq->mutex); in dtlsserverrd() 289 pthread_cond_signal(&client->replyq->cond); in dtlsserverrd() 290 pthread_mutex_unlock(&client->replyq->mutex); in dtlsserverrd()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/krb5-src-0.2.4+1.18.2/krb5/src/tests/ |
H A D | t_otp.py | 92 replyq = {'user': usernm, 'pass': passwd} 95 replyq['reply'] = True 98 replyq['reply'] = False 100 outq.put(replyq)
|
/dports/security/krb5/krb5-1.19.2/src/tests/ |
H A D | t_otp.py | 92 replyq = {'user': usernm, 'pass': passwd} 95 replyq['reply'] = True 98 replyq['reply'] = False 100 outq.put(replyq)
|