Home
last modified time | relevance | path

Searched refs:header_cnt (Results 1 – 14 of 14) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0072-headers_ut.c265 size_t header_cnt; in on_send1() local
276 header_cnt = rd_kafka_header_cnt(hdrs); in on_send1()
277 TEST_ASSERT(header_cnt == 7, in on_send1()
282 header_cnt = rd_kafka_header_cnt(hdrs); in on_send1()
283 TEST_ASSERT(header_cnt == 8, in on_send1()
293 header_cnt = rd_kafka_header_cnt(hdrs); in on_send1()
294 TEST_ASSERT(header_cnt == 9, in on_send1()
299 header_cnt = rd_kafka_header_cnt(hdrs); in on_send1()
300 TEST_ASSERT(header_cnt == 5, in on_send1()
306 TEST_ASSERT(header_cnt == 6, in on_send1()
[all …]
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/
H A D0072-headers_ut.c265 size_t header_cnt; in on_send1() local
276 header_cnt = rd_kafka_header_cnt(hdrs); in on_send1()
277 TEST_ASSERT(header_cnt == 7, in on_send1()
282 header_cnt = rd_kafka_header_cnt(hdrs); in on_send1()
283 TEST_ASSERT(header_cnt == 8, in on_send1()
293 header_cnt = rd_kafka_header_cnt(hdrs); in on_send1()
294 TEST_ASSERT(header_cnt == 9, in on_send1()
299 header_cnt = rd_kafka_header_cnt(hdrs); in on_send1()
300 TEST_ASSERT(header_cnt == 5, in on_send1()
306 TEST_ASSERT(header_cnt == 6, in on_send1()
[all …]
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/
H A D0072-headers_ut.c265 size_t header_cnt; in on_send1() local
276 header_cnt = rd_kafka_header_cnt(hdrs); in on_send1()
277 TEST_ASSERT(header_cnt == 7, in on_send1()
282 header_cnt = rd_kafka_header_cnt(hdrs); in on_send1()
283 TEST_ASSERT(header_cnt == 8, in on_send1()
293 header_cnt = rd_kafka_header_cnt(hdrs); in on_send1()
294 TEST_ASSERT(header_cnt == 9, in on_send1()
299 header_cnt = rd_kafka_header_cnt(hdrs); in on_send1()
300 TEST_ASSERT(header_cnt == 5, in on_send1()
306 TEST_ASSERT(header_cnt == 6, in on_send1()
[all …]
/dports/emulators/mess/mame-mame0226/src/devices/sound/
H A Ds_dsp.cpp315 vp->header_cnt = 0; in dsp_update()
387 if (!vp->header_cnt) in dsp_update()
423 vp->header_cnt = 8; in dsp_update()
445 vp->header_cnt--; in dsp_update()
1050 save_item(NAME(m_voice_state[v].header_cnt), v); in state_register()
H A Ds_dsp.h65 int header_cnt; /* Bytes before new header (0-8)*/ member
/dports/emulators/mame/mame-mame0226/src/devices/sound/
H A Ds_dsp.cpp315 vp->header_cnt = 0; in dsp_update()
387 if (!vp->header_cnt) in dsp_update()
423 vp->header_cnt = 8; in dsp_update()
445 vp->header_cnt--; in dsp_update()
1050 save_item(NAME(m_voice_state[v].header_cnt), v); in state_register()
H A Ds_dsp.h65 int header_cnt; /* Bytes before new header (0-8)*/ member
/dports/mail/courier-analog/courier-analog-0.17/
H A Dcourier-analog.in1015 my $header_cnt=Math::BigInt->bzero();
1026 $header_cnt->badd(new Math::BigInt $h);
1032 my $total=$header_cnt->copy->badd($body_cnt);
1035 my $header_avg=$header_cnt->copy;
1049 $header_cnt->as_number,
/dports/comms/qsstv/qsstv/drmrx/
H A Dstructtemplates.h180 int header_cnt; member
/dports/www/uwsgi/uwsgi-2.0.20/core/
H A Dwriter.c90 wsgi_req->header_cnt = 0; in uwsgi_response_prepare_headers()
165 wsgi_req->header_cnt++; in uwsgi_response_add_header_do()
H A Dlogging.c730 …sgi_req->protocol_len, wsgi_req->protocol, wsgi_req->status, wsgi_req->header_cnt, (unsigned long …
735 …size, (unsigned long long) rt, tsize, via, wsgi_req->status, wsgi_req->header_cnt, (unsigned long …
1249 *buf = uwsgi_num2str(wsgi_req->header_cnt);
/dports/sysutils/u-boot-imx-serial-loader/imx_usb_loader-ba6b31c/
H A Dimx_sdp.c1331 int header_cnt = 0; in process_header() local
1362 if (*p_plugin && (!curr->plug) && (!header_cnt)) { in process_header()
1363 header_cnt++; in process_header()
/dports/devel/ga/ga-5.8/armci/src/devices/lapi/
H A Dlapi.c73 volatile static int hndlcnt=0, header_cnt=0; variable
/dports/www/uwsgi/uwsgi-2.0.20/
H A Duwsgi.h1469 uint16_t header_cnt; member