Home
last modified time | relevance | path

Searched refs:VIO (Results 1 – 25 of 95) sorted by relevance

1234

/trafficserver/iocore/eventsystem/
H A DP_VIO.h28 VIO::VIO(int aop) : op(aop), buffer(), mutex(nullptr) {} in VIO() function in VIO
31 VIO::VIO() : buffer(), mutex(nullptr) {} in VIO() function in VIO
34 VIO::get_continuation() const in get_continuation()
52 VIO::get_writer() const in get_writer()
58 VIO::get_reader() const in get_reader()
64 VIO::ntodo() const in ntodo()
70 VIO::done() in done()
96 VIO::reenable() in reenable()
105 VIO::reenable_re() in reenable_re()
114 VIO::disable() in disable()
[all …]
H A DI_VIO.h68 class VIO class
71 explicit VIO(int aop);
72 VIO();
73 ~VIO() {} in ~VIO()
191 int op = VIO::NONE;
H A DI_VConnection.h203 …virtual VIO *do_io_read(Continuation *c = nullptr, int64_t nbytes = INT64_MAX, MIOBuffer *buf = nu…
253 …virtual VIO *do_io_write(Continuation *c = nullptr, int64_t nbytes = INT64_MAX, IOBufferReader *bu…
322 virtual void set_continuation(VIO *vio, Continuation *cont);
325 virtual void reenable(VIO *vio);
326 virtual void reenable_re(VIO *vio);
413 VIO *
422 VIO *
H A DP_VConnection.h71 TS_INLINE VIO *
84 VConnection::set_continuation(VIO *, Continuation *) in set_continuation() argument
88 VConnection::reenable(VIO *) in reenable() argument
92 VConnection::reenable_re(VIO *vio) in reenable_re()
/trafficserver/proxy/
H A DTransformInternal.h37 VIO *do_io_read(Continuation *c, int64_t nbytes, MIOBuffer *buf) override;
38VIO *do_io_write(Continuation *c, int64_t nbytes, IOBufferReader *buf, bool owner = false) overrid…
42 void reenable(VIO *vio) override;
46 VIO m_read_vio;
47 VIO m_write_vio;
62 VIO *do_io_read(Continuation *c, int64_t nbytes, MIOBuffer *buf) override;
63VIO *do_io_write(Continuation *c, int64_t nbytes, IOBufferReader *buf, bool owner = false) overrid…
67 void reenable(VIO *vio) override;
106 VIO *m_output_vio;
129 VIO *m_output_vio;
H A DTransform.cc159 if (m_read_vio.op == VIO::NONE) { in handle_event()
268 VIO *
272 m_read_vio.op = VIO::READ; in do_io_read()
291 VIO *
297 m_write_vio.op = VIO::WRITE; in do_io_write()
332 m_read_vio.op = VIO::NONE; in do_io_close()
335 m_write_vio.op = VIO::NONE; in do_io_close()
348 m_read_vio.op = VIO::NONE; in do_io_shutdown()
353 m_write_vio.op = VIO::NONE; in do_io_shutdown()
428 VIO *
[all …]
H A DPluginVC.h46 VIO vio;
77VIO *do_io_read(Continuation *c = nullptr, int64_t nbytes = INT64_MAX, MIOBuffer *buf = nullptr) o…
79VIO *do_io_write(Continuation *c = nullptr, int64_t nbytes = INT64_MAX, IOBufferReader *buf = null…
86 void reenable(VIO *vio) override;
87 void reenable_re(VIO *vio) override;
/trafficserver/iocore/utils/
H A DI_OneWayTunnel.h150 …void init(VConnection *vcSource, VConnection *vcTarget, Continuation *aCont, VIO *SourceVio, IOBuf…
170 …void init(Continuation *aCont, VIO *SourceVio, VIO *TargetVio, bool aclose_source = true, bool acl…
184 virtual void close_target_vio(int result, VIO *vio = ONE_WAY_TUNNEL_CLOSE_ALL);
192 VIO *vioSource = nullptr;
193 VIO *vioTarget = nullptr;
H A DI_OneWayMultiTunnel.h117 …void init(Continuation *aCont, VIO *SourceVio, VIO **TargetVios, int n_vioTargets, bool aclose_sou…
126 void close_target_vio(int result, VIO *vio = nullptr) override;
131 VIO *vioTargets[ONE_WAY_MULTI_TUNNEL_LIMIT];
H A DOneWayMultiTunnel.cc99 OneWayMultiTunnel::init(Continuation *aCont, VIO *SourceVio, VIO **TargetVios, int n_TargetVios, bo… in init()
140 VIO *vio = static_cast<VIO *>(data); in startEvent()
199 close_target_vio(0, static_cast<VIO *>(data)); in startEvent()
229 OneWayMultiTunnel::close_target_vio(int result, VIO *vio) in close_target_vio()
232 VIO *v = vioTargets[i]; in close_target_vio()
/trafficserver/src/traffic_server/
H A DInkIOCoreAPI.cc329 VIO *vio = (VIO *)viop; in TSVIOReenable()
338 VIO *vio = (VIO *)viop; in TSVIOBufferGet()
347 VIO *vio = (VIO *)viop; in TSVIOReaderGet()
356 VIO *vio = (VIO *)viop; in TSVIONBytesGet()
366 VIO *vio = (VIO *)viop; in TSVIONBytesSet()
375 VIO *vio = (VIO *)viop; in TSVIONDoneGet()
385 VIO *vio = (VIO *)viop; in TSVIONDoneSet()
394 VIO *vio = (VIO *)viop; in TSVIONTodoGet()
403 VIO *vio = (VIO *)viop; in TSVIOContGet()
412 VIO *vio = (VIO *)viop; in TSVIOVConnGet()
[all …]
/trafficserver/proxy/http/
H A DHttp1ClientSession.h66 VIO *do_io_read(Continuation *c, int64_t nbytes = INT64_MAX, MIOBuffer *buf = nullptr) override;
67VIO *do_io_write(Continuation *c = nullptr, int64_t nbytes = INT64_MAX, IOBufferReader *buf = null…
72 void reenable(VIO *vio) override;
120 VIO *ka_vio = nullptr;
121 VIO *slave_ka_vio = nullptr;
H A DHttp1Transaction.h43 VIO *do_io_read(Continuation *c, int64_t nbytes = INT64_MAX, MIOBuffer *buf = nullptr) override;
44VIO *do_io_write(Continuation *c = nullptr, int64_t nbytes = INT64_MAX, IOBufferReader *buf = null…
48 void reenable(VIO *vio) override;
/trafficserver/proxy/http3/
H A DHttp3StreamDataVIOAdaptor.h28 class VIO;
33 Http3StreamDataVIOAdaptor(VIO *sink);
40 VIO *_sink_vio = nullptr;
H A DHttp3Transaction.h59 …virtual VIO *do_io_read(Continuation *c, int64_t nbytes = INT64_MAX, MIOBuffer *buf = 0) override;
60 …virtual VIO *do_io_write(Continuation *c = nullptr, int64_t nbytes = INT64_MAX, IOBufferReader *bu…
64 virtual void reenable(VIO *) override;
74 Event *_send_tracked_event(Event *, int, VIO *);
84 VIO _read_vio;
85 VIO _write_vio;
H A DHttp3DataFramer.h30 class VIO;
35 Http3DataFramer(Http3Transaction *transaction, VIO *source);
43 VIO *_source_vio = nullptr;
H A DHttp3Transaction.cc121 VIO *
135 this->_read_vio.op = VIO::READ; in do_io_read()
143 VIO *
157 this->_write_vio.op = VIO::WRITE; in do_io_write()
180 this->_read_vio.op = VIO::NONE; in do_io_close()
185 this->_write_vio.op = VIO::NONE; in do_io_close()
198 HQTransaction::reenable(VIO *vio) in reenable()
200 if (vio->op == VIO::READ) { in reenable()
207 } else if (vio->op == VIO::WRITE) { in reenable()
258 HQTransaction::_send_tracked_event(Event *event, int send_event, VIO *vio) in _send_tracked_event()
[all …]
H A DHttp3HeaderFramer.h34 class VIO;
39 Http3HeaderFramer(Http3Transaction *transaction, VIO *source, QPACK *qpack, uint64_t stream_id);
47 VIO *_source_vio = nullptr;
/trafficserver/iocore/net/quic/
H A DQUICUnidirectionalStream.h48 VIO *do_io_read(Continuation *c, int64_t nbytes = INT64_MAX, MIOBuffer *buf = 0) override;
49VIO *do_io_write(Continuation *c = nullptr, int64_t nbytes = INT64_MAX, IOBufferReader *buf = 0, b…
52 void reenable(VIO *vio) override;
98 VIO *do_io_read(Continuation *c, int64_t nbytes = INT64_MAX, MIOBuffer *buf = 0) override;
99VIO *do_io_write(Continuation *c = nullptr, int64_t nbytes = INT64_MAX, IOBufferReader *buf = 0, b…
102 void reenable(VIO *vio) override;
H A DQUICUnidirectionalStream.cc269 VIO *
278 VIO *
312 this->_write_vio.op = VIO::NONE; in do_io_close()
334 QUICSendStream::reenable(VIO *vio) in reenable()
337 ink_assert(vio->op == VIO::WRITE); in reenable()
637 VIO *
651 this->_read_vio.op = VIO::READ; in do_io_read()
659 VIO *
680 this->_read_vio.op = VIO::NONE; in do_io_close()
702 QUICReceiveStream::reenable(VIO *vio) in reenable()
[all …]
/trafficserver/include/ts/
H A DInkAPIPrivateIOCore.h76 VIO *do_io_read(Continuation *c, int64_t nbytes, MIOBuffer *buf) override;
78VIO *do_io_write(Continuation *c, int64_t nbytes, IOBufferReader *buf, bool owner = false) overrid…
86 void reenable(VIO *vio) override;
98 VIO m_read_vio;
99 VIO m_write_vio;
/trafficserver/doc/developer-guide/plugins/http-transformations/
H A Dindex.en.rst58 and virtual IO descriptors (``VIO``\ s).
75 A ``VIO`` is a description of an IO operation that is in progress.
76 Every ``VConnection`` has an associated *input VIO* and an associated
77 *output VIO*. When ``VConnection``\ s are transferring data to one
78 another, one ``VConnection``'s input ``VIO`` is another
79 ``VConnection``'s output ``VIO``. A ``VConnection``'s input ``VIO`` is
80 also called its **write ``VIO``** because the input ``VIO`` refers to a
82 output ``VIO`` is also called the **read ``VIO``**. For transformations,
85 ``VIO``\ s as follows:
125 A ``VIO`` or virtual IO is a description of an in progress IO
[all …]
/trafficserver/proxy/http2/
H A DHttp2ClientSession.h93 VIO *do_io_read(Continuation *c, int64_t nbytes = INT64_MAX, MIOBuffer *buf = nullptr) override;
94VIO *do_io_write(Continuation *c = nullptr, int64_t nbytes = INT64_MAX, IOBufferReader *buf = 0, b…
97 void reenable(VIO *vio) override;
156 int state_process_frame_read(int event, VIO *vio, bool inside_frame);
178 VIO *write_vio = nullptr;
/trafficserver/doc/developer-guide/plugins/io/
H A Dtransformations.en.rst33 examining the VIO returned by a call to :c:func:`TSVConnRead` or
34 :c:func:`TSVConnWrite`. The implementer, in turn, gets a handle on the VIO
35 operation by examining the VIO returned by :c:func:`TSVConnReadVIOGet` or
37 the Traffic Server API has an associated read VIO and write VIO, even if
41 input VIO by calling:
52 to examine the event, the current state of its read VIO and write VIO,
83 back-pointer in the VIO structure to the vconnection. The vconnection
144 and increase the value of ndone for the input VIO, as in the
153 /* Modify the input VIO to reflect how much has been read.*/
158 vconnection's write VIO (input VIO) using the function
[all …]
/trafficserver/iocore/net/
H A DSSLNextProtocolAccept.cc41 VIO *vio; in ssl_netvc_cast()
52 ptr.vio = static_cast<VIO *>(edata); in ssl_netvc_cast()
73 VIO *vio; in ioCompletionEvent()
77 vio = static_cast<VIO *>(edata); in ioCompletionEvent()

Completed in 220 milliseconds

1234