| /third_party/ffmpeg/libavformat/ |
| D | sapdec.c | 67 uint8_t recvbuf[RTP_MAX_PACKET_LENGTH]; in sap_read_header() local
97 ret = ffurl_read(sap->ann_fd, recvbuf, sizeof(recvbuf) - 1); in sap_read_header()
102 recvbuf[ret] = '\0'; /* Null terminate for easier parsing */ in sap_read_header()
108 if ((recvbuf[0] & 0xe0) != 0x20) { in sap_read_header()
114 if (recvbuf[0] & 0x04) { in sap_read_header()
119 addr_type = recvbuf[0] & 0x10; in sap_read_header()
120 auth_len = recvbuf[1]; in sap_read_header()
121 sap->hash = AV_RB16(&recvbuf[2]); in sap_read_header()
133 if (strcmp(&recvbuf[pos], MIME) == 0) { in sap_read_header()
135 } else if (strncmp(&recvbuf[pos], "v=0\r\n", 5) == 0) { in sap_read_header()
[all …]
|
| D | rtsp.c | 825 av_freep(&rt->recvbuf); in ff_rtsp_close_streams()
2118 if (RTP_PT_IS_RTCP(rt->recvbuf[1])) { in pick_stream()
2161 len = ff_rtsp_tcp_read_packet(s, rtsp_st, rt->recvbuf, RECVBUF_SIZE); in read_packet()
2166 len = udp_read_packet(s, rtsp_st, rt->recvbuf, RECVBUF_SIZE, wait_end); in read_packet()
2175 len = avio_read_partial(s->pb, rt->recvbuf, RECVBUF_SIZE); in read_packet()
2176 len = pick_stream(s, rtsp_st, rt->recvbuf, len); in read_packet()
2205 …ret = avpriv_mpegts_parse_packet(rt->ts, pkt, rt->recvbuf + rt->recvbuf_pos, rt->recvbuf_len - rt-… in ff_rtsp_fetch_packet()
2246 if (!rt->recvbuf) { in ff_rtsp_fetch_packet()
2247 rt->recvbuf = av_malloc(RECVBUF_SIZE); in ff_rtsp_fetch_packet()
2248 if (!rt->recvbuf) in ff_rtsp_fetch_packet()
[all …]
|
| D | rtsp.h | 348 uint8_t* recvbuf; member
|
| /third_party/node/benchmark/net/ |
| D | net-s2c.js | 19 let recvbuf; variable
24 recvbuf = Buffer.alloc(recvbuflen);
45 if (recvbuf === undefined) {
49 let buffer = recvbuf;
53 recvbuf,
54 Buffer.from(recvbuf),
55 Buffer.from(recvbuf),
83 if (recvbuf === undefined)
|
| /third_party/node/benchmark/tls/ |
| D | throughput-s2c.js | 13 let recvbuf; variable
19 recvbuf = Buffer.alloc(recvbuflen);
48 if (recvbuf === undefined) {
51 let buffer = recvbuf;
55 recvbuf,
56 Buffer.from(recvbuf),
57 Buffer.from(recvbuf),
|
| /third_party/ltp/testcases/network/stress/ns-tools/ |
| D | ns-udpclient.c | 156 char *recvbuf = NULL; /* Pointer to the message */ in main() local
291 recvbuf = malloc(MESSAGE_LEN + 1); in main()
292 if (recvbuf == NULL) { in main()
320 if ((recvlen = recvfrom(sock_fd, recvbuf, MESSAGE_LEN, 0, in main()
336 recvbuf[recvlen] = '\0'; in main()
338 fprintf(stderr, "Message is %s\n", recvbuf); in main()
|
| D | ns-tcpclient.c | 145 char *recvbuf; /* pointer to the received message */ in main() local
305 recvbuf = malloc(recvbuf_size); in main()
306 if (recvbuf == NULL) { in main()
319 recvbyte_size = recv(sock_fd, recvbuf, recvbuf_size, 0); in main()
340 free(recvbuf); in main()
|
| /third_party/curl/tests/http/clients/ |
| D | ws-data.c | 105 char recvbuf[256]; in recv_binary() local
112 result = curl_ws_recv(curl, recvbuf, sizeof(recvbuf), &nread, &frame); in recv_binary()
119 (long)r_offset, (long)sizeof(recvbuf), result, (long)nread); in recv_binary()
143 if(memcmp(exp_data + r_offset, recvbuf, nread)) { in recv_binary()
147 dump("received:", (unsigned char *)recvbuf, nread, 0); in recv_binary()
|
| /third_party/curl/lib/ |
| D | mqtt.c | 112 Curl_dyn_init(&mq->recvbuf, DYN_MQTT_RECV); in mqtt_setup_conn()
354 Curl_dyn_free(&mq->recvbuf); in mqtt_disconnect()
361 size_t rlen = Curl_dyn_len(&mq->recvbuf); in mqtt_recv_atleast()
374 if(Curl_dyn_addn(&mq->recvbuf, readbuf, (size_t)nread)) in mqtt_recv_atleast()
376 rlen = Curl_dyn_len(&mq->recvbuf); in mqtt_recv_atleast()
384 size_t rlen = Curl_dyn_len(&mq->recvbuf); in mqtt_recv_consume()
386 Curl_dyn_reset(&mq->recvbuf); in mqtt_recv_consume()
388 Curl_dyn_tail(&mq->recvbuf, rlen - nbytes); in mqtt_recv_consume()
402 DEBUGASSERT(Curl_dyn_len(&mq->recvbuf) >= MQTT_CONNACK_LEN); in mqtt_verify_connack()
403 ptr = Curl_dyn_ptr(&mq->recvbuf); in mqtt_verify_connack()
[all …]
|
| D | ws.c | 619 Curl_bufq_init(&ws->recvbuf, WS_CHUNK_SIZE, WS_CHUNK_COUNT); in Curl_ws_accept()
626 Curl_bufq_reset(&ws->recvbuf); in Curl_ws_accept()
663 nwritten = Curl_bufq_write(&ws->recvbuf, (const unsigned char *)mem, in Curl_ws_accept()
744 nwritten = Curl_bufq_write(&ws->recvbuf, (const unsigned char *)buffer, in Curl_ws_writecb()
753 while(!Curl_bufq_is_empty(&ws->recvbuf)) { in Curl_ws_writecb()
755 result = ws_dec_pass(&ws->dec, data, &ws->recvbuf, in Curl_ws_writecb()
886 if(Curl_bufq_is_empty(&ws->recvbuf)) { in curl_ws_recv()
887 ssize_t n = Curl_bufq_slurp(&ws->recvbuf, nw_in_recv, data, &result); in curl_ws_recv()
897 Curl_bufq_len(&ws->recvbuf))); in curl_ws_recv()
900 result = ws_dec_pass(&ws->dec, data, &ws->recvbuf, in curl_ws_recv()
[all …]
|
| D | cf-h2-proxy.c | 70 struct bufq recvbuf; member
92 Curl_bufq_init2(&ts->recvbuf, PROXY_H2_CHUNK_SIZE, H2_TUNNEL_RECV_CHUNKS, in tunnel_stream_init()
111 Curl_bufq_free(&ts->recvbuf); in tunnel_stream_clear()
491 !Curl_bufq_is_full(&ctx->tunnel.recvbuf)) { in proxy_h2_progress_ingress()
868 nwritten = Curl_bufq_write(&ctx->tunnel.recvbuf, mem, len, &result); in tunnel_recv_callback()
1185 !Curl_bufq_is_empty(&ctx->tunnel.recvbuf))) in cf_h2_proxy_data_pending()
1252 if(!Curl_bufq_is_empty(&ctx->tunnel.recvbuf)) { in tunnel_recv()
1253 nread = Curl_bufq_read(&ctx->tunnel.recvbuf, in tunnel_recv()
1297 if(Curl_bufq_is_empty(&ctx->tunnel.recvbuf)) { in cf_h2_proxy_recv()
1327 if(!Curl_bufq_is_empty(&ctx->tunnel.recvbuf) && in cf_h2_proxy_recv()
[all …]
|
| D | cf-socket.c | 772 struct bufq recvbuf; /* used when `buffer_recv` is set */ member
801 Curl_bufq_init(&ctx->recvbuf, NW_RECV_CHUNK_SIZE, NW_RECV_CHUNKS); in cf_socket_ctx_init()
914 Curl_bufq_reset(&ctx->recvbuf); in cf_socket_close()
930 Curl_bufq_free(&ctx->recvbuf); in cf_socket_destroy()
1278 if(!Curl_bufq_is_empty(&ctx->recvbuf)) in cf_socket_data_pending()
1396 if(ctx->buffer_recv && !Curl_bufq_is_empty(&ctx->recvbuf)) { in cf_socket_recv()
1398 nread = Curl_bufq_read(&ctx->recvbuf, (unsigned char *)buf, len, err); in cf_socket_recv()
1410 nwritten = Curl_bufq_slurp(&ctx->recvbuf, nw_in_read, &rctx, err); in cf_socket_recv()
1411 if(nwritten < 0 && !Curl_bufq_is_empty(&ctx->recvbuf)) { in cf_socket_recv()
1415 nread = Curl_bufq_read(&ctx->recvbuf, (unsigned char *)buf, len, err); in cf_socket_recv()
[all …]
|
| D | mqtt.h | 59 struct dynbuf recvbuf; member
|
| D | ws.h | 71 struct bufq recvbuf; /* raw data from the server */ member
|
| D | http2.c | 177 struct bufq recvbuf; /* response buffer */ member
256 Curl_bufq_initp(&stream->recvbuf, &ctx->stream_bufcp, in http2_data_setup()
301 if(!Curl_bufq_is_empty(&stream->recvbuf)) { in http2_data_done()
307 Curl_bufq_len(&stream->recvbuf)); in http2_data_done()
317 Curl_bufq_free(&stream->recvbuf); in http2_data_done()
967 nwritten = Curl_bufq_write(&stream->recvbuf, in recvbuf_write_hds()
994 rbuflen = Curl_bufq_len(&stream->recvbuf); in on_stream_frame()
1301 nwritten = Curl_bufq_write(&stream->recvbuf, mem, len, &result); in on_data_chunk_recv()
1851 if(!Curl_bufq_is_empty(&stream->recvbuf)) { in stream_recv()
1852 nread = Curl_bufq_read(&stream->recvbuf, in stream_recv()
[all …]
|
| /third_party/curl/lib/vquic/ |
| D | curl_msh3.c | 135 struct bufq recvbuf; /* h3 response */ member
174 Curl_bufq_init2(&stream->recvbuf, H3_STREAM_CHUNK_SIZE, in h3_data_setup()
187 Curl_bufq_free(&stream->recvbuf); in h3_data_done()
316 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
538 if(!Curl_bufq_is_empty(&stream->recvbuf)) { in cf_msh3_recv()
539 nread = Curl_bufq_read(&stream->recvbuf, in cf_msh3_recv()
715 Curl_bufq_len(&stream->recvbuf)); in cf_msh3_data_pending()
716 pending = !Curl_bufq_is_empty(&stream->recvbuf); in cf_msh3_data_pending()
|
| D | curl_quiche.c | 234 struct bufq recvbuf; /* h3 response */ member
322 Curl_bufq_initp(&stream->recvbuf, &ctx->stream_bufcp, in h3_data_setup()
340 Curl_bufq_free(&stream->recvbuf); in h3_data_done()
400 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
503 nwritten = Curl_bufq_slurp(&stream->recvbuf, in cf_recv_body()
891 if(!Curl_bufq_is_empty(&stream->recvbuf)) { in cf_quiche_recv()
892 nread = Curl_bufq_read(&stream->recvbuf, in cf_quiche_recv()
908 if(nread < 0 && !Curl_bufq_is_empty(&stream->recvbuf)) { in cf_quiche_recv()
909 nread = Curl_bufq_read(&stream->recvbuf, in cf_quiche_recv()
1211 return stream && !Curl_bufq_is_empty(&stream->recvbuf); in cf_quiche_data_pending()
|
| D | curl_ngtcp2.c | 182 struct bufq recvbuf; /* h3 response body */ member
228 Curl_bufq_initp(&stream->recvbuf, &ctx->stream_bufcp, in h3_data_setup()
245 Curl_bufq_free(&stream->recvbuf); in h3_data_done()
1167 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
1489 if(!Curl_bufq_is_empty(&stream->recvbuf)) { in cf_ngtcp2_recv()
1490 nread = Curl_bufq_read(&stream->recvbuf, in cf_ngtcp2_recv()
1507 if(nread < 0 && !Curl_bufq_is_empty(&stream->recvbuf)) { in cf_ngtcp2_recv()
1508 nread = Curl_bufq_read(&stream->recvbuf, in cf_ngtcp2_recv()
2252 return stream && !Curl_bufq_is_empty(&stream->recvbuf); in cf_ngtcp2_data_pending()
|
| /third_party/ltp/testcases/kernel/syscalls/send/ |
| D | send02.c | 76 char recvbuf[RECVSIZE] = {0}; in check_recv() local
79 TEST(recv(sock, recvbuf, RECVSIZE, MSG_DONTWAIT)); in check_recv()
|
| /third_party/gstreamer/gstplugins_base/tests/check/elements/ |
| D | appsrc.c | 692 GstBuffer *recvbuf = GST_PAD_PROBE_INFO_BUFFER (info); in appsrc_pad_probe() local
701 fail_unless_equals_uint64 (GST_BUFFER_PTS (recvbuf), in appsrc_pad_probe()
703 fail_unless_equals_uint64 (GST_BUFFER_DTS (recvbuf), in appsrc_pad_probe()
705 fail_unless_equals_uint64 (GST_BUFFER_DURATION (recvbuf), in appsrc_pad_probe()
|
| /third_party/curl/ |
| D | CHANGES | 71 - add `mq->recvbuf` to provide buffering of incomplete
|