| /external/chromium_org/content/browser/dom_storage/ |
| session_storage_namespace_impl.cc | 14 : session_(new DOMStorageSession(context->context())) {
19 : session_(DOMStorageSession::CloneFrom(context->context(),
25 : session_(new DOMStorageSession(context->context(), persistent_id)) {
30 : session_(new DOMStorageSession(
31 master_session_storage_namespace->session_)) {
36 return session_->namespace_id();
40 return session_->persistent_namespace_id();
44 session_->SetShouldPersist(should_persist);
48 return session_->should_persist();
52 return new SessionStorageNamespaceImpl(session_->Clone())
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/xmpp/ |
| util_unittest.cc | 29 session_ << "[START]";
32 session_ << "[OPENING]";
35 session_ << "[OPEN]";
38 session_ << "[CLOSED]";
44 session_ << "[ERROR-XML]";
47 session_ << "[ERROR-STREAM]";
50 session_ << "[ERROR-VERSION]";
53 session_ << "[ERROR-UNAUTHORIZED]";
56 session_ << "[ERROR-TLS]";
59 session_ << "[ERROR-AUTH]"
[all...] |
| /external/chromium_org/net/tools/quic/ |
| quic_client_session_test.cc | 37 session_.reset(new QuicClientSession(
42 session_->config()->SetDefaults();
46 ASSERT_TRUE(session_->CryptoConnect());
48 connection_, session_->GetCryptoStream());
52 scoped_ptr<QuicClientSession> session_; member in class:net::tools::test::__anon13773::ToolsQuicClientSessionTest
64 session_->config()->set_max_streams_per_connection(1, 1);
70 session_->CreateOutgoingDataStream();
72 EXPECT_FALSE(session_->CreateOutgoingDataStream());
75 session_->CloseStream(stream->id());
76 stream = session_->CreateOutgoingDataStream()
[all...] |
| quic_server_session_test.cc | 64 session_.reset(new QuicServerSession(config_, connection_, &owner_));
65 session_->InitializeSession(crypto_config_);
75 scoped_ptr<QuicServerSession> session_; member in class:net::tools::test::__anon13778::QuicServerSessionTest
88 session_->OnStreamFrames(frames);
89 EXPECT_EQ(1u, session_->GetNumOpenStreams());
96 EXPECT_EQ(0u, session_->GetNumOpenStreams());
102 EXPECT_EQ(0u, session_->GetNumOpenStreams());
112 EXPECT_EQ(0u, session_->GetNumOpenStreams());
121 EXPECT_EQ(0u, session_->GetNumOpenStreams());
133 EXPECT_EQ(2u, session_->GetNumOpenStreams())
[all...] |
| /external/chromium_org/net/http/ |
| http_network_session_peer.cc | 19 : session_(session) {}
25 session_->normal_socket_pool_manager_.swap(socket_pool_manager);
29 session_->proxy_service_ = proxy_service;
34 session_->http_stream_factory_.swap(http_stream_factory);
39 session_->http_stream_factory_for_websocket_.swap(http_stream_factory);
|
| http_network_layer.cc | 24 : session_(session),
26 DCHECK(session_.get());
75 HttpNetworkSession* HttpNetworkLayer::GetSession() { return session_.get(); }
80 if (session_.get())
81 session_->CloseIdleConnections();
|
| failing_http_transaction_factory.h | 36 HttpNetworkSession* session_; member in class:net::FailingHttpTransactionFactory
|
| http_stream_factory_impl.cc | 44 : session_(session),
124 new Job(this, session_, alternate_request_info, priority,
130 Job* job = new Job(this, session_, request_info, priority,
164 job = new Job(this, session_, alternate_request_info, priority,
165 server_ssl_config, proxy_ssl_config, session_->net_log());
168 job = new Job(this, session_, request_info, priority,
169 server_ssl_config, proxy_ssl_config, session_->net_log());
176 return session_->params().host_mapping_rules;
182 if (!session_->params().use_alternate_protocols)
192 *session_->http_server_properties()
[all...] |
| /external/chromium_org/net/quic/ |
| quic_session_test.cc | 109 : session_(session),
114 session_->MarkWriteBlocked(stream_id_, kSomeMiddlePriority);
118 QuicSession* const session_; member in class:net::test::__anon13509::StreamBlocker
188 session_(connection_) {
189 session_.config()->SetInitialFlowControlWindowToSend(
191 session_.config()->SetInitialStreamFlowControlWindowToSend(
193 session_.config()->SetInitialSessionFlowControlWindowToSend(
227 EXPECT_FALSE(session_.IsClosedStream(i)) << " stream id: " << i;
229 EXPECT_TRUE(session_.IsClosedStream(i)) << " stream id: " << i;
235 session_.CloseStream(id)
242 TestSession session_; member in class:net::test::__anon13509::QuicSessionTest
[all...] |
| quic_client_session_test.cc | 70 session_(connection_, GetSocket().Pass(), writer_.Pass(), NULL, NULL,
77 session_.config()->SetDefaults();
82 session_.CloseSessionOnError(ERR_ABORTED);
94 session_.CryptoConnect(false, callback_.callback()));
96 connection_, session_.GetCryptoStream());
105 QuicClientSession session_; member in class:net::test::__anon13474::QuicClientSessionTest
125 QuicReliableClientStream* stream = session_.CreateOutgoingDataStream();
129 EXPECT_FALSE(session_.CreateOutgoingDataStream());
132 session_.CloseStream(streams[0]->id());
133 EXPECT_TRUE(session_.CreateOutgoingDataStream())
[all...] |
| quic_crypto_client_stream_test.cc | 31 session_(new TestClientSession(connection_, DefaultQuicConfig())),
34 server_id_, session_.get(), NULL, &crypto_config_)) {
35 session_->SetCryptoStream(stream_.get());
36 session_->config()->SetDefaults();
51 scoped_ptr<TestClientSession> session_; member in class:net::test::__anon13483::QuicCryptoClientStreamTest
94 const QuicConfig* config = session_->config();
111 stream_.reset(new QuicCryptoClientStream(server_id, session_.get(), NULL,
113 session_->SetCryptoStream(stream_.get());
125 session_.reset(new TestClientSession(connection_, DefaultQuicConfig()));
126 stream_.reset(new QuicCryptoClientStream(server_id_, session_.get(), NULL
[all...] |
| reliable_quic_stream_test.cc | 115 session_.reset(new StrictMock<MockSession>(connection_));
120 session_->config(), initial_flow_control_window_bytes_);
122 session_->config(), initial_flow_control_window_bytes_);
124 stream_.reset(new TestStream(kHeadersStreamId, session_.get(),
127 QuicSessionPeer::GetWriteBlockedStreams(session_.get());
144 scoped_ptr<MockSession> session_; member in class:net::test::__anon13523::ReliableQuicStreamTest
162 EXPECT_CALL(*session_, WritevData(kHeadersStreamId, _, _, _, _, _)).WillOnce(
182 EXPECT_CALL(*session_, WritevData(kHeadersStreamId, _, _, _, _, _))
195 EXPECT_CALL(*session_, WritevData(kHeadersStreamId, _, _, _, _, _))
206 EXPECT_CALL(*session_, WritevData(kHeadersStreamId, _, _, _, _, _)
[all...] |
| /external/chromium_org/remoting/protocol/ |
| connection_to_client_unittest.cc | 30 session_ = new FakeSession();
33 viewer_.reset(new ConnectionToClient(session_));
40 session_->event_handler()->OnSessionStateChange(Session::CONNECTED);
41 session_->event_handler()->OnSessionStateChange(Session::AUTHENTICATED);
58 FakeSession* session_; member in class:remoting::protocol::ConnectionToClientTest
72 ASSERT_TRUE(session_->GetStreamChannel(kVideoChannelName));
73 EXPECT_GT(session_->GetStreamChannel(kVideoChannelName)->
97 session_->event_handler()->OnSessionStateChange(Session::CLOSED);
101 session_->set_error(SESSION_REJECTED);
102 session_->event_handler()->OnSessionStateChange(Session::FAILED)
[all...] |
| connection_to_client.cc | 25 session_(session) {
26 session_->SetEventHandler(this);
39 return session_.get();
49 session_->Close();
122 session_.get(), session_->config().control_config(),
130 session_.get(), session_->config().event_config(),
137 video_writer_ = VideoWriter::Create(session_->config());
138 video_writer_->Init(session_.get(), base::Bind
[all...] |
| connection_to_host.cc | 44 if (session_.get())
45 session_.reset();
83 return session_->config();
150 session_ = session_manager_->Connect(
152 session_->SetEventHandler(this);
182 session_.get(), session_->config().control_config(),
190 session_.get(), session_->config().event_config(),
194 video_reader_ = VideoReader::Create(session_->config())
[all...] |
| /external/chromium_org/net/dns/ |
| dns_client.cc | 29 session_ = NULL;
35 session_ = new DnsSession(config,
39 factory_ = DnsTransactionFactory::CreateFactory(session_.get());
44 return session_.get() ? &session_->config() : NULL;
48 return session_.get() ? factory_.get() : NULL;
56 scoped_refptr<DnsSession> session_; member in class:net::__anon13204::DnsClientImpl
|
| /external/chromium_org/net/ftp/ |
| ftp_network_layer.cc | 14 : session_(new FtpNetworkSession(host_resolver)),
31 return new FtpNetworkTransaction(session_.get(),
40 session_->connection_manager()->CloseIdleSockets();
|
| ftp_network_layer.h | 31 scoped_refptr<FtpNetworkSession> session_; member in class:net::FtpNetworkLayer
|
| /external/google-tv-pairing-protocol/cpp/tests/polo/pairing/ |
| pairingsessiontest.cc | 86 session_(&wire_, &context_, &challenge_) {
99 EXPECT_CALL(session_, DoInitializationPhase());
101 session_.DoPair(&listener_);
109 StrictMock<TestPairingSession> session_; member in class:polo::pairing::PairingSessionTest
121 session_.TestSetConfiguration(configuration);
123 ASSERT_TRUE(session_.GetConfiguration());
125 session_.GetConfiguration()->encoding().encoding_type());
126 ASSERT_EQ(8, session_.GetConfiguration()->encoding().symbol_length());
128 session_.GetConfiguration()->client_role());
130 ASSERT_TRUE(session_.encoder())
[all...] |
| serverpairingsessiontest.cc | 59 session_(&wire_, &context_, &challenge_) {
74 session_.DoPair(&listener_);
82 StrictMock<TestServerPairingSession> session_; member in class:polo::pairing::ServerPairingSessionTest
94 session_.TestDoInitializationPhase();
104 session_.OnPairingRequestMessage(message);
114 session_.OnOptionsMessage(message);
119 session_.AddInputEncoding(encoding);
120 session_.AddOutputEncoding(encoding);
133 session_.OnConfigurationMessage(message);
|
| clientpairingsessiontest.cc | 64 session_(&wire_, &context_, &challenge_) {
83 session_.DoPair(&listener_);
91 StrictMock<TestClientPairingSession> session_; member in class:polo::pairing::ClientPairingSessionTest
104 session_.TestSetConfiguration(configuration);
109 session_.TestDoConfigurationPhase();
119 session_.OnPairingRequestAckMessage(message);
124 session_.AddInputEncoding(encoding);
125 session_.AddOutputEncoding(encoding);
138 session_.OnOptionsMessage(message);
147 session_.TestSetConfiguration(configuration)
[all...] |
| /external/chromium_org/third_party/webrtc/modules/video_coding/main/source/ |
| session_info_unittest.cc | 25 session_.Reset();
59 VCMSessionInfo session_; member in class:webrtc::TestSessionInfo
105 EXPECT_GE(session_.SessionLength(),
157 session_.InsertPacket(packet_,
161 EXPECT_FALSE(session_.HaveLastPacket());
162 EXPECT_EQ(kVideoFrameKey, session_.FrameType());
168 session_.InsertPacket(packet_,
172 EXPECT_TRUE(session_.HaveLastPacket());
173 EXPECT_EQ(packet_.seqNum, session_.HighSequenceNumber());
174 EXPECT_EQ(0xFFFE, session_.LowSequenceNumber())
[all...] |
| /external/chromium_org/chrome/browser/extensions/api/bluetooth_low_energy/ |
| bluetooth_low_energy_notify_session.cc | 26 session_(session.release()) {
34 return session_.get();
|
| /external/chromium_org/net/spdy/ |
| spdy_stream.cc | 95 session_(session),
161 session_->CloseActiveStream(stream_id_, ERR_SPDY_PROTOCOL_ERROR);
188 session_->CloseActiveStream(stream_id_, OK);
204 scoped_ptr<SpdyFrame> frame(session_->CreateSynStream(
217 DCHECK_GE(session_->flow_control_state(), SpdySession::FLOW_CONTROL_STREAM);
237 DCHECK_GE(session_->flow_control_state(), SpdySession::FLOW_CONTROL_STREAM);
252 DCHECK_GE(session_->flow_control_state(), SpdySession::FLOW_CONTROL_STREAM);
267 session_->ResetStream(stream_id_, RST_STREAM_FLOW_CONTROL_ERROR, desc);
283 DCHECK_GE(session_->flow_control_state(), SpdySession::FLOW_CONTROL_STREAM);
308 DCHECK_GE(session_->flow_control_state(), SpdySession::FLOW_CONTROL_STREAM)
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/p2p/client/ |
| basicportallocator.cc | 156 BasicPortAllocatorSession* session_; member in class:cricket::AllocationSequence
703 : session_(session),
724 udp_socket_.reset(session_->socket_factory()->CreateUdpSocket(
725 talk_base::SocketAddress(ip_, 0), session_->allocator()->min_port(),
726 session_->allocator()->max_port()));
743 session_->network_thread()->Clear(this);
777 session_->network_thread()->Post(this, MSG_ALLOCATION_PHASE);
784 session_->network_thread()->Clear(this, MSG_ALLOCATION_PHASE);
789 ASSERT(talk_base::Thread::Current() == session_->network_thread());
827 session_->network_thread()->PostDelayed
[all...] |
