/* * bbftpd/bbftp_socket.c * Copyright (C) 1999, 2000, 2001, 2002 IN2P3, CNRS * bbftp@in2p3.fr * http://doc.in2p3.fr/bbftp * * This program is free software; you can redistribute it and/or * modify it under the terms of the GNU General Public License * as published by the Free Software Foundation; either version 2 * of the License, or any later version. * * This program 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 General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. */ /**************************************************************************** bbftp_socket.c v 3.0.0 2003/02/24 - Routines creation *****************************************************************************/ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include extern int sendwinsize ; extern int recvwinsize ; extern struct sockaddr_in hisctladdr; /* Remote adresse */ extern struct sockaddr_in myctladdr; /* Local adresse */ extern int warning ; extern int timestamp ; extern int debug ; extern int transferoption ; /******************************************************************************* ** bbftp_createdatasock : * ** * ** Routine to create a receive socket * ** This routine may send MSG_INFO * ** * ** INPUT variable : * ** portnumber : portnumber to connect NOT MODIFIED * ** * ** OUPUT variable : * ** logmessage : to write the error message in case of error * ** * ** RETURN: * ** -1 Creation failed unrecoverable error * ** 0 OK * ** >0 Creation failed recoverable error * ** * *******************************************************************************/ int bbftp_createdatasock(int portnumber/*,char *logmessage*/) { int sock ; struct sockaddr_in data_source ; int on = 1 ; int tcpwinsize ; #if defined(SUNOS) || defined(_HPUX_SOURCE) || defined(IRIX) int addrlen ; #else size_t addrlen ; #endif int retcode ; /* Declaring the variables need to change the value of the TOS */ int tos_value, tos_len; int qbss_value = 0x20; tos_len = sizeof(tos_value); sock = socket ( AF_INET, SOCK_STREAM, IPPROTO_TCP ) ; if ( sock < 0 ) { printmessage(stderr,CASE_ERROR,91,timestamp,"Cannot create data socket: %s\n",strerror(errno)); return (-1) ; } if ( setsockopt(sock,SOL_SOCKET, SO_REUSEADDR,(char *)&on,sizeof(on)) < 0 ) { close(sock) ; if (warning) printmessage(stderr,CASE_ERROR,92,timestamp,"Cannot set SO_REUSEADDR on data socket : %s\n",strerror(errno)); return (-1) ; } tcpwinsize = 1024 * recvwinsize ; if ( setsockopt(sock,SOL_SOCKET, SO_RCVBUF,(char *)&tcpwinsize,sizeof(tcpwinsize)) < 0 ) { /* ** In this case we are going to log a message */ if ( warning ) printmessage(stderr,CASE_WARNING,23,timestamp,"Cannot set SO_RCVBUF on data socket : %s\n",strerror(errno)); } addrlen = sizeof(tcpwinsize) ; if ( getsockopt(sock,SOL_SOCKET,SO_RCVBUF,(char *)&tcpwinsize,&addrlen) < 0 ) { close(sock) ; printmessage(stderr,CASE_ERROR,93,timestamp,"Cannot get SO_RCVBUF on data socket : %s\n",strerror(errno)); return (-1) ; } if ( tcpwinsize < 1024 * recvwinsize ) { if ( warning ) printmessage(stderr,CASE_WARNING,24,timestamp,"Receive buffer on port %d cannot be set to %d Bytes, Value is %d Bytes",portnumber,1024*recvwinsize,tcpwinsize) ; } tcpwinsize = 1024 * sendwinsize ; if ( setsockopt(sock,SOL_SOCKET, SO_SNDBUF,(char *)&tcpwinsize,sizeof(tcpwinsize)) < 0 ) { /* ** In this case we just log an error */ if ( warning ) printmessage(stderr,CASE_WARNING,25,timestamp,"Cannot set SO_SNDBUF on data socket : %s\n",strerror(errno)); } addrlen = sizeof(tcpwinsize) ; if ( getsockopt(sock,SOL_SOCKET, SO_SNDBUF,(char *)&tcpwinsize,&addrlen) < 0 ) { close(sock) ; printmessage(stderr,CASE_ERROR,93,timestamp,"Cannot get SO_SNDBUF on data socket : %s\n",strerror(errno)); return (-1) ; } if ( tcpwinsize < 1024 * sendwinsize ) { if ( warning ) printmessage(stderr,CASE_WARNING,26,timestamp ,"Send buffer on port %d cannot be set to %d Bytes, Value is %d Bytes",portnumber,1024*sendwinsize,tcpwinsize) ; } if ( setsockopt(sock,IPPROTO_TCP, TCP_NODELAY,(char *)&on,sizeof(on)) < 0 ) { close(sock) ; printmessage(stderr,CASE_ERROR,94,timestamp,"Cannot set TCP_NODELAY on data socket : %s\n",strerror(errno)); return (-1) ; } if ( (transferoption & TROPT_QBSS ) == TROPT_QBSS ) { /* Setting the value for IP_TOS to be 0x20 */ if ( setsockopt(sock,IPPROTO_IP, IP_TOS, (char *)&qbss_value, sizeof(qbss_value)) < 0 ) { close(sock) ; printmessage(stderr,CASE_ERROR,95,timestamp, "Cannot set IP_TOS on data socket : %s\n", strerror(errno)); return (-1) ; } } data_source.sin_family = AF_INET; /* #ifdef SUNOS data_source.sin_addr = myctladdr.sin_addr; #else data_source.sin_addr.s_addr = INADDR_ANY; #endif data_source.sin_port = 0; if ( bind(sock, (struct sockaddr *) &data_source,sizeof(data_source)) < 0) { close(sock) ; printmessage(stderr,CASE_ERROR,95,timestamp,"Cannot bind on data socket on port %d: %s\n",portnumber,strerror(errno)); return (-1) ; } */ data_source.sin_addr = hisctladdr.sin_addr; data_source.sin_port = htons(portnumber); addrlen = sizeof(data_source) ; retcode = connect(sock,(struct sockaddr *) &data_source,addrlen) ; if ( retcode < 0 ) { close(sock) ; printmessage(stderr,CASE_ERROR,96,timestamp,"Cannot connect to data socket on port %d: %s\n",portnumber,strerror(errno)); if ( errno == EINTR ) { /* ** In this case we are going to tell the calling program ** to retry so we close the socket and set the return code ** to zero */ return 0 ; } else { return (-1) ; } } if ( debug ) printmessage(stdout,CASE_NORMAL,91,timestamp,"Connected to port: %d\n",portnumber); return sock ; }