Home
last modified time | relevance | path

Searched refs:stream (Results 1 – 25 of 92) 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_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_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.c62 size_t loclen, FILE *stream);
101 if(per->config->headerfile && heads->stream) { in tool_header_cb()
106 if(fflush(heads->stream)) { in tool_header_cb()
147 if(fseek(etag_save->stream, 0, SEEK_SET)) { in tool_header_cb()
154 fputc('\n', etag_save->stream); in tool_header_cb()
155 (void)fflush(etag_save->stream); in tool_header_cb()
196 if(outs->stream) { in tool_header_cb()
260 outs->stream); in tool_header_cb()
268 fwrite(ptr, cb, 1, outs->stream); in tool_header_cb()
384 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()
348 rc = fwrite(buffer, sz, nmemb, outs->stream); in tool_write_cb()
361 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()
235 if(!stream) in h2_stream_ctx_create()
413 if(!stream->closed && stream->id > 0) { in http2_data_done()
850 stream = h->stream; in curl_pushheader_byname()
974 heads.stream = stream; in push_promise()
1470 if(!stream || !stream->bodystarted) { in on_begin_headers()
1611 stream->id, stream->status_code); in on_header()
1872 if(stream && stream->id > 0 && in h2_progress_egress()
2266 if(!stream || stream->id == -1) { in cf_h2_send()
2299 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.c231 if(stream) in h3_data_setup()
234 stream = calloc(1, sizeof(*stream)); in h3_data_setup()
298 if(stream && stream->id == stream_id) { in get_stream_easy()
310 if(stream && stream->id == stream_id) { in get_stream_easy()
329 if(stream && stream->upload_left && !stream->send_closed) in h3_drain_stream()
675 if(s_data && stream && stream->quic_flow_blocked) { in cb_extend_max_stream_data()
897 stream->id, stream->error3); in cb_h3_stream_close()
1479 stream->send_closed = (stream->upload_left == 0); in h3_stream_open()
1544 if(!stream || stream->id < 0) { in cf_ngtcp2_send()
1972 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()
1445 if(stream && !stream->closed && in cf_progress_ingress()
1473 if(stream && stream->s.ssl && stream->s.send_blocked && in cf_osslq_check_and_unblock()
1940 if(!stream || stream->s.id < 0) { in cf_osslq_send()
2142 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(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.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 85 milliseconds

1234