| /external/webrtc/webrtc/base/ |
| D | socketpool.h | 26 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 …]
|
| D | stream.h | 60 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 …]
|
| D | stream.cc | 41 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 …]
|
| D | socketpool.cc | 41 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 …]
|
| D | httpbase.h | 19 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_;
|
| D | httpserver.h | 43 int HandleConnection(StreamInterface* stream);
45 sigslot::signal3<HttpServer*, int, StreamInterface*> SignalConnectionClosed;
85 void BeginProcess(StreamInterface* stream);
86 StreamInterface* EndProcess();
128 StreamInterface* stream);
|
| D | multipart.h | 27 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);
|
| D | httpserver.cc | 38 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()
|
| D | httpclient.h | 33 StreamInterface* output, size_t* size);
36 bool HttpReadCacheHeaders(StreamInterface* input,
114 StreamInterface* request_doc);
117 StreamInterface* GetDocumentStream();
|
| D | httpclient.cc | 196 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 …]
|
| D | diskcache.h | 23 class StreamInterface; variable
46 StreamInterface* WriteResource(const std::string& id, size_t index);
49 StreamInterface* ReadResource(const std::string& id, size_t index) const;
|
| D | httpbase.cc | 242 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()
|
| /external/piex/src/ |
| D | tiff_parser.h | 111 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,
175 explicit TiffParser(StreamInterface* stream);
176 TiffParser(StreamInterface* stream, const std::uint32_t offset);
[all …]
|
| D | piex.cc | 54 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 …]
|
| D | piex.h | 62 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);
|
| D | tiff_parser.cc | 128 void GetImageSize(const TiffDirectory& tiff_directory, StreamInterface* stream, in GetImageSize()
144 StreamInterface* stream, in FillPreviewImageData()
265 StreamInterface* stream, TiffDirectory* tiff_ifd) { in ParseSubIfds()
293 bool Get16u(StreamInterface* stream, const std::uint32_t offset, in Get16u()
308 bool Get32u(StreamInterface* stream, const std::uint32_t offset, in Get32u()
326 StreamInterface* stream, Error* error) { in GetData()
347 bool GetEndianness(const std::uint32_t tiff_offset, StreamInterface* stream, in GetEndianness()
368 bool GetImageData(const TiffDirectory& tiff_directory, StreamInterface* stream, in GetImageData()
432 bool GetJpegDimensions(const std::uint32_t jpeg_offset, StreamInterface* stream, in GetJpegDimensions()
472 const TagSet& desired_tags, StreamInterface* stream, in ParseDirectory()
[all …]
|
| /external/puffin/src/include/puffin/ |
| D | stream.h | 16 class StreamInterface {
18 virtual ~StreamInterface() = default;
42 using UniqueStreamPtr = std::unique_ptr<StreamInterface>;
|
| /external/webrtc/talk/media/base/ |
| D | rtpdump.h | 106 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/llvm/include/llvm/DebugInfo/PDB/Raw/ |
| D | PDBFileBuilder.h | 25 class StreamInterface; variable
35 std::unique_ptr<codeview::StreamInterface> PdbFileBuffer);
51 std::unique_ptr<codeview::StreamInterface> PdbFileBuffer;
|
| /external/eigen/unsupported/Eigen/CXX11/src/Tensor/ |
| D | TensorDeviceCuda.h | 19 class StreamInterface {
21 virtual ~StreamInterface() {} in ~StreamInterface()
99 class CudaStreamDevice : public StreamInterface { in initializeDeviceProp()
186 explicit GpuDevice(const StreamInterface* stream) : stream_(stream), max_blocks_(INT_MAX) { in initializeDeviceProp()
189 …explicit GpuDevice(const StreamInterface* stream, int num_blocks) : stream_(stream), max_blocks_(n… in initializeDeviceProp()
313 const StreamInterface* stream_; in initializeDeviceProp()
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| D | xmppsocket.h | 25 class StreamInterface; variable
57 void OnEvent(rtc::StreamInterface* stream, int events, int err);
62 rtc::StreamInterface *stream_;
|
| /external/tensorflow/tensorflow/stream_executor/ |
| D | stream_executor_internal.h | 114 class StreamInterface {
117 StreamInterface() {} in StreamInterface() function
120 virtual ~StreamInterface() {} in ~StreamInterface()
138 SE_DISALLOW_COPY_AND_ASSIGN(StreamInterface);
360 virtual std::unique_ptr<StreamInterface> GetStreamImplementation() = 0;
384 using StreamFactory = std::function<StreamInterface *(StreamExecutor *)>;
|
| /external/webrtc/webrtc/sound/ |
| D | alsasoundsystem.h | 67 template <typename StreamInterface>
68 StreamInterface *OpenDevice(
72 StreamInterface *(AlsaSoundSystem::*start_fn)(
|
| /external/llvm/include/llvm/DebugInfo/CodeView/ |
| D | StreamRef.h | 22 StreamRef(const StreamInterface &Stream) in StreamRef()
24 StreamRef(const StreamInterface &Stream, uint32_t Offset, uint32_t Length) in StreamRef()
97 const StreamInterface *Stream;
|
| /external/puffin/src/ |
| D | stream_unittest.cc | 25 void TestRead(StreamInterface* stream, const Buffer& data) { in TestRead()
88 void TestWriteBoundary(StreamInterface* stream) { in TestWriteBoundary()
112 void TestWrite(StreamInterface* write_stream, StreamInterface* read_stream) { in TestWrite()
140 void TestSeek(StreamInterface* stream, bool seek_end_is_fine) { in TestSeek()
156 void TestClose(StreamInterface* stream) { ASSERT_TRUE(stream->Close()); } in TestClose()
|