Lines Matching refs:PseudoTcpChannel
62 // PseudoTcpChannel::InternalStream
65 class PseudoTcpChannel::InternalStream : public StreamInterface {
67 InternalStream(PseudoTcpChannel* parent);
79 // avoid thread contention. This means that the PseudoTcpChannel cannot go
81 PseudoTcpChannel* parent_;
85 // PseudoTcpChannel
102 PseudoTcpChannel::PseudoTcpChannel(Thread* stream_thread, Session* session)
113 PseudoTcpChannel::~PseudoTcpChannel() {
122 bool PseudoTcpChannel::Connect(const std::string& content_name,
140 &PseudoTcpChannel::OnChannelDestroyed);
142 &PseudoTcpChannel::OnChannelWritableState);
144 &PseudoTcpChannel::OnChannelRead);
146 &PseudoTcpChannel::OnChannelConnectionChanged);
160 StreamInterface* PseudoTcpChannel::GetStream() {
165 stream_ = new PseudoTcpChannel::InternalStream(this);
170 void PseudoTcpChannel::OnChannelDestroyed(TransportChannel* channel) {
192 void PseudoTcpChannel::OnSessionTerminate(Session* session) {
199 LOG(LS_INFO) << "Destroying unconnected PseudoTcpChannel";
212 void PseudoTcpChannel::GetOption(PseudoTcp::Option opt, int* value) {
219 void PseudoTcpChannel::SetOption(PseudoTcp::Option opt, int value) {
230 StreamState PseudoTcpChannel::GetState() const {
250 StreamResult PseudoTcpChannel::Read(void* buffer, size_t buffer_len,
281 StreamResult PseudoTcpChannel::Write(const void* data, size_t data_len,
303 void PseudoTcpChannel::Close() {
321 void PseudoTcpChannel::OnChannelWritableState(TransportChannel* channel) {
342 void PseudoTcpChannel::OnChannelRead(TransportChannel* channel,
362 void PseudoTcpChannel::OnChannelConnectionChanged(TransportChannel* channel,
397 void PseudoTcpChannel::OnTcpOpen(PseudoTcp* tcp) {
410 void PseudoTcpChannel::OnTcpReadable(PseudoTcp* tcp) {
424 void PseudoTcpChannel::OnTcpWriteable(PseudoTcp* tcp) {
433 void PseudoTcpChannel::OnTcpClosed(PseudoTcp* tcp, uint32 nError) {
446 void PseudoTcpChannel::OnMessage(Message* pmsg) {
450 //LOG(LS_INFO) << "PseudoTcpChannel::OnMessage(MSG_WK_CLOCK)";
471 //LOG(LS_INFO) << "PseudoTcpChannel::OnMessage(MSG_ST_EVENT, "
502 IPseudoTcpNotify::WriteResult PseudoTcpChannel::TcpWritePacket(
519 PLOG(LS_ERROR, channel_->GetError()) << "PseudoTcpChannel::TcpWritePacket";
525 void PseudoTcpChannel::AdjustClock(bool clear) {
549 void PseudoTcpChannel::CheckDestroy() {
557 // PseudoTcpChannel::InternalStream
560 PseudoTcpChannel::InternalStream::InternalStream(PseudoTcpChannel* parent)
564 PseudoTcpChannel::InternalStream::~InternalStream() {
568 StreamState PseudoTcpChannel::InternalStream::GetState() const {
574 StreamResult PseudoTcpChannel::InternalStream::Read(
584 StreamResult PseudoTcpChannel::InternalStream::Write(
594 void PseudoTcpChannel::InternalStream::Close() {