Home
last modified time | relevance | path

Searched refs:replyq (Results 1 – 25 of 103) sorted by relevance

12345

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_queue.h670 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 Drdkafka_request.h78 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 Drdkafka_request.c1035 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 Drdkafka_coord.c224 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 Drdkafka_partition.h499 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 Drdkafka_cgrp.h316 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 Drdkafka_partition.c1301 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 Drdkafka_queue.h670 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 Drdkafka_request.h76 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 Drdkafka_request.c960 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 Drdkafka_coord.c224 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 Drdkafka_partition.h499 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 Drdkafka_cgrp.h309 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 Drdkafka_partition.c1301 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 Drdkafka_request.h72 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 Drdkafka_queue.h641 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 Drdkafka_request.c787 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 Drdkafka_coord.c224 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 Drdkafka_cgrp.h282 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 Dtcp.c240 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 Dudp.c95 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 Dtls.c389 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 Ddtls.c200 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 Dt_otp.py92 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 Dt_otp.py92 replyq = {'user': usernm, 'pass': passwd}
95 replyq['reply'] = True
98 replyq['reply'] = False
100 outq.put(replyq)

12345