Searched defs:sink (Results 76 - 100 of 154) sorted by relevance

1234567

/external/chromium_org/third_party/webrtc/modules/video_coding/main/test/
H A Dvcm_payload_sink_factory.cc174 scoped_ptr<VcmPayloadSink> sink(
177 sinks_.push_back(sink.get());
178 return sink.release();
213 void VcmPayloadSinkFactory::Remove(VcmPayloadSink* sink) { argument
214 assert(sink);
216 Sinks::iterator it = std::find(sinks_.begin(), sinks_.end(), sink);
/external/icu/icu4c/source/i18n/
H A Dcollationruleparser.h114 sink = sinkAlias;
186 Sink *sink; member in class:CollationRuleParser
/external/okhttp/okio/src/main/java/okio/
H A DGzipSource.java49 * decompressed sink buffers.
62 @Override public long read(OkBuffer sink, long byteCount) throws IOException { argument
74 long offset = sink.size;
75 long result = inflaterSource.read(sink, byteCount);
77 updateCrc(sink, offset, result);
H A DRealBufferedSink.java23 public final Sink sink; field in class:RealBufferedSink
26 public RealBufferedSink(Sink sink, OkBuffer buffer) { argument
27 if (sink == null) throw new IllegalArgumentException("sink == null");
29 this.sink = sink;
32 public RealBufferedSink(Sink sink) { argument
33 this(sink, new OkBuffer());
116 if (byteCount > 0) sink.write(buffer, byteCount);
154 sink
[all...]
H A DOkBuffer.java103 @Override public int read(byte[] sink, int offset, int byteCount) {
104 return OkBuffer.this.read(sink, offset, byteCount);
122 * number of bytes that can be flushed immediately to an underlying sink
364 int read(byte[] sink, int offset, int byteCount) { argument
368 System.arraycopy(s.data, s.pos, sink, offset, toCopy);
561 // Occasionally we write only part of a source buffer to a sink buffer. For
562 // example, given a sink [51%, 91%], we may want to write the first 30% of
565 // yielding sink [51%, 91%, 30%] and source [62%, 82%].
607 @Override public long read(OkBuffer sink, long byteCount) { argument
610 sink
[all...]
/external/chromium_org/chrome/browser/extensions/api/alarms/
H A Dalarms_api_unittest.cc281 IPC::TestSink& sink = static_cast<content::MockRenderProcessHost*>( local
282 contents()->GetRenderViewHost()->GetProcess())->sink();
283 const IPC::Message* warning = sink.GetUniqueMessageMatching(
/external/chromium_org/content/renderer/media/
H A Dmedia_stream_video_track.cc221 MediaStreamVideoSink* sink, const VideoCaptureDeliverFrameCB& callback) {
223 DCHECK(std::find(sinks_.begin(), sinks_.end(), sink) == sinks_.end());
224 sinks_.push_back(sink);
225 frame_deliverer_->AddCallback(sink, callback);
228 void MediaStreamVideoTrack::RemoveSink(MediaStreamVideoSink* sink) { argument
231 std::find(sinks_.begin(), sinks_.end(), sink);
234 frame_deliverer_->RemoveCallback(sink);
220 AddSink( MediaStreamVideoSink* sink, const VideoCaptureDeliverFrameCB& callback) argument
H A Dmedia_stream_video_track_unittest.cc49 void DeliverVideoFrameAndWaitForRenderer(MockMediaStreamVideoSink* sink) { argument
52 EXPECT_CALL(*sink, OnVideoFrame()).WillOnce(
99 MockMediaStreamVideoSink sink; local
102 &sink, sink.GetDeliverFrameCB(), track);
104 DeliverVideoFrameAndWaitForRenderer(&sink);
105 EXPECT_EQ(1, sink.number_of_frames());
107 DeliverVideoFrameAndWaitForRenderer(&sink);
109 MediaStreamVideoSink::RemoveFromVideoTrack(&sink, track);
118 EXPECT_EQ(2, sink
149 MockMediaStreamVideoSink sink; local
166 MockMediaStreamVideoSink sink; local
194 MockMediaStreamVideoSink sink; local
[all...]
H A Dmedia_stream_video_source_unittest.cc124 MockMediaStreamVideoSink sink; local
126 &sink, sink.GetDeliverFrameCB(), track);
127 DeliverVideoFrameAndWaitForRenderer(capture_width, capture_height, &sink);
128 EXPECT_EQ(1, sink.number_of_frames());
131 EXPECT_EQ(expected_height, sink.frame_size().height());
132 EXPECT_EQ(expected_width, sink.frame_size().width());
133 MediaStreamVideoSink::RemoveFromVideoTrack(&sink, track);
137 MockMediaStreamVideoSink* sink) {
140 EXPECT_CALL(*sink, OnVideoFram
136 DeliverVideoFrameAndWaitForRenderer(int width, int height, MockMediaStreamVideoSink* sink) argument
672 MockMediaStreamVideoSink sink; local
738 MockMediaStreamVideoSink sink; local
766 MockMediaStreamVideoSink sink; local
[all...]
H A Dwebrtc_audio_device_impl.cc80 // webrtc::AudioTransport sink. Keep writing until our internal byte
207 // Notify the playout sink of the change.
498 WebRtcPlayoutDataSource::Sink* sink) {
500 DCHECK(sink);
502 DCHECK(std::find(playout_sinks_.begin(), playout_sinks_.end(), sink) ==
504 playout_sinks_.push_back(sink);
508 WebRtcPlayoutDataSource::Sink* sink) {
510 DCHECK(sink);
512 playout_sinks_.remove(sink);
497 AddPlayoutSink( WebRtcPlayoutDataSource::Sink* sink) argument
507 RemovePlayoutSink( WebRtcPlayoutDataSource::Sink* sink) argument
/external/chromium_org/courgette/
H A Dencoded_program_fuzz_unittest.cc60 courgette::SinkStream sink; local
61 bool can_collect = sinks.CopyTo(&sink);
64 size_t length = sink.Length();
66 std::string base_buffer(reinterpret_cast<const char*>(sink.Buffer()), length);
H A Dstreams.cc125 void SourceStream::Init(const SinkStream& sink) { argument
126 Init(sink.Buffer(), sink.Length());
/external/chromium_org/third_party/angle/src/compiler/translator/
H A DValidateLimitations.cpp139 TInfoSinkBase &sink)
141 mSink(sink),
138 ValidateLimitations(sh::GLenum shaderType, TInfoSinkBase &sink) argument
H A DparseConst.cpp17 TOperator constructType, TInfoSink &sink, TType &t)
24 mInfoSink(sink),
16 TConstTraverser(ConstantUnion *cUnion, bool singleConstParam, TOperator constructType, TInfoSink &sink, TType &t) argument
/external/chromium_org/third_party/skia/src/views/
H A DSkEventSink.cpp55 SkEventSink* sink = globals.fSinkHead; local
59 SkEventSink* next = sink->fNextSink;
60 if (sink == this) {
68 prev = sink;
69 sink = next;
164 void SkEventSink::copyListeners(const SkEventSink& sink) argument
166 SkListenersTagList* sinkList = (SkListenersTagList*)sink.findTagList(kListeners_SkTagList);
228 SkEventSink* sink = SkEventSink::FindSink(evt.getTargetID()); local
229 if (sink) {
230 return sink
243 SkEventSink* sink = globals.fSinkHead; local
[all...]
/external/chromium_org/third_party/webrtc/base/
H A Dhttpbase_unittest.cc113 testing::StreamSink sink; member in class:rtc::HttpBaseTest
191 sink.Monitor(http_stream);
198 EXPECT_EQ(0, sink.Events(http_stream));
211 EXPECT_EQ(SE_OPEN | SE_READ, sink.Events(http_stream));
251 EXPECT_EQ(0, sink.Events(http_stream));
506 EXPECT_EQ(testing::SSE_ERROR, sink.Events(http_stream));
/external/clang/test/SemaCXX/
H A Dlinkage-spec.cpp114 int sink; member in struct:PR9162::_ArtsSink
/external/kernel-headers/original/uapi/linux/
H A Dmedia.h116 struct media_pad_desc sink; member in struct:media_link_desc
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
H A DRequest.java161 public abstract void writeTo(BufferedSink sink) throws IOException; argument
193 @Override public void writeTo(BufferedSink sink) throws IOException {
194 sink.write(content);
213 @Override public void writeTo(BufferedSink sink) throws IOException {
222 sink.write(buffer, 0, c);
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/
H A DSpdyTransport.java265 @Override public long read(OkBuffer sink, long byteCount) argument
271 long read = source.read(sink, byteCount);
281 Okio.copy(sink, sink.size() - read, read, cacheBody);
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/
H A DSpdyStream.java66 final SpdyDataSink sink; field in class:SpdyStream
85 this.sink = new SpdyDataSink();
87 this.sink.finished = outFinished;
111 && (sink.finished || sink.closed)
192 this.sink.finished = true;
221 * Returns a sink that can be used to write data to the peer.
229 throw new IllegalStateException("reply before requesting the sink");
232 return sink;
264 if (source.finished && sink
362 read(OkBuffer sink, long byteCount) argument
[all...]
/external/skia/src/views/
H A DSkEventSink.cpp55 SkEventSink* sink = globals.fSinkHead; local
59 SkEventSink* next = sink->fNextSink;
60 if (sink == this) {
68 prev = sink;
69 sink = next;
164 void SkEventSink::copyListeners(const SkEventSink& sink) argument
166 SkListenersTagList* sinkList = (SkListenersTagList*)sink.findTagList(kListeners_SkTagList);
228 SkEventSink* sink = SkEventSink::FindSink(evt.getTargetID()); local
229 if (sink) {
230 return sink
243 SkEventSink* sink = globals.fSinkHead; local
[all...]
/external/ceres-solver/internal/ceres/miniglog/glog/
H A Dlogging.h129 // added, all log output is also sent to each sink through the send function.
152 // Note: the Log sink functions are not thread safe.
153 inline void AddLogSink(LogSink *sink) { argument
155 log_sinks_global.insert(sink);
157 inline void RemoveLogSink(LogSink *sink) { argument
158 log_sinks_global.erase(sink);
/external/chromium_org/components/cronet/android/java/src/org/chromium/net/
H A DHttpUrlConnectionUrlRequest.java105 WritableByteChannel sink, HttpUrlRequestListener listener) {
115 mSink = sink;
103 HttpUrlConnectionUrlRequest(Context context, String url, int requestPriority, Map<String, String> headers, WritableByteChannel sink, HttpUrlRequestListener listener) argument
/external/chromium_org/media/audio/win/
H A Daudio_low_latency_input_win_unittest.cc85 // This audio sink implementation should be used for manual tests only since
317 MockAudioInputCallback sink; local
318 ais->Start(&sink);
330 MockAudioInputCallback sink; local
331 ais->Start(&sink);
350 MockAudioInputCallback sink; local
353 ais->Start(&sink);
355 ais->Start(&sink);
382 MockAudioInputCallback sink; local
391 EXPECT_CALL(sink, OnDat
454 FakeAudioInputCallback sink; local
[all...]

Completed in 606 milliseconds

1234567