33 #define CONTROL_BUFFER_SIZE 1024
34 #define DIR_BUFFER_SIZE 4096
80 #define OFFSET(x) offsetof(FTPContext, x)
81 #define D AV_OPT_FLAG_DECODING_PARAM
82 #define E AV_OPT_FLAG_ENCODING_PARAM
84 {
"timeout",
"set timeout of socket I/O operations",
OFFSET(rw_timeout),
AV_OPT_TYPE_INT, {.i64 = -1}, -1, INT_MAX,
D|
E },
85 {
"ftp-write-seekable",
"control seekability of connection during encoding",
OFFSET(write_seekable),
AV_OPT_TYPE_BOOL, {.i64 = 0}, 0, 1,
E },
86 {
"ftp-anonymous-password",
"password for anonymous login. E-mail address should be used.",
OFFSET(anonymous_password),
AV_OPT_TYPE_STRING, { 0 }, 0, 0,
D|
E },
87 {
"ftp-user",
"user for FTP login. Overridden by whatever is in the URL.",
OFFSET(option_user),
AV_OPT_TYPE_STRING, { 0 }, 0, 0,
D|
E },
88 {
"ftp-password",
"password for FTP login. Overridden by whatever is in the URL.",
OFFSET(option_password),
AV_OPT_TYPE_STRING, { 0 }, 0, 0,
D|
E },
104 if (
s->control_buf_ptr >=
s->control_buf_end) {
111 s->control_buf_ptr =
s->control_buffer;
112 s->control_buf_end =
s->control_buffer +
len;
115 return *
s->control_buf_ptr++;
130 if (q >
line && q[-1] ==
'\r')
135 if ((q -
line) < line_size - 1)
148 int err,
i, dash = 0, result = 0, code_found = 0, linesize;
150 AVBPrint line_buffer;
155 while (!code_found || dash) {
164 linesize = strlen(buf);
167 for (
i = 0;
i < 3; ++
i) {
168 if (buf[
i] <
'0' || buf[
i] >
'9') {
182 for (
i = 0; response_codes[
i]; ++
i) {
183 if (err == response_codes[
i]) {
194 if (!dash && buf[3] ==
'-')
196 else if (err == dash && buf[3] ==
' ')
208 const int response_codes[],
char **response)
217 if (!
s->conn_control)
226 if (response_codes) {
248 static const int user_codes[] = {331, 230, 0};
249 static const int pass_codes[] = {230, 0};
251 if (strpbrk(
s->user,
"\r\n"))
253 snprintf(buf,
sizeof(buf),
"USER %s\r\n",
s->user);
257 if (strpbrk(
s->password,
"\r\n"))
259 snprintf(buf,
sizeof(buf),
"PASS %s\r\n",
s->password);
274 static const char d =
'|';
275 static const char *
command =
"EPSV\r\n";
276 static const int epsv_codes[] = {229, 0};
281 for (
i = 0; res[
i]; ++
i) {
284 }
else if (res[
i] ==
')') {
293 if (strlen(start) < 5)
295 if (start[0] != d || start[1] != d || start[2] != d || end[-1] != d)
300 s->server_data_port = atoi(start);
301 ff_dlog(
s,
"Server data port: %d\n",
s->server_data_port);
308 s->server_data_port = -1;
316 static const char *
command =
"PASV\r\n";
317 static const int pasv_codes[] = {227, 0};
322 for (
i = 0; res[
i]; ++
i) {
325 }
else if (res[
i] ==
')') {
342 if (!start)
goto fail;
343 s->server_data_port = atoi(start) * 256;
345 if (!start)
goto fail;
346 s->server_data_port += atoi(start);
347 ff_dlog(
s,
"Server data port: %d\n",
s->server_data_port);
354 s->server_data_port = -1;
362 static const char *
command =
"PWD\r\n";
363 static const int pwd_codes[] = {257, 0};
368 for (
i = 0; res[
i]; ++
i) {
400 static const int size_codes[] = {213, 0};
404 s->filesize = strtoll(&res[4],
NULL, 10);
418 static const int retr_codes[] = {150, 125, 0};
423 if (resp_code != 125 && resp_code != 150)
434 static const int stor_codes[] = {150, 125, 0};
439 if (resp_code != 125 && resp_code != 150)
449 static const char *
command =
"TYPE I\r\n";
450 static const int type_codes[] = {200, 0};
461 static const int rest_codes[] = {350, 0};
472 static const int cwd_codes[] = {250, 550, 0};
483 static const char *
command =
"MLSD\r\n";
484 static const int mlsd_codes[] = {150, 500, 0};
488 s->listing_method =
MLSD;
494 static const char *
command =
"NLST\r\n";
495 static const int nlst_codes[] = {226, 425, 426, 451, 450, 550, 0};
499 s->listing_method =
NLST;
524 static const char *feat_command =
"FEAT\r\n";
525 static const char *enable_utf8_command =
"OPTS UTF8 ON\r\n";
526 static const int feat_codes[] = {211, 0};
527 static const int opts_codes[] = {200, 202, 451, 0};
536 if (ret == 200 || ret == 202)
549 static const int connect_codes[] = {220, 0};
551 if (!
s->conn_control) {
553 s->hostname,
s->server_control_port,
NULL);
554 if (
s->rw_timeout != -1) {
558 &
h->interrupt_callback, &
opts,
559 h->protocol_whitelist,
h->protocol_blacklist,
h);
573 av_log(
h,
AV_LOG_WARNING,
"Pure-FTPd server is used as an output protocol. It is known issue this implementation may produce incorrect content and it cannot be fixed at this moment.");
608 if (
s->rw_timeout != -1) {
612 &
h->interrupt_callback, &
opts,
613 h->protocol_whitelist,
h->protocol_blacklist,
h);
628 static const char *
command =
"ABOR\r\n";
630 static const int abor_codes[] = {225, 226, 0};
667 const char *tok_user =
NULL, *tok_pass =
NULL;
668 char *newpath =
NULL;
679 credentials,
sizeof(credentials),
680 hostname,
sizeof(hostname),
681 &
s->server_control_port,
686 if (!
s->option_user) {
687 tok_user =
"anonymous";
688 tok_pass =
av_x_if_null(
s->anonymous_password,
"nopassword");
690 tok_user =
s->option_user;
691 tok_pass =
s->option_password;
696 char *
pass = strchr(credentials,
':');
702 tok_pass =
s->option_password;
708 if (!
s->hostname || !
s->user || (tok_pass && !
s->password)) {
712 if (
s->server_control_port < 0 ||
s->server_control_port > 65535)
713 s->server_control_port = 21;
762 ff_dlog(
h,
"ftp protocol seek %"PRId64
" %d\n",
pos, whence);
771 new_pos =
s->position +
pos;
776 new_pos =
s->filesize +
pos;
790 if (new_pos !=
s->position) {
793 s->position = new_pos;
801 int read, err, retry_done = 0;
819 s->filesize =
FFMAX(
s->filesize,
s->position);
822 static const int retr_codes[] = {226, 250, 425, 426, 451, 0};
823 char *response =
NULL;
836 if (read <= 0 && !h->is_streamed) {
872 s->position += written;
873 s->filesize =
FFMAX(
s->filesize,
s->position);
902 ff_dlog(
h,
"ftp protocol get_file_handle\n");
914 ff_dlog(
h,
"ftp protocol shutdown\n");
936 if (!
s->dir_buffer) {
940 s->dir_buffer[0] = 0;
952 memset(&tv, 0,
sizeof(
struct tm));
954 return INT64_C(1000000) *
av_timegm(&tv);
966 char *saveptr =
NULL, *p = mlsd;
970 if (
fact[0] ==
' ') {
1007 switch (
s->listing_method) {
1021 char *start, *found;
1026 start =
s->dir_buffer +
s->dir_buffer_offset;
1027 while (!(found = strstr(start,
"\n"))) {
1030 s->dir_buffer_size -=
s->dir_buffer_offset;
1031 s->dir_buffer_offset = 0;
1032 if (
s->dir_buffer_size)
1033 memmove(
s->dir_buffer, start,
s->dir_buffer_size);
1041 s->dir_buffer_size += ret;
1042 s->dir_buffer[
s->dir_buffer_size] = 0;
1043 start =
s->dir_buffer;
1046 s->dir_buffer_offset += (found + 1 - start);
1048 if (found > start && found[-1] ==
'\r')
1054 (*next)->utf8 =
s->utf8;
1078 static const int del_codes[] = {250, 421, 450, 500, 501, 502, 530, 550, 0};
1079 static const int rmd_codes[] = {250, 421, 500, 501, 502, 530, 550, 0};
1106 static const int rnfr_codes[] = {350, 421, 450, 500, 501, 502, 503, 530, 0};
1107 static const int rnto_codes[] = {250, 421, 500, 501, 502, 503, 530, 532, 553, 0};
1150 .default_whitelist =
"tcp",
static double fact(double i)
int ffurl_shutdown(URLContext *h, int flags)
Signal the URLContext that we are done reading or writing the stream.
int ffurl_read(URLContext *h, unsigned char *buf, int size)
Read up to size bytes from the resource accessed by h, and store the read bytes in buf.
int ffurl_open_whitelist(URLContext **puc, const char *filename, int flags, const AVIOInterruptCB *int_cb, AVDictionary **options, const char *whitelist, const char *blacklist, URLContext *parent)
Create an URLContext for accessing to the resource indicated by url, and open it.
int ffurl_closep(URLContext **hh)
Close the resource accessed by the URLContext h, and free the memory used by it.
void avio_free_directory_entry(AVIODirEntry **entry)
Free entry allocated by avio_read_dir().
int ffurl_write(URLContext *h, const unsigned char *buf, int size)
Write size bytes from buf to the resource accessed by h.
int ffurl_get_file_handle(URLContext *h)
Return the file descriptor associated with this URL.
#define AVSEEK_SIZE
ORing this as the "whence" parameter to a seek function causes it to return the filesize without seek...
#define AVIO_FLAG_WRITE
write-only
#define AVIO_FLAG_READ_WRITE
read-write pseudo flag
@ AVIO_ENTRY_SYMBOLIC_LINK
void av_bprintf(AVBPrint *buf, const char *fmt,...)
void av_bprint_init(AVBPrint *buf, unsigned size_init, unsigned size_max)
int av_bprint_finalize(AVBPrint *buf, char **ret_str)
Finalize a print buffer.
#define AV_BPRINT_SIZE_AUTOMATIC
#define flags(name, subs,...)
static av_cold void cleanup(FlashSV2Context *s)
static int ftp_connect(URLContext *h, const char *url)
static const AVClass ftp_context_class
static int ftp_shutdown(URLContext *h, int flags)
static int ftp_read_dir(URLContext *h, AVIODirEntry **next)
static void ftp_close_data_connection(FTPContext *s)
static int ftp_store(FTPContext *s)
static int ftp_file_size(FTPContext *s)
static int ftp_set_dir(FTPContext *s)
static int ftp_close(URLContext *h)
static int ftp_connect_data_connection(URLContext *h)
static int ftp_getc(FTPContext *s)
static const AVOption options[]
static int ftp_get_file_handle(URLContext *h)
static int ftp_connect_control_connection(URLContext *h)
static int ftp_passive_mode_epsv(FTPContext *s)
static int ftp_passive_mode(FTPContext *s)
static int ftp_auth(FTPContext *s)
static int ftp_read(URLContext *h, unsigned char *buf, int size)
static int ftp_current_dir(FTPContext *s)
static int ftp_delete(URLContext *h)
static int ftp_status(FTPContext *s, char **line, const int response_codes[])
static int ftp_list(FTPContext *s)
static int ftp_list_nlst(FTPContext *s)
static int ftp_abort(URLContext *h)
static int ftp_type(FTPContext *s)
static int ftp_open(URLContext *h, const char *url, int flags)
static int ftp_get_line(FTPContext *s, char *line, int line_size)
static int ftp_write(URLContext *h, const unsigned char *buf, int size)
static int ftp_parse_entry_nlst(char *line, AVIODirEntry *next)
#define CONTROL_BUFFER_SIZE
static int ftp_restart(FTPContext *s, int64_t pos)
static int ftp_parse_entry_mlsd(char *mlsd, AVIODirEntry *next)
static int ftp_list_mlsd(FTPContext *s)
static int64_t ftp_seek(URLContext *h, int64_t pos, int whence)
static int64_t ftp_parse_date(const char *date)
static int ftp_close_dir(URLContext *h)
static int ftp_move(URLContext *h_src, URLContext *h_dst)
static int ftp_parse_entry(URLContext *h, char *line, AVIODirEntry *next)
static int ftp_features(FTPContext *s)
static void ftp_close_both_connections(FTPContext *s)
static int ftp_retrieve(FTPContext *s)
static int ftp_has_feature(FTPContext *s, const char *feature_name)
static int ftp_open_dir(URLContext *h)
const URLProtocol ff_ftp_protocol
static int ftp_send_command(FTPContext *s, const char *command, const int response_codes[], char **response)
void av_url_split(char *proto, int proto_size, char *authorization, int authorization_size, char *hostname, int hostname_size, int *port_ptr, char *path, int path_size, const char *url)
Split a URL string into components.
void av_dict_free(AVDictionary **pm)
Free all the memory allocated for an AVDictionary struct and all keys and values.
int av_dict_set_int(AVDictionary **pm, const char *key, int64_t value, int flags)
Convenience wrapper for av_dict_set that converts the value to a string and stores it.
#define AVERROR_EOF
End of file.
#define av_err2str(errnum)
Convenience macro, the return value should be used only directly in function arguments but never stan...
#define AV_LOG_DEBUG
Stuff which is only useful for libav* developers.
#define AV_LOG_WARNING
Something somehow does not look correct.
#define AV_LOG_INFO
Standard information.
#define AV_LOG_ERROR
Something went wrong and cannot losslessly be recovered.
const char * av_default_item_name(void *ptr)
Return the context name.
char * av_strdup(const char *s)
Duplicate a string.
static void * av_x_if_null(const void *p, const void *x)
Return x default pointer in case p is NULL.
char * av_strtok(char *s, const char *delim, char **saveptr)
Split the string into several tokens which can be accessed by successive calls to av_strtok().
char * av_stristr(const char *s1, const char *s2)
Locate the first case-independent occurrence in the string haystack of the string needle.
int av_strcasecmp(const char *a, const char *b)
Locale-independent case-insensitive compare.
char * av_append_path_component(const char *path, const char *component)
Append path component to the existing path.
#define LIBAVUTIL_VERSION_INT
common internal API header
char * av_small_strptime(const char *p, const char *fmt, struct tm *dt)
Simplified version of strptime.
time_t av_timegm(struct tm *tm)
Convert the decomposed UTC time in tm to a time_t value.
Describe the class of an AVClass context structure.
const char * class_name
The name of the class; usually it is the same name as the context structure type to which the AVClass...
Describes single entry of the directory.
int64_t user_id
User ID of owner, -1 if unknown.
int type
Type of the entry.
int64_t size
File size in bytes, -1 if unknown.
int64_t group_id
Group ID of owner, -1 if unknown.
int64_t modification_timestamp
Time of last modification in microseconds since unix epoch, -1 if unknown.
int64_t filemode
Unix file mode, -1 if unknown.
int write_seekable
Control seekability, 0 = disable, 1 = enable.
const char * option_password
Password to be used if none given in the URL.
char * features
List of server's features represented as raw response.
int64_t filesize
Size of file on server, -1 on error.
FTPState state
State of data connection.
uint8_t * control_buf_end
char * password
Server user's password.
URLContext * conn_control
Control connection.
int rw_timeout
Network timeout.
int server_control_port
Control connection port, default is 21.
FTPListingMethod listing_method
Called listing method.
int64_t position
Current position, calculated.
int server_data_port
Data connection port opened by server, -1 on error.
const char * option_user
User to be used if none given in the URL.
char * hostname
Server address.
URLContext * conn_data
Data connection, NULL when not connected.
char * path
Path to resource on server.
const char * anonymous_password
Password to be used for anonymous user.
char * filename
specified URL
AVIODirEntry * ff_alloc_dir_entry(void)
Allocate directory entry with default values.
int ff_url_join(char *str, int size, const char *proto, const char *authorization, const char *hostname, int port, const char *fmt,...)
unbuffered private I/O API
#define URL_PROTOCOL_FLAG_NETWORK
char * ff_urldecode(const char *url, int decode_plus_sign)
Decodes an URL from its percent-encoded form back into normal representation.
static int command(AVFilterContext *ctx, const char *cmd, const char *arg, char *res, int res_len, int flags)