Lines Matching refs:sink
189 MonoPipe* sink = out->dev->rsxSink.get(); in out_set_parameters() local
190 if (sink != NULL) { in out_set_parameters()
191 sink->incStrong(out); in out_set_parameters()
198 sink->shutdown(true); in out_set_parameters()
200 sink->decStrong(out); in out_set_parameters()
243 MonoPipe* sink = out->dev->rsxSink.get(); in out_write() local
244 if (sink != NULL) { in out_write()
245 if (sink->isShutdown()) { in out_write()
252 sink->incStrong(buffer); in out_write()
262 written_frames = sink->write(buffer, frames); in out_write()
268 sink->decStrong(buffer); in out_write()
276 written_frames = sink->write(buffer, frames); in out_write()
282 sink->decStrong(buffer); in out_write()
579 MonoPipe* sink = new MonoPipe(MAX_PIPE_DEPTH_IN_FRAMES, format, true/*writeCanBlock*/); in adev_open_output_stream() local
580 ssize_t index = sink->negotiate(offers, 1, NULL, numCounterOffers); in adev_open_output_stream()
582 MonoPipeReader* source = new MonoPipeReader(sink); in adev_open_output_stream()
586 rsxadev->rsxSink = sink; in adev_open_output_stream()
752 MonoPipe* sink = rsxadev->rsxSink.get(); in adev_close_input_stream() local
753 if (sink != NULL) { in adev_close_input_stream()
755 sink->shutdown(true); in adev_close_input_stream()