Home
last modified time | relevance | path

Searched refs:stream (Results 1 – 25 of 94) sorted by relevance

1234

/curl/src/
H A Dtool_writeout_json.c92 fputc('\"', stream); in jsonWriteString()
95 fputc('\"', stream); in jsonWriteString()
106 fputs("{", stream); in ourWriteOutJSON()
111 fputs(",", stream); in ourWriteOutJSON()
118 fprintf(stream, "}"); in ourWriteOutJSON()
131 fputc('{', stream); in headerJSON()
144 fputc(':', stream); in headerJSON()
163 fputc(':', stream); in headerJSON()
164 fputc('[', stream); in headerJSON()
166 fputc(']', stream); in headerJSON()
[all …]
H A Dtool_binmode.c40 void set_binmode(FILE *stream) in set_binmode() argument
44 _setmode(stream, O_BINARY); in set_binmode()
46 (void)_setmode(fileno(stream), O_BINARY); in set_binmode()
48 (void)setmode(fileno(stream), O_BINARY); in set_binmode()
51 (void)stream; in set_binmode()
H A Dtool_writeout.c421 fputs(strinfo, stream); in writeString()
542 FILE *stream = stdout; in ourWriteOut() local
557 fputc('%', stream); in ourWriteOut()
593 stream = stdout; in ourWriteOut()
672 fputc('%', stream); in ourWriteOut()
681 fputc('\r', stream); in ourWriteOut()
684 fputc('\n', stream); in ourWriteOut()
687 fputc('\t', stream); in ourWriteOut()
691 fputc(*ptr, stream); in ourWriteOut()
698 fputc(*ptr, stream); in ourWriteOut()
[all …]
H A Dtool_cb_hdr.c62 size_t loclen, FILE *stream);
72 if(len != fwrite(h->data, 1, len, stream)) in tool_write_headers()
120 if(per->config->headerfile && heads->stream) { in tool_header_cb()
125 if(fflush(heads->stream)) { in tool_header_cb()
173 fputc('\n', etag_save->stream); in tool_header_cb()
174 (void)fflush(etag_save->stream); in tool_header_cb()
215 if(outs->stream) { in tool_header_cb()
306 outs->stream); in tool_header_cb()
314 fwrite(ptr, cb, 1, outs->stream); in tool_header_cb()
430 FILE *stream) { in write_linked_location() argument
[all …]
H A Dtool_writeout_json.h32 void ourWriteOutJSON(FILE *stream, const struct writeoutvar mappings[],
35 void headerJSON(FILE *stream, struct per_transfer *per);
36 void jsonWriteString(FILE *stream, const char *in, bool lowercase);
H A Dtool_cb_dbg.c36 FILE *stream, const unsigned char *ptr, size_t size,
248 FILE *stream, const unsigned char *ptr, size_t size, in dump() argument
260 fprintf(stream, "%s%s%s, %zu bytes (0x%zx)\n", timebuf, idsbuf, in dump()
265 fprintf(stream, "%04zx: ", i); in dump()
271 fprintf(stream, "%02x ", ptr[i + c]); in dump()
273 fputs(" ", stream); in dump()
285 fprintf(stream, "%c", ((ptr[i + c] >= 0x20) && (ptr[i + c] < 0x7F)) ? in dump()
295 fputc('\n', stream); /* newline */ in dump()
297 fflush(stream); in dump()
H A Dtool_cb_wrt.c125 outs->stream = file; in tool_create_output_file()
180 if(outs->fopened && !outs->stream) in tool_write_cb()
182 if(!outs->fopened && outs->stream) in tool_write_cb()
189 if(!outs->stream || outs->s_isreg || outs->fopened) in tool_write_cb()
201 if(!outs->stream && !tool_create_output_file(outs, per->config)) in tool_write_cb()
216 fhnd = _get_osfhandle(fileno(outs->stream)); in tool_write_cb()
218 if(isatty(fileno(outs->stream)) && in tool_write_cb()
350 if(tool_write_headers(&per->hdrcbdata, outs->stream)) in tool_write_cb()
353 rc = fwrite(buffer, sz, nmemb, outs->stream); in tool_write_cb()
367 int res = fflush(outs->stream); in tool_write_cb()
/curl/lib/
H A Dhttp2.c234 stream = calloc(1, sizeof(*stream)); in h2_stream_ctx_create()
413 if(!stream->closed && stream->id > 0) { in http2_data_done()
858 stream = h->stream; in curl_pushheader_byname()
982 heads.stream = stream; in push_promise()
1191 if(!stream->closed && !stream->body_eos && in on_stream_frame()
1491 if(!stream || !stream->bodystarted) { in on_begin_headers()
1632 stream->id, stream->status_code); in on_header()
1893 if(stream && stream->id > 0 && in h2_progress_egress()
2292 if(!stream || stream->id == -1) { in cf_h2_send()
2325 if(stream && stream->closed) { in cf_h2_send()
[all …]
/curl/lib/vquic/
H A Dcurl_quiche.c210 if(stream && stream->quic_flow_blocked) { in check_resumes()
225 if(stream) in h3_data_setup()
228 stream = calloc(1, sizeof(*stream)); in h3_data_setup()
229 if(!stream) in h3_data_setup()
280 if(stream && !stream->send_closed) in h3_drain_stream()
298 if(stream && stream->id == stream_id) { in get_stream_easy()
310 if(stream && stream->id == stream_id) { in get_stream_easy()
351 if(!stream) in write_resp_raw()
1110 if(!stream || !stream->opened) { in cf_quiche_send()
1239 if(stream && !stream->send_closed) { in cf_quiche_data_event()
[all …]
H A Dcurl_msh3.c203 if(stream) in h3_data_setup()
206 stream = calloc(1, sizeof(*stream)); in h3_data_setup()
207 if(!stream) in h3_data_setup()
243 if(stream && !stream->upload_done) in drain_stream_from_other_thread()
260 if(stream && !stream->upload_done) in h3_drain_stream()
358 if(!stream) in write_resp_raw()
386 if(!stream || stream->recv_header_complete) { in msh3_header_received()
442 if(!stream) in msh3_data_received()
475 if(!stream) in msh3_complete()
558 if(stream && stream->req && !stream->closed) { in set_quic_expire()
[all …]
H A Dcurl_ngtcp2.c232 if(stream) in h3_data_setup()
235 stream = calloc(1, sizeof(*stream)); in h3_data_setup()
299 if(stream && stream->id == stream_id) { in get_stream_easy()
311 if(stream && stream->id == stream_id) { in get_stream_easy()
330 if(stream && stream->upload_left && !stream->send_closed) in h3_drain_stream()
674 if(s_data && stream && stream->quic_flow_blocked) { in cb_extend_max_stream_data()
896 stream->id, stream->error3); in cb_h3_stream_close()
1478 stream->send_closed = (stream->upload_left == 0); in h3_stream_open()
1543 if(!stream || stream->id < 0) { in cf_ngtcp2_send()
1957 if(stream && !stream->send_closed) { in cf_ngtcp2_data_event()
[all …]
H A Dcurl_osslq.c621 stream = calloc(1, sizeof(*stream)); in h3_data_setup()
673 if(stream && stream->s.id == stream_id) { in cf_osslq_get_qstream()
710 if(stream && stream->upload_left && !stream->send_closed) in h3_drain_stream()
751 stream->s.id, stream->error3); in cb_h3_stream_close()
949 if(!stream || !stream->s.ssl) in cb_h3_stop_sending()
968 if(stream && stream->s.ssl) { in cb_h3_reset_stream()
1446 if(stream && !stream->closed && in cf_progress_ingress()
1474 if(stream && stream->s.ssl && stream->s.send_blocked && in cf_osslq_check_and_unblock()
1948 if(!stream || stream->s.id < 0) { in cf_osslq_send()
2150 if(stream && !stream->send_closed) { in cf_osslq_data_event()
[all …]
/curl/docs/examples/
H A Dftpget.c35 FILE *stream; member
38 static size_t my_fwrite(void *buffer, size_t size, size_t nmemb, void *stream) in my_fwrite() argument
40 struct FtpFile *out = (struct FtpFile *)stream; in my_fwrite()
41 if(!out->stream) { in my_fwrite()
43 out->stream = fopen(out->filename, "wb"); in my_fwrite()
44 if(!out->stream) in my_fwrite()
47 return fwrite(buffer, size, nmemb, out->stream); in my_fwrite()
88 if(ftpfile.stream) in main()
89 fclose(ftpfile.stream); /* close the local file */ in main()
H A Dftpsget.c36 FILE *stream; member
40 void *stream) in my_fwrite() argument
42 struct FtpFile *out = (struct FtpFile *)stream; in my_fwrite()
43 if(!out->stream) { in my_fwrite()
45 out->stream = fopen(out->filename, "wb"); in my_fwrite()
46 if(!out->stream) in my_fwrite()
49 return fwrite(buffer, size, nmemb, out->stream); in my_fwrite()
95 if(ftpfile.stream) in main()
96 fclose(ftpfile.stream); /* close the local file */ in main()
H A Dsftpget.c45 FILE *stream; member
49 void *stream) in my_fwrite() argument
51 struct FtpFile *out = (struct FtpFile *)stream; in my_fwrite()
52 if(!out->stream) { in my_fwrite()
54 out->stream = fopen(out->filename, "wb"); in my_fwrite()
55 if(!out->stream) in my_fwrite()
58 return fwrite(buffer, size, nmemb, out->stream); in my_fwrite()
106 if(ftpfile.stream) in main()
107 fclose(ftpfile.stream); /* close the local file */ in main()
H A Dmulti-debugcallback.c37 static void dump(const char *text, FILE *stream, unsigned char *ptr, in dump() argument
49 fprintf(stream, "%s, %10.10lu bytes (0x%8.8lx)\n", in dump()
54 fprintf(stream, "%4.4lx: ", (unsigned long)i); in dump()
60 fprintf(stream, "%02x ", ptr[i + c]); in dump()
62 fputs(" ", stream); in dump()
72 fprintf(stream, "%c", in dump()
81 fputc('\n', stream); /* newline */ in dump()
83 fflush(stream); in dump()
H A Ddebug.c37 FILE *stream, unsigned char *ptr, size_t size, in dump() argument
49 fprintf(stream, "%s, %10.10lu bytes (0x%8.8lx)\n", in dump()
54 fprintf(stream, "%4.4lx: ", (unsigned long)i); in dump()
60 fprintf(stream, "%02x ", ptr[i + c]); in dump()
62 fputs(" ", stream); in dump()
72 fprintf(stream, "%c", in dump()
81 fputc('\n', stream); /* newline */ in dump()
83 fflush(stream); in dump()
H A Dftpuploadresume.c35 void *stream) in getcontentlengthfunc() argument
42 *((long *) stream) = len; in getcontentlengthfunc()
48 static size_t discardfunc(void *ptr, size_t size, size_t nmemb, void *stream) in discardfunc() argument
51 (void)stream; in discardfunc()
56 static size_t readfunc(char *ptr, size_t size, size_t nmemb, void *stream) in readfunc() argument
58 FILE *f = stream; in readfunc()
/curl/tests/libtest/
H A Dlib552.c39 FILE *stream, unsigned char *ptr, size_t size, in dump() argument
51 fprintf(stream, "%s, %zu bytes (0x%zx)\n", text, size, size); in dump()
55 fprintf(stream, "%04zx: ", i); in dump()
61 fprintf(stream, "%02x ", ptr[i + c]); in dump()
63 fputs(" ", stream); in dump()
73 fprintf(stream, "%c", in dump()
82 fputc('\n', stream); /* newline */ in dump()
84 fflush(stream); in dump()
137 (void)stream; in read_callback()
145 void *stream) in write_callback() argument
[all …]
H A Dtesttrace.c36 void libtest_debug_dump(const char *timebuf, const char *text, FILE *stream, in libtest_debug_dump() argument
48 fprintf(stream, "%s%s, %zu bytes (0x%zx)\n", timebuf, text, in libtest_debug_dump()
53 fprintf(stream, "%04zx: ", i); in libtest_debug_dump()
59 fprintf(stream, "%02x ", ptr[i + c]); in libtest_debug_dump()
61 fputs(" ", stream); in libtest_debug_dump()
72 fprintf(stream, "%c", ((ptr[i + c] >= 0x20) && (ptr[i + c] < 0x80)) ? in libtest_debug_dump()
82 fputc('\n', stream); /* newline */ in libtest_debug_dump()
84 fflush(stream); in libtest_debug_dump()
H A Dlib1509.c30 size_t WriteOutput(char *ptr, size_t size, size_t nmemb, void *stream);
31 size_t WriteHeader(char *ptr, size_t size, size_t nmemb, void *stream);
85 size_t WriteOutput(char *ptr, size_t size, size_t nmemb, void *stream) in WriteOutput() argument
87 fwrite(ptr, size, nmemb, stream); in WriteOutput()
91 size_t WriteHeader(char *ptr, size_t size, size_t nmemb, void *stream) in WriteHeader() argument
94 (void)stream; in WriteHeader()
/curl/tests/
H A Dutil.py51 def setStream(self, stream): argument
54 return setStream(stream)
55 if stream is self.stream:
58 result = self.stream
62 self.stream = stream
/curl/docs/libcurl/opts/
H A DCURLOPT_STREAM_DEPENDS_E.md19 CURLOPT_STREAM_DEPENDS_E - stream this transfer depends on exclusively
32 Pass a CURL pointer in *dephandle* to identify the stream within the same
33 connection that this stream is depending upon exclusively. That means it
37 resources to the identified stream rather than to the dependent stream."
39 Setting a dependency with the exclusive flag for a reprioritized stream causes
40 all the dependencies of the new parent stream to become dependent on the
41 reprioritized stream.
H A DCURLOPT_STREAM_DEPENDS.md19 CURLOPT_STREAM_DEPENDS - stream this transfer depends on
32 Pass a CURL pointer in *dephandle* to identify the stream within the same
33 connection that this stream is depending upon. This option clears the
38 resources to the identified stream rather than to the dependent stream."
/curl/docs/cmdline-opts/
H A Dno-buffer.md6 Help: Disable buffering of the output stream
18 Disables the buffering of the output stream. In normal work situations, curl
19 uses a standard buffered output stream that has the effect that it outputs the

Completed in 62 milliseconds

1234