yading@11: /*
yading@11:  * RTMP network protocol
yading@11:  * Copyright (c) 2010 Howard Chu
yading@11:  *
yading@11:  * This file is part of FFmpeg.
yading@11:  *
yading@11:  * FFmpeg is free software; you can redistribute it and/or
yading@11:  * modify it under the terms of the GNU Lesser General Public
yading@11:  * License as published by the Free Software Foundation; either
yading@11:  * version 2.1 of the License, or (at your option) any later version.
yading@11:  *
yading@11:  * FFmpeg is distributed in the hope that it will be useful,
yading@11:  * but WITHOUT ANY WARRANTY; without even the implied warranty of
yading@11:  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
yading@11:  * Lesser General Public License for more details.
yading@11:  *
yading@11:  * You should have received a copy of the GNU Lesser General Public
yading@11:  * License along with FFmpeg; if not, write to the Free Software
yading@11:  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
yading@11:  */
yading@11: 
yading@11: /**
yading@11:  * @file
yading@11:  * RTMP protocol based on http://rtmpdump.mplayerhq.hu/ librtmp
yading@11:  */
yading@11: 
yading@11: #include "libavutil/avstring.h"
yading@11: #include "libavutil/mathematics.h"
yading@11: #include "libavutil/opt.h"
yading@11: #include "avformat.h"
yading@11: #include "url.h"
yading@11: 
yading@11: #include <librtmp/rtmp.h>
yading@11: #include <librtmp/log.h>
yading@11: 
yading@11: typedef struct LibRTMPContext {
yading@11:     const AVClass *class;
yading@11:     RTMP rtmp;
yading@11:     char *app;
yading@11:     char *playpath;
yading@11: } LibRTMPContext;
yading@11: 
yading@11: static void rtmp_log(int level, const char *fmt, va_list args)
yading@11: {
yading@11:     switch (level) {
yading@11:     default:
yading@11:     case RTMP_LOGCRIT:    level = AV_LOG_FATAL;   break;
yading@11:     case RTMP_LOGERROR:   level = AV_LOG_ERROR;   break;
yading@11:     case RTMP_LOGWARNING: level = AV_LOG_WARNING; break;
yading@11:     case RTMP_LOGINFO:    level = AV_LOG_INFO;    break;
yading@11:     case RTMP_LOGDEBUG:   level = AV_LOG_VERBOSE; break;
yading@11:     case RTMP_LOGDEBUG2:  level = AV_LOG_DEBUG;   break;
yading@11:     }
yading@11: 
yading@11:     av_vlog(NULL, level, fmt, args);
yading@11:     av_log(NULL, level, "\n");
yading@11: }
yading@11: 
yading@11: static int rtmp_close(URLContext *s)
yading@11: {
yading@11:     LibRTMPContext *ctx = s->priv_data;
yading@11:     RTMP *r = &ctx->rtmp;
yading@11: 
yading@11:     RTMP_Close(r);
yading@11:     return 0;
yading@11: }
yading@11: 
yading@11: /**
yading@11:  * Open RTMP connection and verify that the stream can be played.
yading@11:  *
yading@11:  * URL syntax: rtmp://server[:port][/app][/playpath][ keyword=value]...
yading@11:  *             where 'app' is first one or two directories in the path
yading@11:  *             (e.g. /ondemand/, /flash/live/, etc.)
yading@11:  *             and 'playpath' is a file name (the rest of the path,
yading@11:  *             may be prefixed with "mp4:")
yading@11:  *
yading@11:  *             Additional RTMP library options may be appended as
yading@11:  *             space-separated key-value pairs.
yading@11:  */
yading@11: static int rtmp_open(URLContext *s, const char *uri, int flags)
yading@11: {
yading@11:     LibRTMPContext *ctx = s->priv_data;
yading@11:     RTMP *r = &ctx->rtmp;
yading@11:     int rc = 0, level;
yading@11:     char *filename = s->filename;
yading@11: 
yading@11:     switch (av_log_get_level()) {
yading@11:     default:
yading@11:     case AV_LOG_FATAL:   level = RTMP_LOGCRIT;    break;
yading@11:     case AV_LOG_ERROR:   level = RTMP_LOGERROR;   break;
yading@11:     case AV_LOG_WARNING: level = RTMP_LOGWARNING; break;
yading@11:     case AV_LOG_INFO:    level = RTMP_LOGINFO;    break;
yading@11:     case AV_LOG_VERBOSE: level = RTMP_LOGDEBUG;   break;
yading@11:     case AV_LOG_DEBUG:   level = RTMP_LOGDEBUG2;  break;
yading@11:     }
yading@11:     RTMP_LogSetLevel(level);
yading@11:     RTMP_LogSetCallback(rtmp_log);
yading@11: 
yading@11:     if (ctx->app || ctx->playpath) {
yading@11:         int len = strlen(s->filename) + 1;
yading@11:         if (ctx->app)      len += strlen(ctx->app)      + sizeof(" app=");
yading@11:         if (ctx->playpath) len += strlen(ctx->playpath) + sizeof(" playpath=");
yading@11: 
yading@11:         if (!(filename = av_malloc(len)))
yading@11:             return AVERROR(ENOMEM);
yading@11: 
yading@11:         av_strlcpy(filename, s->filename, len);
yading@11:         if (ctx->app) {
yading@11:             av_strlcat(filename, " app=", len);
yading@11:             av_strlcat(filename, ctx->app, len);
yading@11:         }
yading@11:         if (ctx->playpath) {
yading@11:             av_strlcat(filename, " playpath=", len);
yading@11:             av_strlcat(filename, ctx->playpath, len);
yading@11:         }
yading@11:     }
yading@11: 
yading@11:     RTMP_Init(r);
yading@11:     if (!RTMP_SetupURL(r, filename)) {
yading@11:         rc = AVERROR_UNKNOWN;
yading@11:         goto fail;
yading@11:     }
yading@11: 
yading@11:     if (flags & AVIO_FLAG_WRITE)
yading@11:         RTMP_EnableWrite(r);
yading@11: 
yading@11:     if (!RTMP_Connect(r, NULL) || !RTMP_ConnectStream(r, 0)) {
yading@11:         rc = AVERROR_UNKNOWN;
yading@11:         goto fail;
yading@11:     }
yading@11: 
yading@11:     s->is_streamed = 1;
yading@11:     rc = 0;
yading@11: fail:
yading@11:     if (filename != s->filename)
yading@11:         av_freep(&filename);
yading@11:     return rc;
yading@11: }
yading@11: 
yading@11: static int rtmp_write(URLContext *s, const uint8_t *buf, int size)
yading@11: {
yading@11:     LibRTMPContext *ctx = s->priv_data;
yading@11:     RTMP *r = &ctx->rtmp;
yading@11: 
yading@11:     return RTMP_Write(r, buf, size);
yading@11: }
yading@11: 
yading@11: static int rtmp_read(URLContext *s, uint8_t *buf, int size)
yading@11: {
yading@11:     LibRTMPContext *ctx = s->priv_data;
yading@11:     RTMP *r = &ctx->rtmp;
yading@11: 
yading@11:     return RTMP_Read(r, buf, size);
yading@11: }
yading@11: 
yading@11: static int rtmp_read_pause(URLContext *s, int pause)
yading@11: {
yading@11:     LibRTMPContext *ctx = s->priv_data;
yading@11:     RTMP *r = &ctx->rtmp;
yading@11: 
yading@11:     if (!RTMP_Pause(r, pause))
yading@11:         return AVERROR_UNKNOWN;
yading@11:     return 0;
yading@11: }
yading@11: 
yading@11: static int64_t rtmp_read_seek(URLContext *s, int stream_index,
yading@11:                               int64_t timestamp, int flags)
yading@11: {
yading@11:     LibRTMPContext *ctx = s->priv_data;
yading@11:     RTMP *r = &ctx->rtmp;
yading@11: 
yading@11:     if (flags & AVSEEK_FLAG_BYTE)
yading@11:         return AVERROR(ENOSYS);
yading@11: 
yading@11:     /* seeks are in milliseconds */
yading@11:     if (stream_index < 0)
yading@11:         timestamp = av_rescale_rnd(timestamp, 1000, AV_TIME_BASE,
yading@11:             flags & AVSEEK_FLAG_BACKWARD ? AV_ROUND_DOWN : AV_ROUND_UP);
yading@11: 
yading@11:     if (!RTMP_SendSeek(r, timestamp))
yading@11:         return AVERROR_UNKNOWN;
yading@11:     return timestamp;
yading@11: }
yading@11: 
yading@11: static int rtmp_get_file_handle(URLContext *s)
yading@11: {
yading@11:     LibRTMPContext *ctx = s->priv_data;
yading@11:     RTMP *r = &ctx->rtmp;
yading@11: 
yading@11:     return RTMP_Socket(r);
yading@11: }
yading@11: 
yading@11: #define OFFSET(x) offsetof(LibRTMPContext, x)
yading@11: #define DEC AV_OPT_FLAG_DECODING_PARAM
yading@11: #define ENC AV_OPT_FLAG_ENCODING_PARAM
yading@11: static const AVOption options[] = {
yading@11:     {"rtmp_app",      "Name of application to connect to on the RTMP server", OFFSET(app),      AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
yading@11:     {"rtmp_playpath", "Stream identifier to play or to publish",              OFFSET(playpath), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
yading@11:     { NULL },
yading@11: };
yading@11: 
yading@11: #define RTMP_CLASS(flavor)\
yading@11: static const AVClass lib ## flavor ## _class = {\
yading@11:     .class_name = "lib" #flavor " protocol",\
yading@11:     .item_name  = av_default_item_name,\
yading@11:     .option     = options,\
yading@11:     .version    = LIBAVUTIL_VERSION_INT,\
yading@11: };
yading@11: 
yading@11: RTMP_CLASS(rtmp)
yading@11: URLProtocol ff_librtmp_protocol = {
yading@11:     .name                = "rtmp",
yading@11:     .url_open            = rtmp_open,
yading@11:     .url_read            = rtmp_read,
yading@11:     .url_write           = rtmp_write,
yading@11:     .url_close           = rtmp_close,
yading@11:     .url_read_pause      = rtmp_read_pause,
yading@11:     .url_read_seek       = rtmp_read_seek,
yading@11:     .url_get_file_handle = rtmp_get_file_handle,
yading@11:     .priv_data_size      = sizeof(LibRTMPContext),
yading@11:     .priv_data_class     = &librtmp_class,
yading@11:     .flags               = URL_PROTOCOL_FLAG_NETWORK,
yading@11: };
yading@11: 
yading@11: RTMP_CLASS(rtmpt)
yading@11: URLProtocol ff_librtmpt_protocol = {
yading@11:     .name                = "rtmpt",
yading@11:     .url_open            = rtmp_open,
yading@11:     .url_read            = rtmp_read,
yading@11:     .url_write           = rtmp_write,
yading@11:     .url_close           = rtmp_close,
yading@11:     .url_read_pause      = rtmp_read_pause,
yading@11:     .url_read_seek       = rtmp_read_seek,
yading@11:     .url_get_file_handle = rtmp_get_file_handle,
yading@11:     .priv_data_size      = sizeof(LibRTMPContext),
yading@11:     .priv_data_class     = &librtmpt_class,
yading@11:     .flags               = URL_PROTOCOL_FLAG_NETWORK,
yading@11: };
yading@11: 
yading@11: RTMP_CLASS(rtmpe)
yading@11: URLProtocol ff_librtmpe_protocol = {
yading@11:     .name                = "rtmpe",
yading@11:     .url_open            = rtmp_open,
yading@11:     .url_read            = rtmp_read,
yading@11:     .url_write           = rtmp_write,
yading@11:     .url_close           = rtmp_close,
yading@11:     .url_read_pause      = rtmp_read_pause,
yading@11:     .url_read_seek       = rtmp_read_seek,
yading@11:     .url_get_file_handle = rtmp_get_file_handle,
yading@11:     .priv_data_size      = sizeof(LibRTMPContext),
yading@11:     .priv_data_class     = &librtmpe_class,
yading@11:     .flags               = URL_PROTOCOL_FLAG_NETWORK,
yading@11: };
yading@11: 
yading@11: RTMP_CLASS(rtmpte)
yading@11: URLProtocol ff_librtmpte_protocol = {
yading@11:     .name                = "rtmpte",
yading@11:     .url_open            = rtmp_open,
yading@11:     .url_read            = rtmp_read,
yading@11:     .url_write           = rtmp_write,
yading@11:     .url_close           = rtmp_close,
yading@11:     .url_read_pause      = rtmp_read_pause,
yading@11:     .url_read_seek       = rtmp_read_seek,
yading@11:     .url_get_file_handle = rtmp_get_file_handle,
yading@11:     .priv_data_size      = sizeof(LibRTMPContext),
yading@11:     .priv_data_class     = &librtmpte_class,
yading@11:     .flags               = URL_PROTOCOL_FLAG_NETWORK,
yading@11: };
yading@11: 
yading@11: RTMP_CLASS(rtmps)
yading@11: URLProtocol ff_librtmps_protocol = {
yading@11:     .name                = "rtmps",
yading@11:     .url_open            = rtmp_open,
yading@11:     .url_read            = rtmp_read,
yading@11:     .url_write           = rtmp_write,
yading@11:     .url_close           = rtmp_close,
yading@11:     .url_read_pause      = rtmp_read_pause,
yading@11:     .url_read_seek       = rtmp_read_seek,
yading@11:     .url_get_file_handle = rtmp_get_file_handle,
yading@11:     .priv_data_size      = sizeof(LibRTMPContext),
yading@11:     .priv_data_class     = &librtmps_class,
yading@11:     .flags               = URL_PROTOCOL_FLAG_NETWORK,
yading@11: };