connection_ 88 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.cc if (connection_.get() && connection_->Connected()) { connection_ 90 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.cc if (!connection_->GetDisplaySize(&size)) { connection_ 102 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.cc if (connection_ && connection_->Connected()) { connection_ 104 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.cc if (!connection_->GetDisplaySize(&size)) { connection_ 111 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.cc if (!connection_->WriteDots(&sizedCells[0])) connection_ 210 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.cc if (!connection_.get()) connection_ 211 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.cc connection_ = create_brlapi_connection_function_.Run(); connection_ 212 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.cc if (connection_.get() && !connection_->Connected()) { connection_ 214 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.cc BrlapiConnection::ConnectResult result = connection_->Connect(base::Bind( connection_ 260 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.cc if (!connection_ || !connection_->Connected()) connection_ 262 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.cc connection_->Disconnect(); connection_ 319 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.cc DCHECK(connection_.get()); connection_ 322 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.cc int result = connection_->ReadKey(&code); connection_ 324 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.cc brlapi_error_t* err = connection_->BrlapiError(); connection_ 328 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.cc VLOG(1) << "BrlAPI error: " << connection_->BrlapiStrError(); connection_ 72 chrome/browser/extensions/api/braille_display_private/braille_controller_brlapi.h scoped_ptr<BrlapiConnection> connection_; connection_ 25 chrome/browser/extensions/api/hid/hid_connection_resource.h return connection_; connection_ 36 chrome/browser/extensions/api/hid/hid_connection_resource.h scoped_refptr<device::HidConnection> connection_; connection_ 146 chrome/browser/extensions/api/serial/serial_api.cc connection_ = CreateSerialConnection(params_->path, extension_->id()); connection_ 147 chrome/browser/extensions/api/serial/serial_api.cc connection_->Open(base::Bind(&SerialConnectFunction::OnConnected, this)); connection_ 151 chrome/browser/extensions/api/serial/serial_api.cc DCHECK(connection_); connection_ 154 chrome/browser/extensions/api/serial/serial_api.cc if (!connection_->Configure(*params_->options.get())) { connection_ 155 chrome/browser/extensions/api/serial/serial_api.cc connection_->Close(); connection_ 156 chrome/browser/extensions/api/serial/serial_api.cc delete connection_; connection_ 157 chrome/browser/extensions/api/serial/serial_api.cc connection_ = NULL; connection_ 160 chrome/browser/extensions/api/serial/serial_api.cc delete connection_; connection_ 161 chrome/browser/extensions/api/serial/serial_api.cc connection_ = NULL; connection_ 171 chrome/browser/extensions/api/serial/serial_api.cc if (!connection_) { connection_ 174 chrome/browser/extensions/api/serial/serial_api.cc int id = manager_->Add(connection_); connection_ 177 chrome/browser/extensions/api/serial/serial_api.cc if (connection_->GetInfo(&info)) { connection_ 181 chrome/browser/extensions/api/serial/serial_api.cc connection_->Close(); connection_ 84 chrome/browser/extensions/api/serial/serial_api.h SerialConnection* connection_; connection_ 44 content/browser/indexed_db/indexed_db_database.cc connection_(connection.Pass()), connection_ 50 content/browser/indexed_db/indexed_db_database.cc return connection_.Pass(); connection_ 57 content/browser/indexed_db/indexed_db_database.cc scoped_ptr<IndexedDBConnection> connection_; connection_ 70 content/browser/indexed_db/indexed_db_database.cc : callbacks_(callbacks), connection_(connection), version_(version) {} connection_ 72 content/browser/indexed_db/indexed_db_database.cc IndexedDBConnection* connection() const { return connection_; } connection_ 77 content/browser/indexed_db/indexed_db_database.cc IndexedDBConnection* connection_; connection_ 405 content/browser/indexed_db/indexed_db_factory_unittest.cc EXPECT_TRUE(connection_.get()); connection_ 413 content/browser/indexed_db/indexed_db_factory_unittest.cc connection_ = connection.Pass(); connection_ 130 content/browser/indexed_db/indexed_db_unittest.cc connection_ = connection.Pass(); connection_ 131 content/browser/indexed_db/indexed_db_unittest.cc idb_context_->ConnectionOpened(origin_url_, connection_.get()); connection_ 134 content/browser/indexed_db/indexed_db_unittest.cc IndexedDBConnection* connection() { return connection_.get(); } connection_ 142 content/browser/indexed_db/indexed_db_unittest.cc scoped_ptr<IndexedDBConnection> connection_; connection_ 17 content/browser/indexed_db/mock_indexed_db_callbacks.cc EXPECT_EQ(expect_connection_, !!connection_); connection_ 27 content/browser/indexed_db/mock_indexed_db_callbacks.cc connection_ = connection.Pass(); connection_ 22 content/browser/indexed_db/mock_indexed_db_callbacks.h IndexedDBConnection* connection() { return connection_.get(); } connection_ 27 content/browser/indexed_db/mock_indexed_db_callbacks.h scoped_ptr<IndexedDBConnection> connection_; connection_ 63 content/browser/renderer_host/pepper/pepper_renderer_connection.cc BrowserMessageFilter* connection_; connection_ 75 content/browser/renderer_host/pepper/pepper_renderer_connection.cc connection_(connection), connection_ 88 content/browser/renderer_host/pepper/pepper_renderer_connection.cc connection_->Send(new PpapiHostMsg_CreateResourceHostsFromHostReply( connection_ 194 dbus/bus.cc connection_(NULL), connection_ 211 dbus/bus.cc DCHECK(!connection_); connection_ 378 dbus/bus.cc if (connection_) connection_ 384 dbus/bus.cc connection_ = dbus_connection_open_private(address_.c_str(), error.get()); connection_ 386 dbus/bus.cc connection_ = dbus_connection_open(address_.c_str(), error.get()); connection_ 391 dbus/bus.cc connection_ = dbus_bus_get_private(dbus_bus_type, error.get()); connection_ 393 dbus/bus.cc connection_ = dbus_bus_get(dbus_bus_type, error.get()); connection_ 396 dbus/bus.cc if (!connection_) { connection_ 408 dbus/bus.cc if (!dbus_bus_register(connection_, error.get())) { connection_ 415 dbus/bus.cc dbus_connection_set_exit_on_disconnect(connection_, false); connection_ 429 dbus/bus.cc dbus_connection_close(connection_); connection_ 470 dbus/bus.cc if (connection_) { connection_ 479 dbus/bus.cc dbus_connection_unref(connection_); connection_ 482 dbus/bus.cc connection_ = NULL; connection_ 533 dbus/bus.cc DCHECK(connection_); connection_ 543 dbus/bus.cc const int result = dbus_bus_request_name(connection_, connection_ 557 dbus/bus.cc DCHECK(connection_); connection_ 570 dbus/bus.cc const int result = dbus_bus_release_name(connection_, service_name.c_str(), connection_ 584 dbus/bus.cc DCHECK(connection_); connection_ 594 dbus/bus.cc bool success = dbus_connection_set_watch_functions(connection_, connection_ 602 dbus/bus.cc success = dbus_connection_set_timeout_functions(connection_, connection_ 611 dbus/bus.cc connection_, connection_ 624 dbus/bus.cc DCHECK(connection_); connection_ 628 dbus/bus.cc connection_, request, timeout_ms, error); connection_ 634 dbus/bus.cc DCHECK(connection_); connection_ 638 dbus/bus.cc connection_, request, pending_call, timeout_ms); connection_ 643 dbus/bus.cc DCHECK(connection_); connection_ 646 dbus/bus.cc const bool success = dbus_connection_send(connection_, request, serial); connection_ 652 dbus/bus.cc DCHECK(connection_); connection_ 665 dbus/bus.cc connection_, filter_function, user_data, NULL); connection_ 673 dbus/bus.cc DCHECK(connection_); connection_ 686 dbus/bus.cc dbus_connection_remove_filter(connection_, filter_function, user_data); connection_ 692 dbus/bus.cc DCHECK(connection_); connection_ 705 dbus/bus.cc dbus_bus_add_match(connection_, match_rule.c_str(), error); connection_ 710 dbus/bus.cc DCHECK(connection_); connection_ 723 dbus/bus.cc dbus_bus_remove_match(connection_, match_rule.c_str(), error); connection_ 733 dbus/bus.cc DCHECK(connection_); connection_ 743 dbus/bus.cc connection_, connection_ 754 dbus/bus.cc DCHECK(connection_); connection_ 765 dbus/bus.cc connection_, connection_ 782 dbus/bus.cc if (!connection_) connection_ 788 dbus/bus.cc if (dbus_connection_get_dispatch_status(connection_) == connection_ 790 dbus/bus.cc while (dbus_connection_dispatch(connection_) == connection_ 1060 dbus/bus.cc DCHECK_EQ(connection, connection_); connection_ 591 dbus/bus.h bool is_connected() { return connection_ != NULL; } connection_ 693 dbus/bus.h DBusConnection* connection_; connection_ 49 device/hid/hid_connection_win.cc scoped_refptr<HidConnectionWin> connection_; connection_ 70 device/hid/hid_connection_win.cc : connection_(connection), connection_ 85 device/hid/hid_connection_win.cc connection_->OnTransferFinished(this); connection_ 94 device/hid/hid_connection_win.cc connection_->OnTransferFinished(this); connection_ 100 device/hid/hid_connection_win.cc connection_->OnTransferCanceled(this); connection_ 56 net/dns/mdns_client_impl.cc connection_(connection), connection_ 77 net/dns/mdns_client_impl.cc connection_->OnDatagramReceived(&response_, recv_addr_, rv); connection_ 98 net/dns/mdns_client_impl.cc connection_->OnError(this, rv); connection_ 182 net/dns/mdns_client_impl.cc return connection_->Init(socket_factory); connection_ 193 net/dns/mdns_client_impl.cc return connection_->Send(query.io_buffer(), query.io_buffer()->size()); connection_ 75 net/dns/mdns_client_impl.h MDnsConnection* connection_; connection_ 162 net/dns/mdns_client_impl.h scoped_ptr<MDnsConnection> connection_; connection_ 1086 net/dns/mdns_client_unittest.cc MDnsConnectionTest() : connection_(&delegate_) { connection_ 1099 net/dns/mdns_client_unittest.cc return connection_.Init(&factory_); connection_ 1107 net/dns/mdns_client_unittest.cc MDnsConnection connection_; connection_ 1166 net/dns/mdns_client_unittest.cc connection_.Send(buf, buf->size()); connection_ 21 net/http/http_basic_state.cc connection_(connection), connection_ 34 net/http/http_basic_state.cc connection_.get(), request_info, read_buf_.get(), net_log)); connection_ 39 net/http/http_basic_state.cc return connection_.Pass(); connection_ 46 net/http/http_basic_state.h ClientSocketHandle* connection() const { return connection_.get(); } connection_ 61 net/http/http_basic_state.h scoped_ptr<ClientSocketHandle> connection_; connection_ 78 net/http/http_pipelined_connection_impl.cc connection_(connection), connection_ 96 net/http/http_pipelined_connection_impl.cc CHECK(connection_.get()); connection_ 112 net/http/http_pipelined_connection_impl.cc connection_->socket()->Disconnect(); connection_ 114 net/http/http_pipelined_connection_impl.cc connection_->Reset(); connection_ 134 net/http/http_pipelined_connection_impl.cc connection_.get(), request, read_buf_.get(), net_log)); connection_ 646 net/http/http_pipelined_connection_impl.cc ClientSocketHandle::SocketReuseType reuse_type = connection_->reuse_type(); connection_ 647 net/http/http_pipelined_connection_impl.cc return connection_->is_reused() || connection_ 653 net/http/http_pipelined_connection_impl.cc connection_->set_reuse_type(ClientSocketHandle::REUSED_IDLE); connection_ 666 net/http/http_pipelined_connection_impl.cc return connection_->GetLoadTimingInfo(IsConnectionReused(pipeline_id), connection_ 298 net/http/http_pipelined_connection_impl.h scoped_ptr<ClientSocketHandle> connection_; connection_ 36 net/http/http_pipelined_host_forced_unittest.cc EXPECT_CALL(*factory_, CreateNewPipeline(&connection_, host_.get(), connection_ 47 net/http/http_pipelined_host_forced_unittest.cc &connection_, ssl_config_, proxy_info_, net_log_, true, connection_ 52 net/http/http_pipelined_host_forced_unittest.cc ClientSocketHandle connection_; connection_ 90 net/http/http_stream_factory_impl_job.cc connection_(new ClientSocketHandle), connection_ 122 net/http/http_stream_factory_impl_job.cc connection_->socket()->Disconnect(); connection_ 123 net/http/http_stream_factory_impl_job.cc connection_.reset(); connection_ 170 net/http/http_stream_factory_impl_job.cc return using_quic_ ? LOAD_STATE_CONNECTING : connection_->GetLoadState(); connection_ 220 net/http/http_stream_factory_impl_job.cc connection_ && connection_->socket()) connection_ 221 net/http/http_stream_factory_impl_job.cc connection_->socket()->Disconnect(); connection_ 227 net/http/http_stream_factory_impl_job.cc if (connection_ && connection_->socket()) connection_ 228 net/http/http_stream_factory_impl_job.cc connection_->socket()->Disconnect(); connection_ 266 net/http/http_stream_factory_impl_job.cc DCHECK(connection_.get() && connection_->socket()); connection_ 268 net/http/http_stream_factory_impl_job.cc static_cast<SSLClientSocket*>(connection_->socket()); connection_ 477 net/http/http_stream_factory_impl_job.cc DCHECK(connection_.get()); connection_ 478 net/http/http_stream_factory_impl_job.cc DCHECK(connection_->socket()); connection_ 483 net/http/http_stream_factory_impl_job.cc static_cast<ProxyClientSocket*>(connection_->socket()); connection_ 496 net/http/http_stream_factory_impl_job.cc connection_->ssl_error_response_info().cert_request_info)); connection_ 500 net/http/http_stream_factory_impl_job.cc DCHECK(connection_.get()); connection_ 501 net/http/http_stream_factory_impl_job.cc DCHECK(connection_->socket()); connection_ 505 net/http/http_stream_factory_impl_job.cc static_cast<ProxyClientSocket*>(connection_->socket()); connection_ 725 net/http/http_stream_factory_impl_job.cc DCHECK(!connection_->is_initialized()); connection_ 862 net/http/http_stream_factory_impl_job.cc connection_.get(), resolution_callback, io_callback_); connection_ 869 net/http/http_stream_factory_impl_job.cc connection_.get(), resolution_callback, io_callback_); connection_ 918 net/http/http_stream_factory_impl_job.cc bool ssl_started = using_ssl_ && (result == OK || connection_->socket() || connection_ 919 net/http/http_stream_factory_impl_job.cc connection_->is_ssl_error()); connection_ 929 net/http/http_stream_factory_impl_job.cc static_cast<SSLClientSocket*>(connection_->socket()); connection_ 949 net/http/http_stream_factory_impl_job.cc } else if (proxy_info_.is_https() && connection_->socket() && connection_ 952 net/http/http_stream_factory_impl_job.cc static_cast<ProxyClientSocket*>(connection_->socket()); connection_ 973 net/http/http_stream_factory_impl_job.cc connection_.reset(connection_->release_pending_http_proxy_connection()); connection_ 996 net/http/http_stream_factory_impl_job.cc if (connection_->socket()) { connection_ 997 net/http/http_stream_factory_impl_job.cc LogHttpConnectedMetrics(*connection_); connection_ 1000 net/http/http_stream_factory_impl_job.cc if (!connection_->is_reused()) { connection_ 1017 net/http/http_stream_factory_impl_job.cc if (result == OK && !connection_->socket()->IsConnectedAndIdle()) { connection_ 1041 net/http/http_stream_factory_impl_job.cc DCHECK(connection_->socket() || existing_spdy_session_.get() || connection_ 1049 net/http/http_stream_factory_impl_job.cc if (connection_->socket() && !connection_->is_reused()) connection_ 1069 net/http/http_stream_factory_impl_job.cc ->CreateBasicStream(connection_.Pass(), using_proxy)); connection_ 1075 net/http/http_stream_factory_impl_job.cc connection_.release(), connection_ 1083 net/http/http_stream_factory_impl_job.cc stream_.reset(new HttpBasicStream(connection_.release(), using_proxy)); connection_ 1107 net/http/http_stream_factory_impl_job.cc if (connection_->socket()) connection_ 1108 net/http/http_stream_factory_impl_job.cc connection_->socket()->Disconnect(); connection_ 1109 net/http/http_stream_factory_impl_job.cc connection_->Reset(); connection_ 1117 net/http/http_stream_factory_impl_job.cc connection_.Pass(), connection_ 1169 net/http/http_stream_factory_impl_job.cc static_cast<ProxyClientSocket*>(connection_->socket()); connection_ 1194 net/http/http_stream_factory_impl_job.cc if (close_connection && connection_->socket()) connection_ 1195 net/http/http_stream_factory_impl_job.cc connection_->socket()->Disconnect(); connection_ 1196 net/http/http_stream_factory_impl_job.cc connection_->Reset(); connection_ 1208 net/http/http_stream_factory_impl_job.cc connection_->socket()->SetSubresourceSpeculation(); connection_ 1210 net/http/http_stream_factory_impl_job.cc connection_->socket()->SetOmniboxSpeculation(); connection_ 1350 net/http/http_stream_factory_impl_job.cc if (connection_->socket()) connection_ 1351 net/http/http_stream_factory_impl_job.cc connection_->socket()->Disconnect(); connection_ 1352 net/http/http_stream_factory_impl_job.cc connection_->Reset(); connection_ 1374 net/http/http_stream_factory_impl_job.cc static_cast<SSLClientSocket*>(connection_->socket()); connection_ 243 net/http/http_stream_factory_impl_job.h scoped_ptr<ClientSocketHandle> connection_; connection_ 272 net/http/http_stream_factory_impl_unittest.cc connection_->socket()->Disconnect(); connection_ 275 net/http/http_stream_factory_impl_unittest.cc ClientSocketHandle* connection() { return connection_.get(); } connection_ 278 net/http/http_stream_factory_impl_unittest.cc scoped_ptr<ClientSocketHandle> connection_; connection_ 187 net/http/http_stream_parser.cc connection_(connection), connection_ 220 net/http/http_stream_parser.cc int result = connection_->socket()->GetPeerAddress(&ip_endpoint); connection_ 323 net/http/http_stream_parser.cc if (not_reusable && connection_->socket()) connection_ 324 net/http/http_stream_parser.cc connection_->socket()->Disconnect(); connection_ 325 net/http/http_stream_parser.cc connection_->Reset(); connection_ 427 net/http/http_stream_parser.cc result = connection_->socket() connection_ 455 net/http/http_stream_parser.cc return connection_->socket() connection_ 517 net/http/http_stream_parser.cc return connection_->socket() connection_ 534 net/http/http_stream_parser.cc connection_->is_reused()) { connection_ 657 net/http/http_stream_parser.cc return connection_->socket() connection_ 901 net/http/http_stream_parser.cc ClientSocketHandle::SocketReuseType reuse_type = connection_->reuse_type(); connection_ 902 net/http/http_stream_parser.cc return connection_->is_reused() || connection_ 907 net/http/http_stream_parser.cc connection_->set_reuse_type(ClientSocketHandle::REUSED_IDLE); connection_ 911 net/http/http_stream_parser.cc return connection_->socket() && connection_->socket()->IsConnectedAndIdle(); connection_ 915 net/http/http_stream_parser.cc if (request_->url.SchemeIsSecure() && connection_->socket()) { connection_ 917 net/http/http_stream_parser.cc static_cast<SSLClientSocket*>(connection_->socket()); connection_ 924 net/http/http_stream_parser.cc if (request_->url.SchemeIsSecure() && connection_->socket()) { connection_ 926 net/http/http_stream_parser.cc static_cast<SSLClientSocket*>(connection_->socket()); connection_ 224 net/http/http_stream_parser.h ClientSocketHandle* const connection_; connection_ 69 net/quic/quic_client_session_test.cc connection_( connection_ 71 net/quic/quic_client_session_test.cc session_(connection_, GetSocket().Pass(), writer_.Pass(), NULL, NULL, connection_ 95 net/quic/quic_client_session_test.cc connection_, session_.GetCryptoStream()); connection_ 100 net/quic/quic_client_session_test.cc PacketSavingConnection* connection_; connection_ 68 net/quic/quic_connection.cc : connection_(connection) { connection_ 72 net/quic/quic_connection.cc connection_->SendAck(); connection_ 77 net/quic/quic_connection.cc QuicConnection* connection_; connection_ 86 net/quic/quic_connection.cc : connection_(connection) { connection_ 90 net/quic/quic_connection.cc connection_->OnRetransmissionTimeout(); connection_ 95 net/quic/quic_connection.cc QuicConnection* connection_; connection_ 103 net/quic/quic_connection.cc : connection_(connection) { connection_ 107 net/quic/quic_connection.cc connection_->WriteIfNotBlocked(); connection_ 113 net/quic/quic_connection.cc QuicConnection* connection_; connection_ 119 net/quic/quic_connection.cc : connection_(connection) { connection_ 123 net/quic/quic_connection.cc connection_->CheckForTimeout(); connection_ 129 net/quic/quic_connection.cc QuicConnection* connection_; connection_ 1805 net/quic/quic_connection.cc : connection_(connection), connection_ 1811 net/quic/quic_connection.cc connection_->packet_generator_.StartBatchOperations(); connection_ 1816 net/quic/quic_connection.cc connection_->ack_alarm_->IsSet() || connection_->stop_waiting_count_ > 1; connection_ 1819 net/quic/quic_connection.cc connection_->SendAck(); connection_ 1827 net/quic/quic_connection.cc connection_->packet_generator_.FinishBatchOperations(); connection_ 1830 net/quic/quic_connection.cc connection_->packet_generator_.InBatchMode()); connection_ 491 net/quic/quic_connection.h QuicConnection* connection_; connection_ 551 net/quic/quic_connection_test.cc connection_(connection_id_, IPEndPoint(), helper_.get(), connection_ 557 net/quic/quic_connection_test.cc connection_.set_visitor(&visitor_); connection_ 558 net/quic/quic_connection_test.cc connection_.SetSendAlgorithm(send_algorithm_); connection_ 559 net/quic/quic_connection_test.cc connection_.SetLossAlgorithm(loss_algorithm_); connection_ 591 net/quic/quic_connection_test.cc outgoing_ack_.reset(QuicConnectionPeer::CreateAckFrame(&connection_)); connection_ 655 net/quic/quic_connection_test.cc connection_.is_server()); connection_ 661 net/quic/quic_connection_test.cc connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); connection_ 680 net/quic/quic_connection_test.cc connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); connection_ 689 net/quic/quic_connection_test.cc connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); connection_ 753 net/quic/quic_connection_test.cc connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); connection_ 765 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(id, data, offset, fin, NULL); connection_ 768 net/quic/quic_connection_test.cc QuicConnectionPeer::GetPacketCreator(&connection_)->sequence_number(); connection_ 777 net/quic/quic_connection_test.cc connection_.SendAck(); connection_ 844 net/quic/quic_connection_test.cc connection_.SetReceiveAlgorithm(receive_algorithm_); connection_ 861 net/quic/quic_connection_test.cc QuicConnectionPeer::GetSentEntropyHash(&connection_, largest_observed); connection_ 876 net/quic/quic_connection_test.cc QuicConnectionPeer::GetSentEntropyHash(&connection_, missing); connection_ 879 net/quic/quic_connection_test.cc QuicConnectionPeer::GetSentEntropyHash(&connection_, missing - 1); connection_ 888 net/quic/quic_connection_test.cc QuicConnectionPeer::GetSentEntropyHash(&connection_, arrived); connection_ 891 net/quic/quic_connection_test.cc QuicConnectionPeer::GetSentEntropyHash(&connection_, arrived - 1); connection_ 903 net/quic/quic_connection_test.cc QuicConnectionPeer::GetConnectionClosePacket(&connection_) == NULL); connection_ 923 net/quic/quic_connection_test.cc TestConnection connection_; connection_ 1043 net/quic/quic_connection_test.cc QuicConnectionPeer::GetConnectionClosePacket(&connection_) == NULL); connection_ 1073 net/quic/quic_connection_test.cc QuicConnectionPeer::GetReceivedPacketManager(&connection_); connection_ 1099 net/quic/quic_connection_test.cc QuicConnectionPeer::SendAck(&connection_); connection_ 1140 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); connection_ 1171 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 3, !kFin, NULL); connection_ 1183 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 3, !kFin, NULL); connection_ 1293 net/quic/quic_connection_test.cc connection_.options()->send_sequence_number_length); connection_ 1303 net/quic/quic_connection_test.cc connection_.options()->send_sequence_number_length); connection_ 1315 net/quic/quic_connection_test.cc connection_.options()->send_sequence_number_length); connection_ 1325 net/quic/quic_connection_test.cc connection_.options()->send_sequence_number_length); connection_ 1335 net/quic/quic_connection_test.cc connection_.options()->send_sequence_number_length); connection_ 1345 net/quic/quic_connection_test.cc connection_.options()->send_sequence_number_length); connection_ 1349 net/quic/quic_connection_test.cc QuicConnectionPeer::GetPacketCreator(&connection_)->set_sequence_number(100); connection_ 1353 net/quic/quic_connection_test.cc connection_.options()->send_sequence_number_length); connection_ 1357 net/quic/quic_connection_test.cc QuicConnectionPeer::GetPacketCreator(&connection_)->set_sequence_number( connection_ 1362 net/quic/quic_connection_test.cc connection_.options()->send_sequence_number_length); connection_ 1366 net/quic/quic_connection_test.cc QuicConnectionPeer::GetPacketCreator(&connection_)->set_sequence_number( connection_ 1371 net/quic/quic_connection_test.cc connection_.options()->send_sequence_number_length); connection_ 1375 net/quic/quic_connection_test.cc QuicConnectionPeer::GetPacketCreator(&connection_)->set_sequence_number( connection_ 1380 net/quic/quic_connection_test.cc connection_.options()->send_sequence_number_length); connection_ 1444 net/quic/quic_connection_test.cc connection_.options()->max_packet_length = connection_ 1446 net/quic/quic_connection_test.cc connection_.version(), kIncludeVersion, PACKET_1BYTE_SEQUENCE_NUMBER, connection_ 1449 net/quic/quic_connection_test.cc connection_.options()->max_packets_per_fec_group = 2; connection_ 1455 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(1, payload, 0, !kFin, NULL); connection_ 1466 net/quic/quic_connection_test.cc connection_.options()->max_packet_length = connection_ 1468 net/quic/quic_connection_test.cc connection_.version(), kIncludeVersion, PACKET_1BYTE_SEQUENCE_NUMBER, connection_ 1471 net/quic/quic_connection_test.cc connection_.options()->max_packets_per_fec_group = 2; connection_ 1473 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 1476 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(1, payload, 0, !kFin, NULL); connection_ 1479 net/quic/quic_connection_test.cc EXPECT_EQ(2u, connection_.NumQueuedPackets()); connection_ 1486 net/quic/quic_connection_test.cc connection_.options()->max_packets_per_fec_group = 1; connection_ 1489 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); connection_ 1499 net/quic/quic_connection_test.cc connection_.OnRetransmissionTimeout(); connection_ 1507 net/quic/quic_connection_test.cc connection_.options()->max_packets_per_fec_group = 1; connection_ 1511 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); connection_ 1513 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 3, !kFin, NULL); connection_ 1514 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 6, !kFin, NULL); connection_ 1531 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->Fire(); connection_ 1539 net/quic/quic_connection_test.cc connection_.options()->max_packets_per_fec_group = 1; connection_ 1543 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); connection_ 1545 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 3, !kFin, NULL); connection_ 1548 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 6, !kFin, NULL); connection_ 1571 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->Fire(); connection_ 1574 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetRetransmissionAlarm()->IsSet()); connection_ 1579 net/quic/quic_connection_test.cc connection_.GetSendAlarm()->Set( connection_ 1583 net/quic/quic_connection_test.cc connection_.SendAck(); connection_ 1585 net/quic/quic_connection_test.cc IgnoreResult(InvokeWithoutArgs(&connection_, connection_ 1587 net/quic/quic_connection_test.cc IgnoreResult(InvokeWithoutArgs(&connection_, connection_ 1592 net/quic/quic_connection_test.cc connection_.GetSendAlarm()->Fire(); connection_ 1593 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 1594 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.HasQueuedData()); connection_ 1612 net/quic/quic_connection_test.cc connection_.GetSendAlarm()->Set( connection_ 1617 net/quic/quic_connection_test.cc connection_.SendAck(); connection_ 1619 net/quic/quic_connection_test.cc IgnoreResult(InvokeWithoutArgs(&connection_, connection_ 1621 net/quic/quic_connection_test.cc IgnoreResult(InvokeWithoutArgs(&connection_, connection_ 1626 net/quic/quic_connection_test.cc connection_.GetSendAlarm()->Fire(); connection_ 1627 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 1628 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.HasQueuedData()); connection_ 1638 net/quic/quic_connection_test.cc connection_.GetSendAlarm()->Set( connection_ 1643 net/quic/quic_connection_test.cc connection_.SendAck(); connection_ 1645 net/quic/quic_connection_test.cc IgnoreResult(InvokeWithoutArgs(&connection_, connection_ 1647 net/quic/quic_connection_test.cc IgnoreResult(InvokeWithoutArgs(&connection_, connection_ 1652 net/quic/quic_connection_test.cc connection_.GetSendAlarm()->Fire(); connection_ 1653 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 1654 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.HasQueuedData()); connection_ 1667 net/quic/quic_connection_test.cc connection_.options()->max_packets_per_fec_group = 6; connection_ 1669 net/quic/quic_connection_test.cc connection_.GetSendAlarm()->Set( connection_ 1673 net/quic/quic_connection_test.cc connection_.SendAck(); connection_ 1675 net/quic/quic_connection_test.cc IgnoreResult(InvokeWithoutArgs(&connection_, connection_ 1677 net/quic/quic_connection_test.cc IgnoreResult(InvokeWithoutArgs(&connection_, connection_ 1682 net/quic/quic_connection_test.cc connection_.GetSendAlarm()->Fire(); connection_ 1683 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 1684 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.HasQueuedData()); connection_ 1698 net/quic/quic_connection_test.cc IgnoreResult(InvokeWithoutArgs(&connection_, connection_ 1700 net/quic/quic_connection_test.cc IgnoreResult(InvokeWithoutArgs(&connection_, connection_ 1710 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 1711 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.HasQueuedData()); connection_ 1736 net/quic/quic_connection_test.cc connection_.SendStreamData(1, data_iov, 0, !kFin, NULL); connection_ 1738 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 1739 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.HasQueuedData()); connection_ 1761 net/quic/quic_connection_test.cc connection_.SendStreamData(1, data_iov, 0, !kFin, NULL); connection_ 1763 net/quic/quic_connection_test.cc EXPECT_EQ(1u, connection_.NumQueuedPackets()); connection_ 1764 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.HasQueuedData()); connection_ 1768 net/quic/quic_connection_test.cc connection_.OnCanWrite(); connection_ 1769 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 1781 net/quic/quic_connection_test.cc connection_.SendStreamData(1, empty_iov, 0, kFin, NULL); connection_ 1783 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 1784 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.HasQueuedData()); connection_ 1796 net/quic/quic_connection_test.cc IgnoreResult(InvokeWithoutArgs(&connection_, connection_ 1798 net/quic/quic_connection_test.cc IgnoreResult(InvokeWithoutArgs(&connection_, connection_ 1805 net/quic/quic_connection_test.cc connection_.OnCanWrite(); connection_ 1871 net/quic/quic_connection_test.cc EXPECT_EQ(1u, connection_.NumQueuedPackets()); connection_ 1886 net/quic/quic_connection_test.cc connection_.OnCanWrite(); connection_ 1888 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 1898 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); connection_ 1918 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", i * 3, !kFin, NULL); connection_ 1926 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->Fire(); connection_ 1927 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.HasQueuedData()); connection_ 1936 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->Fire(); connection_ 1937 net/quic/quic_connection_test.cc connection_.OnCanWrite(); connection_ 1943 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(1, "foo", 0, !kFin, NULL); connection_ 1944 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetRetransmissionAlarm()->IsSet()); connection_ 1947 net/quic/quic_connection_test.cc connection_.OnPacketSent(WriteResult(WRITE_STATUS_OK, 0)); connection_ 1948 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.GetRetransmissionAlarm()->IsSet()); connection_ 1955 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(1, "foo", 0, !kFin, NULL); connection_ 1956 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetRetransmissionAlarm()->IsSet()); connection_ 1964 net/quic/quic_connection_test.cc connection_.OnPacketSent(WriteResult(WRITE_STATUS_OK, 0)); connection_ 1965 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetRetransmissionAlarm()->IsSet()); connection_ 1970 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); connection_ 1971 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.GetRetransmissionAlarm()->IsSet()); connection_ 1978 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->Fire(); connection_ 1986 net/quic/quic_connection_test.cc connection_.OnPacketSent(WriteResult(WRITE_STATUS_OK, 0)); connection_ 1989 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetRetransmissionAlarm()->IsSet()); connection_ 1995 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); connection_ 2001 net/quic/quic_connection_test.cc connection_.GetResumeWritesAlarm()->Set(clock_.ApproximateNow()); connection_ 2002 net/quic/quic_connection_test.cc connection_.GetSendAlarm()->Set(clock_.ApproximateNow()); connection_ 2003 net/quic/quic_connection_test.cc connection_.GetResumeWritesAlarm()->Fire(); connection_ 2004 net/quic/quic_connection_test.cc connection_.GetSendAlarm()->Fire(); connection_ 2139 net/quic/quic_connection_test.cc EXPECT_EQ(0u, QuicConnectionPeer::ReceivedEntropyHash(&connection_, 2)); connection_ 2152 net/quic/quic_connection_test.cc EXPECT_NE(0u, QuicConnectionPeer::ReceivedEntropyHash(&connection_, 2)); connection_ 2166 net/quic/quic_connection_test.cc EXPECT_EQ(0u, QuicConnectionPeer::ReceivedEntropyHash(&connection_, 2)); connection_ 2167 net/quic/quic_connection_test.cc EXPECT_NE(0u, QuicConnectionPeer::ReceivedEntropyHash(&connection_, 4)); connection_ 2181 net/quic/quic_connection_test.cc EXPECT_EQ(0u, QuicConnectionPeer::ReceivedEntropyHash(&connection_, 2)); connection_ 2197 net/quic/quic_connection_test.cc EXPECT_EQ(0u, QuicConnectionPeer::ReceivedEntropyHash(&connection_, 2)); connection_ 2198 net/quic/quic_connection_test.cc EXPECT_NE(0u, QuicConnectionPeer::ReceivedEntropyHash(&connection_, 3)); connection_ 2209 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->deadline()); connection_ 2214 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->Fire(); connection_ 2227 net/quic/quic_connection_test.cc connection_.SetEncrypter(ENCRYPTION_NONE, new TaggingEncrypter(0x01)); connection_ 2231 net/quic/quic_connection_test.cc connection_.SetEncrypter(ENCRYPTION_INITIAL, new TaggingEncrypter(0x02)); connection_ 2232 net/quic/quic_connection_test.cc connection_.SetDefaultEncryptionLevel(ENCRYPTION_INITIAL); connection_ 2237 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->deadline()); connection_ 2247 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->Fire(); connection_ 2260 net/quic/quic_connection_test.cc connection_.SetEncrypter(ENCRYPTION_NONE, new TaggingEncrypter(0x01)); connection_ 2267 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(1, "foo", 0, !kFin, NULL); connection_ 2269 net/quic/quic_connection_test.cc EXPECT_EQ(1u, connection_.NumQueuedPackets()); connection_ 2272 net/quic/quic_connection_test.cc connection_.SetEncrypter(ENCRYPTION_INITIAL, new TaggingEncrypter(0x02)); connection_ 2273 net/quic/quic_connection_test.cc connection_.SetDefaultEncryptionLevel(ENCRYPTION_INITIAL); connection_ 2278 net/quic/quic_connection_test.cc connection_.OnCanWrite(); connection_ 2279 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 2288 net/quic/quic_connection_test.cc connection_.SetEncrypter(ENCRYPTION_NONE, new TaggingEncrypter(0x01)); connection_ 2292 net/quic/quic_connection_test.cc connection_.SetEncrypter(ENCRYPTION_FORWARD_SECURE, connection_ 2294 net/quic/quic_connection_test.cc connection_.SetDefaultEncryptionLevel(ENCRYPTION_FORWARD_SECURE); connection_ 2303 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->deadline()); connection_ 2306 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->Fire(); connection_ 2311 net/quic/quic_connection_test.cc connection_.SetEncrypter(ENCRYPTION_NONE, new TaggingEncrypter(0x01)); connection_ 2312 net/quic/quic_connection_test.cc connection_.SetDefaultEncryptionLevel(ENCRYPTION_NONE); connection_ 2316 net/quic/quic_connection_test.cc connection_.SetEncrypter(ENCRYPTION_INITIAL, new TaggingEncrypter(0x02)); connection_ 2317 net/quic/quic_connection_test.cc connection_.SetDefaultEncryptionLevel(ENCRYPTION_INITIAL); connection_ 2324 net/quic/quic_connection_test.cc connection_.RetransmitUnackedPackets(INITIAL_ENCRYPTION_ONLY); connection_ 2341 net/quic/quic_connection_test.cc connection_.SetDecrypter(new StrictTaggingDecrypter(tag)); connection_ 2342 net/quic/quic_connection_test.cc connection_.SetDefaultEncryptionLevel(ENCRYPTION_INITIAL); connection_ 2343 net/quic/quic_connection_test.cc connection_.SetEncrypter(ENCRYPTION_INITIAL, new TaggingEncrypter(tag)); connection_ 2359 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "first_packet", 0, !kFin, NULL); connection_ 2363 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "second_packet", 12, !kFin, NULL); connection_ 2375 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->Fire(); connection_ 2387 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->Fire(); connection_ 2395 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); connection_ 2398 net/quic/quic_connection_test.cc &connection_, original_sequence_number)); connection_ 2400 net/quic/quic_connection_test.cc &connection_, original_sequence_number)); connection_ 2407 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->Fire(); connection_ 2409 net/quic/quic_connection_test.cc &connection_, original_sequence_number)); connection_ 2411 net/quic/quic_connection_test.cc &connection_, rto_sequence_number)); connection_ 2413 net/quic/quic_connection_test.cc &connection_, rto_sequence_number)); connection_ 2438 net/quic/quic_connection_test.cc &connection_, rto_sequence_number)); connection_ 2440 net/quic/quic_connection_test.cc &connection_, nack_sequence_number)); connection_ 2442 net/quic/quic_connection_test.cc &connection_, nack_sequence_number)); connection_ 2447 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(1, "foo", 0, !kFin, NULL); connection_ 2449 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetRetransmissionAlarm()->IsSet()); connection_ 2453 net/quic/quic_connection_test.cc connection_.OnCanWrite(); connection_ 2454 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.GetRetransmissionAlarm()->IsSet()); connection_ 2461 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(2, "foo", 0, !kFin, NULL); connection_ 2462 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "bar", 0, !kFin, NULL); connection_ 2463 net/quic/quic_connection_test.cc QuicAlarm* retransmission_alarm = connection_.GetRetransmissionAlarm(); connection_ 2487 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->Fire(); connection_ 2494 net/quic/quic_connection_test.cc connection_.sent_packet_manager().GetRetransmissionTime(); connection_ 2499 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 2501 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(1, "foo", 0, !kFin, NULL); connection_ 2502 net/quic/quic_connection_test.cc EXPECT_EQ(1u, connection_.NumQueuedPackets()); connection_ 2506 net/quic/quic_connection_test.cc connection_.OnCanWrite(); connection_ 2507 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 2516 net/quic/quic_connection_test.cc ASSERT_EQ(1u, connection_.NumFecGroups()); connection_ 2527 net/quic/quic_connection_test.cc ASSERT_EQ(0u, connection_.NumFecGroups()); connection_ 2566 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.connected()); connection_ 2572 net/quic/quic_connection_test.cc EXPECT_EQ(default_timeout, connection_.GetTimeoutAlarm()->deadline()); connection_ 2577 net/quic/quic_connection_test.cc connection_.GetTimeoutAlarm()->Fire(); connection_ 2578 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetTimeoutAlarm()->IsSet()); connection_ 2579 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.connected()); connection_ 2581 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); connection_ 2582 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetResumeWritesAlarm()->IsSet()); connection_ 2583 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetRetransmissionAlarm()->IsSet()); connection_ 2584 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetSendAlarm()->IsSet()); connection_ 2585 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetTimeoutAlarm()->IsSet()); connection_ 2589 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.connected()); connection_ 2600 net/quic/quic_connection_test.cc EXPECT_EQ(default_timeout, connection_.GetTimeoutAlarm()->deadline()); connection_ 2607 net/quic/quic_connection_test.cc connection_.GetTimeoutAlarm()->Fire(); connection_ 2608 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.GetTimeoutAlarm()->IsSet()); connection_ 2609 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.connected()); connection_ 2611 net/quic/quic_connection_test.cc connection_.GetTimeoutAlarm()->deadline()); connection_ 2619 net/quic/quic_connection_test.cc connection_.GetTimeoutAlarm()->Fire(); connection_ 2620 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetTimeoutAlarm()->IsSet()); connection_ 2621 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.connected()); connection_ 2631 net/quic/quic_connection_test.cc connection_.SendPacket( connection_ 2633 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 2643 net/quic/quic_connection_test.cc connection_.SendPacket( connection_ 2645 net/quic/quic_connection_test.cc EXPECT_EQ(1u, connection_.NumQueuedPackets()); connection_ 2655 net/quic/quic_connection_test.cc connection_.SendPacket( connection_ 2657 net/quic/quic_connection_test.cc EXPECT_EQ(1u, connection_.NumQueuedPackets()); connection_ 2666 net/quic/quic_connection_test.cc connection_.SendPacket( connection_ 2668 net/quic/quic_connection_test.cc EXPECT_EQ(1u, connection_.NumQueuedPackets()); connection_ 2677 net/quic/quic_connection_test.cc connection_.GetSendAlarm()->Fire(); connection_ 2678 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 2685 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); connection_ 2686 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 2695 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->Fire(); connection_ 2696 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 2707 net/quic/quic_connection_test.cc connection_.GetSendAlarm()->Fire(); connection_ 2708 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 2716 net/quic/quic_connection_test.cc connection_.SendPacket( connection_ 2718 net/quic/quic_connection_test.cc EXPECT_EQ(1u, connection_.NumQueuedPackets()); connection_ 2722 net/quic/quic_connection_test.cc connection_.SendPacket( connection_ 2724 net/quic/quic_connection_test.cc EXPECT_EQ(2u, connection_.NumQueuedPackets()); connection_ 2733 net/quic/quic_connection_test.cc connection_.SendPacket( connection_ 2735 net/quic/quic_connection_test.cc EXPECT_EQ(1u, connection_.NumQueuedPackets()); connection_ 2747 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 2749 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetSendAlarm()->IsSet()); connection_ 2758 net/quic/quic_connection_test.cc connection_.SendPacket( connection_ 2760 net/quic/quic_connection_test.cc EXPECT_EQ(1u, connection_.NumQueuedPackets()); connection_ 2770 net/quic/quic_connection_test.cc EXPECT_EQ(1u, connection_.NumQueuedPackets()); connection_ 2780 net/quic/quic_connection_test.cc connection_.SendPacket( connection_ 2782 net/quic/quic_connection_test.cc EXPECT_EQ(1u, connection_.NumQueuedPackets()); connection_ 2786 net/quic/quic_connection_test.cc connection_.OnCanWrite(); connection_ 2787 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 2793 net/quic/quic_connection_test.cc connection_.options()->max_packet_length = connection_ 2795 net/quic/quic_connection_test.cc connection_.version(), kIncludeVersion, PACKET_1BYTE_SEQUENCE_NUMBER, connection_ 2804 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, payload, 0, connection_ 2806 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 2812 net/quic/quic_connection_test.cc connection_.options()->max_packet_length = connection_ 2814 net/quic/quic_connection_test.cc connection_.version(), kIncludeVersion, PACKET_1BYTE_SEQUENCE_NUMBER, connection_ 2822 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(1, payload, 0, connection_ 2829 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); connection_ 2834 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.GetAckAlarm()->IsSet()); connection_ 2835 net/quic/quic_connection_test.cc EXPECT_EQ(ack_time, connection_.GetAckAlarm()->deadline()); connection_ 2837 net/quic/quic_connection_test.cc connection_.GetAckAlarm()->Fire(); connection_ 2846 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); connection_ 2852 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); connection_ 2856 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.GetAckAlarm()->IsSet()); connection_ 2857 net/quic/quic_connection_test.cc EXPECT_EQ(ack_time, connection_.GetAckAlarm()->deadline()); connection_ 2859 net/quic/quic_connection_test.cc connection_.GetAckAlarm()->Fire(); connection_ 2868 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); connection_ 2883 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); connection_ 2909 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.GetAckAlarm()->IsSet()); connection_ 2915 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(kStreamId3, "foo", 0, !kFin, NULL); connection_ 2925 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); connection_ 2931 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(kCryptoStreamId, "foo", 0, !kFin, NULL); connection_ 2935 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); connection_ 2940 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(kStreamId3, "foo", 0, !kFin, NULL); connection_ 2941 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(kStreamId3, "foo", 3, !kFin, NULL); connection_ 2970 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); connection_ 2980 net/quic/quic_connection_test.cc &connection_, connection_ 2994 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); connection_ 3007 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.connected()); connection_ 3009 net/quic/quic_connection_test.cc connection_.CloseConnection(QUIC_PEER_GOING_AWAY, false); connection_ 3010 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.connected()); connection_ 3013 net/quic/quic_connection_test.cc connection_.SendPacket( connection_ 3026 net/quic/quic_connection_test.cc connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *packet); connection_ 3069 net/quic/quic_connection_test.cc connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), encrypted); connection_ 3191 net/quic/quic_connection_test.cc &connection_, i)); connection_ 3208 net/quic/quic_connection_test.cc connection_.SendPacket( connection_ 3220 net/quic/quic_connection_test.cc &connection_, max_sequence_number, missing_packets, entropy_hash)) connection_ 3225 net/quic/quic_connection_test.cc connection_.SetSupportedVersions(QuicSupportedVersions()); connection_ 3246 net/quic/quic_connection_test.cc connection_.set_is_server(true); connection_ 3247 net/quic/quic_connection_test.cc connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); connection_ 3263 net/quic/quic_connection_test.cc connection_.SetSupportedVersions(QuicSupportedVersions()); connection_ 3284 net/quic/quic_connection_test.cc connection_.set_is_server(true); connection_ 3286 net/quic/quic_connection_test.cc connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); connection_ 3288 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.HasQueuedData()); connection_ 3291 net/quic/quic_connection_test.cc connection_.OnCanWrite(); connection_ 3308 net/quic/quic_connection_test.cc connection_.SetSupportedVersions(QuicSupportedVersions()); connection_ 3329 net/quic/quic_connection_test.cc connection_.set_is_server(true); connection_ 3332 net/quic/quic_connection_test.cc connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); connection_ 3334 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.HasQueuedData()); connection_ 3339 net/quic/quic_connection_test.cc QuicConnectionPeer::GetFramer(&connection_)->set_version_for_tests( connection_ 3360 net/quic/quic_connection_test.cc connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); connection_ 3373 net/quic/quic_connection_test.cc connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); connection_ 3376 net/quic/quic_connection_test.cc QuicConnectionPeer::GetPacketCreator(&connection_))); connection_ 3402 net/quic/quic_connection_test.cc connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); connection_ 3407 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "first", 0, !kFin, NULL); connection_ 3412 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(5, "second", 0, !kFin, NULL); connection_ 3422 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->Fire(); connection_ 3443 net/quic/quic_connection_test.cc const QuicConnectionStats& stats = connection_.GetStats(); connection_ 3469 net/quic/quic_connection_test.cc const QuicConnectionStats& stats = connection_.GetStats(); connection_ 3479 net/quic/quic_connection_test.cc ASSERT_TRUE(QuicConnectionPeer::GetFecGroup(&connection_, 1) != NULL); connection_ 3482 net/quic/quic_connection_test.cc ASSERT_TRUE(QuicConnectionPeer::GetFecGroup(&connection_, 2) != NULL); connection_ 3485 net/quic/quic_connection_test.cc ASSERT_TRUE(QuicConnectionPeer::GetFecGroup(&connection_, 4) != NULL); connection_ 3486 net/quic/quic_connection_test.cc ASSERT_TRUE(QuicConnectionPeer::GetFecGroup(&connection_, 1) == NULL); connection_ 3487 net/quic/quic_connection_test.cc ASSERT_TRUE(QuicConnectionPeer::GetFecGroup(&connection_, 2) != NULL); connection_ 3490 net/quic/quic_connection_test.cc ASSERT_TRUE(QuicConnectionPeer::GetFecGroup(&connection_, 3) != NULL); connection_ 3491 net/quic/quic_connection_test.cc ASSERT_TRUE(QuicConnectionPeer::GetFecGroup(&connection_, 2) == NULL); connection_ 3494 net/quic/quic_connection_test.cc ASSERT_TRUE(QuicConnectionPeer::GetFecGroup(&connection_, 5) != NULL); connection_ 3495 net/quic/quic_connection_test.cc ASSERT_TRUE(QuicConnectionPeer::GetFecGroup(&connection_, 4) != NULL); connection_ 3496 net/quic/quic_connection_test.cc ASSERT_TRUE(QuicConnectionPeer::GetFecGroup(&connection_, 3) == NULL); connection_ 3527 net/quic/quic_connection_test.cc connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); connection_ 3558 net/quic/quic_connection_test.cc connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted); connection_ 3562 net/quic/quic_connection_test.cc connection_.SetSupportedVersions(QuicSupportedVersions()); connection_ 3564 net/quic/quic_connection_test.cc connection_.set_version(QuicVersionMin()); connection_ 3565 net/quic/quic_connection_test.cc EXPECT_EQ(QuicVersionMin(), connection_.version()); connection_ 3573 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.SelectMutualVersion(supported_versions)); connection_ 3574 net/quic/quic_connection_test.cc EXPECT_EQ(QuicVersionMax(), connection_.version()); connection_ 3582 net/quic/quic_connection_test.cc EXPECT_TRUE(connection_.SelectMutualVersion(lowest_version_vector)); connection_ 3583 net/quic/quic_connection_test.cc EXPECT_EQ(QuicVersionMin(), connection_.version()); connection_ 3588 net/quic/quic_connection_test.cc EXPECT_FALSE(connection_.SelectMutualVersion(unsupported_version)); connection_ 3595 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(1, "foo", 0, !kFin, NULL); connection_ 3596 net/quic/quic_connection_test.cc EXPECT_EQ(0u, connection_.NumQueuedPackets()); connection_ 3612 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(1, "foo", 0, !kFin, NULL); connection_ 3613 net/quic/quic_connection_test.cc EXPECT_EQ(1u, connection_.NumQueuedPackets()); connection_ 3628 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(1, "foo", 0, !kFin, delegate.get()); connection_ 3649 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(1, "foo", 0, !kFin, delegate.get()); connection_ 3652 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(1, "foo", 0, !kFin, NULL); connection_ 3653 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(1, "bar", 0, !kFin, NULL); connection_ 3676 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); connection_ 3677 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "bar", 0, !kFin, delegate.get()); connection_ 3678 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "baz", 0, !kFin, NULL); connection_ 3679 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "qux", 0, !kFin, NULL); connection_ 3717 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 0, !kFin, delegate.get()); connection_ 3722 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->deadline()); connection_ 3727 net/quic/quic_connection_test.cc connection_.GetRetransmissionAlarm()->Fire(); connection_ 3757 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); connection_ 3758 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "bar", 0, !kFin, delegate.get()); connection_ 3759 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "baz", 0, !kFin, NULL); connection_ 3760 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(3, "qux", 0, !kFin, NULL); connection_ 3815 net/quic/quic_connection_test.cc connection_.SendStreamDataWithString(1, "foo", 0, !kFin, delegate.get()); connection_ 3906 net/quic/quic_connection_test.cc connection_.set_debug_visitor(debug_visitor.get()); connection_ 3908 net/quic/quic_connection_test.cc connection_.OnPacketHeader(header); connection_ 3938 net/quic/quic_connection_test.cc QuicAlarm* ack_alarm = QuicConnectionPeer::GetAckAlarm(&connection_); connection_ 30 net/quic/quic_crypto_client_stream_test.cc : connection_(new PacketSavingConnection(false)), connection_ 31 net/quic/quic_crypto_client_stream_test.cc session_(new TestClientSession(connection_, DefaultQuicConfig())), connection_ 42 net/quic/quic_crypto_client_stream_test.cc CryptoTestUtils::HandshakeWithFakeServer(connection_, stream_.get()); connection_ 50 net/quic/quic_crypto_client_stream_test.cc PacketSavingConnection* connection_; connection_ 73 net/quic/quic_crypto_client_stream_test.cc EXPECT_CALL(*connection_, SendConnectionClose( connection_ 86 net/quic/quic_crypto_client_stream_test.cc EXPECT_CALL(*connection_, SendConnectionCloseWithDetails( connection_ 124 net/quic/quic_crypto_client_stream_test.cc connection_ = new PacketSavingConnection(true); connection_ 125 net/quic/quic_crypto_client_stream_test.cc session_.reset(new TestClientSession(connection_, DefaultQuicConfig())); connection_ 134 net/quic/quic_crypto_client_stream_test.cc reinterpret_cast<MockClock*>(const_cast<QuicClock*>(connection_->clock())) connection_ 140 net/quic/quic_crypto_client_stream_test.cc ASSERT_EQ(1u, connection_->packets_.size()); connection_ 58 net/quic/quic_crypto_server_stream_test.cc : connection_(new PacketSavingConnection(true)), connection_ 59 net/quic/quic_crypto_server_stream_test.cc session_(connection_, DefaultQuicConfig()), connection_ 69 net/quic/quic_crypto_server_stream_test.cc connection_->AdvanceTime(QuicTime::Delta::FromSeconds(100000)); connection_ 75 net/quic/quic_crypto_server_stream_test.cc connection_->clock(), connection_->random_generator(), connection_ 83 net/quic/quic_crypto_server_stream_test.cc static_cast<uint32>(connection_->clock()->WallNow().ToUNIXSeconds()), connection_ 102 net/quic/quic_crypto_server_stream_test.cc return CryptoTestUtils::HandshakeWithFakeClient(connection_, &stream_, connection_ 107 net/quic/quic_crypto_server_stream_test.cc PacketSavingConnection* connection_; connection_ 229 net/quic/quic_crypto_server_stream_test.cc EXPECT_CALL(*connection_, SendConnectionClose( connection_ 239 net/quic/quic_crypto_server_stream_test.cc EXPECT_CALL(*connection_, SendConnectionClose( connection_ 50 net/quic/quic_crypto_stream_test.cc : connection_(new MockConnection(false)), connection_ 51 net/quic/quic_crypto_stream_test.cc session_(connection_), connection_ 65 net/quic/quic_crypto_stream_test.cc MockConnection* connection_; connection_ 100 net/quic/quic_crypto_stream_test.cc EXPECT_CALL(*connection_, connection_ 95 net/quic/quic_data_stream_test.cc connection_ = new testing::StrictMock<MockConnection>( connection_ 97 net/quic/quic_data_stream_test.cc session_.reset(new testing::StrictMock<MockSession>(connection_)); connection_ 107 net/quic/quic_data_stream_test.cc MockConnection* connection_; connection_ 303 net/quic/quic_data_stream_test.cc EXPECT_CALL(*connection_, SendBlocked(kStreamId)); connection_ 330 net/quic/quic_data_stream_test.cc EXPECT_CALL(*connection_, SendWindowUpdate(_, _)).Times(0); connection_ 400 net/quic/quic_data_stream_test.cc *connection_, connection_ 436 net/quic/quic_data_stream_test.cc EXPECT_CALL(*connection_, SendConnectionClose(QUIC_FLOW_CONTROL_ERROR)); connection_ 461 net/quic/quic_data_stream_test.cc EXPECT_CALL(*connection_, SendBlocked(kStreamId)).Times(0); connection_ 69 net/quic/quic_default_packet_writer.cc connection_->OnPacketSent(result); connection_ 70 net/quic/quic_default_packet_writer.cc connection_->OnCanWrite(); connection_ 39 net/quic/quic_default_packet_writer.h connection_ = connection; connection_ 45 net/quic/quic_default_packet_writer.h QuicConnection* connection_; connection_ 76 net/quic/quic_headers_stream_test.cc : connection_(new StrictMock<MockConnection>(is_server(), GetVersions())), connection_ 77 net/quic/quic_headers_stream_test.cc session_(connection_), connection_ 163 net/quic/quic_headers_stream_test.cc QuicConnectionPeer::CloseConnection(connection_); connection_ 169 net/quic/quic_headers_stream_test.cc StrictMock<MockConnection>* connection_; connection_ 241 net/quic/quic_headers_stream_test.cc EXPECT_CALL(*connection_, connection_ 252 net/quic/quic_headers_stream_test.cc EXPECT_CALL(*connection_, connection_ 265 net/quic/quic_headers_stream_test.cc EXPECT_CALL(*connection_, connection_ 277 net/quic/quic_headers_stream_test.cc EXPECT_CALL(*connection_, connection_ 288 net/quic/quic_headers_stream_test.cc EXPECT_CALL(*connection_, connection_ 299 net/quic/quic_headers_stream_test.cc EXPECT_CALL(*connection_, connection_ 310 net/quic/quic_headers_stream_test.cc EXPECT_CALL(*connection_, connection_ 163 net/quic/quic_http_stream_test.cc connection_->ProcessUdpPacket(self_addr_, peer_addr_, *packet); connection_ 198 net/quic/quic_http_stream_test.cc connection_ = new TestQuicConnection(SupportedVersions(GetParam()), connection_ 201 net/quic/quic_http_stream_test.cc connection_->set_visitor(&visitor_); connection_ 202 net/quic/quic_http_stream_test.cc connection_->SetSendAlgorithm(send_algorithm_); connection_ 203 net/quic/quic_http_stream_test.cc connection_->SetReceiveAlgorithm(receive_algorithm_); connection_ 206 net/quic/quic_http_stream_test.cc new QuicClientSession(connection_, connection_ 285 net/quic/quic_http_stream_test.cc TestQuicConnection* connection_; connection_ 95 net/quic/quic_session.cc : connection_(connection), connection_ 106 net/quic/quic_session.cc connection_->set_visitor(visitor_shim_.get()); connection_ 107 net/quic/quic_session.cc connection_->SetFromConfig(config_); connection_ 108 net/quic/quic_session.cc if (connection_->connected()) { connection_ 109 net/quic/quic_session.cc connection_->SetOverallConnectionTimeout( connection_ 211 net/quic/quic_session.cc DCHECK(!connection_->connected()); connection_ 272 net/quic/quic_session.cc connection_->CloseConnection(QUIC_INTERNAL_ERROR, false); connection_ 275 net/quic/quic_session.cc if (!connection_->CanWriteStreamData()) { connection_ 305 net/quic/quic_session.cc return connection_->SendStreamData(id, data, offset, fin, connection_ 320 net/quic/quic_session.cc connection_->SendRstStream(id, error, bytes_written); connection_ 329 net/quic/quic_session.cc connection_->SendGoAway(error_code, largest_peer_created_stream_id_, reason); connection_ 366 net/quic/quic_session.cc connection_->SetFromConfig(config_); connection_ 378 net/quic/quic_session.cc connection_->SendConnectionClose(QUIC_FLOW_CONTROL_ERROR); connection_ 399 net/quic/quic_session.cc connection_->RetransmitUnackedPackets(INITIAL_ENCRYPTION_ONLY); connection_ 405 net/quic/quic_session.cc connection_->SetOverallConnectionTimeout(QuicTime::Delta::Infinite()); connection_ 576 net/quic/quic_session.cc connection_->HasQueuedData(); connection_ 165 net/quic/quic_session.h QuicConnection* connection() { return connection_.get(); } connection_ 166 net/quic/quic_session.h const QuicConnection* connection() const { return connection_.get(); } connection_ 169 net/quic/quic_session.h return connection_->peer_address(); connection_ 172 net/quic/quic_session.h return connection_->connection_id(); connection_ 200 net/quic/quic_session.h bool is_server() const { return connection_->is_server(); } connection_ 257 net/quic/quic_session.h scoped_ptr<QuicConnection> connection_; connection_ 163 net/quic/quic_session_test.cc : connection_(new MockConnection(true, SupportedVersions(GetParam()))), connection_ 164 net/quic/quic_session_test.cc session_(connection_) { connection_ 209 net/quic/quic_session_test.cc QuicVersion version() const { return connection_->version(); } connection_ 211 net/quic/quic_session_test.cc MockConnection* connection_; connection_ 284 net/quic/quic_session_test.cc EXPECT_CALL(*connection_, SendConnectionClose(QUIC_INVALID_STREAM_ID)); connection_ 298 net/quic/quic_session_test.cc EXPECT_CALL(*connection_, connection_ 461 net/quic/quic_session_test.cc EXPECT_CALL(*connection_, connection_ 466 net/quic/quic_session_test.cc EXPECT_CALL(*connection_, connection_ 472 net/quic/quic_session_test.cc EXPECT_CALL(*connection_, connection_ 481 net/quic/quic_session_test.cc QuicConnectionPeer::GetNetworkTimeout(connection_).ToSeconds()); connection_ 485 net/quic/quic_session_test.cc QuicConnectionPeer::GetNetworkTimeout(connection_).ToSeconds()); connection_ 517 net/quic/quic_session_test.cc EXPECT_CALL(*connection_, SendConnectionClose(QUIC_INVALID_STREAM_ID)) connection_ 522 net/quic/quic_session_test.cc QuicConnectionPeer::CloseConnection(connection_); connection_ 576 net/quic/quic_session_test.cc EXPECT_CALL(*connection_, SendConnectionClose(QUIC_FLOW_CONTROL_ERROR)); connection_ 97 net/quic/quic_stream_sequencer_test.cc : connection_(new MockConnection(false)), connection_ 98 net/quic/quic_stream_sequencer_test.cc session_(connection_), connection_ 141 net/quic/quic_stream_sequencer_test.cc MockConnection* connection_; connection_ 109 net/quic/reliable_quic_stream_test.cc connection_ = new StrictMock<MockConnection>(kIsServer); connection_ 110 net/quic/reliable_quic_stream_test.cc session_.reset(new StrictMock<MockSession>(connection_)); connection_ 133 net/quic/reliable_quic_stream_test.cc MockConnection* connection_; connection_ 145 net/quic/reliable_quic_stream_test.cc connection_->options()->max_packet_length = connection_ 147 net/quic/reliable_quic_stream_test.cc connection_->version(), PACKET_8BYTE_CONNECTION_ID, !kIncludeVersion, connection_ 204 net/quic/reliable_quic_stream_test.cc connection_->options()->max_packet_length = connection_ 206 net/quic/reliable_quic_stream_test.cc connection_->version(), PACKET_8BYTE_CONNECTION_ID, !kIncludeVersion, connection_ 72 net/server/web_socket.cc connection_->Send(base::StringPrintf( connection_ 81 net/server/web_socket.cc connection_->Send(reinterpret_cast<char*>(digest.a), 16); connection_ 86 net/server/web_socket.cc const std::string& data = connection_->recv_data(); connection_ 96 net/server/web_socket.cc connection_->Shift(pos + 1); connection_ 104 net/server/web_socket.cc connection_->Send(&message_start, 1); connection_ 105 net/server/web_socket.cc connection_->Send(message); connection_ 106 net/server/web_socket.cc connection_->Send(&message_end, 1); connection_ 204 net/server/web_socket.cc connection_->Send(response); connection_ 208 net/server/web_socket.cc const std::string& frame = connection_->recv_data(); connection_ 214 net/server/web_socket.cc connection_->Shift(bytes_consumed); connection_ 224 net/server/web_socket.cc connection_->Send(data); connection_ 403 net/server/web_socket.cc WebSocket::WebSocket(HttpConnection* connection) : connection_(connection) { connection_ 45 net/server/web_socket.h HttpConnection* connection_; connection_ 64 net/socket/deterministic_socket_data_unittest.cc ClientSocketHandle connection_; connection_ 98 net/socket/deterministic_socket_data_unittest.cc connection_.Init(endpoint_.ToString(), connection_ 104 net/socket/deterministic_socket_data_unittest.cc sock_ = connection_.socket(); connection_ 120 net/socket/tcp_listen_socket_unittest.cc connection_.reset(); connection_ 138 net/socket/tcp_listen_socket_unittest.cc connection_->Send(kHelloWorld); connection_ 240 net/socket/tcp_listen_socket_unittest.cc connection_ = connection.Pass(); connection_ 102 net/socket/tcp_listen_socket_unittest.h scoped_ptr<StreamListenSocket> connection_; connection_ 107 net/socket/unix_domain_socket_posix_unittest.cc connection_ = connection.Pass(); connection_ 141 net/socket/unix_domain_socket_posix_unittest.cc scoped_ptr<StreamListenSocket> connection_; connection_ 102 net/socket_stream/socket_stream.cc connection_(new ClientSocketHandle), connection_ 216 net/socket_stream/socket_stream.cc if (!connection_->socket() || connection_ 217 net/socket_stream/socket_stream.cc !connection_->socket()->IsConnected() || next_state_ == STATE_NONE) { connection_ 277 net/socket_stream/socket_stream.cc if (!connection_->socket()) { connection_ 387 net/socket_stream/socket_stream.cc if (!connection_->socket() || !connection_->socket()->IsConnected()) { connection_ 750 net/socket_stream/socket_stream.cc connection_->SetSocket( connection_ 755 net/socket_stream/socket_stream.cc return connection_->socket()->Connect(io_callback_); connection_ 840 net/socket_stream/socket_stream.cc return connection_->socket()->Write( connection_ 884 net/socket_stream/socket_stream.cc return connection_->socket()->Read( connection_ 981 net/socket_stream/socket_stream.cc s.reset(new SOCKS5ClientSocket(connection_.Pass(), req_info)); connection_ 983 net/socket_stream/socket_stream.cc s.reset(new SOCKSClientSocket(connection_.Pass(), connection_ 988 net/socket_stream/socket_stream.cc connection_.reset(new ClientSocketHandle); connection_ 989 net/socket_stream/socket_stream.cc connection_->SetSocket(s.Pass()); connection_ 991 net/socket_stream/socket_stream.cc return connection_->socket()->Connect(io_callback_); connection_ 1015 net/socket_stream/socket_stream.cc connection_.Pass(), connection_ 1019 net/socket_stream/socket_stream.cc connection_.reset(new ClientSocketHandle); connection_ 1020 net/socket_stream/socket_stream.cc connection_->SetSocket(socket.Pass()); connection_ 1023 net/socket_stream/socket_stream.cc return connection_->socket()->Connect(io_callback_); connection_ 1055 net/socket_stream/socket_stream.cc if (!connection_->socket()->IsConnectedAndIdle()) connection_ 1071 net/socket_stream/socket_stream.cc factory_->CreateSSLClientSocket(connection_.Pass(), connection_ 1075 net/socket_stream/socket_stream.cc connection_.reset(new ClientSocketHandle); connection_ 1076 net/socket_stream/socket_stream.cc connection_->SetSocket(socket.Pass()); connection_ 1079 net/socket_stream/socket_stream.cc return connection_->socket()->Connect(io_callback_); connection_ 1115 net/socket_stream/socket_stream.cc if (!connection_->socket()->IsConnectedAndIdle()) connection_ 1129 net/socket_stream/socket_stream.cc if (!connection_->socket() || !connection_->socket()->IsConnected()) { connection_ 1138 net/socket_stream/socket_stream.cc connection_->socket()->Disconnect(); connection_ 1150 net/socket_stream/socket_stream.cc result = connection_->socket()->Read( connection_ 1189 net/socket_stream/socket_stream.cc result = connection_->socket()->Write( connection_ 1221 net/socket_stream/socket_stream.cc DCHECK(connection_->socket()); connection_ 1224 net/socket_stream/socket_stream.cc static_cast<SSLClientSocket*>(connection_->socket()); connection_ 1271 net/socket_stream/socket_stream.cc static_cast<SSLClientSocket*>(connection_->socket()); connection_ 1293 net/socket_stream/socket_stream.cc connection_->socket()->Disconnect(); connection_ 1294 net/socket_stream/socket_stream.cc connection_->SetSocket(scoped_ptr<StreamSocket>()); connection_ 1321 net/socket_stream/socket_stream.cc static_cast<SSLClientSocket*>(connection_->socket()); connection_ 373 net/socket_stream/socket_stream.h scoped_ptr<ClientSocketHandle> connection_; connection_ 526 net/spdy/spdy_session.cc DCHECK(connection_->socket()); connection_ 528 net/spdy/spdy_session.cc connection_->socket()->Disconnect(); connection_ 544 net/spdy/spdy_session.cc DCHECK(!connection_); connection_ 555 net/spdy/spdy_session.cc connection_ = connection.Pass(); connection_ 560 net/spdy/spdy_session.cc connection_->socket()->GetNegotiatedProtocol(); connection_ 594 net/spdy/spdy_session.cc connection_->socket()->NetLog().source().ToEventParametersCallback()); connection_ 597 net/spdy/spdy_session.cc connection_->AddHigherLayeredPool(this); connection_ 726 net/spdy/spdy_session.cc DCHECK(connection_->socket()); connection_ 727 net/spdy/spdy_session.cc DCHECK(connection_->socket()->IsConnected()); connection_ 728 net/spdy/spdy_session.cc if (connection_->socket()) { connection_ 730 net/spdy/spdy_session.cc connection_->socket()->IsConnected()); connection_ 731 net/spdy/spdy_session.cc if (!connection_->socket()->IsConnected()) { connection_ 1110 net/spdy/spdy_session.cc if (active_streams_.empty() && connection_->IsPoolStalled()) { connection_ 1230 net/spdy/spdy_session.cc CHECK(connection_); connection_ 1231 net/spdy/spdy_session.cc CHECK(connection_->socket()); connection_ 1233 net/spdy/spdy_session.cc return connection_->socket()->Read( connection_ 1405 net/spdy/spdy_session.cc return connection_->socket()->Write( connection_ 1660 net/spdy/spdy_session.cc connection_->socket()->GetNegotiatedProtocol())); connection_ 1685 net/spdy/spdy_session.cc connection_->reuse_type() == ClientSocketHandle::UNUSED_IDLE; connection_ 1690 net/spdy/spdy_session.cc return connection_->GetLoadTimingInfo(stream_id != kFirstStreamId, connection_ 1696 net/spdy/spdy_session.cc if (connection_->socket()) { connection_ 1697 net/spdy/spdy_session.cc rv = connection_->socket()->GetPeerAddress(address); connection_ 1708 net/spdy/spdy_session.cc if (connection_->socket()) { connection_ 1709 net/spdy/spdy_session.cc rv = connection_->socket()->GetLocalAddress(address); connection_ 1838 net/spdy/spdy_session.cc *was_npn_negotiated = connection_->socket()->WasNpnNegotiated(); connection_ 1839 net/spdy/spdy_session.cc *protocol_negotiated = connection_->socket()->GetNegotiatedProtocol(); connection_ 1840 net/spdy/spdy_session.cc return connection_->socket()->GetSSLInfo(ssl_info); connection_ 2859 net/spdy/spdy_session.cc reinterpret_cast<SSLClientSocket*>(connection_->socket()); connection_ 377 net/spdy/spdy_session.h return connection_->socket()->WasEverUsed(); connection_ 947 net/spdy/spdy_session.h scoped_ptr<ClientSocketHandle> connection_; connection_ 22 net/tools/flip_server/http_interface.cc connection_(connection), connection_ 60 net/tools/flip_server/http_interface.cc << connection_->server_ip_ << ":" << connection_->server_port_ connection_ 105 net/tools/flip_server/http_interface.cc connection_->InitSMConnection(connection_pool, connection_ 130 net/tools/flip_server/http_interface.cc connection_->EnqueueDataFrame(data_frame); connection_ 154 net/tools/flip_server/http_interface.cc << "to: " << connection_->server_ip_ << ":" connection_ 155 net/tools/flip_server/http_interface.cc << connection_->server_port_ << " "; connection_ 174 net/tools/flip_server/http_interface.cc connection_->Cleanup("request complete"); connection_ 299 net/tools/flip_server/http_interface.cc connection_->EnqueueDataFrame(df); connection_ 132 net/tools/flip_server/http_interface.h SMConnection* connection_; connection_ 77 net/tools/flip_server/http_interface_test.cc connection_.reset(new MockSMConnection(epoll_server_.get(), connection_ 83 net/tools/flip_server/http_interface_test.cc interface_.reset(new HttpSM(connection_.get(), connection_ 95 net/tools/flip_server/http_interface_test.cc STLDeleteElements(connection_->output_list()); connection_ 107 net/tools/flip_server/http_interface_test.cc scoped_ptr<MockSMConnection> connection_; connection_ 165 net/tools/flip_server/http_interface_test.cc EXPECT_CALL(*connection_, InitSMConnection(_, _, _, _, _, _, _, _)); connection_ 201 net/tools/flip_server/http_interface_test.cc ASSERT_EQ(1u, connection_->output_list()->size()); connection_ 202 net/tools/flip_server/http_interface_test.cc std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); connection_ 205 net/tools/flip_server/http_interface_test.cc ASSERT_EQ(connection_->output_list()->end(), i); connection_ 278 net/tools/flip_server/http_interface_test.cc ASSERT_EQ(3u, connection_->output_list()->size()); connection_ 279 net/tools/flip_server/http_interface_test.cc std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); connection_ 309 net/tools/flip_server/http_interface_test.cc ASSERT_EQ(3u, connection_->output_list()->size()); connection_ 310 net/tools/flip_server/http_interface_test.cc std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); connection_ 330 net/tools/flip_server/http_interface_test.cc ASSERT_EQ(0u, connection_->output_list()->size()); connection_ 342 net/tools/flip_server/http_interface_test.cc ASSERT_EQ(1u, connection_->output_list()->size()); connection_ 343 net/tools/flip_server/http_interface_test.cc DataFrame* df = connection_->output_list()->front(); connection_ 351 net/tools/flip_server/http_interface_test.cc ASSERT_EQ(1u, connection_->output_list()->size()); connection_ 352 net/tools/flip_server/http_interface_test.cc DataFrame* df = connection_->output_list()->front(); connection_ 390 net/tools/flip_server/http_interface_test.cc EXPECT_CALL(*connection_, Cleanup()).Times(0); connection_ 400 net/tools/flip_server/http_interface_test.cc ASSERT_EQ(1u, connection_->output_list()->size()); connection_ 401 net/tools/flip_server/http_interface_test.cc DataFrame* df = connection_->output_list()->front(); connection_ 436 net/tools/flip_server/http_interface_test.cc EXPECT_CALL(*connection_, Cleanup()).Times(0); connection_ 446 net/tools/flip_server/http_interface_test.cc ASSERT_EQ(1u, connection_->output_list()->size()); connection_ 447 net/tools/flip_server/http_interface_test.cc DataFrame* df = connection_->output_list()->front(); connection_ 474 net/tools/flip_server/http_interface_test.cc EXPECT_CALL(*connection_, Cleanup()).Times(0); connection_ 484 net/tools/flip_server/http_interface_test.cc ASSERT_EQ(1u, connection_->output_list()->size()); connection_ 485 net/tools/flip_server/http_interface_test.cc DataFrame* df = connection_->output_list()->front(); connection_ 91 net/tools/flip_server/output_ordering.cc connection_->ReadyToSend(); connection_ 43 net/tools/flip_server/output_ordering.h SMConnectionInterface* connection_; connection_ 43 net/tools/flip_server/spdy_interface.cc connection_(connection), connection_ 65 net/tools/flip_server/spdy_interface.cc connection_->InitSMConnection(connection_pool, connection_ 215 net/tools/flip_server/spdy_interface.cc connection_->client_ip() + "\r\n"; connection_ 553 net/tools/flip_server/spdy_interface.cc connection_->EnqueueDataFrame(df); connection_ 201 net/tools/flip_server/spdy_interface.h SMConnection* connection_; connection_ 140 net/tools/flip_server/spdy_interface_test.cc connection_.reset(new FakeSMConnection(epoll_server_.get(), connection_ 146 net/tools/flip_server/spdy_interface_test.cc interface_.reset(new TestSpdySM(connection_.get(), connection_ 164 net/tools/flip_server/spdy_interface_test.cc OutputList& output_list = *connection_->output_list(); connection_ 182 net/tools/flip_server/spdy_interface_test.cc scoped_ptr<FakeSMConnection> connection_; connection_ 208 net/tools/flip_server/spdy_interface_test.cc EXPECT_CALL(*connection_, InitSMConnection(_, _, _, _, _, _, _, _)); connection_ 416 net/tools/flip_server/spdy_interface_test.cc ASSERT_EQ(1u, connection_->output_list()->size()); connection_ 417 net/tools/flip_server/spdy_interface_test.cc std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); connection_ 464 net/tools/flip_server/spdy_interface_test.cc ASSERT_EQ(2u, connection_->output_list()->size()); connection_ 486 net/tools/flip_server/spdy_interface_test.cc std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); connection_ 513 net/tools/flip_server/spdy_interface_test.cc ASSERT_EQ(2u, connection_->output_list()->size()); connection_ 537 net/tools/flip_server/spdy_interface_test.cc std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); connection_ 564 net/tools/flip_server/spdy_interface_test.cc ASSERT_EQ(1u, connection_->output_list()->size()); connection_ 565 net/tools/flip_server/spdy_interface_test.cc std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); connection_ 598 net/tools/flip_server/spdy_interface_test.cc ASSERT_EQ(1u, connection_->output_list()->size()); connection_ 599 net/tools/flip_server/spdy_interface_test.cc std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); connection_ 632 net/tools/flip_server/spdy_interface_test.cc ASSERT_EQ(1u, connection_->output_list()->size()); connection_ 633 net/tools/flip_server/spdy_interface_test.cc std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); connection_ 668 net/tools/flip_server/spdy_interface_test.cc ASSERT_EQ(1u, connection_->output_list()->size()); connection_ 669 net/tools/flip_server/spdy_interface_test.cc std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); connection_ 699 net/tools/flip_server/spdy_interface_test.cc ASSERT_EQ(1u, connection_->output_list()->size()); connection_ 700 net/tools/flip_server/spdy_interface_test.cc std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); connection_ 739 net/tools/flip_server/spdy_interface_test.cc ASSERT_EQ(3u, connection_->output_list()->size()); connection_ 740 net/tools/flip_server/spdy_interface_test.cc std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); connection_ 780 net/tools/flip_server/spdy_interface_test.cc ASSERT_EQ(1u, connection_->output_list()->size()); connection_ 781 net/tools/flip_server/spdy_interface_test.cc std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); connection_ 800 net/tools/flip_server/spdy_interface_test.cc ASSERT_EQ(1u, connection_->output_list()->size()); connection_ 801 net/tools/flip_server/spdy_interface_test.cc std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); connection_ 847 net/tools/flip_server/spdy_interface_test.cc ASSERT_EQ(2u, connection_->output_list()->size()); connection_ 869 net/tools/flip_server/spdy_interface_test.cc std::list<DataFrame*>::const_iterator i = connection_->output_list()->begin(); connection_ 22 net/tools/flip_server/streamer_interface.cc : connection_(connection), connection_ 60 net/tools/flip_server/streamer_interface.cc connection_->InitSMConnection(connection_pool, connection_ 86 net/tools/flip_server/streamer_interface.cc connection_->EnqueueDataFrame(df); connection_ 104 net/tools/flip_server/streamer_interface.cc connection_->Cleanup("Server Reset"); connection_ 178 net/tools/flip_server/streamer_interface.cc connection_->client_ip()); connection_ 125 net/tools/flip_server/streamer_interface.h SMConnection* connection_; connection_ 34 net/tools/quic/quic_client_session_test.cc : connection_(new PacketSavingConnection(false, connection_ 40 net/tools/quic/quic_client_session_test.cc connection_, connection_ 48 net/tools/quic/quic_client_session_test.cc connection_, session_->GetCryptoStream()); connection_ 51 net/tools/quic/quic_client_session_test.cc PacketSavingConnection* connection_; connection_ 53 net/tools/quic/quic_server_session_test.cc connection_ = connection_ 56 net/tools/quic/quic_server_session_test.cc config_, connection_, &owner_)); connection_ 58 net/tools/quic/quic_server_session_test.cc visitor_ = QuicConnectionPeer::GetVisitor(connection_); connection_ 61 net/tools/quic/quic_server_session_test.cc QuicVersion version() const { return connection_->version(); } connection_ 64 net/tools/quic/quic_server_session_test.cc StrictMock<MockConnection>* connection_; connection_ 87 net/tools/quic/quic_server_session_test.cc EXPECT_CALL(*connection_, connection_ 106 net/tools/quic/quic_server_session_test.cc EXPECT_CALL(*connection_, connection_ 136 net/tools/quic/quic_server_session_test.cc EXPECT_CALL(*connection_, connection_ 160 net/tools/quic/quic_server_session_test.cc EXPECT_CALL(*connection_, SendConnectionClose(QUIC_TOO_MANY_OPEN_STREAMS)); connection_ 171 net/tools/quic/quic_server_session_test.cc EXPECT_CALL(*connection_, SendConnectionClose(QUIC_TOO_MANY_OPEN_STREAMS)); connection_ 178 net/tools/quic/quic_server_session_test.cc EXPECT_CALL(*connection_, SendConnectionClose(QUIC_INVALID_STREAM_ID)); connection_ 31 net/tools/quic/quic_spdy_client_stream_test.cc : connection_(new StrictMock<MockConnection>( connection_ 35 net/tools/quic/quic_spdy_client_stream_test.cc connection_, connection_ 52 net/tools/quic/quic_spdy_client_stream_test.cc StrictMock<MockConnection>* connection_; connection_ 91 net/tools/quic/quic_spdy_client_stream_test.cc EXPECT_CALL(*connection_, connection_ 74 net/tools/quic/quic_spdy_server_stream_test.cc : connection_(new StrictMock<MockConnection>( connection_ 76 net/tools/quic/quic_spdy_server_stream_test.cc session_(connection_), connection_ 137 net/tools/quic/quic_spdy_server_stream_test.cc StrictMock<MockConnection>* connection_; connection_ 76 net/websockets/websocket_basic_stream.cc connection_(connection.Pass()), connection_ 84 net/websockets/websocket_basic_stream.cc DCHECK(connection_->is_initialized()); connection_ 119 net/websockets/websocket_basic_stream.cc int result = connection_->socket()->Read( connection_ 177 net/websockets/websocket_basic_stream.cc void WebSocketBasicStream::Close() { connection_->socket()->Disconnect(); } connection_ 205 net/websockets/websocket_basic_stream.cc int result = connection_->socket()->Write( connection_ 127 net/websockets/websocket_basic_stream.h scoped_ptr<ClientSocketHandle> connection_; connection_ 18 ppapi/proxy/plugin_resource.cc connection_(connection), connection_ 29 ppapi/proxy/plugin_resource.cc connection_.browser_sender->Send( connection_ 33 ppapi/proxy/plugin_resource.cc connection_.renderer_sender->Send( connection_ 127 ppapi/proxy/plugin_resource.cc if (dest == BROWSER && connection_.in_process) { connection_ 129 ppapi/proxy/plugin_resource.cc connection_.browser_sender_routing_id, connection_ 153 ppapi/proxy/plugin_resource.h const Connection& connection() { return connection_; } connection_ 157 ppapi/proxy/plugin_resource.h return dest == RENDERER ? connection_.renderer_sender : connection_ 158 ppapi/proxy/plugin_resource.h connection_.browser_sender; connection_ 169 ppapi/proxy/plugin_resource.h Connection connection_; connection_ 36 remoting/client/chromoting_client.cc connection_(connection), connection_ 69 remoting/client/chromoting_client.cc connection_->Connect(signal_strategy, connection_ 161 remoting/client/chromoting_client.cc video_renderer_->Initialize(connection_->config()); connection_ 162 remoting/client/chromoting_client.cc if (connection_->config().is_audio_enabled()) connection_ 163 remoting/client/chromoting_client.cc audio_decode_scheduler_->Initialize(connection_->config()); connection_ 167 remoting/client/chromoting_client.cc if (!connection_->config().SupportsCapabilities()) { connection_ 179 remoting/client/chromoting_client.cc if (connection_->config().SupportsCapabilities()) { connection_ 184 remoting/client/chromoting_client.cc connection_->host_stub()->SetCapabilities(capabilities); connection_ 94 remoting/client/chromoting_client.h protocol::ConnectionToHost* connection_; connection_ 149 remoting/client/jni/chromoting_jni_instance.cc connection_->input_stub()->InjectMouseEvent(event); connection_ 164 remoting/client/jni/chromoting_jni_instance.cc connection_->input_stub()->InjectMouseEvent(event); connection_ 180 remoting/client/jni/chromoting_jni_instance.cc connection_->input_stub()->InjectKeyEvent(event); connection_ 196 remoting/client/jni/chromoting_jni_instance.cc connection_->input_stub()->InjectTextEvent(event); connection_ 222 remoting/client/jni/chromoting_jni_instance.cc connection_->host_stub()->RequestPairing(request); connection_ 317 remoting/client/jni/chromoting_jni_instance.cc connection_.reset(new protocol::ConnectionToHost(true)); connection_ 327 remoting/client/jni/chromoting_jni_instance.cc client_config_, client_context_.get(), connection_.get(), connection_ 359 remoting/client/jni/chromoting_jni_instance.cc connection_.reset(); connection_ 147 remoting/client/jni/chromoting_jni_instance.h scoped_ptr<protocol::ConnectionToHost> connection_; connection_ 50 remoting/host/client_session.cc connection_(connection.Pass()), connection_ 51 remoting/host/client_session.cc client_jid_(connection_->session()->jid()), connection_ 70 remoting/host/client_session.cc connection_->SetEventHandler(this); connection_ 75 remoting/host/client_session.cc connection_->set_clipboard_stub(&auth_clipboard_filter_); connection_ 76 remoting/host/client_session.cc connection_->set_host_stub(this); connection_ 77 remoting/host/client_session.cc connection_->set_input_stub(&auth_input_filter_); connection_ 98 remoting/host/client_session.cc connection_.reset(); connection_ 155 remoting/host/client_session.cc if (!connection_->session()->config().SupportsCapabilities()) { connection_ 186 remoting/host/client_session.cc connection_->client_stub()->SetPairingResponse(pairing_response); connection_ 198 remoting/host/client_session.cc connection_->client_stub()->DeliverHostMessage(reply); connection_ 216 remoting/host/client_session.cc DCHECK_EQ(connection_.get(), connection); connection_ 226 remoting/host/client_session.cc clipboard_echo_filter_.set_client_stub(connection_->client_stub()); connection_ 227 remoting/host/client_session.cc mouse_clamping_filter_.set_video_stub(connection_->video_stub()); connection_ 255 remoting/host/client_session.cc if (!connection_->session()->config().SupportsCapabilities()) { connection_ 274 remoting/host/client_session.cc CreateVideoEncoder(connection_->session()->config()); connection_ 283 remoting/host/client_session.cc connection_->client_stub(), connection_ 287 remoting/host/client_session.cc if (connection_->session()->config().is_audio_enabled()) { connection_ 289 remoting/host/client_session.cc CreateAudioEncoder(connection_->session()->config()); connection_ 295 remoting/host/client_session.cc connection_->audio_stub()); connection_ 300 remoting/host/client_session.cc connection_->client_stub()); connection_ 306 remoting/host/client_session.cc DCHECK_EQ(connection_.get(), connection); connection_ 309 remoting/host/client_session.cc if (connection_->session()->config().SupportsCapabilities()) { connection_ 314 remoting/host/client_session.cc connection_->client_stub()->SetCapabilities(capabilities); connection_ 325 remoting/host/client_session.cc if (connection_->session()->config().is_audio_enabled()) connection_ 336 remoting/host/client_session.cc DCHECK_EQ(connection_.get(), connection); connection_ 378 remoting/host/client_session.cc DCHECK_EQ(connection_.get(), connection); connection_ 391 remoting/host/client_session.cc DCHECK_EQ(connection_.get(), connection); connection_ 401 remoting/host/client_session.cc DCHECK(connection_.get()); connection_ 407 remoting/host/client_session.cc connection_->Disconnect(); connection_ 141 remoting/host/client_session.h return connection_.get(); connection_ 161 remoting/host/client_session.h scoped_ptr<protocol::ConnectionToClient> connection_; connection_ 129 remoting/host/client_session_unittest.cc MockConnectionToClient* connection_; connection_ 169 remoting/host/client_session_unittest.cc connection_ = connection.get(); connection_ 274 remoting/host/client_session_unittest.cc InjectClipboardEvent(connection_, clipboard_event2), connection_ 278 remoting/host/client_session_unittest.cc InjectClipboardEvent(connection_, clipboard_event3), connection_ 288 remoting/host/client_session_unittest.cc connection_->clipboard_stub()->InjectClipboardEvent(clipboard_event1); connection_ 357 remoting/host/client_session_unittest.cc InjectKeyEvent(connection_, key_event2_down), connection_ 358 remoting/host/client_session_unittest.cc InjectKeyEvent(connection_, key_event2_up), connection_ 359 remoting/host/client_session_unittest.cc InjectMouseEvent(connection_, mouse_event2), connection_ 363 remoting/host/client_session_unittest.cc InjectKeyEvent(connection_, key_event3), connection_ 364 remoting/host/client_session_unittest.cc InjectMouseEvent(connection_, mouse_event3), connection_ 377 remoting/host/client_session_unittest.cc connection_->input_stub()->InjectKeyEvent(key_event1); connection_ 378 remoting/host/client_session_unittest.cc connection_->input_stub()->InjectMouseEvent(mouse_event1); connection_ 412 remoting/host/client_session_unittest.cc InjectMouseEvent(connection_, mouse_event1), connection_ 418 remoting/host/client_session_unittest.cc InjectMouseEvent(connection_, mouse_event2), connection_ 423 remoting/host/client_session_unittest.cc InjectMouseEvent(connection_, mouse_event3), connection_ 468 remoting/host/client_session_unittest.cc InjectKeyEvent(connection_, key1), connection_ 469 remoting/host/client_session_unittest.cc InjectKeyEvent(connection_, key2), connection_ 470 remoting/host/client_session_unittest.cc InjectMouseEvent(connection_, mousedown), connection_ 524 remoting/host/client_session_unittest.cc .WillOnce(InjectMouseEvent(connection_, injected_event)); connection_ 533 remoting/host/client_session_unittest.cc .WillOnce(InjectMouseEvent(connection_, injected_event)); connection_ 179 sql/connection.cc : connection_(connection), connection_ 183 sql/connection.cc connection_->StatementRefCreated(this); connection_ 187 sql/connection.cc if (connection_) connection_ 188 sql/connection.cc connection_->StatementRefDeleted(this); connection_ 205 sql/connection.cc connection_ = NULL; // The connection may be getting deleted. connection_ 485 sql/connection.h Connection* connection() const { return connection_; } connection_ 498 sql/connection.h void AssertIOAllowed() { if (connection_) connection_->AssertIOAllowed(); } connection_ 505 sql/connection.h Connection* connection_; connection_ 13 sql/transaction.cc : connection_(connection), connection_ 19 sql/transaction.cc connection_->RollbackTransaction(); connection_ 24 sql/transaction.cc is_open_ = connection_->BeginTransaction(); connection_ 32 sql/transaction.cc connection_->RollbackTransaction(); connection_ 39 sql/transaction.cc return connection_->CommitTransaction(); connection_ 49 sql/transaction.h Connection* connection_; connection_ 122 sync/engine/net/server_connection_manager.cc if (connection_) connection_ 123 sync/engine/net/server_connection_manager.cc manager_->OnConnectionDestroyed(connection_.get()); connection_ 124 sync/engine/net/server_connection_manager.cc connection_.reset(); connection_ 129 sync/engine/net/server_connection_manager.cc return connection_.get(); connection_ 325 sync/engine/net/server_connection_manager.h scoped_ptr<Connection> connection_; connection_ 129 sync/engine/sync_scheduler_unittest.cc connection_.reset(new MockConnectionManager(directory(), connection_ 131 sync/engine/sync_scheduler_unittest.cc connection_->SetServerReachable(); connection_ 136 sync/engine/sync_scheduler_unittest.cc connection_.get(), directory(), connection_ 157 sync/engine/sync_scheduler_unittest.cc MockConnectionManager* connection() { return connection_.get(); } connection_ 231 sync/engine/sync_scheduler_unittest.cc scoped_ptr<MockConnectionManager> connection_; connection_ 140 ui/ozone/platform/caca/caca_event_factory.cc : connection_(connection), connection_ 174 ui/ozone/platform/caca/caca_event_factory.cc if (connection_->display() && connection_ 175 ui/ozone/platform/caca/caca_event_factory.cc caca_get_event(connection_->display(), event_mask, &event, 0)) { connection_ 197 ui/ozone/platform/caca/caca_event_factory.cc caca_gotoxy(caca_get_canvas(connection_->display()), connection_ 217 ui/ozone/platform/caca/caca_event_factory.cc connection_); connection_ 32 ui/ozone/platform/caca/caca_event_factory.h CacaConnection* connection_; // Not owned. connection_ 32 ui/ozone/platform/caca/caca_surface_factory.cc CacaConnection* connection_; // Not owned. connection_ 42 ui/ozone/platform/caca/caca_surface_factory.cc : connection_(connection) {} connection_ 49 ui/ozone/platform/caca/caca_surface_factory.cc SkImageInfo info = SkImageInfo::Make(connection_->bitmap_size().width(), connection_ 50 ui/ozone/platform/caca/caca_surface_factory.cc connection_->bitmap_size().height(), connection_ 82 ui/ozone/platform/caca/caca_surface_factory.cc caca_canvas_t* canvas = caca_get_canvas(connection_->display()); connection_ 88 ui/ozone/platform/caca/caca_surface_factory.cc caca_refresh_display(connection_->display()); connection_ 107 ui/ozone/platform/caca/caca_surface_factory.cc connection_->Initialize(); connection_ 133 ui/ozone/platform/caca/caca_surface_factory.cc return make_scoped_ptr<gfx::SurfaceOzone>(new CacaSurface(connection_)); connection_ 35 ui/ozone/platform/caca/caca_surface_factory.h CacaConnection* connection_; // Not owned. connection_ 13 ui/ozone/platform/caca/ozone_platform_caca.cc : connection_(), connection_ 14 ui/ozone/platform/caca/ozone_platform_caca.cc surface_factory_ozone_(&connection_), connection_ 15 ui/ozone/platform/caca/ozone_platform_caca.cc event_factory_ozone_(&connection_) {} connection_ 31 ui/ozone/platform/caca/ozone_platform_caca.h ui::CacaConnection connection_;