Home
last modified time | relevance | path

Searched refs:recvbuf (Results 1 - 25 of 27) sorted by relevance

12

/third_party/ffmpeg/libavformat/
H A Dsapdec.c66 uint8_t recvbuf[RTP_MAX_PACKET_LENGTH]; in sap_read_header() local
96 ret = ffurl_read(sap->ann_fd, recvbuf, sizeof(recvbuf) - 1); in sap_read_header()
101 recvbuf[ret] = '\0'; /* Null terminate for easier parsing */ in sap_read_header()
107 if ((recvbuf[0] & 0xe0) != 0x20) { in sap_read_header()
113 if (recvbuf[0] & 0x04) { in sap_read_header()
118 addr_type = recvbuf[0] & 0x10; in sap_read_header()
119 auth_len = recvbuf[1]; in sap_read_header()
120 sap->hash = AV_RB16(&recvbuf[2]); in sap_read_header()
132 if (strcmp(&recvbuf[po in sap_read_header()
198 uint8_t recvbuf[RTP_MAX_PACKET_LENGTH]; sap_fetch_packet() local
[all...]
H A Drtsp.c822 av_freep(&rt->recvbuf); in ff_rtsp_close_streams()
2129 if (RTP_PT_IS_RTCP(rt->recvbuf[1])) { in pick_stream()
2172 len = ff_rtsp_tcp_read_packet(s, rtsp_st, rt->recvbuf, RECVBUF_SIZE); in read_packet()
2177 len = udp_read_packet(s, rtsp_st, rt->recvbuf, RECVBUF_SIZE, wait_end); in read_packet()
2186 len = avio_read_partial(s->pb, rt->recvbuf, RECVBUF_SIZE); in read_packet()
2187 len = pick_stream(s, rtsp_st, rt->recvbuf, len); in read_packet()
2216 ret = avpriv_mpegts_parse_packet(rt->ts, pkt, rt->recvbuf + rt->recvbuf_pos, rt->recvbuf_len - rt->recvbuf_pos); in ff_rtsp_fetch_packet()
2257 if (!rt->recvbuf) { in ff_rtsp_fetch_packet()
2258 rt->recvbuf = av_malloc(RECVBUF_SIZE); in ff_rtsp_fetch_packet()
2259 if (!rt->recvbuf) in ff_rtsp_fetch_packet()
2508 uint8_t recvbuf[RTP_MAX_PACKET_LENGTH]; rtp_read_header() local
[all...]
H A Drtsp.h346 uint8_t* recvbuf; member
/third_party/node/benchmark/tls/
H A Dthroughput-s2c.js13 let recvbuf;
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/curl/lib/
H A Dpingpong.c149 Curl_dyn_init(&pp->recvbuf, DYN_PINGPPONG_CMD); in Curl_pp_init()
292 size_t full = Curl_dyn_len(&pp->recvbuf); in Curl_pp_readresp()
295 Curl_dyn_tail(&pp->recvbuf, full - pp->nfinal); in Curl_pp_readresp()
315 result = Curl_dyn_addn(&pp->recvbuf, buffer, gotbytes); in Curl_pp_readresp()
325 char *line = Curl_dyn_ptr(&pp->recvbuf); in Curl_pp_readresp()
326 char *nl = memchr(line, '\n', Curl_dyn_len(&pp->recvbuf)); in Curl_pp_readresp()
352 if(Curl_dyn_len(&pp->recvbuf) > length) in Curl_pp_readresp()
353 pp->overflow = Curl_dyn_len(&pp->recvbuf) - length; in Curl_pp_readresp()
360 if(Curl_dyn_len(&pp->recvbuf) > length) in Curl_pp_readresp()
362 Curl_dyn_tail((&pp->recvbuf), Curl_dyn_le in Curl_pp_readresp()
[all...]
H A Dmqtt.c112 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...]
H A Dimap.c358 char *message = Curl_dyn_ptr(&data->conn->proto.imapc.pp.recvbuf); in imap_get_message()
899 const char *line = Curl_dyn_ptr(&imapc->pp.recvbuf); in imap_state_capability_resp()
1061 char *line = Curl_dyn_ptr(&data->conn->proto.imapc.pp.recvbuf); in imap_state_listsearch_resp()
1085 const char *line = Curl_dyn_ptr(&data->conn->proto.imapc.pp.recvbuf); in imap_state_select_resp()
1144 const char *ptr = Curl_dyn_ptr(&data->conn->proto.imapc.pp.recvbuf); in imap_state_fetch_resp()
1179 Curl_dyn_tail(&pp->recvbuf, chunk); in imap_state_fetch_resp()
1192 Curl_dyn_ptr(&pp->recvbuf), chunk); in imap_state_fetch_resp()
1203 Curl_dyn_tail(&pp->recvbuf, pp->overflow); in imap_state_fetch_resp()
1208 Curl_dyn_reset(&pp->recvbuf); in imap_state_fetch_resp()
H A Dmqtt.h59 struct dynbuf recvbuf; member
H A Dws.c761 Curl_bufq_init2(&ws->recvbuf, WS_CHUNK_SIZE, WS_CHUNK_COUNT, in Curl_ws_accept()
769 Curl_bufq_reset(&ws->recvbuf); in Curl_ws_accept()
818 nwritten = Curl_bufq_write(&ws->recvbuf, (const unsigned char *)mem, in Curl_ws_accept()
951 if(Curl_bufq_is_empty(&ws->recvbuf)) { in curl_ws_recv()
952 ssize_t n = Curl_bufq_slurp(&ws->recvbuf, nw_in_recv, data, &result); in curl_ws_recv()
962 Curl_bufq_len(&ws->recvbuf))); in curl_ws_recv()
965 result = ws_dec_pass(&ws->dec, data, &ws->recvbuf, in curl_ws_recv()
1136 Curl_bufq_free(&conn->proto.ws->recvbuf); in ws_free()
H A Dws.h71 struct bufq recvbuf; /* raw data from the server */ member
H A Dcf-h2-proxy.c70 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()
860 nwritten = Curl_bufq_write(&ctx->tunnel.recvbuf, mem, len, &result); in tunnel_recv_callback()
1166 !Curl_bufq_is_empty(&ctx->tunnel.recvbuf))) in cf_h2_proxy_data_pending()
1239 if(!Curl_bufq_is_empty(&ctx->tunnel.recvbuf)) { in tunnel_recv()
1240 nread = Curl_bufq_read(&ctx->tunnel.recvbuf, in tunnel_recv()
1284 if(Curl_bufq_is_empty(&ctx->tunnel.recvbuf)) { in cf_h2_proxy_recv()
1314 if(!Curl_bufq_is_empty(&ctx->tunnel.recvbuf) in cf_h2_proxy_recv()
[all...]
H A Dcf-socket.c778 struct bufq recvbuf; /* used when `buffer_recv` is set */ member
808 Curl_bufq_init(&ctx->recvbuf, NW_RECV_CHUNK_SIZE, NW_RECV_CHUNKS); in cf_socket_ctx_init()
901 Curl_bufq_reset(&ctx->recvbuf); in cf_socket_close()
917 Curl_bufq_free(&ctx->recvbuf); in cf_socket_destroy()
1267 if(!Curl_bufq_is_empty(&ctx->recvbuf)) in cf_socket_data_pending()
1385 if(ctx->buffer_recv && !Curl_bufq_is_empty(&ctx->recvbuf)) { in cf_socket_recv()
1387 nread = Curl_bufq_read(&ctx->recvbuf, (unsigned char *)buf, len, err); in cf_socket_recv()
1399 nwritten = Curl_bufq_slurp(&ctx->recvbuf, nw_in_read, &rctx, err); in cf_socket_recv()
1400 if(nwritten < 0 && !Curl_bufq_is_empty(&ctx->recvbuf)) { in cf_socket_recv()
1404 nread = Curl_bufq_read(&ctx->recvbuf, (unsigne in cf_socket_recv()
[all...]
H A Dpop3.c255 char *message = Curl_dyn_ptr(&data->conn->proto.pop3c.pp.recvbuf); in pop3_get_message()
652 const char *line = Curl_dyn_ptr(&data->conn->proto.pop3c.pp.recvbuf); in pop3_state_servergreet_resp()
702 const char *line = Curl_dyn_ptr(&data->conn->proto.pop3c.pp.recvbuf); in pop3_state_capa_resp()
945 Curl_dyn_tail(&pp->recvbuf, pp->overflow); in pop3_state_command_resp()
949 result = Curl_pop3_write(data, Curl_dyn_ptr(&pp->recvbuf), in pop3_state_command_resp()
950 Curl_dyn_len(&pp->recvbuf)); in pop3_state_command_resp()
956 Curl_dyn_reset(&pp->recvbuf); in pop3_state_command_resp()
H A Dhttp2.c177 struct bufq recvbuf; /* response buffer */ member
181 size_t resp_hds_len; /* amount of response header bytes in recvbuf */
256 Curl_bufq_initp(&stream->recvbuf, &ctx->stream_bufcp, in http2_data_setup()
310 if(!Curl_bufq_is_empty(&stream->recvbuf)) { in http2_data_done()
311 /* Anything in the recvbuf is still being counted in http2_data_done()
316 Curl_bufq_len(&stream->recvbuf)); in http2_data_done()
326 Curl_bufq_free(&stream->recvbuf); in http2_data_done()
971 nwritten = Curl_bufq_write(&stream->recvbuf, in recvbuf_write_hds()
998 rbuflen = Curl_bufq_len(&stream->recvbuf); in on_stream_frame()
1295 nwritten = Curl_bufq_write(&stream->recvbuf, me in on_data_chunk_recv()
[all...]
H A Dpingpong.h62 struct dynbuf recvbuf; member
H A Dkrb5.c240 char *line = Curl_dyn_ptr(&pp->recvbuf); in krb5_auth()
329 size_t len = Curl_dyn_len(&pp->recvbuf); in krb5_auth()
330 p = Curl_dyn_ptr(&pp->recvbuf); in krb5_auth()
774 line = Curl_dyn_ptr(&pp->recvbuf); in sec_set_protection_level()
/third_party/node/benchmark/net/
H A Dnet-s2c.js19 let recvbuf;
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/ltp/testcases/network/stress/ns-tools/
H A Dns-udpclient.c156 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()
H A Dns-tcpclient.c145 char *recvbuf; /* pointer to the received message */ in main() local
301 fprintf(stderr, "recvbuf size of socket(%d) is %d\n", sock_fd, in main()
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/
H A Dws-data.c105 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/vquic/
H A Dcurl_osslq.c215 struct bufq recvbuf; /* QUIC war data recv buffer */ member
229 Curl_bufq_initp(&s->recvbuf, bufcp, 1, BUFQ_OPT_NONE); in cf_osslq_stream_open()
245 Curl_bufq_free(&s->recvbuf); in cf_osslq_stream_cleanup()
368 Curl_bufq_initp(&nstream->recvbuf, &ctx->stream_bufcp, 1, BUFQ_OPT_NONE); in cf_osslq_h3conn_add_stream()
482 struct bufq recvbuf; /* h3 response body */ member
530 Curl_bufq_initp(&stream->recvbuf, &ctx->stream_bufcp, in h3_data_setup()
557 Curl_bufq_free(&stream->recvbuf); in h3_data_done()
671 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
1188 if(Curl_bufq_is_empty(&s->recvbuf) && !s->recvd_eos) { in cf_osslq_stream_recv()
1189 while(!eagain && !s->recvd_eos && !Curl_bufq_is_full(&s->recvbuf)) { in cf_osslq_stream_recv()
[all...]
H A Dcurl_msh3.c140 struct bufq recvbuf; /* h3 response */ member
179 Curl_bufq_init2(&stream->recvbuf, H3_STREAM_CHUNK_SIZE, in h3_data_setup()
192 Curl_bufq_free(&stream->recvbuf); in h3_data_done()
321 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
543 if(!Curl_bufq_is_empty(&stream->recvbuf)) { in cf_msh3_recv()
544 nread = Curl_bufq_read(&stream->recvbuf, in cf_msh3_recv()
546 CURL_TRC_CF(data, cf, "read recvbuf(len=%zu) -> %zd, %d", in cf_msh3_recv()
714 Curl_bufq_len(&stream->recvbuf)); in cf_msh3_data_pending()
715 pending = !Curl_bufq_is_empty(&stream->recvbuf); in cf_msh3_data_pending()
H A Dcurl_quiche.c142 struct bufq recvbuf; /* h3 response */ member
195 Curl_bufq_initp(&stream->recvbuf, &ctx->stream_bufcp, in h3_data_setup()
219 Curl_bufq_free(&stream->recvbuf); in h3_data_done()
279 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
382 nwritten = Curl_bufq_slurp(&stream->recvbuf, in cf_recv_body()
771 if(!Curl_bufq_is_empty(&stream->recvbuf)) { in cf_quiche_recv()
772 nread = Curl_bufq_read(&stream->recvbuf, in cf_quiche_recv()
774 CURL_TRC_CF(data, cf, "[%" PRId64 "] read recvbuf(len=%zu) " in cf_quiche_recv()
787 /* recvbuf had nothing before, maybe after progressing ingress? */ in cf_quiche_recv()
788 if(nread < 0 && !Curl_bufq_is_empty(&stream->recvbuf)) { in cf_quiche_recv()
[all...]
H A Dcurl_ngtcp2.c148 struct bufq recvbuf; /* h3 response body */ member
195 Curl_bufq_initp(&stream->recvbuf, &ctx->stream_bufcp, in h3_data_setup()
222 Curl_bufq_free(&stream->recvbuf); in h3_data_done()
817 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
1139 if(!Curl_bufq_is_empty(&stream->recvbuf)) { in cf_ngtcp2_recv()
1140 nread = Curl_bufq_read(&stream->recvbuf, in cf_ngtcp2_recv()
1143 CURL_TRC_CF(data, cf, "[%" PRId64 "] read recvbuf(len=%zu) " in cf_ngtcp2_recv()
1156 /* recvbuf had nothing before, maybe after progressing ingress? */ in cf_ngtcp2_recv()
1157 if(nread < 0 && !Curl_bufq_is_empty(&stream->recvbuf)) { in cf_ngtcp2_recv()
1158 nread = Curl_bufq_read(&stream->recvbuf, in cf_ngtcp2_recv()
[all...]
/third_party/ltp/testcases/kernel/syscalls/send/
H A Dsend02.c76 char recvbuf[RECVSIZE] = {0}; in check_recv() local
79 TEST(recv(sock, recvbuf, RECVSIZE, MSG_DONTWAIT)); in check_recv()

Completed in 35 milliseconds

12