Home
last modified time | relevance | path

Searched refs:channel_ (Results 1 – 25 of 29) sorted by relevance

12

/external/chromium/third_party/libjingle/source/talk/session/tunnel/
Dpseudotcpchannel.cc105 session_(session), channel_(NULL), tcp_(NULL), stream_(NULL), in PseudoTcpChannel()
116 ASSERT(channel_ == NULL); in ~PseudoTcpChannel()
126 if (channel_) in Connect()
132 channel_ = session_->CreateChannel(content_name, channel_name); in Connect()
134 channel_->SetOption(Socket::OPT_DONTFRAGMENT, 1); in Connect()
136 channel_->SignalDestroyed.connect(this, in Connect()
138 channel_->SignalWritableState.connect(this, in Connect()
140 channel_->SignalReadPacket.connect(this, in Connect()
142 channel_->SignalRouteChange.connect(this, in Connect()
171 ASSERT(channel == channel_); in OnChannelDestroyed()
[all …]
Dtunnelsessionclient.cc305 : client_(client), session_(session), channel_(NULL) { in TunnelSession()
309 channel_ = new PseudoTcpChannel(stream_thread, session_); in TunnelSession()
310 channel_->SignalChannelClosed.connect(this, &TunnelSession::OnChannelClosed); in TunnelSession()
316 ASSERT(channel_ == NULL); in ~TunnelSession()
320 ASSERT(channel_ != NULL); in GetStream()
321 return channel_->GetStream(); in GetStream()
331 ASSERT(NULL != channel_); in ReleaseSession()
336 channel_->SignalChannelClosed.disconnect(this); in ReleaseSession()
337 channel_ = NULL; in ReleaseSession()
378 ASSERT(channel_ != NULL); in OnAccept()
[all …]
Dsecuretunnelsessionclient.cc338 ASSERT(channel_ != NULL); in GetStream()
340 return MakeSecureStream(channel_->GetStream()); in GetStream()
346 ASSERT(channel_ != NULL); in OnAccept()
379 VERIFY(channel_->Connect(content_name, "tcp")); in OnAccept()
Dpseudotcpchannel.h125 TransportChannel* channel_; variable
/external/chromium/chrome/browser/
Dplugin_data_remover.cc37 channel_(NULL) { in PluginDataRemover()
42 if (channel_) in ~PluginDataRemover()
43 BrowserThread::DeleteSoon(BrowserThread::IO, FROM_HERE, channel_); in ~PluginDataRemover()
106 DCHECK(!channel_); in ConnectToChannel()
107 channel_ = new IPC::Channel(handle, IPC::Channel::MODE_CLIENT, this); in ConnectToChannel()
108 if (!channel_->Connect()) { in ConnectToChannel()
114 if (!channel_->Send(new PluginMsg_ClearSiteData(std::string(), in ConnectToChannel()
Dplugin_data_remover.h84 IPC::Channel* channel_; variable
/external/chromium/chrome/browser/importer/
Dfirefox_importer_unittest_utils_mac.cc130 channel_.reset(new IPC::Channel(kTestChannelID, in Setup()
133 CHECK(channel_->Connect()); in Setup()
134 listener_->SetSender(channel_.get()); in Setup()
138 *(channel_.get()), in Setup()
145 channel_->Close(); in ~FFUnitTestDecryptorProxy()
189 channel_->Send(new Msg_Decryptor_Init(dll_path, db_path)); in DecryptorInit()
199 channel_->Send(new Msg_Decrypt(crypt)); in Decrypt()
Dfirefox_importer_unittest_utils.h53 scoped_ptr<IPC::Channel> channel_; variable
/external/chromium/chrome/browser/service/
Dservice_process_control.cc39 if (channel_.get()) { in ConnectInternal()
51 channel_.reset( in ConnectInternal()
202 channel_->set_sync_messages_with_no_timeout_allowed(false); in OnChannelConnected()
218 channel_.reset(); in OnChannelError()
224 if (!channel_.get()) in Send()
226 return channel_->Send(message); in Send()
265 channel_.reset(); in Shutdown()
Dservice_process_control.h67 bool is_connected() const { return channel_.get() != NULL; } in is_connected()
179 scoped_ptr<IPC::SyncChannel> channel_; variable
/external/chromium/chrome/browser/sync/syncable/
Ddirectory_manager.cc43 channel_(new Channel(DirectoryManagerShutdownEvent())), in DirectoryManager()
51 delete channel_; in ~DirectoryManager()
108 channel_->NotifyListeners(event); in Close()
Ddirectory_manager.h74 Channel* channel() const { return channel_; } in channel()
102 Channel* const channel_; variable
/external/chromium/chrome/browser/web_resource/
Dpromo_resource_service.h83 void set_channel(const char* channel) { channel_ = channel; } in set_channel()
190 const char* channel_; variable
Dpromo_resource_service.cc105 channel_(NULL) { in PromoResourceService()
116 if (channel_ == NULL) { in IsThisBuildTargeted()
118 channel_ = platform_util::GetVersionStringModifier().c_str(); in IsThisBuildTargeted()
121 return IsBuildTargeted(channel_, builds_targeted); in IsThisBuildTargeted()
/external/chromium/third_party/libjingle/source/talk/p2p/client/
Dsocketmonitor.h75 P2PTransportChannel* GetP2PChannel() { return channel_->GetP2PChannel(); } in GetP2PChannel()
81 TransportChannel* channel_; variable
Dsocketmonitor.cc41 channel_ = channel; in SocketMonitor()
/external/chromium/chrome/browser/automation/
Dautomation_resource_message_filter.cc107 : channel_(NULL) { in AutomationResourceMessageFilter()
124 DCHECK(!channel_); in OnFilterAdded()
125 channel_ = channel; in OnFilterAdded()
129 channel_ = NULL; in OnFilterRemoved()
138 channel_ = NULL; in OnChannelClosing()
196 if (!channel_) { in Send()
201 return channel_->Send(message); in Send()
Dautomation_provider.cc135 if (channel_.get()) in ~AutomationProvider()
136 channel_->Close(); in ~AutomationProvider()
164 channel_.reset(new IPC::SyncChannel( in InitializeChannel()
171 channel_->AddFilter(automation_resource_message_filter_); in InitializeChannel()
302 channel_->Send(new AutomationMsg_Hello(GetProtocolVersion())); in OnChannelConnected()
389 channel_->Close(); in OnUnhandledMessage()
395 channel_->Close(); in OnMessageDeserializationFailure()
426 channel_.reset(); in ReinitializeChannel()
442 DCHECK(channel_.get()); in Send()
443 return channel_->Send(msg); in Send()
/external/chromium/chrome/common/deprecated/
Devent_sys-inl.h236 : channel_(channel), deleted_(NULL) { in EventListenerHookupImpl()
245 channel_->RemoveListener(this); in ~EventListenerHookupImpl()
258 channel_->RemoveListener(this); in HandleEvent()
264 EventChannel* const channel_;
/external/chromium/net/tools/dump_cache/
Dupgrade.cc130 HANDLE channel_; member in __anona64442140111::BaseSM
143 : entry_(NULL), channel_(channel), state_(0), pending_count_(0), in BaseSM()
154 MessageLoopForIO::current()->RegisterIOHandler(channel_, this); in BaseSM()
172 if (!WriteFile(channel_, output_, sizeof(msg) + msg.buffer_bytes, &written, in SendMsg()
183 if (!ReadFile(channel_, input_, kChannelSize, &read, in ReceiveMsg()
193 if (!ConnectNamedPipe(channel_, &in_context_.overlapped)) { in ConnectChannel()
876 CancelIo(channel_); in Fail()
/external/chromium/chrome/common/net/gaia/
Dgaia_authenticator.cc52 channel_ = new Channel(done); in GaiaAuthenticator()
56 delete channel_; in ~GaiaAuthenticator()
106 channel_->NotifyListeners(event); in AuthenticateImpl()
Dgaia_authenticator.h256 return channel_; in channel()
281 Channel* channel_; variable
/external/chromium/chrome/browser/cocoa/
Dkeystone_glue.h84 NSString* channel_; // Logically: Dev, Beta, or Stable. variable
/external/chromium/chrome/browser/sync/engine/net/
Dserver_connection_manager.h258 inline Channel* channel() const { return channel_; } in channel()
368 Channel* const channel_; variable
Dserver_connection_manager.cc148 channel_(new Channel(shutdown_event)), in ServerConnectionManager()
157 delete channel_; in ~ServerConnectionManager()

12