| /external/chromium_org/net/quic/ |
| D | quic_connection_test.cc | 513 connection_(guid_, IPEndPoint(), helper_.get(), writer_.get(), false), in QuicConnectionTest()
517 connection_.set_visitor(&visitor_); in QuicConnectionTest()
518 connection_.SetSendAlgorithm(send_algorithm_); in QuicConnectionTest()
543 outgoing_ack_.reset(QuicConnectionPeer::CreateAckFrame(&connection_)); in outgoing_ack()
588 connection_.is_server()); in ProcessFramePacket()
594 connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); in ProcessFramePacket()
613 connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); in ProcessDataPacketAtLevel()
622 connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); in ProcessClosePacket()
686 connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); in ProcessFecPacket()
698 connection_.SendStreamDataWithString(id, data, offset, fin, NULL); in SendStreamDataToPeer()
[all …]
|
| D | quic_crypto_client_stream_test.cc | 27 : connection_(new PacketSavingConnection(false)), in QuicCryptoClientStreamTest()
28 session_(new TestSession(connection_, DefaultQuicConfig())), in QuicCryptoClientStreamTest()
37 CryptoTestUtils::HandshakeWithFakeServer(connection_, stream_.get()); in CompleteCryptoHandshake()
45 PacketSavingConnection* connection_; member in net::test::__anon47045c7a0111::QuicCryptoClientStreamTest
67 EXPECT_CALL(*connection_, SendConnectionClose( in TEST_F()
80 EXPECT_CALL(*connection_, SendConnectionCloseWithDetails( in TEST_F()
117 connection_ = new PacketSavingConnection(true); in TEST_F()
118 session_.reset(new TestSession(connection_, DefaultQuicConfig())); in TEST_F()
127 reinterpret_cast<MockClock*>(const_cast<QuicClock*>(connection_->clock())) in TEST_F()
133 ASSERT_EQ(1u, connection_->packets_.size()); in TEST_F()
|
| D | quic_session.cc | 82 : connection_(connection), in QuicSession()
93 connection_->set_visitor(visitor_shim_.get()); in QuicSession()
94 connection_->SetFromConfig(config_); in QuicSession()
95 if (connection_->connected()) { in QuicSession()
96 connection_->SetOverallConnectionTimeout( in QuicSession()
199 DCHECK(!connection_->connected()); in OnConnectionClosed()
222 while (!connection_->HasQueuedData() && in OnCanWrite()
227 connection_->CloseConnection(QUIC_INTERNAL_ERROR, false); in OnCanWrite()
260 return connection_->SendStreamData(id, data, offset, fin, in WritevData()
266 connection_->SendRstStream(id, error); in SendRstStream()
[all …]
|
| D | quic_crypto_server_stream_test.cc | 55 : connection_(new PacketSavingConnection(true)), in QuicCryptoServerStreamTest()
56 session_(connection_, DefaultQuicConfig()), in QuicCryptoServerStreamTest()
66 connection_->AdvanceTime(QuicTime::Delta::FromSeconds(100000)); in QuicCryptoServerStreamTest()
72 connection_->clock(), connection_->random_generator(), in QuicCryptoServerStreamTest()
80 static_cast<uint32>(connection_->clock()->WallNow().ToUNIXSeconds()), in QuicCryptoServerStreamTest()
99 return CryptoTestUtils::HandshakeWithFakeClient(connection_, &stream_, in CompleteCryptoHandshake()
104 PacketSavingConnection* connection_; member in net::test::__anon87d45e920111::QuicCryptoServerStreamTest
224 EXPECT_CALL(*connection_, SendConnectionClose( in TEST_P()
234 EXPECT_CALL(*connection_, SendConnectionClose( in TEST_P()
|
| D | reliable_quic_stream_test.cc | 100 connection_ = new StrictMock<MockConnection>(kIsServer); in Initialize()
101 session_.reset(new StrictMock<MockSession>(connection_)); in Initialize()
113 MockConnection* connection_; member in net::test::__anon2fded6fb0111::ReliableQuicStreamTest
126 connection_->options()->max_packet_length = in TEST_F()
128 connection_->version(), PACKET_8BYTE_GUID, !kIncludeVersion, in TEST_F()
192 connection_->options()->max_packet_length = in TEST_F()
194 connection_->version(), PACKET_8BYTE_GUID, !kIncludeVersion, in TEST_F()
|
| /external/chromium-trace/trace-viewer/src/tracing/importer/ |
| D | timeline_stream_importer.js | 72 this.connection_ = undefined;
88 if (!this.connection_)
90 this.connection_.removeEventListener('open',
92 this.connection_.removeEventListener('close',
94 this.connection_.removeEventListener('error',
96 this.connection_.removeEventListener('message',
196 if (this.connection_ !== undefined &&
197 this.connection_.readyState == WebSocket.OPEN) {
212 this.connection_ = wsConnection;
213 this.connection_.addEventListener('open',
[all …]
|
| /external/chromium_org/remoting/host/ |
| D | client_session.cc | 50 connection_(connection.Pass()), in ClientSession()
51 client_jid_(connection_->session()->jid()), in ClientSession()
70 connection_->SetEventHandler(this); in ClientSession()
75 connection_->set_clipboard_stub(&auth_clipboard_filter_); in ClientSession()
76 connection_->set_host_stub(this); in ClientSession()
77 connection_->set_input_stub(&auth_input_filter_); in ClientSession()
98 connection_.reset(); in ~ClientSession()
155 if (!connection_->session()->config().SupportsCapabilities()) { in SetCapabilities()
186 connection_->client_stub()->SetPairingResponse(pairing_response); in RequestPairing()
198 connection_->client_stub()->DeliverHostMessage(reply); in DeliverClientMessage()
[all …]
|
| D | client_session_unittest.cc | 117 MockConnectionToClient* connection_; member in remoting::ClientSessionTest
157 connection_ = connection.get(); in SetUp()
262 InjectClipboardEvent(connection_, clipboard_event2), in TEST_F()
266 InjectClipboardEvent(connection_, clipboard_event3), in TEST_F()
276 connection_->clipboard_stub()->InjectClipboardEvent(clipboard_event1); in TEST_F()
345 InjectKeyEvent(connection_, key_event2_down), in TEST_F()
346 InjectKeyEvent(connection_, key_event2_up), in TEST_F()
347 InjectMouseEvent(connection_, mouse_event2), in TEST_F()
351 InjectKeyEvent(connection_, key_event3), in TEST_F()
352 InjectMouseEvent(connection_, mouse_event3), in TEST_F()
[all …]
|
| /external/chromium/net/http/ |
| D | http_stream_factory_impl_job.cc | 48 connection_(new ClientSocketHandle), in Job()
76 connection_->socket()->Disconnect(); in ~Job()
77 connection_.reset(); in ~Job()
113 return connection_->GetLoadState(); in GetLoadState()
181 DCHECK(connection_.get() && connection_->socket()); in GetSSLInfo()
183 static_cast<SSLClientSocket*>(connection_->socket()); in GetSSLInfo()
317 DCHECK(connection_.get()); in RunLoop()
318 DCHECK(connection_->socket()); in RunLoop()
322 static_cast<HttpProxyClientSocket*>(connection_->socket()); in RunLoop()
341 connection_->ssl_error_response_info().cert_request_info)); in RunLoop()
[all …]
|
| D | http_stream_parser.cc | 41 connection_(connection), in HttpStreamParser()
76 int result = connection_->socket()->GetPeerAddress(&address); in SendRequest()
130 if (not_reusable && connection_->socket()) in Close()
131 connection_->socket()->Disconnect(); in Close()
132 connection_->Reset(); in Close()
273 result = connection_->socket()->Write(request_headers_, in DoSendHeaders()
291 return connection_->socket()->Write(chunk_buf_, chunk_length_, in DoSendBody()
326 return connection_->socket()->Write(chunk_buf_, chunk_length_, in DoSendBody()
335 result = connection_->socket()->Write(request_body_->buf(), buf_len, in DoSendBody()
354 return connection_->socket()->Read(read_buf_, in DoReadHeaders()
[all …]
|
| /external/chromium_org/chrome/browser/extensions/api/braille_display_private/ |
| D | braille_controller_brlapi.cc | 83 if (connection_.get() && connection_->Connected()) { in GetDisplayState()
85 if (!connection_->GetDisplaySize(&size)) { in GetDisplayState()
97 if (connection_ && connection_->Connected()) { in WriteDots()
99 if (!connection_->GetDisplaySize(&size)) { in WriteDots()
106 if (!connection_->WriteDots(&sizedCells[0])) in WriteDots()
205 if (!connection_.get()) in TryToConnect()
206 connection_ = create_brlapi_connection_function_.Run(); in TryToConnect()
207 if (connection_.get() && !connection_->Connected()) { in TryToConnect()
209 BrlapiConnection::ConnectResult result = connection_->Connect(base::Bind( in TryToConnect()
255 if (!connection_ || !connection_->Connected()) in Disconnect()
[all …]
|
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| D | dbus.cc | 152 connection_(NULL), in DBusMonitoringThread()
167 ASSERT(NULL == connection_); in Run()
206 connection_)); in RegisterAllFilters()
217 GetSymbols()->dbus_g_connection_get_connection()(connection_), in RegisterAllFilters()
221 GetSymbols()->dbus_g_connection_get_connection()(connection_), in RegisterAllFilters()
233 connection_)); in UnRegisterAllFilters()
243 GetSymbols()->dbus_g_connection_get_connection()(connection_), in UnRegisterAllFilters()
254 connection_ = GetSymbols()->dbus_g_bus_get_private()(monitor_->type_, in Setup()
256 if (NULL == connection_) { in Setup()
260 if (NULL == GetSymbols()->dbus_g_connection_get_connection()(connection_)) { in Setup()
[all …]
|
| /external/chromium_org/net/http/ |
| D | http_stream_factory_impl_job.cc | 90 connection_(new ClientSocketHandle), in Job()
122 connection_->socket()->Disconnect(); in ~Job()
123 connection_.reset(); in ~Job()
170 return using_quic_ ? LOAD_STATE_CONNECTING : connection_->GetLoadState(); in GetLoadState()
220 connection_ && connection_->socket()) in Orphan()
221 connection_->socket()->Disconnect(); in Orphan()
227 if (connection_ && connection_->socket()) in Orphan()
228 connection_->socket()->Disconnect(); in Orphan()
266 DCHECK(connection_.get() && connection_->socket()); in GetSSLInfo()
268 static_cast<SSLClientSocket*>(connection_->socket()); in GetSSLInfo()
[all …]
|
| D | http_stream_parser.cc | 187 connection_(connection), in HttpStreamParser()
220 int result = connection_->socket()->GetPeerAddress(&ip_endpoint); in SendRequest()
323 if (not_reusable && connection_->socket()) in Close()
324 connection_->socket()->Disconnect(); in Close()
325 connection_->Reset(); in Close()
427 result = connection_->socket() in DoSendHeaders()
455 return connection_->socket() in DoSendBody()
517 return connection_->socket() in DoReadHeaders()
534 connection_->is_reused()) { in DoReadHeadersComplete()
657 return connection_->socket() in DoReadBody()
[all …]
|
| /external/chromium_org/dbus/ |
| D | bus.cc | 194 connection_(NULL), in Bus()
211 DCHECK(!connection_); in ~Bus()
378 if (connection_) in Connect()
384 connection_ = dbus_connection_open_private(address_.c_str(), error.get()); in Connect()
386 connection_ = dbus_connection_open(address_.c_str(), error.get()); in Connect()
391 connection_ = dbus_bus_get_private(dbus_bus_type, error.get()); in Connect()
393 connection_ = dbus_bus_get(dbus_bus_type, error.get()); in Connect()
396 if (!connection_) { in Connect()
408 if (!dbus_bus_register(connection_, error.get())) { in Connect()
415 dbus_connection_set_exit_on_disconnect(connection_, false); in Connect()
[all …]
|
| /external/chromium_org/net/tools/flip_server/ |
| D | http_interface_test.cc | 77 connection_.reset(new MockSMConnection(epoll_server_.get(), in FlipHttpSMTest()
83 interface_.reset(new HttpSM(connection_.get(), in FlipHttpSMTest()
95 STLDeleteElements(connection_->output_list()); in TearDown()
107 scoped_ptr<MockSMConnection> connection_; member in net::__anon17cfd0fe0111::FlipHttpSMTest
165 EXPECT_CALL(*connection_, InitSMConnection(_, _, _, _, _, _, _, _)); in TEST_F()
201 ASSERT_EQ(1u, connection_->output_list()->size()); in TEST_F()
202 std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); in TEST_F()
205 ASSERT_EQ(connection_->output_list()->end(), i); in TEST_F()
278 ASSERT_EQ(3u, connection_->output_list()->size()); in TEST_F()
279 std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); in TEST_F()
[all …]
|
| D | spdy_interface_test.cc | 142 connection_.reset(new FakeSMConnection(epoll_server_.get(), in SpdySMTestBase()
148 interface_.reset(new TestSpdySM(connection_.get(), in SpdySMTestBase()
166 OutputList& output_list = *connection_->output_list(); in ~SpdySMTestBase()
184 scoped_ptr<FakeSMConnection> connection_; member in net::__anon363dce1e0111::SpdySMTestBase
210 EXPECT_CALL(*connection_, InitSMConnection(_, _, _, _, _, _, _, _)); in TEST_P()
406 ASSERT_EQ(1u, connection_->output_list()->size()); in TEST_P()
407 std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); in TEST_P()
454 ASSERT_EQ(2u, connection_->output_list()->size()); in TEST_P()
471 std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); in TEST_P()
498 ASSERT_EQ(2u, connection_->output_list()->size()); in TEST_P()
[all …]
|
| /external/chromium/app/sql/ |
| D | transaction.cc | 13 : connection_(connection), in Transaction()
19 connection_->RollbackTransaction(); in ~Transaction()
27 is_open_ = connection_->BeginTransaction(); in Begin()
38 connection_->RollbackTransaction(); in Rollback()
48 return connection_->CommitTransaction(); in Commit()
|
| /external/chromium_org/sql/ |
| D | transaction.cc | 13 : connection_(connection), in Transaction()
19 connection_->RollbackTransaction(); in ~Transaction()
27 is_open_ = connection_->BeginTransaction(); in Begin()
38 connection_->RollbackTransaction(); in Rollback()
48 return connection_->CommitTransaction(); in Commit()
|
| /external/chromium_org/remoting/client/ |
| D | chromoting_client.cc | 36 connection_(connection), in ChromotingClient()
72 connection_->Connect(signal_strategy, in Start()
166 rectangle_decoder_->Initialize(connection_->config()); in OnAuthenticated()
167 if (connection_->config().is_audio_enabled()) in OnAuthenticated()
168 audio_decode_scheduler_->Initialize(connection_->config()); in OnAuthenticated()
172 if (!connection_->config().SupportsCapabilities()) { in OnAuthenticated()
184 if (connection_->config().SupportsCapabilities()) { in OnChannelsConnected()
189 connection_->host_stub()->SetCapabilities(capabilities); in OnChannelsConnected()
|
| /external/chromium/chrome/browser/debugger/ |
| D | devtools_protocol_handler.cc | 36 connection_(NULL), in DevToolsProtocolHandler()
44 DCHECK(connection_.get() == NULL); in ~DevToolsProtocolHandler()
67 connection_ = NULL; in Teardown()
103 if (connection_ != NULL) { in Send()
104 connection_->Send(message.ToString()); in Send()
110 connection_ = connection; in OnAcceptConnection()
115 connection_ = NULL; in OnConnectionLost()
|
| /external/chromium_org/net/socket_stream/ |
| D | socket_stream.cc | 100 connection_(new ClientSocketHandle), in SocketStream()
210 if (!connection_->socket() || in SendData()
211 !connection_->socket()->IsConnected() || next_state_ == STATE_NONE) { in SendData()
271 if (!connection_->socket()) { in RestartWithAuth()
381 if (!connection_->socket() || !connection_->socket()->IsConnected()) { in DidEstablishConnection()
744 connection_->SetSocket( in DoTcpConnect()
749 return connection_->socket()->Connect(io_callback_); in DoTcpConnect()
834 return connection_->socket()->Write( in DoWriteTunnelHeaders()
878 return connection_->socket()->Read( in DoReadTunnelHeaders()
975 s.reset(new SOCKS5ClientSocket(connection_.Pass(), req_info)); in DoSOCKSConnect()
[all …]
|
| /external/chromium_org/chrome/browser/extensions/api/serial/ |
| D | serial_api.cc | 136 connection_ = CreateSerialConnection(params_->path, extension_->id()); in AsyncWorkStart()
137 connection_->Open(base::Bind(&SerialConnectFunction::OnConnected, this)); in AsyncWorkStart()
141 DCHECK(connection_); in OnConnected()
144 if (!connection_->Configure(*params_->options.get())) { in OnConnected()
145 connection_->Close(); in OnConnected()
146 delete connection_; in OnConnected()
147 connection_ = NULL; in OnConnected()
150 delete connection_; in OnConnected()
151 connection_ = NULL; in OnConnected()
161 if (!connection_) { in FinishConnect()
[all …]
|
| /external/chromium_org/net/server/ |
| D | web_socket.cc | 72 connection_->Send(base::StringPrintf( in Accept()
81 connection_->Send(reinterpret_cast<char*>(digest.a), 16); in Accept()
86 const std::string& data = connection_->recv_data(); in Read()
96 connection_->Shift(pos + 1); in Read()
104 connection_->Send(&message_start, 1); in Send()
105 connection_->Send(message); in Send()
106 connection_->Send(&message_end, 1); in Send()
204 connection_->Send(response); in Accept()
208 const std::string& frame = connection_->recv_data(); in Read()
214 connection_->Shift(bytes_consumed); in Read()
[all …]
|
| /external/chromium_org/net/tools/quic/ |
| D | quic_client_session_test.cc | 31 : connection_(new PacketSavingConnection(false)) { in ToolsQuicClientSessionTest()
34 connection_, &crypto_config_)); in ToolsQuicClientSessionTest()
41 connection_, session_->GetCryptoStream()); in CompleteCryptoHandshake()
44 PacketSavingConnection* connection_; member in net::tools::test::__anonf5b2bad20111::ToolsQuicClientSessionTest
|