Lines Matching refs:channel_
86 // session_ - passed in constructor, cleared when channel_ goes away.
87 // channel_ - created in Connect, destroyed when session_ or tcp_ goes away.
88 // tcp_ - created in Connect, destroyed when channel_ goes away, or connection
90 // worker_thread_ - created when channel_ is created, purged when channel_ is
105 session_(session), channel_(NULL), tcp_(NULL), stream_(NULL),
116 ASSERT(channel_ == NULL);
126 if (channel_)
132 channel_ = session_->CreateChannel(content_name, channel_name);
134 channel_->SetOption(Socket::OPT_DONTFRAGMENT, 1);
136 channel_->SignalDestroyed.connect(this,
138 channel_->SignalWritableState.connect(this,
140 channel_->SignalReadPacket.connect(this,
142 channel_->SignalRouteChange.connect(this,
171 ASSERT(channel == channel_);
178 channel_ = NULL;
192 if (session_ != NULL && channel_ == NULL) {
203 // since we'll need it to tear down channel_.
205 // TODO(wez): Is it always the case that if channel_ != NULL then we'll get
322 if (!channel_) {
326 ASSERT(channel == channel_);
344 if (!channel_) {
348 ASSERT(channel == channel_);
362 if (!channel_) {
366 ASSERT(channel == channel_);
453 ASSERT(NULL == channel_);
476 ASSERT(channel_ != NULL);
477 session_->DestroyChannel(content_name_, channel_->name());
495 ASSERT(NULL != channel_);
496 int sent = channel_->SendPacket(buffer, len);
500 } else if (IsBlockingError(channel_->GetError())) {
503 } else if (channel_->GetError() == EMSGSIZE) {
507 PLOG(LS_ERROR, channel_->GetError()) << "PseudoTcpChannel::TcpWritePacket";
519 ASSERT(NULL != channel_);
531 if (channel_) {
532 // If TCP has failed, no need for channel_ anymore
