Lines Matching refs:channel_
87 // session_ - passed in constructor, cleared when channel_ goes away.
88 // channel_ - created in Connect, destroyed when session_ or tcp_ goes away.
89 // tcp_ - created in Connect, destroyed when channel_ goes away, or connection
91 // worker_thread_ - created when channel_ is created, purged when channel_ is
106 session_(session), channel_(NULL), tcp_(NULL), stream_(NULL),
117 ASSERT(channel_ == NULL);
128 if (channel_)
134 channel_ = session_->CreateChannel(
137 channel_->SetOption(Socket::OPT_DONTFRAGMENT, 1);
139 channel_->SignalDestroyed.connect(this,
141 channel_->SignalWritableState.connect(this,
143 channel_->SignalReadPacket.connect(this,
145 channel_->SignalRouteChange.connect(this,
174 ASSERT(channel == channel_);
181 channel_ = NULL;
195 if (session_ != NULL && channel_ == NULL) {
206 // since we'll need it to tear down channel_.
208 // TODO: Is it always the case that if channel_ != NULL then we'll get
325 if (!channel_) {
329 ASSERT(channel == channel_);
347 if (!channel_) {
351 ASSERT(channel == channel_);
365 if (!channel_) {
369 ASSERT(channel == channel_);
462 ASSERT(NULL == channel_);
485 ASSERT(channel_ != NULL);
486 session_->DestroyChannel(content_name_, channel_->component());
504 ASSERT(NULL != channel_);
505 int sent = channel_->SendPacket(buffer, len);
509 } else if (IsBlockingError(channel_->GetError())) {
512 } else if (channel_->GetError() == EMSGSIZE) {
516 PLOG(LS_ERROR, channel_->GetError()) << "PseudoTcpChannel::TcpWritePacket";
528 ASSERT(NULL != channel_);
540 if (channel_) {
541 // If TCP has failed, no need for channel_ anymore
