Home
last modified time | relevance | path

Searched refs:nbytes (Results 1 – 8 of 8) sorted by relevance

/curl/lib/
H A Dcontent_encoding.c303 if(!(type & CLIENTWRITE_BODY) || !nbytes) in deflate_do_write()
308 z->avail_in = (uInt) nbytes; in deflate_do_write()
466 z->avail_in = (uInt) nbytes; in gzip_do_write()
509 z->avail_in = (uInt) nbytes; in gzip_do_write()
531 z->avail_in += (uInt) nbytes; in gzip_do_write()
537 memcpy(z->next_in + z->avail_in - nbytes, buf, nbytes); in gzip_do_write()
563 z->avail_in = (uInt) nbytes; in gzip_do_write()
570 z->avail_in = (uInt) nbytes; in gzip_do_write()
699 if(nbytes) in brotli_do_write()
775 in.size = nbytes; in zstd_do_write()
[all …]
H A Dsendf.c179 const char *buf, size_t nbytes) in Curl_cwriter_write() argument
196 const char *buf, size_t nbytes) in Curl_cwriter_def_write() argument
255 type, nbytes, result); in cw_download_write()
265 if(data->req.no_body && nbytes > 0) { in cw_download_write()
269 "did not want a BODY", type, nbytes); in cw_download_write()
281 nwrite = nbytes; in cw_download_write()
285 excess_len = nbytes - wmax; in cw_download_write()
313 type, nbytes, result); in cw_download_write()
339 else if((nwrite < nbytes) && !data->req.ignorebody) { in cw_download_write()
362 const char *buf, size_t nbytes) in cw_raw_write() argument
[all …]
H A Dsendf.h114 const char *buf, size_t nbytes);
181 const char *buf, size_t nbytes);
201 const char *buf, size_t nbytes);
H A Dmqtt.c359 static CURLcode mqtt_recv_atleast(struct Curl_easy *data, size_t nbytes) in mqtt_recv_atleast() argument
365 if(rlen < nbytes) { in mqtt_recv_atleast()
369 DEBUGASSERT(nbytes - rlen < sizeof(readbuf)); in mqtt_recv_atleast()
370 result = Curl_xfer_recv(data, (char *)readbuf, nbytes - rlen, &nread); in mqtt_recv_atleast()
378 return (rlen >= nbytes) ? CURLE_OK : CURLE_AGAIN; in mqtt_recv_atleast()
381 static void mqtt_recv_consume(struct Curl_easy *data, size_t nbytes) in mqtt_recv_consume() argument
385 if(rlen <= nbytes) in mqtt_recv_consume()
388 Curl_dyn_tail(&mq->recvbuf, rlen - nbytes); in mqtt_recv_consume()
H A Dws.c427 const char *buf, size_t nbytes) in ws_cw_write() argument
434 return Curl_cwriter_write(data, writer->next, type, buf, nbytes); in ws_cw_write()
442 if(nbytes) { in ws_cw_write()
445 nbytes, &result); in ws_cw_write()
H A Dcw-out.c111 const char *buf, size_t nbytes);
/curl/tests/server/
H A Dsockfilt.c232 static ssize_t fullread(int filedes, void *buffer, size_t nbytes) in fullread() argument
239 (unsigned char *)buffer + nread, nbytes - nread); in fullread()
268 } while((size_t)nread < nbytes); in fullread()
290 nbytes - nwrite); in fullwrite()
314 } while((size_t)nwrite < nbytes); in fullwrite()
329 static bool read_stdin(void *buffer, size_t nbytes) in read_stdin() argument
331 ssize_t nread = fullread(fileno(stdin), buffer, nbytes); in read_stdin()
332 if(nread != (ssize_t)nbytes) { in read_stdin()
346 static bool write_stdout(const void *buffer, size_t nbytes) in write_stdout() argument
348 ssize_t nwrite = fullwrite(fileno(stdout), buffer, nbytes); in write_stdout()
[all …]
/curl/tests/
H A Dftpserver.pl242 my $nbytes = shift;
253 if((not defined $nbytes) || ($nbytes < 1)) {
270 while($nread < $nbytes) {
275 $rc = sysread($FH, $$scalar, $nbytes - $nread, $nread);
285 $rc = sysread($FH, $$scalar, $nbytes - $nread, $nread);
328 my $nbytes = shift;
333 $timeout = $sockfilt_timeout + ($nbytes >> 12);
335 if(eXsysread($FH, $scalar, $nbytes, $timeout) != $nbytes) {
352 my $nbytes = shift;
357 $timeout = $sockfilt_timeout + ($nbytes >> 12);
[all …]

Completed in 28 milliseconds