Home
last modified time | relevance | path

Searched refs:eos (Results 1 – 25 of 28) sorted by relevance

12

/curl/lib/
H A Dsendf.h212 char *buf, size_t blen, size_t *nread, bool *eos);
260 size_t *nread, bool *eos);
283 char *buf, size_t blen, size_t *nread, bool *eos);
326 size_t *nread, bool *eos) WARN_UNUSED_RESULT;
H A Dhttp_chunks.c481 BIT(eos); /* we have returned an EOS */
562 bool eos; in add_chunk() local
576 result = Curl_creader_read(data, reader->next, buf, blen, &nread, &eos); in add_chunk()
579 if(eos) in add_chunk()
617 *peos = ctx->eos; in cr_chunked_read()
619 if(!ctx->eos) { in cr_chunked_read()
631 ctx->eos = TRUE; in cr_chunked_read()
638 DEBUGASSERT(ctx->eos || !ctx->read_eos); in cr_chunked_read()
H A Drequest.c190 bool eos = FALSE; in xfer_send() local
219 eos = TRUE; in xfer_send()
221 result = Curl_xfer_send(data, buf, blen, eos, pnwritten); in xfer_send()
223 if(eos && (blen == *pnwritten)) in xfer_send()
353 bool eos; in add_from_client() local
355 *err = Curl_client_read(data, (char *)buf, buflen, &nread, &eos); in add_from_client()
358 if(eos) in add_from_client()
H A Dsendf.c531 *eos = FALSE; in Curl_creader_read()
562 *eos = FALSE; in Curl_creader_def_read()
979 bool eos; in cr_lc_read() local
981 if(ctx->eos) { in cr_lc_read()
989 ctx->eos = TRUE; in cr_lc_read()
998 ctx->read_eos = eos; in cr_lc_read()
1003 ctx->eos = TRUE; in cr_lc_read()
1005 *peos = ctx->eos; in cr_lc_read()
1046 ctx->eos = TRUE; in cr_lc_read()
1187 DEBUGASSERT(eos); in Curl_client_read()
[all …]
H A Dcfilters.h109 bool eos, /* last chunk */
252 const void *buf, size_t len, bool eos,
329 const void *buf, size_t len, bool eos,
477 const void *buf, size_t len, bool eos, CURLcode *code);
581 const void *buf, size_t blen, bool eos,
H A Dcfilters.c104 const void *buf, size_t len, bool eos, in Curl_cf_def_send() argument
108 cf->next->cft->do_send(cf->next, data, buf, len, eos, err) : in Curl_cf_def_send()
264 const void *mem, size_t len, bool eos, in Curl_cf_send() argument
277 ssize_t nwritten = cf->cft->do_send(cf, data, mem, len, eos, code); in Curl_cf_send()
388 const void *buf, size_t len, bool eos, in Curl_conn_cf_send() argument
392 return cf->cft->do_send(cf, data, buf, len, eos, err); in Curl_conn_cf_send()
863 const void *buf, size_t blen, bool eos, in Curl_conn_send() argument
889 eos = FALSE; in Curl_conn_send()
890 nwritten = conn->send[sockindex](data, sockindex, buf, write_len, eos, in Curl_conn_send()
H A Dtransfer.h132 const void *buf, size_t blen, bool eos,
H A Dhttp2.c1063 if(!stream->xfer_result && !eos) in h2_xfer_write_resp_hd()
1080 if(!stream->xfer_result && !eos) in h2_xfer_write_resp()
2128 if(eos) in cf_h2_body_send()
2143 if(eos && (blen == (size_t)nwritten)) in cf_h2_body_send()
2146 if(eos || !Curl_bufq_is_empty(&stream->sendbuf)) { in cf_h2_body_send()
2160 bool eos, CURLcode *err) in h2_submit() argument
2258 if(bodylen || eos) { in h2_submit()
2281 const void *buf, size_t len, bool eos, in cf_h2_send() argument
2304 DEBUGASSERT(eos); in cf_h2_send()
2307 stream->id, nwritten, *err, eos); in cf_h2_send()
[all …]
H A Dcurl_rtmp.c332 const void *buf, size_t len, bool eos, CURLcode *err) in rtmp_send() argument
339 (void)eos; /* unused */ in rtmp_send()
H A Dfile.c308 bool eos = FALSE; in file_upload() local
356 while(!result && !eos) { in file_upload()
361 result = Curl_client_read(data, xfer_ulbuf, xfer_ulblen, &readcount, &eos); in file_upload()
H A Dsmtp.c1792 BIT(eos); /* we have returned an EOS */
1827 bool eos; in cr_eob_read() local
1831 result = Curl_creader_read(data, reader->next, buf, blen, &nread, &eos); in cr_eob_read()
1835 ctx->read_eos = eos; in cr_eob_read()
1908 ctx->eos = TRUE; in cr_eob_read()
1910 *peos = ctx->eos; in cr_eob_read()
H A Dtransfer.c935 const void *buf, size_t blen, bool eos, in Curl_xfer_send() argument
946 result = Curl_conn_send(data, sockindex, buf, blen, eos, pnwritten); in Curl_xfer_send()
955 blen, eos, result, *pnwritten)); in Curl_xfer_send()
H A Dc-hyper.c665 bool eos; in uploadstreamed() local
673 result = Curl_client_read(data, xfer_ulbuf, xfer_ulblen, &fillcount, &eos); in uploadstreamed()
688 if(eos) in uploadstreamed()
693 else if(eos) { in uploadstreamed()
H A Dkrb5.c693 const void *buffer, size_t len, bool eos, in sec_send() argument
697 (void)eos; /* unused */ in sec_send()
H A Dsmb.c811 bool eos; in smb_send_and_recv() local
813 result = Curl_client_read(data, smbc->send_buf, nread, &nread, &eos); in smb_send_and_recv()
H A Dtftp.c708 bool eos; in tftp_tx() local
775 &cb, &eos); in tftp_tx()
H A Dhttp.c4424 size_t *nread, bool *eos) in cr_exp100_read() argument
4436 *eos = FALSE; in cr_exp100_read()
4449 *eos = FALSE; in cr_exp100_read()
4454 *eos = FALSE; in cr_exp100_read()
4463 *eos = FALSE; in cr_exp100_read()
4472 return Curl_creader_read(data, reader->next, buf, blen, nread, eos); in cr_exp100_read()
H A Dcf-h2-proxy.c1400 const void *buf, size_t len, bool eos, in cf_h2_proxy_send() argument
1409 (void)eos; /* TODO, maybe useful for blocks? */ in cf_h2_proxy_send()
/curl/lib/vquic/
H A Dcurl_quiche.c920 const void *buf, size_t len, bool eos, in cf_quiche_send_body() argument
927 (uint8_t *)buf, len, eos); in cf_quiche_send_body()
958 if(eos && (len == (size_t)nwritten)) in cf_quiche_send_body()
974 const char *buf, size_t len, bool eos, in h3_open_stream() argument
1030 if(eos && ((size_t)nwritten == len)) in h3_open_stream()
1077 buf + hds_len, len - hds_len, eos, err); in h3_open_stream()
1094 const void *buf, size_t len, bool eos, in cf_quiche_send() argument
1111 nwritten = h3_open_stream(cf, data, buf, len, eos, err); in cf_quiche_send()
1139 nwritten = cf_quiche_send_body(cf, data, stream, buf, len, eos, err); in cf_quiche_send()
H A Dcurl_osslq.c1502 int eos, ok, rv; in h3_send_streams() local
1506 n = nghttp3_conn_writev_stream(ctx->h3.conn, &stream_id, &eos, in h3_send_streams()
1535 uint64_t flags = (eos && ((i + 1) == n)) ? SSL_WRITE_FLAG_CONCLUDE : 0; in h3_send_streams()
1569 if(acked_len > 0 || (eos && !s->send_blocked)) { in h3_send_streams()
1588 "to QUIC, eos=%d", s->id, acked_len, total_len, eos); in h3_send_streams()
1591 if(eos && !s->send_blocked && !eos_written) { in h3_send_streams()
1918 const void *buf, size_t len, bool eos, in cf_osslq_send() argument
1927 (void)eos; /* TODO: use to end stream */ in cf_osslq_send()
H A Dcurl_ngtcp2.c908 const char *buf, size_t blen, bool eos) in h3_xfer_write_resp_hd() argument
913 stream->xfer_result = Curl_xfer_write_resp_hd(data, buf, blen, eos); in h3_xfer_write_resp_hd()
923 const char *buf, size_t blen, bool eos) in h3_xfer_write_resp() argument
928 stream->xfer_result = Curl_xfer_write_resp(data, buf, blen, eos); in h3_xfer_write_resp()
1519 const void *buf, size_t len, bool eos, in cf_ngtcp2_send() argument
1536 (void)eos; /* TODO: use for stream EOF and block handling */ in cf_ngtcp2_send()
H A Dcurl_msh3.c618 const void *buf, size_t len, bool eos, in cf_msh3_send() argument
674 eos ? MSH3_REQUEST_FLAG_FIN : in cf_msh3_send()
/curl/lib/vssh/
H A Dwolfssh.c221 const void *mem, size_t len, bool eos, in wscp_send() argument
229 (void)eos; in wscp_send()
250 const void *mem, size_t len, bool eos, CURLcode *err) in wsftp_send() argument
257 (void)eos; in wsftp_send()
H A Dlibssh.c2411 const void *mem, size_t len, bool eos, CURLcode *err) in scp_send() argument
2417 (void)eos; in scp_send()
2560 const void *mem, size_t len, bool eos, in sftp_send() argument
2566 (void)eos; in sftp_send()
H A Dlibssh2.c3504 const void *mem, size_t len, bool eos, CURLcode *err) in scp_send() argument
3510 (void)eos; in scp_send()
3643 const void *mem, size_t len, bool eos, CURLcode *err) in sftp_send() argument
3649 (void)eos; in sftp_send()

Completed in 126 milliseconds

12