Home
last modified time | relevance | path

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

1234

/curl/src/
H A Dtool_writeout_json.c95 fputc('\"', stream); in jsonWriteString()
98 fputc('\"', stream); in jsonWriteString()
108 fputs("{", stream); in ourWriteOutJSON()
113 fputs(",", stream); in ourWriteOutJSON()
120 fprintf(stream, "}"); in ourWriteOutJSON()
133 fputc('{', stream); in headerJSON()
146 fputc(':', stream); in headerJSON()
165 fputc(':', stream); in headerJSON()
166 fputc('[', stream); in headerJSON()
168 fputc(']', stream); in headerJSON()
[all …]
H A Dtool_writeout.c410 fputs(strinfo, stream); in writeString()
515 FILE *stream = stdout; in ourWriteOut() local
533 fputc('%', stream); in ourWriteOut()
644 fputc('%', stream); in ourWriteOut()
653 fputc('\r', stream); in ourWriteOut()
656 fputc('\n', stream); in ourWriteOut()
659 fputc('\t', stream); in ourWriteOut()
663 fputc(*ptr, stream); in ourWriteOut()
664 fputc(ptr[1], stream); in ourWriteOut()
670 fputc(*ptr, stream); in ourWriteOut()
[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()
49 (void)stream; in set_binmode()
H A Dtool_cb_hdr.c64 size_t loclen, FILE *stream);
103 if(per->config->headerfile && heads->stream) { in tool_header_cb()
108 (void)fflush(heads->stream); in tool_header_cb()
144 if(fseek(etag_save->stream, 0, SEEK_SET)) { in tool_header_cb()
151 fputc('\n', etag_save->stream); in tool_header_cb()
152 (void)fflush(etag_save->stream); in tool_header_cb()
193 if(outs->stream) { in tool_header_cb()
257 outs->stream); in tool_header_cb()
265 fwrite(ptr, cb, 1, outs->stream); in tool_header_cb()
381 FILE *stream) { in write_linked_location() argument
[all …]
H A Dtool_writeout_json.h32 void ourWriteOutJSON(FILE *stream, const struct writeoutvar mappings[],
34 void headerJSON(FILE *stream, struct per_transfer *per);
35 void jsonWriteString(FILE *stream, const char *in, bool lowercase);
H A Dtool_cb_dbg.c38 FILE *stream, const unsigned char *ptr, size_t size,
250 FILE *stream, const unsigned char *ptr, size_t size, in dump() argument
262 fprintf(stream, "%s%s%s, %zu bytes (0x%zx)\n", timebuf, idsbuf, in dump()
267 fprintf(stream, "%04zx: ", i); in dump()
273 fprintf(stream, "%02x ", ptr[i + c]); in dump()
275 fputs(" ", stream); in dump()
287 fprintf(stream, "%c", ((ptr[i + c] >= 0x20) && (ptr[i + c] < 0x7F)) ? in dump()
297 fputc('\n', stream); /* newline */ in dump()
299 fflush(stream); in dump()
/curl/lib/
H A Dhttp2.c216 stream = calloc(1, sizeof(*stream)); in h2_stream_ctx_create()
217 if(!stream) in h2_stream_ctx_create()
329 if(!stream->closed && stream->id > 0) { in http2_data_done()
776 stream = h->stream; in curl_pushheader_byname()
911 heads.stream = stream; in push_promise()
1398 if(!stream || !stream->bodystarted) { in on_begin_headers()
1539 stream->id, stream->status_code); in on_header()
1832 if(stream && stream->id > 0 && in h2_progress_egress()
2199 if(stream && stream->id != -1) { in cf_h2_send()
2270 if(stream && stream->closed && !was_blocked) { in cf_h2_send()
[all …]
/curl/lib/vquic/
H A Dcurl_quiche.c188 if(stream && stream->quic_flow_blocked) { in check_resumes()
203 if(stream) in h3_data_setup()
206 stream = calloc(1, sizeof(*stream)); in h3_data_setup()
207 if(!stream) in h3_data_setup()
258 if(stream && !stream->send_closed && stream->upload_left) in drain_stream()
277 if(stream && stream->id == stream_id) { in get_stream_easy()
287 if(stream && stream->id == stream_id) { in get_stream_easy()
327 if(!stream) in write_resp_raw()
1034 if(!stream || !stream->opened) { in cf_quiche_send()
1213 if(stream && !stream->send_closed) { in cf_quiche_data_event()
[all …]
H A Dcurl_msh3.c181 if(stream) in h3_data_setup()
184 stream = calloc(1, sizeof(*stream)); in h3_data_setup()
185 if(!stream) in h3_data_setup()
208 if(stream) { in h3_data_done()
221 if(stream && !stream->upload_done) in drain_stream_from_other_thread()
238 if(stream && !stream->upload_done) in drain_stream()
336 if(!stream) in write_resp_raw()
364 if(!stream || stream->recv_header_complete) { in msh3_header_received()
420 if(!stream) in msh3_data_received()
536 if(stream && stream->req && !stream->closed) { in set_quic_expire()
[all …]
H A Dcurl_ngtcp2.c206 if(stream) in h3_data_setup()
209 stream = calloc(1, sizeof(*stream)); in h3_data_setup()
274 if(stream && stream->id == stream_id) { in get_stream_easy()
284 if(stream && stream->id == stream_id) { in get_stream_easy()
303 if(stream && stream->upload_left && !stream->send_closed) in h3_drain_stream()
649 if(s_data && stream && stream->quic_flow_blocked) { in cb_extend_max_stream_data()
859 stream->id, stream->error3); in cb_h3_stream_close()
1443 stream->send_closed = (stream->upload_left == 0); in h3_stream_open()
1506 if(!stream || stream->id < 0) { in cf_ngtcp2_send()
1962 if(stream && !stream->send_closed) { in cf_ngtcp2_data_event()
[all …]
H A Dcurl_osslq.c532 stream = calloc(1, sizeof(*stream)); in h3_data_setup()
585 if(stream && stream->s.id == stream_id) { in cf_osslq_get_qstream()
620 if(stream && stream->upload_left && !stream->send_closed) in h3_drain_stream()
661 stream->s.id, stream->error3); in cb_h3_stream_close()
859 if(!stream || !stream->s.ssl) in cb_h3_stop_sending()
878 if(stream && stream->s.ssl) { in cb_h3_reset_stream()
1357 if(stream && !stream->closed && in cf_progress_ingress()
1384 if(stream && stream->s.ssl && stream->s.send_blocked && in cf_osslq_check_and_unblock()
1862 if(!stream || stream->s.id < 0) { in cf_osslq_send()
2091 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/server/
H A Dfake_ntlm.c117 FILE *stream; in main() local
197 if(!stream) { in main()
206 fclose(stream); in main()
214 if(!stream) { in main()
222 fclose(stream); in main()
232 if(!stream) { in main()
241 stream); in main()
242 fclose(stream); in main()
253 if(!stream) { in main()
262 stream); in main()
[all …]
/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(void *ptr, size_t size, size_t nmemb, void *stream);
31 size_t WriteHeader(void *ptr, size_t size, size_t nmemb, void *stream);
85 size_t WriteOutput(void *ptr, size_t size, size_t nmemb, void *stream) in WriteOutput() argument
87 fwrite(ptr, size, nmemb, stream); in WriteOutput()
91 size_t WriteHeader(void *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.md18 CURLOPT_STREAM_DEPENDS_E - stream this transfer depends on exclusively
31 Pass a CURL pointer in *dephandle* to identify the stream within the same
32 connection that this stream is depending upon exclusively. That means it
36 resources to the identified stream rather than to the dependent stream."
38 Setting a dependency with the exclusive flag for a reprioritized stream causes
39 all the dependencies of the new parent stream to become dependent on the
40 reprioritized stream.
H A DCURLOPT_STREAM_DEPENDS.md18 CURLOPT_STREAM_DEPENDS - stream this transfer depends on
31 Pass a CURL pointer in *dephandle* to identify the stream within the same
32 connection that this stream is depending upon. This option clears the
37 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 80 milliseconds

1234