Home
last modified time | relevance | path

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

123

/external/webrtc/webrtc/base/
Dsocketpool.h26 class StreamInterface; variable
36 virtual StreamInterface* RequestConnectedStream(const SocketAddress& remote,
38 virtual void ReturnConnectedStream(StreamInterface* stream) = 0;
52 StreamInterface* RequestConnectedStream(const SocketAddress& remote,
54 void ReturnConnectedStream(StreamInterface* stream) override;
57 typedef std::pair<SocketAddress, StreamInterface*> ConnectedStream;
60 void OnStreamEvent(StreamInterface* stream, int events, int err);
81 StreamInterface* RequestConnectedStream(const SocketAddress& remote,
83 void ReturnConnectedStream(StreamInterface* stream) override;
101 StreamInterface* RequestConnectedStream(const SocketAddress& remote,
[all …]
Dstream.h60 class StreamInterface : public MessageHandler {
66 ~StreamInterface() override;
99 sigslot::signal3<StreamInterface*, int, int> SignalEvent;
225 StreamInterface();
231 RTC_DISALLOW_COPY_AND_ASSIGN(StreamInterface);
242 class StreamAdapterInterface : public StreamInterface,
245 explicit StreamAdapterInterface(StreamInterface* stream, bool owned = true);
294 void Attach(StreamInterface* stream, bool owned = true);
295 StreamInterface* Detach();
302 virtual void OnEvent(StreamInterface* stream, int events, int err);
[all …]
Dstream.cc41 StreamInterface::~StreamInterface() { in ~StreamInterface()
44 StreamResult StreamInterface::WriteAll(const void* data, size_t data_len, in WriteAll()
60 StreamResult StreamInterface::ReadAll(void* buffer, size_t buffer_len, in ReadAll()
76 StreamResult StreamInterface::ReadLine(std::string* line) { in ReadLine()
96 void StreamInterface::PostEvent(Thread* t, int events, int err) { in PostEvent()
100 void StreamInterface::PostEvent(int events, int err) { in PostEvent()
104 const void* StreamInterface::GetReadData(size_t* data_len) { in GetReadData()
108 void* StreamInterface::GetWriteBuffer(size_t* buf_len) { in GetWriteBuffer()
112 bool StreamInterface::SetPosition(size_t position) { in SetPosition()
116 bool StreamInterface::GetPosition(size_t* position) const { in GetPosition()
[all …]
Dsocketpool.cc41 StreamInterface* StreamCache::RequestConnectedStream( in RequestConnectedStream()
57 if (StreamInterface* stream = pool_->RequestConnectedStream(remote, err)) { in RequestConnectedStream()
66 void StreamCache::ReturnConnectedStream(StreamInterface* stream) { in ReturnConnectedStream()
88 void StreamCache::OnStreamEvent(StreamInterface* stream, int events, int err) { in OnStreamEvent()
119 StreamInterface*
140 NewSocketPool::ReturnConnectedStream(StreamInterface* stream) { in ReturnConnectedStream()
157 StreamInterface*
199 ReuseSocketPool::ReturnConnectedStream(StreamInterface* stream) { in ReturnConnectedStream()
208 ReuseSocketPool::OnStreamEvent(StreamInterface* stream, int events, int err) { in OnStreamEvent()
249 StreamInterface* LoggingPoolAdapter::RequestConnectedStream( in RequestConnectedStream()
[all …]
Dhttpbase.h19 class StreamInterface; variable
100 bool attach(StreamInterface* stream);
101 StreamInterface* stream() { return http_stream_; } in stream()
102 StreamInterface* detach();
117 StreamInterface* GetDocumentStream();
144 void OnHttpStreamEvent(StreamInterface* stream, int events, int error);
145 void OnDocumentEvent(StreamInterface* stream, int events, int error);
174 StreamInterface* http_stream_;
Dhttpserver.h43 int HandleConnection(StreamInterface* stream);
45 sigslot::signal3<HttpServer*, int, StreamInterface*> SignalConnectionClosed;
85 void BeginProcess(StreamInterface* stream);
86 StreamInterface* EndProcess();
128 StreamInterface* stream);
Dmultipart.h27 class MultipartStream : public StreamInterface, public sigslot::has_slots<> {
36 bool AddPart(StreamInterface* data_stream,
67 typedef std::vector<StreamInterface*> PartList;
70 void OnEvent(StreamInterface* stream, int events, int error);
Dhttpserver.cc38 StreamInterface* stream = it->second->EndProcess(); in ~HttpServer()
45 HttpServer::HandleConnection(StreamInterface* stream) { in HandleConnection()
132 HttpServer::Connection::BeginProcess(StreamInterface* stream) { in BeginProcess()
140 StreamInterface*
274 StreamInterface* stream = new SocketStream(incoming); in OnReadEvent()
282 StreamInterface* stream) { in OnConnectionClosed()
Dhttpclient.h33 StreamInterface* output, size_t* size);
36 bool HttpReadCacheHeaders(StreamInterface* input,
114 StreamInterface* request_doc);
117 StreamInterface* GetDocumentStream();
Ddiskcache.h23 class StreamInterface; variable
46 StreamInterface* WriteResource(const std::string& id, size_t index);
49 StreamInterface* ReadResource(const std::string& id, size_t index) const;
Dhttpclient.cc196 StreamInterface* output, size_t* size) { in HttpWriteCacheHeaders()
227 bool HttpReadCacheHeaders(StreamInterface* input, HttpResponseData* response, in HttpReadCacheHeaders()
332 StreamInterface* HttpClient::GetDocumentStream() { in GetDocumentStream()
403 StreamInterface* stream = pool_->RequestConnectedStream(server_, &stream_err); in connect()
426 StreamInterface* request_doc) { in prepare_post()
436 if (StreamInterface* stream = base_.detach()) { in release()
469 scoped_ptr<StreamInterface> stream(cache_->WriteResource(id, kCacheBody)); in BeginCacheFile()
478 StreamInterface* output = response().document.release(); in BeginCacheFile()
488 scoped_ptr<StreamInterface> stream(cache_->WriteResource(id, kCacheHeader)); in WriteCacheHeaders()
566 scoped_ptr<StreamInterface> stream(cache_->ReadResource(id, kCacheHeader)); in ReadCacheHeaders()
[all …]
Dhttpbase.cc242 class HttpBase::DocumentStream : public StreamInterface {
274 scoped_ptr<StreamInterface> in Read()
377 HttpBase::attach(StreamInterface* stream) { in attach()
388 StreamInterface*
394 StreamInterface* stream = http_stream_; in detach()
472 StreamInterface* HttpBase::GetDocumentStream() { in GetDocumentStream()
757 HttpBase::OnHttpStreamEvent(StreamInterface* stream, int events, int error) { in OnHttpStreamEvent()
792 HttpBase::OnDocumentEvent(StreamInterface* stream, int events, int error) { in OnDocumentEvent()
832 StreamInterface* old_docstream = doc_stream_; in ProcessHeaderComplete()
Dsslstreamadapter_unittest.cc75 class SSLDummyStreamBase : public rtc::StreamInterface,
80 rtc::StreamInterface* in, in SSLDummyStreamBase()
81 rtc::StreamInterface* out) : in SSLDummyStreamBase()
112 void OnEventIn(rtc::StreamInterface* stream, int sig, int err) { in OnEventIn()
123 void OnEventOut(rtc::StreamInterface* stream, int sig, int err) { in OnEventOut()
149 rtc::StreamInterface* in_;
150 rtc::StreamInterface* out_;
165 public rtc::StreamInterface {
316 virtual void OnEvent(rtc::StreamInterface *stream, int sig, int err) { in OnEvent()
512 virtual void ReadData(rtc::StreamInterface *stream) = 0;
[all …]
Dlinux.h48 virtual void Attach(StreamInterface* stream);
54 scoped_ptr<StreamInterface> instream_;
Dopensslstreamadapter.cc209 static BIO* BIO_new_stream(StreamInterface* stream) { in BIO_new_stream()
236 StreamInterface* stream = static_cast<StreamInterface*>(b->ptr); in stream_read()
254 StreamInterface* stream = static_cast<StreamInterface*>(b->ptr); in stream_write()
300 OpenSSLStreamAdapter::OpenSSLStreamAdapter(StreamInterface* stream) in OpenSSLStreamAdapter()
675 void OpenSSLStreamAdapter::OnEvent(StreamInterface* stream, int events, in OnEvent()
764 bio = BIO_new_stream(static_cast<StreamInterface*>(stream())); in BeginSSL()
896 StreamInterface::OnMessage(msg); in OnMessage()
Dsslstreamadapter.h79 static SSLStreamAdapter* Create(StreamInterface* stream);
81 explicit SSLStreamAdapter(StreamInterface* stream) in SSLStreamAdapter()
/external/piex/src/
Dtiff_parser.h111 bool Get16u(StreamInterface* stream, const std::uint32_t offset,
117 bool Get32u(StreamInterface* stream, const std::uint32_t offset,
124 StreamInterface* stream, Error* error);
128 bool GetEndianness(const std::uint32_t tiff_offset, StreamInterface* stream,
133 StreamInterface* stream, Image* image);
137 bool GetJpegDimensions(const std::uint32_t jpeg_offset, StreamInterface* stream,
151 const TagSet& desired_tags, StreamInterface* stream,
157 bool GetExifOrientation(StreamInterface* stream, const std::uint32_t offset,
170 explicit TiffParser(StreamInterface* stream);
171 TiffParser(StreamInterface* stream, const std::uint32_t offset);
[all …]
Dpiex.cc54 bool GetDngInformation(const TagSet& extended_tags, StreamInterface* data, in GetDngInformation()
82 const std::uint32_t number_of_ifds, StreamInterface* stream, in GetPreviewData()
106 const std::uint32_t number_of_ifds, StreamInterface* stream, in GetPreviewData()
114 bool GetExifData(const std::uint32_t exif_offset, StreamInterface* stream, in GetExifData()
125 StreamInterface* stream, in GetThumbnailOffsetAndLength()
137 bool GetExifIfd(const Endian endian, StreamInterface* stream, in GetExifIfd()
163 const std::uint32_t skip_offset, StreamInterface* stream, in GetMakernoteIfd()
182 const Endian endian, StreamInterface* stream, in GetCameraSettingsIfd()
206 const Endian endian, StreamInterface* stream, in GetRawProcessingIfd()
229 bool GetOlympusPreviewImage(StreamInterface* stream, in GetOlympusPreviewImage()
[all …]
Dpiex.h62 bool IsRaw(StreamInterface* data);
73 Error GetPreviewImageData(StreamInterface* data,
78 bool GetDngInformation(StreamInterface* data, std::uint32_t* width,
84 bool GetOrientation(StreamInterface* data, std::uint32_t* orientation);
Dtiff_parser.cc128 void GetImageSize(const TiffDirectory& tiff_directory, StreamInterface* stream, in GetImageSize()
144 StreamInterface* stream, in FillPreviewImageData()
262 StreamInterface* stream, TiffDirectory* tiff_ifd) { in ParseSubIfds()
290 bool Get16u(StreamInterface* stream, const std::uint32_t offset, in Get16u()
305 bool Get32u(StreamInterface* stream, const std::uint32_t offset, in Get32u()
323 StreamInterface* stream, Error* error) { in GetData()
344 bool GetEndianness(const std::uint32_t tiff_offset, StreamInterface* stream, in GetEndianness()
365 bool GetImageData(const TiffDirectory& tiff_directory, StreamInterface* stream, in GetImageData()
429 bool GetJpegDimensions(const std::uint32_t jpeg_offset, StreamInterface* stream, in GetJpegDimensions()
469 const TagSet& desired_tags, StreamInterface* stream, in ParseDirectory()
[all …]
Dpiex_types.h108 class StreamInterface {
110 virtual ~StreamInterface() {} in ~StreamInterface()
/external/webrtc/talk/media/base/
Drtpdump.h106 explicit RtpDumpReader(rtc::StreamInterface* stream) in RtpDumpReader()
129 rtc::StreamInterface* stream_;
145 explicit RtpDumpLoopReader(rtc::StreamInterface* stream);
188 explicit RtpDumpWriter(rtc::StreamInterface* stream);
223 rtc::StreamInterface* stream_;
/external/webrtc/webrtc/libjingle/xmpp/
Dxmppsocket.h25 class StreamInterface; variable
57 void OnEvent(rtc::StreamInterface* stream, int events, int err);
62 rtc::StreamInterface *stream_;
/external/webrtc/webrtc/sound/
Dalsasoundsystem.h67 template <typename StreamInterface>
68 StreamInterface *OpenDevice(
72 StreamInterface *(AlsaSoundSystem::*start_fn)(
Dpulseaudiosoundsystem.h128 template <typename StreamInterface>
129 StreamInterface *OpenDevice(
133 StreamInterface *(PulseAudioSoundSystem::*connect_fn)(

123