Home
last modified time | relevance | path

Searched refs:StreamInterface (Results 1 – 25 of 35) sorted by relevance

12

/external/chromium/third_party/libjingle/source/talk/base/
Dsocketpool.h43 class StreamInterface; variable
53 virtual StreamInterface* RequestConnectedStream(const SocketAddress& remote,
55 virtual void ReturnConnectedStream(StreamInterface* stream) = 0;
69 virtual StreamInterface* RequestConnectedStream(const SocketAddress& remote,
71 virtual void ReturnConnectedStream(StreamInterface* stream);
74 typedef std::pair<SocketAddress, StreamInterface*> ConnectedStream;
77 void OnStreamEvent(StreamInterface* stream, int events, int err);
98 virtual StreamInterface* RequestConnectedStream(const SocketAddress& remote,
100 virtual void ReturnConnectedStream(StreamInterface* stream);
118 virtual StreamInterface* RequestConnectedStream(const SocketAddress& remote,
[all …]
Dstream.h68 class StreamInterface : public MessageHandler {
70 virtual ~StreamInterface();
103 sigslot::signal3<StreamInterface*, int, int> SignalEvent;
226 StreamInterface();
232 DISALLOW_EVIL_CONSTRUCTORS(StreamInterface);
243 class StreamAdapterInterface : public StreamInterface,
246 explicit StreamAdapterInterface(StreamInterface* stream, bool owned = true);
310 void Attach(StreamInterface* stream, bool owned = true);
311 StreamInterface* Detach();
318 virtual void OnEvent(StreamInterface* stream, int events, int err) { in OnEvent()
[all …]
Dsocketpool.cc58 StreamInterface* StreamCache::RequestConnectedStream( in RequestConnectedStream()
74 if (StreamInterface* stream = pool_->RequestConnectedStream(remote, err)) { in RequestConnectedStream()
83 void StreamCache::ReturnConnectedStream(StreamInterface* stream) { in ReturnConnectedStream()
105 void StreamCache::OnStreamEvent(StreamInterface* stream, int events, int err) { in OnStreamEvent()
136 StreamInterface*
157 NewSocketPool::ReturnConnectedStream(StreamInterface* stream) { in ReturnConnectedStream()
174 StreamInterface*
211 ReuseSocketPool::ReturnConnectedStream(StreamInterface* stream) { in ReturnConnectedStream()
220 ReuseSocketPool::OnStreamEvent(StreamInterface* stream, int events, int err) { in OnStreamEvent()
261 StreamInterface* LoggingPoolAdapter::RequestConnectedStream( in RequestConnectedStream()
[all …]
Dhttpbase.h39 class StreamInterface; variable
120 bool attach(StreamInterface* stream);
121 StreamInterface* stream() { return http_stream_; } in stream()
122 StreamInterface* detach();
137 StreamInterface* GetDocumentStream();
164 void OnHttpStreamEvent(StreamInterface* stream, int events, int error);
165 void OnDocumentEvent(StreamInterface* stream, int events, int error);
188 StreamInterface* http_stream_;
Dstream.cc58 StreamInterface::~StreamInterface() { in ~StreamInterface()
66 StreamResult StreamInterface::WriteAll(const void* data, size_t data_len, in WriteAll()
82 StreamResult StreamInterface::ReadAll(void* buffer, size_t buffer_len, in ReadAll()
98 StreamResult StreamInterface::ReadLine(std::string* line) { in ReadLine()
118 void StreamInterface::PostEvent(Thread* t, int events, int err) { in PostEvent()
122 void StreamInterface::PostEvent(int events, int err) { in PostEvent()
126 StreamInterface::StreamInterface() { in StreamInterface() function in talk_base::StreamInterface
129 void StreamInterface::OnMessage(Message* msg) { in OnMessage()
141 StreamAdapterInterface::StreamAdapterInterface(StreamInterface* stream, in StreamAdapterInterface()
148 void StreamAdapterInterface::Attach(StreamInterface* stream, bool owned) { in Attach()
[all …]
Dlogging.h77 class StreamInterface; variable
169 static void LogToStream(StreamInterface* stream, int min_sev);
170 static int GetLogToStream(StreamInterface* stream = NULL);
171 static void AddLogToStream(StreamInterface* stream, int min_sev);
172 static void RemoveLogToStream(StreamInterface* stream);
190 typedef std::list<std::pair<StreamInterface*, int> > StreamList;
201 static void OutputToStream(StreamInterface* stream, const std::string& msg);
Dhttpclient.h49 StreamInterface* output, size_t* size);
52 bool HttpReadCacheHeaders(StreamInterface* input,
136 StreamInterface* request_doc);
139 StreamInterface* GetDocumentStream();
Dopensslstreamadapter.cc78 static BIO* BIO_new_stream(StreamInterface* stream) { in BIO_new_stream()
105 StreamInterface* stream = static_cast<StreamInterface*>(b->ptr); in stream_read()
123 StreamInterface* stream = static_cast<StreamInterface*>(b->ptr); in stream_write()
163 OpenSSLStreamAdapter::OpenSSLStreamAdapter(StreamInterface* stream) in OpenSSLStreamAdapter()
348 void OpenSSLStreamAdapter::OnEvent(StreamInterface* stream, int events, in OnEvent()
436 bio = BIO_new_stream(static_cast<StreamInterface*>(stream())); in BeginSSL()
Dsslstreamadapter.h55 static SSLStreamAdapter* Create(StreamInterface* stream);
57 explicit SSLStreamAdapter(StreamInterface* stream) in SSLStreamAdapter()
Ddiskcache.h40 class StreamInterface; variable
63 StreamInterface* WriteResource(const std::string& id, size_t index);
66 StreamInterface* ReadResource(const std::string& id, size_t index) const;
Dhttpclient.cc211 StreamInterface* output, size_t* size) { in HttpWriteCacheHeaders()
242 bool HttpReadCacheHeaders(StreamInterface* input, HttpResponseData* response, in HttpReadCacheHeaders()
320 StreamInterface* HttpClient::GetDocumentStream() { in GetDocumentStream()
387 StreamInterface* stream = pool_->RequestConnectedStream(server_, &stream_err); in connect()
410 StreamInterface* request_doc) { in prepare_post()
420 if (StreamInterface* stream = base_.detach()) { in release()
453 scoped_ptr<StreamInterface> stream(cache_->WriteResource(id, kCacheBody)); in BeginCacheFile()
462 StreamInterface* output = response().document.release(); in BeginCacheFile()
472 scoped_ptr<StreamInterface> stream(cache_->WriteResource(id, kCacheHeader)); in WriteCacheHeaders()
549 scoped_ptr<StreamInterface> stream(cache_->ReadResource(id, kCacheHeader)); in ReadCacheHeaders()
[all …]
Dlinux.h63 virtual void Attach(StreamInterface* stream);
69 scoped_ptr<StreamInterface> instream_;
Dhttpbase.cc258 class HttpBase::DocumentStream : public StreamInterface {
288 scoped_ptr<StreamInterface> in Read()
389 HttpBase::attach(StreamInterface* stream) { in attach()
400 StreamInterface*
406 StreamInterface* stream = http_stream_; in detach()
484 StreamInterface* HttpBase::GetDocumentStream() { in GetDocumentStream()
768 HttpBase::OnHttpStreamEvent(StreamInterface* stream, int events, int error) { in OnHttpStreamEvent()
803 HttpBase::OnDocumentEvent(StreamInterface* stream, int events, int error) { in OnDocumentEvent()
843 StreamInterface* old_docstream = doc_stream_; in ProcessHeaderComplete()
Dopensslstreamadapter.h74 explicit OpenSSLStreamAdapter(StreamInterface* stream);
92 virtual void OnEvent(StreamInterface* stream, int events, int err);
Dlogging.cc230 void LogMessage::LogToStream(StreamInterface* stream, int min_sev) { in LogToStream()
243 int LogMessage::GetLogToStream(StreamInterface* stream) { in GetLogToStream()
254 void LogMessage::AddLogToStream(StreamInterface* stream, int min_sev) { in AddLogToStream()
260 void LogMessage::RemoveLogToStream(StreamInterface* stream) { in RemoveLogToStream()
483 void LogMessage::OutputToStream(StreamInterface* stream, in OutputToStream()
Dsslstreamadapter.cc57 SSLStreamAdapter* SSLStreamAdapter::Create(StreamInterface* stream) { in Create()
Ddiskcache.cc59 StreamInterface* stream) in DiskCacheAdapter()
128 StreamInterface* DiskCache::WriteResource(const std::string& id, size_t index) { in WriteResource()
171 StreamInterface* DiskCache::ReadResource(const std::string& id, in ReadResource()
Dhttpcommon.h301 scoped_ptr<StreamInterface> document;
381 void setContent(const std::string& content_type, StreamInterface* document);
382 void setDocumentAndLength(StreamInterface* document);
422 void set_success(const std::string& content_type, StreamInterface* document,
/external/chromium/third_party/libjingle/overrides/talk/base/
Dlogging.h77 class StreamInterface; variable
172 static void LogToStream(StreamInterface* stream, int min_sev);
173 static int GetLogToStream(StreamInterface* stream = NULL);
174 static void AddLogToStream(StreamInterface* stream, int min_sev);
175 static void RemoveLogToStream(StreamInterface* stream);
193 typedef std::list<std::pair<StreamInterface*, int> > StreamList;
204 static void OutputToStream(StreamInterface* stream, const std::string& msg);
/external/chromium/third_party/libjingle/source/talk/session/phone/
Drtpdump.h89 explicit RtpDumpReader(talk_base::StreamInterface* stream) in RtpDumpReader()
109 talk_base::StreamInterface* stream_;
123 explicit RtpDumpLoopReader(talk_base::StreamInterface* stream);
166 explicit RtpDumpWriter(talk_base::StreamInterface* stream);
195 talk_base::StreamInterface* stream_;
/external/chromium/third_party/libjingle/source/talk/examples/login/
Dxmppsocket.h41 class StreamInterface; variable
69 void OnEvent(talk_base::StreamInterface* stream, int events, int err);
74 talk_base::StreamInterface *stream_;
/external/chromium/third_party/libjingle/source/talk/session/tunnel/
Dsecuretunnelsessionclient.h132 virtual talk_base::StreamInterface* GetStream();
141 talk_base::StreamInterface* MakeSecureStream(
142 talk_base::StreamInterface* stream);
Dtunnelsessionclient.h72 talk_base::StreamInterface* CreateTunnel(const buzz::Jid& to,
75 talk_base::StreamInterface* AcceptTunnel(Session* session);
160 virtual talk_base::StreamInterface* GetStream();
Dtunnelsessionclient.cc64 talk_base::StreamInterface* stream;
143 talk_base::StreamInterface* TunnelSessionClientBase::CreateTunnel( in CreateTunnel()
154 talk_base::StreamInterface* TunnelSessionClientBase::AcceptTunnel( in AcceptTunnel()
319 talk_base::StreamInterface* TunnelSession::GetStream() { in GetStream()
Dsecuretunnelsessionclient.cc313 talk_base::StreamInterface* SecureTunnelSession::MakeSecureStream( in MakeSecureStream()
314 talk_base::StreamInterface* stream) { in MakeSecureStream()
337 talk_base::StreamInterface* SecureTunnelSession::GetStream() { in GetStream()

12