[FFmpeg-devel] 喔打泼上Re: [PATCH] lavf: add SFTP哦哦了巍峨哦!怕饿惹得地的大山东省审时度势第三代审时度势的是SOS DOS d SSSS店酸涩大老‘ protocol via libssh

Gale gale320 at gmail.com
Sun Sep 22 02:21:16 CEST 2013


啊啊啊是啊啊a泽阿as啊啊啊萨则大as AAA SASA a SASA SaaS AAAAA SA ADS as AAAAA色泽啊神色阿SA a
SASA as a SaaS a酸涩大则达阿洒色ASA SaaS啊AAAAA咋AAA试试AAAA阿斯阿a皑皑噢嚄艾AAAA哦哦啊哦哦啊啊啊啊萨则大啊的a
在 2013-9-18 下午10:29,"Lukasz Marek" <lukasz.m.luki at gmail.com>写道:

> Signed-off-by: Lukasz Marek <lukasz.m.luki at gmail.com>
> ---
>  Changelog                |    1 +
>  configure                |    4 +
>  doc/protocols.texi       |   32 +++++++
>  libavformat/Makefile     |    1 +
>  libavformat/allformats.c |    1 +
>  libavformat/libssh.c     |  230
> ++++++++++++++++++++++++++++++++++++++++++++++
>  6 files changed, 269 insertions(+)
>  create mode 100644 libavformat/libssh.c
>
> diff --git a/Changelog b/Changelog
> index 3e4653b..809a1fd 100644
> --- a/Changelog
> +++ b/Changelog
> @@ -25,6 +25,7 @@ version <next>
>    more consistent with other muxers.
>  - adelay filter
>  - pullup filter ported from libmpcodecs
> +- SFTP protocol (via libssh)
>
>
>  version 2.0:
> diff --git a/configure b/configure
> index e0a6073..a127cdf 100755
> --- a/configure
> +++ b/configure
> @@ -225,6 +225,7 @@ External library support:
>    --enable-libshine        enable fixed-point MP3 encoding via libshine
> [no]
>    --enable-libsoxr         enable Include libsoxr resampling [no]
>    --enable-libspeex        enable Speex de/encoding via libspeex [no]
> +  --enable-libssh          enable SFTP protocol via libssh [no]
>    --enable-libstagefright-h264  enable H.264 decoding via libstagefright
> [no]
>    --enable-libtheora       enable Theora encoding via libtheora [no]
>    --enable-libtwolame      enable MP2 encoding via libtwolame [no]
> @@ -1191,6 +1192,7 @@ EXTERNAL_LIBRARY_LIST="
>      libshine
>      libsoxr
>      libspeex
> +    libssh
>      libstagefright_h264
>      libtheora
>      libtwolame
> @@ -2158,6 +2160,7 @@ librtmpe_protocol_deps="librtmp"
>  librtmps_protocol_deps="librtmp"
>  librtmpt_protocol_deps="librtmp"
>  librtmpte_protocol_deps="librtmp"
> +libssh_protocol_deps="libssh"
>  mmsh_protocol_select="http_protocol"
>  mmst_protocol_select="network"
>  rtmp_protocol_deps="!librtmp_protocol"
> @@ -4222,6 +4225,7 @@ enabled librtmp           && require_pkg_config
> librtmp librtmp/rtmp.h RTMP_Sock
>  enabled libschroedinger   && require_pkg_config schroedinger-1.0
> schroedinger/schro.h schro_init
>  enabled libshine          && require_pkg_config shine shine/layer3.h
> shine_encode_buffer
>  enabled libsoxr           && require libsoxr soxr.h soxr_create -lsoxr
> +enabled libssh            && require_pkg_config libssh libssh/sftp.h
> sftp_init
>  enabled libspeex          && require libspeex speex/speex.h
> speex_decoder_init -lspeex
>  enabled libstagefright_h264 && require_cpp libstagefright_h264
> "binder/ProcessState.h media/stagefright/MetaData.h
>      media/stagefright/MediaBufferGroup.h media/stagefright/MediaDebug.h
> media/stagefright/MediaDefs.h
> diff --git a/doc/protocols.texi b/doc/protocols.texi
> index 5c43f01..15a3443 100644
> --- a/doc/protocols.texi
> +++ b/doc/protocols.texi
> @@ -520,6 +520,38 @@ The Real-Time Messaging Protocol tunneled through
> HTTPS (RTMPTS) is used
>  for streaming multimedia content within HTTPS requests to traverse
>  firewalls.
>
> + at section libssh
> +
> +Secure File Transfer Protocol via libssh
> +
> +Allow to read from or write to remote resources using SFTP protocol.
> +
> +Following syntax is required.
> +
> + at example
> +sftp://[user[:password]@@]server[:port]/path/to/remote/resource.mpeg
> + at end example
> +
> +This protocol accepts the following options.
> +
> + at table @option
> + at item timeout’
> +Set timeout of socket I/O operations used by the underlying low level
> +operation. By default it is set to -1, which means that the timeout
> +is not specified.
> +
> + at item truncate
> +Truncate existing files on write, if set to 1. A value of 0 prevents
> +truncating. Default value is 1.
> +
> + at end table
> +
> +Example: play a file stored on remote server.
> +
> + at example
> +ffplay sftp://user:password@@server_address:22/home/user/resource.mpeg
> + at end example
> +
>  @section librtmp rtmp, rtmpe, rtmps, rtmpt, rtmpte
>
>  Real-Time Messaging Protocol and its variants supported through
> diff --git a/libavformat/Makefile b/libavformat/Makefile
> index ceffa78..f56cc72 100644
> --- a/libavformat/Makefile
> +++ b/libavformat/Makefile
> @@ -425,6 +425,7 @@ OBJS-$(CONFIG_LIBNUT_DEMUXER)            += libnut.o
>  OBJS-$(CONFIG_LIBNUT_MUXER)              += libnut.o
>  OBJS-$(CONFIG_LIBQUVI_DEMUXER)           += libquvi.o
>  OBJS-$(CONFIG_LIBRTMP)                   += librtmp.o
> +OBJS-$(CONFIG_LIBSSH_PROTOCOL)           += libssh.o
>
>  # protocols I/O
>  OBJS-$(CONFIG_APPLEHTTP_PROTOCOL)        += hlsproto.o
> diff --git a/libavformat/allformats.c b/libavformat/allformats.c
> index 03c883b..e9eafb4 100644
> --- a/libavformat/allformats.c
> +++ b/libavformat/allformats.c
> @@ -348,4 +348,5 @@ void av_register_all(void)
>      REGISTER_PROTOCOL(LIBRTMPS,         librtmps);
>      REGISTER_PROTOCOL(LIBRTMPT,         librtmpt);
>      REGISTER_PROTOCOL(LIBRTMPTE,        librtmpte);
> +    REGISTER_PROTOCOL(LIBSSH,           libssh);
>  }
> diff --git a/libavformat/libssh.c b/libavformat/libssh.c
> new file mode 100644
> index 0000000..a175303
> --- /dev/null
> +++ b/libavformat/libssh.c
> @@ -0,0 +1,230 @@
> +/*
> + * Copyright (c) 2013 Lukasz Marek <lukasz.m.luki at gmail.com>
> + *
> + * This file is part of FFmpeg.
> + *
> + * FFmpeg is free software; you can redistribute it and/or
> + * modify it under the terms of the GNU Lesser General Public
> + * License as published by the Free Software Foundation; either
> + * version 2.1 of the License, or (at your option) any later version.
> + *
> + * FFmpeg is distributed in the hope that it will be useful,
> + * but WITHOUT ANY WARRANTY; without even the implied warranty of
> + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
> + * Lesser General Public License for more details.
> + *
> + * You should have received a copy of the GNU Lesser General Public
> + * License along with FFmpeg; if not, write to the Free Software
> + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
> 02110-1301 USA
> + */
> +
> +#define DEBUG 1
> +
> +#include "libavutil/avstring.h"
> +#include "avformat.h"
> +#include "internal.h"
> +#include "url.h"
> +#include "libavutil/opt.h"
> +#include <libssh/sftp.h>
> +#include <fcntl.h>
> +
> +#define CREDENTIALS_BUFFER_SIZE 128
> +
> +typedef struct {
> +    const AVClass *class;
> +    ssh_session session;
> +    sftp_session sftp;
> +    sftp_file file;
> +    int64_t filesize;
> +    int rw_timeout;
> +    int trunc;
> +} LIBSSHContext;
> +
> +#define OFFSET(x) offsetof(LIBSSHContext, x)
> +#define D AV_OPT_FLAG_DECODING_PARAM
> +#define E AV_OPT_FLAG_ENCODING_PARAM
> +static const AVOption options[] = {
> +    {"timeout", "set timeout of socket I/O operations",
> OFFSET(rw_timeout), AV_OPT_TYPE_INT, {.i64 = -1}, -1, INT_MAX, D|E },
> +    {"truncate", "Truncate existing files on write", OFFSET(trunc),
> AV_OPT_TYPE_INT, { .i64 = 1 }, 0, 1, E },
> +    {NULL}
> +};
> +
> +static const AVClass libssh_context_class = {
> +    .class_name     = "libssh",
> +    .item_name      = av_default_item_name,
> +    .option         = options,
> +    .version        = LIBAVUTIL_VERSION_INT,
> +};
> +
> +static int libssh_close(URLContext *h)
> +{
> +    LIBSSHContext *s = h->priv_data;
> +    if (s->file)
> +        sftp_close(s->file);
> +    if (s->sftp)
> +        sftp_free(s->sftp);
> +    if (s->session) {
> +        ssh_disconnect(s->session);
> +        ssh_free(s->session);
> +    }
> +    return 0;
> +}
> +
> +static int libssh_open(URLContext *h, const char *url, int flags)
> +{
> +    static const int verbosity = SSH_LOG_NOLOG;
> +    LIBSSHContext *s = h->priv_data;
> +    char proto[10], path[MAX_URL_SIZE], hostname[1024], credencials[1024];
> +    int port = 22, access;
> +    long timeout = s->rw_timeout * 1000;
> +    const char *user = NULL, *pass = NULL;
> +    char *end = NULL;
> +    sftp_attributes stat;
> +
> +    av_url_split(proto, sizeof(proto),
> +                 credencials, sizeof(credencials),
> +                 hostname, sizeof(hostname),
> +                 &port,
> +                 path, sizeof(path),
> +                 url);
> +
> +    if (port <= 0 || port > 65535)
> +        port = 22;
> +
> +    if (!(s->session = ssh_new())) {
> +        goto fail;
> +    }
> +    user = av_strtok(credencials, ":", &end);
> +    pass = av_strtok(end, ":", &end);
> +    ssh_options_set(s->session, SSH_OPTIONS_HOST, hostname);
> +    ssh_options_set(s->session, SSH_OPTIONS_PORT, &port);
> +    ssh_options_set(s->session, SSH_OPTIONS_LOG_VERBOSITY, &verbosity);
> +    if (timeout > 0)
> +        ssh_options_set(s->session, SSH_OPTIONS_TIMEOUT_USEC, &timeout);
> +    if (user)
> +        ssh_options_set(s->session, SSH_OPTIONS_USER, user);
> +
> +    if (ssh_connect(s->session) != SSH_OK) {
> +        av_log(h, AV_LOG_ERROR, "Connection failed. %s\n",
> ssh_get_error(s->session));
> +        goto fail;
> +    }
> +
> +    if (pass && ssh_userauth_password(s->session, NULL, pass) !=
> SSH_AUTH_SUCCESS) {
> +        av_log(h, AV_LOG_ERROR, "Error authenticating with password:
> %s\n", ssh_get_error(s->session));
> +        goto fail;
> +    }
> +
> +    if (!(s->sftp = sftp_new(s->session))) {
> +        av_log(h, AV_LOG_ERROR, "SFTP session creation failed: %s\n",
> ssh_get_error(s->session));
> +        goto fail;
> +    }
> +
> +    if (sftp_init(s->sftp) != SSH_OK) {
> +        av_log(h, AV_LOG_ERROR, "Error initializing sftp session: %s\n",
> ssh_get_error(s->session));
> +        goto fail;
> +    }
> +
> +    if (flags & AVIO_FLAG_WRITE && flags & AVIO_FLAG_READ) {
> +        access = O_CREAT | O_RDWR;
> +        if (s->trunc)
> +            access |= O_TRUNC;
> +    } else if (flags & AVIO_FLAG_WRITE) {
> +        access = O_CREAT | O_WRONLY;
> +        if (s->trunc)
> +            access |= O_TRUNC;
> +    } else {
> +        access = O_RDONLY;
> +    }
> +
> +    if (!(s->file = sftp_open(s->sftp, path, access, S_IRWXU))) {
> +        av_log(h, AV_LOG_ERROR, "Error opening sftp file: %s\n",
> ssh_get_error(s->session));
> +        goto fail;
> +    }
> +
> +    if (!(stat = sftp_fstat(s->file))) {
> +        av_log(h, AV_LOG_WARNING, "Cannot stat remote file %s.\n", path);
> +        s->filesize = -1;
> +    } else {
> +        s->filesize = stat->size;
> +        sftp_attributes_free(stat);
> +    }
> +
> +    return 0;
> +
> +  fail:
> +    libssh_close(h);
> +    return AVERROR(EIO);
> +}
> +
> +static int64_t libssh_seek(URLContext *h, int64_t pos, int whence)
> +{
> +    LIBSSHContext *s = h->priv_data;
> +    int64_t newpos;
> +
> +    switch(whence) {
> +    case AVSEEK_SIZE:
> +        if (s->filesize != -1) {
> +            return s->filesize;
> +        } else {
> +            return AVERROR(EIO);
> +        }
> +    case SEEK_SET:
> +        newpos = pos;
> +        break;
> +    case SEEK_CUR:
> +        newpos = sftp_tell64(s->file);
> +        break;
> +    case SEEK_END:
> +        if (s->filesize != -1) {
> +            newpos = s->filesize + pos;
> +        } else {
> +            return AVERROR(EIO);
> +        }
> +        break;
> +    default:
> +        return AVERROR(EINVAL);
> +    }
> +
> +    if (sftp_seek64(s->file, newpos)) {
> +        av_log(h, AV_LOG_ERROR, "Error during seeking.\n");
> +        return AVERROR(EIO);
> +    }
> +
> +    return newpos;
> +}
> +
> +static int libssh_read(URLContext *h, unsigned char *buf, int size)
> +{
> +    LIBSSHContext *s = h->priv_data;
> +    int read;
> +
> +    if ((read = sftp_read(s->file, buf, size)) < 0) {
> +        av_log(h, AV_LOG_ERROR, "Read error.\n");
> +        return AVERROR(EIO);
> +    }
> +    return read;
> +}
> +
> +static int libssh_write(URLContext *h, const unsigned char *buf, int size)
> +{
> +    LIBSSHContext *s = h->priv_data;
> +    int written;
> +
> +    if ((written = sftp_write(s->file, buf, size)) < 0) {
> +        av_log(h, AV_LOG_ERROR, "Write error.\n");
> +        return AVERROR(EIO);
> +    }
> +    return written;
> +}
> +
> +URLProtocol ff_libssh_protocol = {
> +    .name                = "sftp",
> +    .url_open            = libssh_open,
> +    .url_read            = libssh_read,
> +    .url_write           = libssh_write,
> +    .url_seek            = libssh_seek,
> +    .url_close           = libssh_close,
> +    .priv_data_size      = sizeof(LIBSSHContext),
> +    .priv_data_class     = &libssh_context_class,
> +    .flags               = URL_PROTOCOL_FLAG_NETWORK,
> +};
> --
> 1.7.10.4
>
> _______________________________________________
> ffmpeg-devel mailing list
> ffmpeg-devel at ffmpeg.org
> http://ffmpeg.org/mailman/listinfo/ffmpeg-devel
>


More information about the ffmpeg-devel mailing list