Home
last modified time | relevance | path

Searched refs:cstream (Results 1 – 25 of 28) sorted by relevance

12

/third_party/gstreamer/gstplugins_bad/gst/rtmp2/rtmp/
Drtmpchunkstream.c78 chunk_stream_is_open (GstRtmpChunkStream * cstream) in chunk_stream_is_open() argument
80 return cstream->map.data != NULL; in chunk_stream_is_open()
84 chunk_stream_take_buffer (GstRtmpChunkStream * cstream, GstBuffer * buffer) in chunk_stream_take_buffer() argument
88 g_assert (cstream->buffer == NULL); in chunk_stream_take_buffer()
89 cstream->buffer = buffer; in chunk_stream_take_buffer()
90 cstream->meta = meta; in chunk_stream_take_buffer()
94 chunk_stream_clear (GstRtmpChunkStream * cstream) in chunk_stream_clear() argument
96 if (chunk_stream_is_open (cstream)) { in chunk_stream_clear()
97 gst_buffer_unmap (cstream->buffer, &cstream->map); in chunk_stream_clear()
98 cstream->map.data = NULL; in chunk_stream_clear()
[all …]
Drtmpchunkstream.h33 void gst_rtmp_chunk_stream_clear (GstRtmpChunkStream * cstream);
36 guint32 gst_rtmp_chunk_stream_parse_header (GstRtmpChunkStream * cstream,
38 guint32 gst_rtmp_chunk_stream_parse_payload (GstRtmpChunkStream * cstream,
40 guint32 gst_rtmp_chunk_stream_wrote_payload (GstRtmpChunkStream * cstream,
42 GstBuffer * gst_rtmp_chunk_stream_parse_finish (GstRtmpChunkStream * cstream);
44 GstBuffer * gst_rtmp_chunk_stream_serialize_start (GstRtmpChunkStream * cstream,
46 GstBuffer * gst_rtmp_chunk_stream_serialize_next (GstRtmpChunkStream * cstream,
48 GstBuffer * gst_rtmp_chunk_stream_serialize_all (GstRtmpChunkStream * cstream,
Drtmpmessage.c168 emeta->cstream = 0; in gst_rtmp_meta_init()
194 dmeta->cstream = smeta->cstream; in gst_rtmp_meta_transform()
231 gst_rtmp_message_new (GstRtmpMessageType type, guint32 cstream, guint32 mstream) in gst_rtmp_message_new() argument
237 meta->cstream = cstream; in gst_rtmp_message_new()
244 gst_rtmp_message_new_wrapped (GstRtmpMessageType type, guint32 cstream, in gst_rtmp_message_new_wrapped() argument
247 GstBuffer *message = gst_rtmp_message_new (type, cstream, mstream); in gst_rtmp_message_new_wrapped()
275 prefix, meta->cstream, meta->mstream, meta->ts_delta, meta->size, in gst_rtmp_buffer_dump()
315 if (meta->cstream != GST_RTMP_CHUNK_STREAM_PROTOCOL) { in gst_rtmp_message_is_protocol_control()
317 G_GUINT32_FORMAT ", not 2", meta->cstream); in gst_rtmp_message_is_protocol_control()
339 if (meta->cstream != GST_RTMP_CHUNK_STREAM_PROTOCOL) { in gst_rtmp_message_is_user_control()
[all …]
Drtmpmessage.h79 guint32 cstream; member
97 GstBuffer * gst_rtmp_message_new (GstRtmpMessageType type, guint32 cstream,
99 GstBuffer * gst_rtmp_message_new_wrapped (GstRtmpMessageType type, guint32 cstream,
Drtmpconnection.c522 GstRtmpChunkStream *cstream; in gst_rtmp_connection_start_write() local
547 cstream = gst_rtmp_chunk_streams_get (self->output_streams, meta->cstream); in gst_rtmp_connection_start_write()
548 if (!cstream) { in gst_rtmp_connection_start_write()
554 chunks = gst_rtmp_chunk_stream_serialize_all (cstream, message, in gst_rtmp_connection_start_write()
678 GstRtmpChunkStream *cstream; in gst_rtmp_connection_do_read() local
690 cstream = gst_rtmp_chunk_streams_get (sc->input_streams, chunk_stream_id); in gst_rtmp_connection_do_read()
691 header_size = gst_rtmp_chunk_stream_parse_header (cstream, in gst_rtmp_connection_do_read()
699 next_size = gst_rtmp_chunk_stream_parse_payload (cstream, in gst_rtmp_connection_do_read()
710 next_size = gst_rtmp_chunk_stream_wrote_payload (cstream, in gst_rtmp_connection_do_read()
714 GstBuffer *buffer = gst_rtmp_chunk_stream_parse_finish (cstream); in gst_rtmp_connection_do_read()
/third_party/glib/gio/
Dgconverteroutputstream.c177 GConverterOutputStream *cstream; in g_converter_output_stream_set_property() local
179 cstream = G_CONVERTER_OUTPUT_STREAM (object); in g_converter_output_stream_set_property()
184 cstream->priv->converter = g_value_dup_object (value); in g_converter_output_stream_set_property()
201 GConverterOutputStream *cstream; in g_converter_output_stream_get_property() local
203 cstream = G_CONVERTER_OUTPUT_STREAM (object); in g_converter_output_stream_get_property()
204 priv = cstream->priv; in g_converter_output_stream_get_property()
403 GConverterOutputStream *cstream; in write_internal() local
414 cstream = G_CONVERTER_OUTPUT_STREAM (stream); in write_internal()
415 priv = cstream->priv; in write_internal()
419 if (!flush_buffer (cstream, blocking, cancellable, error)) in write_internal()
[all …]
Dgconverterinputstream.c161 GConverterInputStream *cstream; in g_converter_input_stream_set_property() local
163 cstream = G_CONVERTER_INPUT_STREAM (object); in g_converter_input_stream_set_property()
168 cstream->priv->converter = g_value_dup_object (value); in g_converter_input_stream_set_property()
185 GConverterInputStream *cstream; in g_converter_input_stream_get_property() local
187 cstream = G_CONVERTER_INPUT_STREAM (object); in g_converter_input_stream_get_property()
188 priv = cstream->priv; in g_converter_input_stream_get_property()
386 GConverterInputStream *cstream; in read_internal() local
396 cstream = G_CONVERTER_INPUT_STREAM (stream); in read_internal()
397 priv = cstream->priv; in read_internal()
424 nread = fill_input_buffer (cstream, count, blocking, cancellable, error); in read_internal()
[all …]
/third_party/glib/gio/tests/
Dconverter-stream.c295 GInputStream *mem, *cstream; in test_expander() local
322 cstream = g_converter_input_stream_new (mem, expander); in test_expander()
323 …g_assert (g_converter_input_stream_get_converter (G_CONVERTER_INPUT_STREAM (cstream)) == expander); in test_expander()
324 g_object_get (cstream, "converter", &converter, NULL); in test_expander()
334 res = g_input_stream_read (cstream, in test_expander()
379 g_object_unref (cstream); in test_expander()
392 GInputStream *mem, *cstream; in test_compressor() local
416 cstream = g_converter_input_stream_new (mem, compressor); in test_compressor()
424 res = g_input_stream_read (cstream, in test_compressor()
437 g_object_unref (cstream); in test_compressor()
[all …]
/third_party/boost/libs/convert/test/
Dperformance.cpp258 local::str_to<int>(boost::cnv::cstream())); in main()
264 local::str_to<long int>(boost::cnv::cstream())); in main()
270 local::str_to<double>(boost::cnv::cstream())); in main()
277 local::to_str<std::string, int>(boost::cnv::cstream())); in main()
283 local::to_str<std::string, long int>(boost::cnv::cstream())); in main()
289 local::to_str<std::string, double>(boost::cnv::cstream()(arg::precision = 6))); in main()
293 performance_str_to_type(boost::cnv::cstream()), in main()
297 performance_type_to_str(boost::cnv::cstream()), in main()
308 local::to_str<std::string, int>(boost::cnv::cstream()), in main()
309 local::to_str< my_string, int>(boost::cnv::cstream())); in main()
Dstream_converter.cpp33 boost::cnv::cstream cnv; in test_dbl_to_str()
57 boost::cnv::cstream ccnv; in test_numbase()
101 boost::cnv::cstream cnv; in test_boolalpha()
122 boost::cnv::cstream ccnv; in test_skipws_char()
169 boost::cnv::cstream cnv; in test_width()
200 boost::cnv::cstream ccnv; in test_manipulators()
243 boost::cnv::cstream cnv; in test_locale_example()
281 test_locale(double v, boost::cnv::cstream const& cnv, char const* expected) in test_locale()
297 boost::cnv::cstream cnv; in test_locale()
339 boost::cnv::cstream cnv; in test_user_str()
Duser_type.cpp25 boost::cnv::cstream cnv; // stringstream-based char converter in test_user_type()
62 boost::cnv::cstream cnv; in test_algorithms()
Dfallbacks.cpp37 boost::cnv::cstream cnv; in main()
Dstr_to_int.cpp136 boost::cnv::cstream stream_cnv; in main()
/third_party/lz4/ossfuzz/
Dround_trip_stream_fuzzer.c31 LZ4_stream_t* cstream; member
72 state.cstream = LZ4_createStream(); in state_create()
73 FUZZ_ASSERT(state.cstream); in state_create()
75 FUZZ_ASSERT(state.cstream); in state_create()
86 LZ4_freeStream(state.cstream); in state_free()
94 LZ4_resetStream_fast(state->cstream); in state_reset()
147 int const cSize = LZ4_compress_fast_continue(state->cstream, src, dst, in state_prefixRoundTrip()
168 int const cSize = LZ4_compress_fast_continue(state->cstream, src, dst, in state_extDictRoundTrip()
192 LZ4_loadDict(state->cstream, dict, dictSize); in state_loadDictRoundTrip()
203 LZ4_attach_dictionary(state->cstream, dictStream); in state_attachDictRoundTrip()
/third_party/boost/libs/convert/example/
Dgetting_serious.cpp24 struct boost::cnv::by_default : boost::cnv::cstream {};
30 boost::cnv::cstream cnv; in example1()
92 boost::cnv::cstream cnv; in example4()
115 boost::cnv::cstream cnv; in example7()
Dalgorithms.cpp27 boost::cnv::cstream cnv; in introduction()
100 boost::cnv::cstream cnv; in example3()
126 boost::cnv::cstream cnv; in example4()
161 boost::cnv::cstream cnv; in example5()
Dstream.cpp16 struct boost::cnv::by_default : boost::cnv::cstream {};
45 boost::cnv::cstream ccnv; in example2()
79 boost::cnv::cstream cnv1; in example6()
Dgetting_started.cpp120 boost::cnv::cstream cnv; in getting_started_example4()
147 boost::cnv::cstream cnv; in getting_started_example5()
167 boost::cnv::cstream cnv; in getting_started_example6()
191 boost::cnv::cstream cnv; in getting_started_example7()
Ddefault_converter.cpp12 struct boost::cnv::by_default : boost::cnv::cstream {};
16 struct boost::cnv::by_default : boost::cnv::cstream
/third_party/grpc/test/cpp/end2end/
Dmock_test.cc87 std::unique_ptr<ClientWriterInterface<EchoRequest>> cstream = in DoRequestStream() local
91 EXPECT_TRUE(cstream->Write(request)); in DoRequestStream()
96 EXPECT_TRUE(cstream->Write(request)); in DoRequestStream()
98 cstream->WritesDone(); in DoRequestStream()
99 Status s = cstream->Finish(); in DoRequestStream()
111 std::unique_ptr<ClientReaderInterface<EchoResponse>> cstream = in DoResponseStream() local
115 EXPECT_TRUE(cstream->Read(&response)); in DoResponseStream()
118 EXPECT_TRUE(cstream->Read(&response)); in DoResponseStream()
121 EXPECT_FALSE(cstream->Read(&response)); in DoResponseStream()
124 Status s = cstream->Finish(); in DoResponseStream()
/third_party/boost/libs/convert/doc/
Dstream_converter.qbk104 …put the result of the requested conversion to. Conceptually `boost::cnv::cstream` achieves that wi…
120 [note [*By default] the `boost::cnv::cstream` and `boost::cnv::wstream` converters require the ['Ty…
136 Now such class can be deployed with `boost::cnv::cstream`:
Ddefault_converter.qbk31 the code compiles and deploys `boost::cnv::cstream` when `boost::convert()` is called without an ex…
Dperformance.qbk29 For user-defined types `cnv::lexical_cast`, `cnv::cstream` and `cnv::strtol` were tested with the f…
34 … deploy the same standard `std::iostream` library. However, `boost::cnv::cstream` considerably out…
/third_party/gstreamer/gstplugins_bad/gst/rtmp2/
Dgstrtmp2sink.c666 guint32 cstream; in buffer_to_message() local
730 cstream = 4; in buffer_to_message()
734 cstream = 5; in buffer_to_message()
738 cstream = 6; in buffer_to_message()
747 message = gst_rtmp_message_new (header.type, cstream, 0); in buffer_to_message()
/third_party/boost/boost/convert/
Dstream.hpp28 using cstream = boost::cnv::basic_stream<char>; typedef

12