#include <Http2ClientSession.h>
Inherits ProxyClientSession.
Public Types | |
typedef int(Http2ClientSession::* | SessionHandler )(int, void *) |
Public Member Functions | |
Http2ClientSession () | |
void | start () |
void | destroy () |
void | new_connection (NetVConnection *new_vc, MIOBuffer *iobuf, IOBufferReader *reader, bool backdoor) |
VIO * | do_io_read (Continuation *c, int64_t nbytes=INT64_MAX, MIOBuffer *buf=0) |
Read data from the VConnection. | |
VIO * | do_io_write (Continuation *c=NULL, int64_t nbytes=INT64_MAX, IOBufferReader *buf=0, bool owner=false) |
Write data to the VConnection. | |
void | do_io_close (int lerrno=-1) |
Indicate that the VConnection is no longer needed. | |
void | do_io_shutdown (ShutdownHowTo_t howto) |
Terminate one or both directions of the VConnection. | |
void | reenable (VIO *vio) |
int64_t | connection_id () const |
Definition at line 113 of file Http2ClientSession.h.
typedef int(Http2ClientSession::* Http2ClientSession::SessionHandler)(int, void *) |
Definition at line 118 of file Http2ClientSession.h.
Http2ClientSession::Http2ClientSession | ( | ) |
Definition at line 61 of file Http2ClientSession.cc.
int64_t Http2ClientSession::connection_id | ( | ) | const [inline] |
Definition at line 132 of file Http2ClientSession.h.
Referenced by rcv_settings_frame().
void Http2ClientSession::destroy | ( | ) | [virtual] |
Implements ProxyClientSession.
Definition at line 67 of file Http2ClientSession.cc.
References ProxyClientSession::cleanup(), DebugHttp2Ssn0, free_MIOBuffer(), http2ClientSessionAllocator, and ink_release_assert.
void Http2ClientSession::do_io_close | ( | int | lerrno = -1 |
) | [virtual] |
Indicate that the VConnection is no longer needed.
Once the state machine has finished using this VConnection, it must call this function to indicate that the VConnection can be deallocated. After a close has been called, the VConnection and underlying processor must not send any more events related to this VConnection to the state machine. Likeswise, the state machine must not access the VConnection or any VIOs obtained from it after calling this method.
lerrno | indicates where a close is a normal close or an abort. The difference between a normal close and an abort depends on the underlying type of the VConnection. |
Implements VConnection.
Definition at line 146 of file Http2ClientSession.cc.
References DebugHttp2Ssn0, ProxyClientSession::do_api_callout(), NetVConnection::do_io_close(), HTTP2_SESSION_EVENT_FINI, send_connection_event(), and TS_HTTP_SSN_CLOSE_HOOK.
VIO * Http2ClientSession::do_io_read | ( | Continuation * | c, | |
int64_t | nbytes = INT64_MAX , |
|||
MIOBuffer * | buf = 0 | |||
) | [virtual] |
Read data from the VConnection.
Called by a state machine to read data from the VConnection. Processors implementing read functionality take out lock, put new bytes on the buffer and call the continuation back before releasing the lock in order to enable the state machine to handle transfer schemes where the end of a given transaction is marked by a special character (ie: NNTP).
Possible Event Codes
On the callback to the continuation, the VConnection may use on of the following values for the event code:
Event code | Meaning |
VC_EVENT_READ_READY | Data has been added to the buffer or the buffer is full |
VC_EVENT_READ_COMPLETE | The amount of data indicated by 'nbytes' has been read into the buffer |
VC_EVENT_EOS | The stream being read from has been shutdown |
VC_EVENT_ERROR | An error occurred during the read |
c | Continuation to be called back with events. | |
nbytes | Number of bytes to read. If unknown, nbytes must be set to INT64_MAX. | |
buf | buffer to read into. |
Implements VConnection.
Definition at line 125 of file Http2ClientSession.cc.
References NetVConnection::do_io_read().
Referenced by start().
void Http2ClientSession::do_io_shutdown | ( | ShutdownHowTo_t | howto | ) | [virtual] |
Terminate one or both directions of the VConnection.
Indicates that one or both sides of the VConnection should be terminated. After this call is issued, no further I/O can be done on the specified direction of the connection. The processor must not send any further events (including timeout events) to the state machine, and the state machine must not use any VIOs from a shutdown direction of the connection. Even if both sides of a connection are shutdown, the state machine must still call do_io_close() when it wishes the VConnection to be deallocated.
Possible howto values
Value | Meaning |
IO_SHUTDOWN_READ | Indicates that this VConnection should not generate any more read events |
IO_SHUTDOWN_WRITE | Indicates that this VConnection should not generate any more write events |
IO_SHUTDOWN_READWRITE | Indicates that this VConnection should not generate any more read nor write events |
howto | Specifies which direction of the VConnection to shutdown. |
Implements VConnection.
Definition at line 137 of file Http2ClientSession.cc.
References NetVConnection::do_io_shutdown().
VIO * Http2ClientSession::do_io_write | ( | Continuation * | c = NULL , |
|
int64_t | nbytes = INT64_MAX , |
|||
IOBufferReader * | buf = 0 , |
|||
bool | owner = false | |||
) | [virtual] |
Write data to the VConnection.
This method is called by a state machine to write data to the VConnection.
Possible Event Codes
On the callback to the continuation, the VConnection may use on of the following event codes:
Event code | Meaning |
VC_EVENT_WRITE_READY | Data was written from the reader or there are no bytes available for the reader to write. |
VC_EVENT_WRITE_COMPLETE | The amount of data indicated by 'nbytes' has been written to the VConnection |
VC_EVENT_INACTIVITY_TIMEOUT | No activity was performed for a certain period. |
VC_EVENT_ACTIVE_TIMEOUT | Write operation continued beyond a time limit. |
VC_EVENT_ERROR | An error occurred during the write |
c | Continuation to be called back with events. | |
nbytes | Number of bytes to write. If unknown, nbytes must be set to INT64_MAX. | |
buf | Reader whose data is to be read from. | |
owner |
Implements VConnection.
Definition at line 131 of file Http2ClientSession.cc.
References NetVConnection::do_io_write().
Referenced by start().
void Http2ClientSession::new_connection | ( | NetVConnection * | new_vc, | |
MIOBuffer * | iobuf, | |||
IOBufferReader * | reader, | |||
bool | backdoor | |||
) | [virtual] |
Implements ProxyClientSession.
Definition at line 101 of file Http2ClientSession.cc.
References MIOBuffer::alloc_reader(), DebugHttp2Ssn, ProxyClientSession::do_api_callout(), HTTP2_HEADER_BUFFER_SIZE_INDEX, ink_release_assert, Continuation::mutex, new_MIOBuffer, new_ProxyMutex(), ProxyClientSession::next_connection_id(), and TS_HTTP_SSN_START_HOOK.
Referenced by Http2SessionAccept::accept().
void Http2ClientSession::reenable | ( | VIO * | vio | ) | [virtual] |
Reimplemented from VConnection.
Definition at line 159 of file Http2ClientSession.cc.
References NetVConnection::reenable().
void Http2ClientSession::start | ( | ) | [virtual] |
Implements ProxyClientSession.
Definition at line 79 of file Http2ClientSession.cc.
References do_io_read(), do_io_write(), Continuation::handleEvent(), HTTP2_SESSION_EVENT_INIT, HTTP2_SET_SESSION_HANDLER, INT64_MAX, Continuation::mutex, MUTEX_LOCK, send_connection_event(), SET_HANDLER, this_ethread(), and VC_EVENT_READ_READY.