Lines Matching defs:stream
63 STATE_FCPUBLISH, ///< client FCPublishing stream (for output)
80 URLContext* stream; ///< TCP stream used in interactions with RTMP server
86 char *playpath; ///< stream identifier to play (with possible "mp4:" prefix)
91 int stream_id; ///< ID assigned by the server for the stream
101 int skip_bytes; ///< number of bytes to skip from the input FLV stream in the next write call
108 char* tcurl; ///< url of the target stream
117 char* subscribe; ///< name of live stream to subscribe
127 int nb_streamid; ///< The next stream id to return on createStream calls
128 double duration; ///< Duration of the stream in seconds as returned by the server (only valid if non-zero)
251 ret = ff_rtmp_packet_write(rt->stream, pkt, rt->out_chunk_size,
426 if ((ret = ff_rtmp_packet_read(rt->stream, &pkt, rt->in_chunk_size,
497 ret = ff_rtmp_packet_write(rt->stream, &pkt, rt->out_chunk_size,
512 ret = ff_rtmp_packet_write(rt->stream, &pkt, rt->out_chunk_size,
526 ret = ff_rtmp_packet_write(rt->stream, &pkt, rt->out_chunk_size,
539 ret = ff_rtmp_packet_write(rt->stream, &pkt, rt->out_chunk_size,
574 ret = ff_rtmp_packet_write(rt->stream, &pkt, rt->out_chunk_size,
589 ret = ff_rtmp_packet_write(rt->stream, &pkt, rt->out_chunk_size,
610 av_log(s, AV_LOG_DEBUG, "Releasing stream...\n");
634 av_log(s, AV_LOG_DEBUG, "FCPublish stream...\n");
646 * the server destroy stream.
658 av_log(s, AV_LOG_DEBUG, "UnPublishing stream...\n");
678 av_log(s, AV_LOG_DEBUG, "Creating stream...\n");
703 av_log(s, AV_LOG_DEBUG, "Deleting stream...\n");
720 * knows the duration of the selected stream, it will reply with the duration
815 * Generate a pause packet that either pauses or unpauses the current stream.
836 ff_amf_write_number(&p, timestamp); //where we pause the stream
1118 URLContext *stream = NULL;
1124 if ((ret = ffurl_open_whitelist(&stream, rt->swfverify, AVIO_FLAG_READ,
1131 if ((in_size = ffurl_seek(stream, 0, AVSEEK_SIZE)) < 0) {
1141 if ((ret = ffurl_read_complete(stream, in_data, in_size)) < 0)
1190 ffurl_close(stream);
1237 if ((ret = ff_rtmpe_gen_pub_key(rt->stream, tosend + 1)) < 0)
1245 if ((ret = ffurl_write(rt->stream, tosend,
1251 if ((ret = ffurl_read_complete(rt->stream, serverdata,
1257 if ((ret = ffurl_read_complete(rt->stream, clientdata,
1306 if ((ret = ff_rtmpe_compute_secret_key(rt->stream, serverdata + 1,
1311 ff_rtmpe_encrypt_sig(rt->stream, signature, digest, serverdata[0]);
1335 ff_rtmpe_encrypt_sig(rt->stream, tosend +
1341 if ((ret = ffurl_write(rt->stream, tosend,
1347 if ((ret = ff_rtmpe_update_keystream(rt->stream)) < 0)
1354 if ((ret = ff_rtmpe_compute_secret_key(rt->stream, serverdata + 1,
1360 ff_rtmpe_encrypt_sig(rt->stream, signature, digest,
1365 if ((ret = ffurl_write(rt->stream, serverdata + 1,
1371 if ((ret = ff_rtmpe_update_keystream(rt->stream)) < 0)
1385 inoutsize = ffurl_read_complete(rt->stream, arraydata,
1407 inoutsize = ffurl_write(rt->stream, arraydata,
1433 inoutsize = ffurl_read_complete(rt->stream, buffer, 1); // Receive C0
1443 if (ffurl_write(rt->stream, buffer, 1) <= 0) { // Send S0
1509 if ((ret = ff_rtmp_packet_write(rt->stream, pkt, rt->out_chunk_size,
1851 ret = ff_rtmp_packet_write(rt->stream, &spkt, rt->out_chunk_size,
1894 ret = ff_rtmp_packet_write(rt->stream, &spkt, rt->out_chunk_size,
1934 av_log(s, AV_LOG_ERROR, "Unable to parse stream name - name too long?\n");
1936 av_log(s, AV_LOG_ERROR, "Unable to parse stream name\n");
1950 av_log(s, AV_LOG_WARNING, "Unexpected stream %s, expecting"
1981 "playing stream", NULL);
1999 * deleteStream. There is no stream creation control
2004 ret = ff_rtmp_packet_write(rt->stream, &spkt, rt->out_chunk_size,
2080 * stream is defined by the user or if it's a live stream. */
2420 if ((ret = ff_rtmp_packet_read(rt->stream, &rpkt,
2517 ffurl_closep(&rt->stream);
2522 * Insert a fake onMetadata packet into the FLV stream to notify the FLV
2523 * demuxer about the duration of the stream.
2526 * server at the start of the stream and if we were able to retrieve a valid
2586 * Open RTMP connection and verify that the stream can be played.
2666 if ((ret = ffurl_open_whitelist(&rt->stream, buf, AVIO_FLAG_READ_WRITE,
2830 ffurl_closep(&rt->stream);
2859 // first packet of an A/V stream, we have a better knowledge about the
2868 // If we received the first packet of an A/V stream and no metadata but
2882 s->max_packet_size = rt->stream->max_packet_size;
2928 "Seek on stream index %d at timestamp %"PRId64" with flags %08x\n",
2932 "Unable to send seek command on stream index %d at timestamp "
3065 /* set stream into nonblocking mode */
3066 rt->stream->flags |= AVIO_FLAG_NONBLOCK;
3068 /* try to read one byte from the stream */
3069 ret = ffurl_read(rt->stream, &c, 1);
3071 /* switch the stream back into blocking mode */
3072 rt->stream->flags &= ~AVIO_FLAG_NONBLOCK;
3082 if ((ret = ff_rtmp_packet_read_internal(rt->stream, &rpkt,
3107 {"rtmp_live", "Specify that the media is a live stream.", OFFSET(live), AV_OPT_TYPE_INT, {.i64 = -2}, INT_MIN, INT_MAX, DEC, "rtmp_live"},
3109 {"live", "live stream", 0, AV_OPT_TYPE_CONST, {.i64 = -1}, 0, 0, DEC, "rtmp_live"},
3110 {"recorded", "recorded stream", 0, AV_OPT_TYPE_CONST, {.i64 = 0}, 0, 0, DEC, "rtmp_live"},
3113 {"rtmp_subscribe", "Name of live stream to subscribe to. Defaults to rtmp_playpath.", OFFSET(subscribe), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC},
3118 {"rtmp_tcurl", "URL of the target stream. Defaults to proto://host[:port]/app.", OFFSET(tcurl), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},