| /dports/sysutils/busybox/busybox-1.26.2/networking/ |
| H A D | ftpgetput.c | 83 FILE *control_stream; member
93 #define control_stream (G.control_stream) macro
125 fprintf(control_stream, (s2 ? "%s %s\r\n" : "%s %s\r\n"+3), in ftpcmd()
127 fflush(control_stream); in ftpcmd()
132 if (fgets(buf, BUFSZ - 2, control_stream) == NULL) { in ftpcmd()
146 control_stream = fdopen(xconnect_stream(lsa), "r+"); in ftp_login()
147 if (control_stream == NULL) { in ftp_login()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/neqo-http3/src/ |
| H A D | server.rs | 305 control_stream, in connect()
324 control_stream_id: control_stream, in connect()
478 sent = peer_conn.stream_send(control_stream, &[0x4]); in test_server_frame_reading()
483 sent = peer_conn.stream_send(control_stream, &[0x4]); in test_server_frame_reading()
488 sent = peer_conn.stream_send(control_stream, &[0x6]); in test_server_frame_reading()
493 sent = peer_conn.stream_send(control_stream, &[0x0]); in test_server_frame_reading()
498 sent = peer_conn.stream_send(control_stream, &[0x8]); in test_server_frame_reading()
503 sent = peer_conn.stream_send(control_stream, &[0x0]); in test_server_frame_reading()
511 sent = peer_conn.stream_send(control_stream, &[0x5]); in test_server_frame_reading()
516 sent = peer_conn.stream_send(control_stream, &[0x5]); in test_server_frame_reading()
[all …]
|
| H A D | connection_client.rs | 651 let mut control_stream = false; in check_control_qpack_streams() localVariable
667 control_stream = true; in check_control_qpack_streams()
689 assert!(control_stream); in check_control_qpack_streams()
992 sent = server.conn.stream_send(control_stream, &[0x4]); in test_frame_reading()
997 sent = server.conn.stream_send(control_stream, &[0x4]); in test_frame_reading()
1002 sent = server.conn.stream_send(control_stream, &[0x6]); in test_frame_reading()
1007 sent = server.conn.stream_send(control_stream, &[0x0]); in test_frame_reading()
2437 let mut control_stream = false; in check_control_qpack_request_streams_resumption() localVariable
2458 control_stream = true; in check_control_qpack_request_streams_resumption()
2493 assert!(control_stream); in check_control_qpack_request_streams_resumption()
[all …]
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/neqo-http3/src/ |
| H A D | server.rs | 488 control_stream, in connect_to()
514 control_stream_id: control_stream, in connect_to()
661 sent = peer_conn.stream_send(control_stream, &[0x4]); in test_server_frame_reading()
666 sent = peer_conn.stream_send(control_stream, &[0x4]); in test_server_frame_reading()
671 sent = peer_conn.stream_send(control_stream, &[0x6]); in test_server_frame_reading()
676 sent = peer_conn.stream_send(control_stream, &[0x0]); in test_server_frame_reading()
681 sent = peer_conn.stream_send(control_stream, &[0x8]); in test_server_frame_reading()
686 sent = peer_conn.stream_send(control_stream, &[0x0]); in test_server_frame_reading()
694 sent = peer_conn.stream_send(control_stream, &[0x5]); in test_server_frame_reading()
699 sent = peer_conn.stream_send(control_stream, &[0x5]); in test_server_frame_reading()
[all …]
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/neqo-http3/src/ |
| H A D | server.rs | 488 control_stream, in connect_to()
514 control_stream_id: control_stream, in connect_to()
661 sent = peer_conn.stream_send(control_stream, &[0x4]); in test_server_frame_reading()
666 sent = peer_conn.stream_send(control_stream, &[0x4]); in test_server_frame_reading()
671 sent = peer_conn.stream_send(control_stream, &[0x6]); in test_server_frame_reading()
676 sent = peer_conn.stream_send(control_stream, &[0x0]); in test_server_frame_reading()
681 sent = peer_conn.stream_send(control_stream, &[0x8]); in test_server_frame_reading()
686 sent = peer_conn.stream_send(control_stream, &[0x0]); in test_server_frame_reading()
694 sent = peer_conn.stream_send(control_stream, &[0x5]); in test_server_frame_reading()
699 sent = peer_conn.stream_send(control_stream, &[0x5]); in test_server_frame_reading()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/third_party/quiche/src/quic/qbone/ |
| H A D | qbone_client_session.cc | 45 auto control_stream = in Initialize() local
47 control_stream_ = control_stream.get(); in Initialize()
48 ActivateStream(std::move(control_stream)); in Initialize()
|
| H A D | qbone_server_session.cc | 61 auto control_stream = in Initialize() local
63 control_stream_ = control_stream.get(); in Initialize()
64 ActivateStream(std::move(control_stream)); in Initialize()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/net/third_party/quiche/src/quic/qbone/ |
| H A D | qbone_client_session.cc | 46 auto control_stream = in Initialize() local
48 control_stream_ = control_stream.get(); in Initialize()
49 ActivateStream(std::move(control_stream)); in Initialize()
|
| H A D | qbone_server_session.cc | 61 auto control_stream = in Initialize() local
63 control_stream_ = control_stream.get(); in Initialize()
64 ActivateStream(std::move(control_stream)); in Initialize()
|
| /dports/www/firefox/firefox-99.0/third_party/rust/neqo-http3/src/ |
| H A D | server.rs | 527 control_stream, in connect_to()
553 control_stream_id: control_stream, in connect_to()
747 sent = peer_conn.stream_send(control_stream, &[0x4]); in test_server_frame_reading()
752 sent = peer_conn.stream_send(control_stream, &[0x4]); in test_server_frame_reading()
757 sent = peer_conn.stream_send(control_stream, &[0x6]); in test_server_frame_reading()
762 sent = peer_conn.stream_send(control_stream, &[0x0]); in test_server_frame_reading()
767 sent = peer_conn.stream_send(control_stream, &[0x8]); in test_server_frame_reading()
772 sent = peer_conn.stream_send(control_stream, &[0x0]); in test_server_frame_reading()
780 sent = peer_conn.stream_send(control_stream, &[0x5]); in test_server_frame_reading()
785 sent = peer_conn.stream_send(control_stream, &[0x5]); in test_server_frame_reading()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/courgette/ |
| H A D | streams.cc | 291 SourceStream* control_stream = this->stream(0); in ReadSet() local
292 if (!control_stream->ReadVarint32(&stream_count)) in ReadSet()
298 if (!control_stream->ReadVarint32(&lengths[i])) in ReadSet()
377 SinkStream* control_stream = this->stream(0); in WriteSet() local
378 bool ret = control_stream->WriteSizeVarint32(stream_count); in WriteSet()
380 ret = control_stream->WriteSizeVarint32(lengths[i]); in WriteSet()
|
| /dports/devel/py-ipyparallel/ipyparallel-6.3.0/ipyparallel/engine/ |
| H A D | engine.py | 246 control_stream = zmqstream.ZMQStream(ctx.socket(zmq.ROUTER), loop)
247 control_stream.setsockopt(zmq.IDENTITY, identity)
248 connect(control_stream, control_addr)
277 … control_stream=control_stream, shell_streams=shell_streams, iopub_socket=iopub_socket,
|
| /dports/devel/py-ipykernel5/ipykernel-5.5.0/ipykernel/ |
| H A D | kernelbase.py | 64 control_stream = Instance(ZMQStream, allow_none=True) variable in Kernel
193 yield gen.maybe_future(handler(self.control_stream, idents, msg))
201 self.control_stream.flush(zmq.POLLOUT)
370 if self.control_stream:
371 self.control_stream.flush()
410 if self.control_stream:
411 self.control_stream.on_recv(
421 if s is self.control_stream:
|
| H A D | kernelapp.py | 440 control_stream = ZMQStream(self.control_socket)
445 control_stream=control_stream,
446 shell_streams=[shell_stream, control_stream],
|
| /dports/devel/py-ipykernel/ipykernel-6.6.0/ipykernel/ |
| H A D | kernelbase.py | 101 control_stream = Instance(ZMQStream, allow_none=True) variable in Kernel
248 self.control_stream.flush()
279 result = handler(self.control_stream, idents, msg)
289 self.control_stream.flush(zmq.POLLOUT)
489 self.control_stream.on_recv(self.dispatch_control, copy=False)
822 control_io_loop = self.control_stream.io_loop
1072 self.control_stream.flush(zmq.POLLOUT)
|
| /dports/multimedia/handbrake/ffmpeg-4.4/libavcodec/ |
| H A D | utvideo.h | 87 const uint8_t *control_stream[4][256]; member
|
| H A D | utvideodec.c | 221 …ret = init_get_bits8_le(&cbit, c->control_stream[plane_no][slice], c->control_stream_size[plane_no… in decode_plane()
581 const uint8_t *control_stream; in decode_frame() local
603 control_stream = packed_stream + (c->offset - nb_cbs); in decode_frame()
604 left = control_stream - packed_stream; in decode_frame()
617 left = buf + buf_size - control_stream; in decode_frame()
621 c->control_stream[i][j] = control_stream; in decode_frame()
626 control_stream += c->control_stream_size[i][j]; in decode_frame()
|
| /dports/multimedia/ffmpeg/ffmpeg-4.4.1/libavcodec/ |
| H A D | utvideo.h | 87 const uint8_t *control_stream[4][256]; member
|
| H A D | utvideodec.c | 221 …ret = init_get_bits8_le(&cbit, c->control_stream[plane_no][slice], c->control_stream_size[plane_no… in decode_plane()
581 const uint8_t *control_stream; in decode_frame() local
603 control_stream = packed_stream + (c->offset - nb_cbs); in decode_frame()
604 left = control_stream - packed_stream; in decode_frame()
617 left = buf + buf_size - control_stream; in decode_frame()
621 c->control_stream[i][j] = control_stream; in decode_frame()
626 control_stream += c->control_stream_size[i][j]; in decode_frame()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/ffmpeg/libavcodec/ |
| H A D | utvideo.h | 87 const uint8_t *control_stream[4][256]; member
|
| H A D | utvideodec.c | 218 …ret = init_get_bits8_le(&cbit, c->control_stream[plane_no][slice], c->control_stream_size[plane_no… in decode_plane()
578 const uint8_t *control_stream; in decode_frame() local
600 control_stream = packed_stream + (c->offset - nb_cbs); in decode_frame()
601 left = control_stream - packed_stream; in decode_frame()
614 left = buf + buf_size - control_stream; in decode_frame()
618 c->control_stream[i][j] = control_stream; in decode_frame()
623 control_stream += c->control_stream_size[i][j]; in decode_frame()
|
| /dports/multimedia/gstreamer1-libav/gst-libav-1.16.2/gst-libs/ext/libav/libavcodec/ |
| H A D | utvideo.h | 90 const uint8_t *control_stream[4][256]; member
|
| H A D | utvideodec.c | 261 …ret = init_get_bits8(&cbit, c->control_stream[plane_no][slice], c->control_stream_size[plane_no][s… in decode_plane()
621 const uint8_t *control_stream; in decode_frame() local
643 control_stream = packed_stream + (c->offset - nb_cbs); in decode_frame()
644 left = control_stream - packed_stream; in decode_frame()
657 left = buf + buf_size - control_stream; in decode_frame()
661 c->control_stream[i][j] = control_stream; in decode_frame()
666 control_stream += c->control_stream_size[i][j]; in decode_frame()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/ffmpeg/libavcodec/ |
| H A D | utvideo.h | 90 const uint8_t *control_stream[4][256]; member
|
| H A D | utvideodec.c | 262 …ret = init_get_bits8_le(&cbit, c->control_stream[plane_no][slice], c->control_stream_size[plane_no… in decode_plane()
622 const uint8_t *control_stream; in decode_frame() local
644 control_stream = packed_stream + (c->offset - nb_cbs); in decode_frame()
645 left = control_stream - packed_stream; in decode_frame()
658 left = buf + buf_size - control_stream; in decode_frame()
662 c->control_stream[i][j] = control_stream; in decode_frame()
667 control_stream += c->control_stream_size[i][j]; in decode_frame()
|