diff options
author | patacongo <patacongo@42af7a65-404d-4744-a932-0658087f49c3> | 2011-06-02 20:45:35 +0000 |
---|---|---|
committer | patacongo <patacongo@42af7a65-404d-4744-a932-0658087f49c3> | 2011-06-02 20:45:35 +0000 |
commit | 944bf89644559cd2ae021122451ff5d0a740cb85 (patch) | |
tree | e60ca1e429abad6bee12af28d65c0f72f795c9c4 /apps/netutils/ftpc | |
parent | 146ccad3863879e9acc928cc2b2087cb45abe4d9 (diff) | |
download | nuttx-944bf89644559cd2ae021122451ff5d0a740cb85.tar.gz nuttx-944bf89644559cd2ae021122451ff5d0a740cb85.tar.bz2 nuttx-944bf89644559cd2ae021122451ff5d0a740cb85.zip |
More FTP client fixes
git-svn-id: svn://svn.code.sf.net/p/nuttx/code/trunk@3661 42af7a65-404d-4744-a932-0658087f49c3
Diffstat (limited to 'apps/netutils/ftpc')
-rw-r--r-- | apps/netutils/ftpc/ftpc_connect.c | 6 | ||||
-rw-r--r-- | apps/netutils/ftpc/ftpc_internal.h | 1 | ||||
-rw-r--r-- | apps/netutils/ftpc/ftpc_socket.c | 105 |
3 files changed, 44 insertions, 68 deletions
diff --git a/apps/netutils/ftpc/ftpc_connect.c b/apps/netutils/ftpc/ftpc_connect.c index ccd68cb03..2b4701d42 100644 --- a/apps/netutils/ftpc/ftpc_connect.c +++ b/apps/netutils/ftpc/ftpc_connect.c @@ -220,10 +220,10 @@ int ftpc_reconnect(FAR struct ftpc_session_s *session) #ifdef CONFIG_DEBUG ndbg("Connected\n"); - tmp = inet_ntoa(session->cmd.raddr.sin_addr); - ndbg(" Remote address: %s:%d\n", tmp, ntohs(session->cmd.raddr.sin_port)); + tmp = inet_ntoa(addr.sin_addr); + ndbg(" Remote address: %s:%d\n", tmp, ntohs(addr.sin_port)); tmp = inet_ntoa(session->cmd.laddr.sin_addr); - ndbg(" Local address: %s:d\n", tmp, ntohs(session->cmd.laddr.sin_port)); + ndbg(" Local address: %s:%d\n", tmp, ntohs(session->cmd.laddr.sin_port)); #endif return OK; diff --git a/apps/netutils/ftpc/ftpc_internal.h b/apps/netutils/ftpc/ftpc_internal.h index 3efac6184..4a7a3ca9b 100644 --- a/apps/netutils/ftpc/ftpc_internal.h +++ b/apps/netutils/ftpc/ftpc_internal.h @@ -140,7 +140,6 @@ struct ftpc_socket_s FILE *instream; /* Incoming stream */ FILE *outstream; /* Outgoing stream */ struct sockaddr_in laddr; /* Local address */ - struct sockaddr_in raddr; /* Remote address */ bool connected; /* True: socket is connected */ }; diff --git a/apps/netutils/ftpc/ftpc_socket.c b/apps/netutils/ftpc/ftpc_socket.c index a77481403..5747a7c66 100644 --- a/apps/netutils/ftpc/ftpc_socket.c +++ b/apps/netutils/ftpc/ftpc_socket.c @@ -82,12 +82,9 @@ int ftpc_sockinit(FAR struct ftpc_socket_s *sock) { - int dupsd; - /* Initialize the socket structure */ memset(sock, 0, sizeof(struct ftpc_socket_s)); - sock->raddr.sin_family = AF_INET; /* Create a socket descriptor */ @@ -98,50 +95,40 @@ int ftpc_sockinit(FAR struct ftpc_socket_s *sock) goto errout; } - /* 'dup' the socket descriptor to create an independent input stream */ - - dupsd = dup(sock->sd); - if (dupsd < 0) - { - ndbg("socket() failed: %d\n", errno); - goto errout_with_sd; - } - - /* Call fdopen to "wrap" the input stream with C buffered I/O */ + /* Call fdopen to "wrap" the socket descriptor as an input stream using C + * buffered I/O. + */ - sock->instream = fdopen(dupsd, "r"); + sock->instream = fdopen(sock->sd, "r"); if (!sock->instream) { ndbg("fdopen() failed: %d\n", errno); - close(dupsd); goto errout_with_sd; } - /* 'dup' the socket descriptor to create an independent output stream */ - - dupsd = dup(sock->sd); - if (dupsd < 0) - { - ndbg("socket() failed: %d\n", errno); - goto errout_with_instream; - } - - /* Call fdopen to "wrap" the output stream with C buffered I/O */ + /* Call fdopen to "wrap" the socket descriptor as an output stream using C + * buffered I/O. + */ - sock->outstream = fdopen(dupsd, "w"); + sock->outstream = fdopen(sock->sd, "w"); if (!sock->outstream) { ndbg("fdopen() failed: %d\n", errno); - close(dupsd); goto errout_with_instream; } return OK; +/* Close the instream. NOTE: Since the underlying socket descriptor is + * *not* dup'ed, the following close should fail harmlessly. + */ + errout_with_instream: fclose(sock->instream); + sock->instream = NULL; errout_with_sd: close(sock->sd); + sock->sd = -1; errout: return ERROR; } @@ -156,17 +143,23 @@ errout: void ftpc_sockclose(struct ftpc_socket_s *sock) { + /* Note that the same underlying socket descriptor is used for both streams. + * There should be harmless failures on the second fclose and the close. + */ + fclose(sock->instream); fclose(sock->outstream); close(sock->sd); memset(sock, 0, sizeof(struct ftpc_socket_s)); + sock->sd = -1; } /**************************************************************************** * Name: ftpc_sockconnect * * Description: - * Connect the socket to the host + * Connect the socket to the host. On a failure, the caller should call. + * ftpc_sockclose() to clean up. * ****************************************************************************/ @@ -174,13 +167,12 @@ int ftpc_sockconnect(struct ftpc_socket_s *sock, struct sockaddr_in *addr) { int ret; - /* Connect to the socket */ + /* Connect to the server */ ret = connect(sock->sd, (struct sockaddr *)addr, sizeof(struct sockaddr)); if (ret < 0) { ndbg("connect() failed: %d\n", errno); - close(sock->sd); return ERROR; } @@ -190,7 +182,6 @@ int ftpc_sockconnect(struct ftpc_socket_s *sock, struct sockaddr_in *addr) if (ret < 0) { ndbg("ftpc_sockgetsockname() failed: %d\n", errno); - close(sock->sd); return ERROR; } sock->connected = true; @@ -209,7 +200,6 @@ int ftpc_sockconnect(struct ftpc_socket_s *sock, struct sockaddr_in *addr) void ftpc_sockcopy(FAR struct ftpc_socket_s *dest, FAR const struct ftpc_socket_s *src) { - memcpy(&dest->raddr, &src->raddr, sizeof(struct sockaddr_in)); memcpy(&dest->laddr, &src->laddr, sizeof(struct sockaddr_in)); dest->connected = ftpc_sockconnected(src); } @@ -226,9 +216,14 @@ int ftpc_sockaccept(struct ftpc_socket_s *sock, const char *mode, bool passive) { struct sockaddr addr; socklen_t addrlen; - int dupsd; int sd; + /* Any previous socket should have been uninitialized (0) or explicitly + * closed (-1). + */ + + DEBUGASSERT(sock->sd == 0 || sock->sd == -1); + /* In active mode FTP the client connects from a random port (N>1023) to the * FTP server's command port, port 21. Then, the client starts listening to * port N+1 and sends the FTP command PORT N+1 to the FTP server. The server @@ -248,63 +243,45 @@ int ftpc_sockaccept(struct ftpc_socket_s *sock, const char *mode, bool passive) if (!passive) { - addrlen = sizeof(addr); - sd = accept(sock->sd, &addr, &addrlen); - close(sock->sd); + addrlen = sizeof(addr); + sock->sd = accept(sock->sd, &addr, &addrlen); if (sd == -1) { ndbg("accept() failed: %d\n", errno); - sock->sd = -1; return ERROR; } - - sock->sd = sd; memcpy(&sock->laddr, &addr, sizeof(sock->laddr)); } - /* Create in/out C buffer I/O streams on the cmd channel */ - - fclose(sock->instream); - fclose(sock->outstream); - - /* Dup the socket descriptor and create the incoming stream */ - - dupsd = dup(sock->sd); - if (dupsd < 0) - { - ndbg("dup() failed: %d\n", errno); - goto errout_with_sd; - } + /* Create in/out C buffer I/O streams on the data channel. First, create + * the incoming buffered stream. + */ - sock->instream = fdopen(dupsd, mode); + sock->instream = fdopen(sock->sd, mode); if (!sock->instream) { ndbg("fdopen() failed: %d\n", errno); - close(dupsd); goto errout_with_sd; } - /* Dup the socket descriptor and create the outgoing stream */ + /* Create the outgoing stream */ - dupsd = dup(sock->sd); - if (dupsd < 0) - { - ndbg("dup() failed: %d\n", errno); - goto errout_with_instream; - } - - sock->outstream = fdopen(dupsd, mode); + sock->outstream = fdopen(sock->sd, mode); if (!sock->outstream) { ndbg("fdopen() failed: %d\n", errno); - close(dupsd); goto errout_with_instream; } return OK; +/* Close the instream. NOTE: Since the underlying socket descriptor is + * *not* dup'ed, the following close should fail harmlessly. + */ + errout_with_instream: fclose(sock->instream); + sock->instream = NULL; errout_with_sd: close(sock->sd); sock->sd = -1; |