| /external/chromium/third_party/libjingle/source/talk/base/ |
| socketpool.h | 43 class StreamInterface;
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...] |
| sslstreamadapter.h | 55 static SSLStreamAdapter* Create(StreamInterface* stream);
57 explicit SSLStreamAdapter(StreamInterface* stream)
|
| stream.h | 41 // StreamInterface is a generic asynchronous stream interface, supporting read,
47 // The following enumerations are declared outside of the StreamInterface
68 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)
[all...] |
| httpbase.h | 39 class StreamInterface;
103 // Attach HttpBase to a StreamInterface which represents a bidirectional HTTP
120 bool attach(StreamInterface* stream);
121 StreamInterface* stream() { return http_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_;
|
| sslstreamadapter.cc | 57 SSLStreamAdapter* SSLStreamAdapter::Create(StreamInterface* stream) {
|
| linux.h | 63 virtual void Attach(StreamInterface* stream);
69 scoped_ptr<StreamInterface> instream_;
|
| socketpool.cc | 58 StreamInterface* StreamCache::RequestConnectedStream(
74 if (StreamInterface* stream = pool_->RequestConnectedStream(remote, err)) {
83 void StreamCache::ReturnConnectedStream(StreamInterface* stream) {
105 void StreamCache::OnStreamEvent(StreamInterface* stream, int events, int err) {
136 StreamInterface*
157 NewSocketPool::ReturnConnectedStream(StreamInterface* stream) {
174 StreamInterface*
211 ReuseSocketPool::ReturnConnectedStream(StreamInterface* stream) {
220 ReuseSocketPool::OnStreamEvent(StreamInterface* stream, int events, int err) {
261 StreamInterface* LoggingPoolAdapter::RequestConnectedStream
[all...] |
| socketstream.h | 39 class SocketStream : public StreamInterface, public sigslot::has_slots<> {
|
| opensslstreamadapter.h | 74 explicit OpenSSLStreamAdapter(StreamInterface* stream);
92 virtual void OnEvent(StreamInterface* stream, int events, int err);
|
| logging.h | 30 // file, or any StreamInterface.
77 class StreamInterface;
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);
|
| diskcache.h | 40 class StreamInterface;
63 StreamInterface* WriteResource(const std::string& id, size_t index);
66 StreamInterface* ReadResource(const std::string& id, size_t index) const;
|
| stream.cc | 51 // StreamInterface
58 StreamInterface::~StreamInterface() {
66 StreamResult StreamInterface::WriteAll(const void* data, size_t data_len,
82 StreamResult StreamInterface::ReadAll(void* buffer, size_t buffer_len,
98 StreamResult StreamInterface::ReadLine(std::string* line) {
118 void StreamInterface::PostEvent(Thread* t, int events, int err) {
122 void StreamInterface::PostEvent(int events, int err) {
126 StreamInterface::StreamInterface() {
[all...] |
| httpclient.h | 49 StreamInterface* output, size_t* size);
52 bool HttpReadCacheHeaders(StreamInterface* input,
136 StreamInterface* request_doc);
139 StreamInterface* GetDocumentStream();
|
| opensslstreamadapter.cc | 78 static BIO* BIO_new_stream(StreamInterface* stream) {
105 StreamInterface* stream = static_cast<StreamInterface*>(b->ptr);
123 StreamInterface* stream = static_cast<StreamInterface*>(b->ptr);
163 OpenSSLStreamAdapter::OpenSSLStreamAdapter(StreamInterface* stream)
204 // StreamInterface Implementation
348 void OpenSSLStreamAdapter::OnEvent(StreamInterface* stream, int events,
436 bio = BIO_new_stream(static_cast<StreamInterface*>(stream()));
|
| httpbase.cc | 258 class HttpBase::DocumentStream : public StreamInterface {
281 // DoReceiveLoop writes http document data to the StreamInterface* document
284 // StreamInterface, and replace the existing document with our wrapper.
286 // pass our StreamInterface* to DoReceiveLoop, but due to the callbacks
288 scoped_ptr<StreamInterface>
389 HttpBase::attach(StreamInterface* stream) {
400 StreamInterface*
406 StreamInterface* stream = http_stream_;
484 StreamInterface* HttpBase::GetDocumentStream() {
768 HttpBase::OnHttpStreamEvent(StreamInterface* stream, int events, int error)
[all...] |
| logging.cc | 230 void LogMessage::LogToStream(StreamInterface* stream, int min_sev) {
243 int LogMessage::GetLogToStream(StreamInterface* stream) {
254 void LogMessage::AddLogToStream(StreamInterface* stream, int min_sev) {
260 void LogMessage::RemoveLogToStream(StreamInterface* stream) {
483 void LogMessage::OutputToStream(StreamInterface* stream,
|
| httpclient.cc | 211 StreamInterface* output, size_t* size) {
242 bool HttpReadCacheHeaders(StreamInterface* input, HttpResponseData* response,
320 StreamInterface* HttpClient::GetDocumentStream() {
387 StreamInterface* stream = pool_->RequestConnectedStream(server_, &stream_err);
410 StreamInterface* request_doc) {
420 if (StreamInterface* stream = base_.detach()) {
453 scoped_ptr<StreamInterface> stream(cache_->WriteResource(id, kCacheBody));
462 StreamInterface* output = response().document.release();
472 scoped_ptr<StreamInterface> stream(cache_->WriteResource(id, kCacheHeader));
549 scoped_ptr<StreamInterface> stream(cache_->ReadResource(id, kCacheHeader))
[all...] |
| /external/chromium/third_party/libjingle/source/talk/examples/login/ |
| xmppsocket.h | 41 class StreamInterface;
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/ |
| securetunnelsessionclient.h | 132 virtual talk_base::StreamInterface* GetStream();
141 talk_base::StreamInterface* MakeSecureStream(
142 talk_base::StreamInterface* stream);
|
| tunnelsessionclient.h | 72 talk_base::StreamInterface* CreateTunnel(const buzz::Jid& to,
75 talk_base::StreamInterface* AcceptTunnel(Session* session);
160 virtual talk_base::StreamInterface* GetStream();
|
| pseudotcpchannel.h | 48 // 1) The StreamInterface provided via GetStream has been closed.
75 talk_base::StreamInterface* GetStream();
|
| securetunnelsessionclient.cc | 313 talk_base::StreamInterface* SecureTunnelSession::MakeSecureStream(
314 talk_base::StreamInterface* stream) {
337 talk_base::StreamInterface* SecureTunnelSession::GetStream() {
|
| /external/chromium/third_party/libjingle/source/talk/session/phone/ |
| rtpdump.h | 89 explicit RtpDumpReader(talk_base::StreamInterface* stream)
109 talk_base::StreamInterface* stream_;
123 explicit RtpDumpLoopReader(talk_base::StreamInterface* stream);
166 explicit RtpDumpWriter(talk_base::StreamInterface* stream);
195 talk_base::StreamInterface* stream_;
|
| filemediaengine.cc | 102 talk_base::scoped_ptr<talk_base::StreamInterface> input_stream_;
103 talk_base::scoped_ptr<talk_base::StreamInterface> output_stream_;
|
| /external/chromium/third_party/libjingle/overrides/talk/base/ |
| logging.h | 30 // file, or any StreamInterface.
77 class StreamInterface;
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);
|
