/* * The MIT License * * Copyright 2018 Ugo Cirmignani. * * Permission is hereby granted, free of charge, to any person obtaining a copy * of this software and associated documentation files (the "Software"), to deal * in the Software without restriction, including without limitation the rights * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell * copies of the Software, and to permit persons to whom the Software is * furnished to do so, subject to the following conditions: * * The above copyright notice and this permission notice shall be included in * all copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN * THE SOFTWARE. */ #include #include #include #include #include #include #include #include #include #include #include #include /* FTP LIBS */ #include "ftpServer.h" #include "ftpData.h" #include "ftpCommandsElaborate.h" #include "library/fileManagement.h" #include "library/logFunctions.h" #include "library/configRead.h" #include "library/daemon.h" #include "library/signals.h" static ftpDataType ftpData; static int createSocket(int port); static void closeSocket(int processingSocket); static void initFtpData(void); static int processCommand(int processingElement); static int getMaximumSocketFd(int mainSocket, ftpDataType * data); void workerCleanup(void *socketId) { int theSocketId = *(int *)socketId; printTimeStamp(); printf("\nCleanup called for thread id: %d", theSocketId); printf("\nClosing pasv socket (%d) ok!", theSocketId); shutdown(ftpData.clients[theSocketId].workerData.socketConnection, SHUT_RDWR); shutdown(ftpData.clients[theSocketId].workerData.passiveListeningSocket, SHUT_RDWR); close(ftpData.clients[theSocketId].workerData.socketConnection); close(ftpData.clients[theSocketId].workerData.passiveListeningSocket); resetWorkerData(&ftpData.clients[theSocketId].workerData, 0); } void *connectionWorkerHandle(void * socketId) { int theSocketId = *(int *)socketId; pthread_cleanup_push(workerCleanup, (void *) &theSocketId); ftpData.clients[theSocketId].workerData.threadIsAlive = 1; if (ftpData.clients[theSocketId].workerData.passiveModeOn == 1) { printf("\nPasv (%d) thread init opening port: %d", theSocketId, ftpData.clients[theSocketId].workerData.connectionPort); printf("\nPasv (%d) open ok: %d", theSocketId, ftpData.clients[theSocketId].workerData.connectionPort); ftpData.clients[theSocketId].workerData.passiveListeningSocket = createPassiveSocket(ftpData.clients[theSocketId].workerData.connectionPort); if (ftpData.clients[theSocketId].workerData.socketIsConnected == 0) { //printTimeStamp(); printf("Waiting for pasv client connection on port: %d", ftpData.clients[theSocketId].workerData.connectionPort); char theResponse[FTP_COMMAND_ELABORATE_CHAR_BUFFER]; memset(theResponse, 0, FTP_COMMAND_ELABORATE_CHAR_BUFFER); sprintf(theResponse, "227 Entering Passive Mode (%d,%d,%d,%d,%d,%d)\r\n", ftpData.clients[theSocketId].serverIpAddressInteger[0], ftpData.clients[theSocketId].serverIpAddressInteger[1], ftpData.clients[theSocketId].serverIpAddressInteger[2], ftpData.clients[theSocketId].serverIpAddressInteger[3], (ftpData.clients[theSocketId].workerData.connectionPort / 256), (ftpData.clients[theSocketId].workerData.connectionPort % 256)); write(ftpData.clients[theSocketId].socketDescriptor, theResponse, strlen(theResponse)); //Wait for sockets if ((ftpData.clients[theSocketId].workerData.socketConnection = accept(ftpData.clients[theSocketId].workerData.passiveListeningSocket, 0, 0))!=-1) { printTimeStamp(); printf("\nPasv (%d) connection initialized", theSocketId); //int error; ftpData.clients[theSocketId].workerData.socketIsConnected = 1; printf("\nPasv (%d) connection ok", theSocketId); //error = fcntl(ftpData.clients[theSocketId].pasvData.passiveSocketConnection, F_SETFL, O_NONBLOCK); } } } else if (ftpData.clients[theSocketId].workerData.activeModeOn == 1) { char *activeResponse = "200 connection accepted\r\n"; printf("\nConnecting on the active client %s:%d", ftpData.clients[theSocketId].workerData.activeIpAddress, ftpData.clients[theSocketId].workerData.connectionPort); ftpData.clients[theSocketId].workerData.socketConnection = createActiveSocket(ftpData.clients[theSocketId].workerData.connectionPort, ftpData.clients[theSocketId].workerData.activeIpAddress); write(ftpData.clients[theSocketId].socketDescriptor, activeResponse, strlen(activeResponse)); if (ftpData.clients[theSocketId].workerData.socketConnection != -1) { ftpData.clients[theSocketId].workerData.socketIsConnected = 1; } } //Endless loop ftp process while (1) { usleep(1000); if (ftpData.clients[theSocketId].workerData.socketIsConnected > 0) { //Conditional lock on thread actions pthread_mutex_lock(&ftpData.clients[theSocketId].workerData.conditionMutex); printTimeStamp(); printf("\nPasv (%d) waiting for commands..", theSocketId); while (ftpData.clients[theSocketId].workerData.commandReceived == 0) { printf("\nPasv (%d) waiting for conditional variable..", theSocketId); pthread_cond_wait(&ftpData.clients[theSocketId].workerData.conditionVariable, &ftpData.clients[theSocketId].workerData.conditionMutex); } printf("\nPasv (%d) waiting ok, unlock mutex", theSocketId); pthread_mutex_unlock(&ftpData.clients[theSocketId].workerData.conditionMutex); printf("\nPasv (%d) processing commands..", theSocketId); //the connection is closed // if ((ftpData.clients[theSocketId].pasvData.bufferIndex = read(ftpData.clients[theSocketId].pasvData.passiveSocketConnection, ftpData.clients[theSocketId].pasvData.buffer, CLIENT_BUFFER_STRING_SIZE)) == 0) // { /// break; // } //Some data is received //if (ftpData.clients[theSocketId].pasvData.bufferIndex > 0) // { // int i = 0; // for (i = 0; i < ftpData.clients[theSocketId].pasvData.bufferIndex; i++) // { // ; // } // usleep(100); //write(ftpData.clients[theSocketId].pasvData.passiveSocketConnection, ftpData.clients[theSocketId].pasvData.buffer, ftpData.clients[theSocketId].pasvData.bufferIndex); // } if (ftpData.clients[theSocketId].workerData.commandReceived == 1 && ((strncmp(ftpData.clients[theSocketId].workerData.theCommandReceived, "STOR", strlen("STOR")) == 0) || (strncmp(ftpData.clients[theSocketId].workerData.theCommandReceived, "stor", strlen("stor")) == 0)) && ftpData.clients[theSocketId].fileToStor.textLen > 0) { //Set the busy flag ftpData.clients[theSocketId].workerData.threadIsBusy = 1; FILE *theStorFile; char theResponse[FTP_COMMAND_ELABORATE_CHAR_BUFFER]; memset(theResponse, 0, FTP_COMMAND_ELABORATE_CHAR_BUFFER); theStorFile = fopen(ftpData.clients[theSocketId].fileToStor.text, "wb"); if (theStorFile == NULL) { perror("Can't open the file"); strcpy(theResponse, "550 Unable to write the file\r\n"); write(ftpData.clients[theSocketId].socketDescriptor, theResponse, strlen(theResponse)); break; } printf("\nftpData.clients[theSocketId].theFileNameToStor: %s", ftpData.clients[theSocketId].fileToStor.text); printf("\nftpData.clients[theSocketId].login.absolutePath.text: %s", ftpData.clients[theSocketId].login.absolutePath.text); strcpy(theResponse, "150 Accepted data connection\r\n"); write(ftpData.clients[theSocketId].socketDescriptor, theResponse, strlen(theResponse)); while(1) { if ((ftpData.clients[theSocketId].workerData.bufferIndex = read(ftpData.clients[theSocketId].workerData.socketConnection, ftpData.clients[theSocketId].workerData.buffer, CLIENT_BUFFER_STRING_SIZE)) == 0) { //Client is disconnected! break; } if (ftpData.clients[theSocketId].workerData.bufferIndex > 0) { fwrite(ftpData.clients[theSocketId].workerData.buffer, ftpData.clients[theSocketId].workerData.bufferIndex, 1, theStorFile); usleep(100); } } fclose(theStorFile); memset(theResponse, 0, FTP_COMMAND_ELABORATE_CHAR_BUFFER); sprintf(theResponse, "226 file stor ok\r\n"); write(ftpData.clients[theSocketId].socketDescriptor, theResponse, strlen(theResponse)); break; } else if (ftpData.clients[theSocketId].workerData.commandReceived == 1 && ((strncmp(ftpData.clients[theSocketId].workerData.theCommandReceived, "LIST", strlen("LIST")) == 0) || (strncmp(ftpData.clients[theSocketId].workerData.theCommandReceived, "list", strlen("list")) == 0)) ) { DYNV_VectorGenericDataType directoryInfo; DYNV_VectorGeneric_Init(&directoryInfo); int i; getListDataInfo(ftpData.clients[theSocketId].listPath.text, &directoryInfo); printf("\nPasv (%d) ftpData.clients[theSocketId].listPath.text = %s", theSocketId, ftpData.clients[theSocketId].listPath.text); char theResponse[FTP_COMMAND_ELABORATE_CHAR_BUFFER]; memset(theResponse, 0, FTP_COMMAND_ELABORATE_CHAR_BUFFER); strcpy(theResponse, "150 Accepted data connection\r\n"); write(ftpData.clients[theSocketId].socketDescriptor, theResponse, strlen(theResponse)); char theBufferWrite[4096]; memset(theBufferWrite, 0, 4096); sprintf(theBufferWrite, "total %d\r\n", directoryInfo.Size); write(ftpData.clients[theSocketId].workerData.socketConnection, theBufferWrite, strlen(theBufferWrite)); //printf("%s", theBufferWrite); for (i = 0; i < directoryInfo.Size; i++) { memset(theBufferWrite, 0, 1024); sprintf(theBufferWrite, "%s %d %s %s %d %s %s\r\n", ((((ftpListDataType *) directoryInfo.Data[i])->inodePermissionString) == NULL? "Uknown" : (((ftpListDataType *) directoryInfo.Data[i])->inodePermissionString)) ,((ftpListDataType *) directoryInfo.Data[i])->numberOfSubDirectories ,((((ftpListDataType *) directoryInfo.Data[i])->owner) == NULL? "Uknown" : (((ftpListDataType *) directoryInfo.Data[i])->owner)) ,((((ftpListDataType *) directoryInfo.Data[i])->groupOwner) == NULL? "Uknown" : (((ftpListDataType *) directoryInfo.Data[i])->groupOwner)) ,((ftpListDataType *) directoryInfo.Data[i])->fileSize ,((((ftpListDataType *) directoryInfo.Data[i])->lastModifiedDataString) == NULL? "Uknown" : (((ftpListDataType *) directoryInfo.Data[i])->lastModifiedDataString)) ,((((ftpListDataType *) directoryInfo.Data[i])->finalStringPath) == NULL? "Uknown" : (((ftpListDataType *) directoryInfo.Data[i])->finalStringPath))); printf("\n%s", theBufferWrite); write(ftpData.clients[theSocketId].workerData.socketConnection, theBufferWrite, strlen(theBufferWrite)); } memset(theResponse, 0, FTP_COMMAND_ELABORATE_CHAR_BUFFER); sprintf(theResponse, "226 %d matches total\r\n", directoryInfo.Size); write(ftpData.clients[theSocketId].socketDescriptor, theResponse, strlen(theResponse)); int theSize = directoryInfo.Size; char ** lastToDestroy = NULL; if (theSize > 0) { lastToDestroy = ((ftpListDataType *)directoryInfo.Data[0])->fileList; } directoryInfo.Destroy(&directoryInfo, deleteListDataInfoVector); if (theSize > 0) { free(lastToDestroy); } printf("\nPasv (%d) List end", theSocketId); break; } else if (ftpData.clients[theSocketId].workerData.commandReceived == 1 && ((strncmp(ftpData.clients[theSocketId].workerData.theCommandReceived, "NLST", strlen("NLST")) == 0) || (strncmp(ftpData.clients[theSocketId].workerData.theCommandReceived, "nlst", strlen("nlst")) == 0)) ) { DYNV_VectorGenericDataType directoryInfo; DYNV_VectorGeneric_Init(&directoryInfo); int i; getListDataInfo(ftpData.clients[theSocketId].nlistPath.text, &directoryInfo); printf("\nPasv (%d) ftpData.clients[theSocketId].login.absolutePath.text = %s",theSocketId, ftpData.clients[theSocketId].login.absolutePath.text); char theResponse[FTP_COMMAND_ELABORATE_CHAR_BUFFER]; memset(theResponse, 0, FTP_COMMAND_ELABORATE_CHAR_BUFFER); strcpy(theResponse, "150 Accepted data connection\r\n"); write(ftpData.clients[theSocketId].socketDescriptor, theResponse, strlen(theResponse)); char theBufferWrite[1024]; memset(theBufferWrite, 0, 1024); sprintf(theBufferWrite, "total %d\r\n", directoryInfo.Size); write(ftpData.clients[theSocketId].workerData.socketConnection, theBufferWrite, strlen(theBufferWrite)); //printf("%s", theBufferWrite); for (i = 0; i < directoryInfo.Size; i++) { memset(theBufferWrite, 0, 1024); sprintf(theBufferWrite, "%s\r\n" ,((ftpListDataType *) directoryInfo.Data[i])->fileNameNoPath); //printf("%s", theBufferWrite); write(ftpData.clients[theSocketId].workerData.socketConnection, theBufferWrite, strlen(theBufferWrite)); } memset(theResponse, 0, FTP_COMMAND_ELABORATE_CHAR_BUFFER); sprintf(theResponse, "226 %d matches total\r\n", directoryInfo.Size); write(ftpData.clients[theSocketId].socketDescriptor, theResponse, strlen(theResponse)); int theSize = directoryInfo.Size; char ** lastToDestroy = NULL; if (theSize > 0) { lastToDestroy = ((ftpListDataType *)directoryInfo.Data[0])->fileList; } directoryInfo.Destroy(&directoryInfo, deleteListDataInfoVector); if (theSize > 0) { free(lastToDestroy); } printf("\nPasv (%d) List end", theSocketId); break; } else if (ftpData.clients[theSocketId].workerData.commandReceived == 1 && ((strncmp(ftpData.clients[theSocketId].workerData.theCommandReceived, "RETR", strlen("RETR")) == 0) || (strncmp(ftpData.clients[theSocketId].workerData.theCommandReceived, "retr", strlen("retr")) == 0))) { ftpData.clients[theSocketId].workerData.threadIsBusy = 1; int writenSize = 0; char theResponse[FTP_COMMAND_ELABORATE_CHAR_BUFFER]; printTimeStamp(); printf("The (%d) pasvData Command: %s",theSocketId, ftpData.clients[theSocketId].workerData.theCommandReceived); int writeReturn = 0; memset(theResponse, 0, FTP_COMMAND_ELABORATE_CHAR_BUFFER); strcpy(theResponse, "150 Accepted data connection\r\n"); writeReturn = write(ftpData.clients[theSocketId].socketDescriptor, theResponse, strlen(theResponse)); printf("\nPasv (%d) writeReturn: %d",theSocketId, writeReturn); writenSize = writeRetrFile(ftpData.clients[theSocketId].fileToRetr.text, ftpData.clients[theSocketId].workerData.socketConnection, ftpData.clients[theSocketId].workerData.retrRestartAtByte); ftpData.clients[theSocketId].workerData.retrRestartAtByte = 0; printf("\nPasv (%d) writeReturn data: %d",theSocketId, writeReturn); if (writenSize == -1) { memset(theResponse, 0, FTP_COMMAND_ELABORATE_CHAR_BUFFER); sprintf(theResponse, "550 unable to open the file for reading\r\n"); writeReturn = write(ftpData.clients[theSocketId].socketDescriptor, theResponse, strlen(theResponse)); break; } memset(theResponse, 0, FTP_COMMAND_ELABORATE_CHAR_BUFFER); sprintf(theResponse, "226-File successfully transferred\r\n226 done\r\n"); writeReturn = write(ftpData.clients[theSocketId].socketDescriptor, theResponse, strlen(theResponse)); printf("\nPasv (%d) writeReturn response to 21: %d",theSocketId, writeReturn); break; } break; } break; } pthread_exit((void *)1); pthread_cleanup_pop(0); pthread_exit((void *)2); return NULL; } void runFtpServer(void) { fd_set rset, wset, eset, rsetAll, wsetAll, esetAll; static int processingSock = 0; static int maxSocketFD = 0; /*Read the configuration file */ configurationRead(&ftpData.ftpParameters); if (ftpData.ftpParameters.singleInstanceModeOn == 1) { int returnCode = isProcessAlreadyRunning(); printf("\nreturnCode : %d", returnCode); if (returnCode == 1) { printf("\nThe process is already running.."); exit(0); } } /* Fork the process daemon mode */ if (ftpData.ftpParameters.daemonModeOn == 1) { daemonize("uFTP"); } signalHandlerInstall(); initFtpData(); //Socket main creator ftpData.theSocket = createSocket(ftpData.ftpParameters.port); printTimeStamp(); printf("uFTP server starting.."); printf("\nServer port: %d", ftpData.ftpParameters.port); printf("\nServer: Clients connected: %d", ftpData.connectedClients); printf("\nServer: Max Client Allowed: %d", ftpData.ftpParameters.maxClients); FD_ZERO(&rset); FD_ZERO(&wset); FD_ZERO(&eset); FD_ZERO(&rsetAll); FD_ZERO(&wsetAll); FD_ZERO(&esetAll); FD_SET(ftpData.theSocket, &rsetAll); FD_SET(ftpData.theSocket, &wsetAll); FD_SET(ftpData.theSocket, &esetAll); maxSocketFD = ftpData.theSocket+1; //Endless loop ftp process while (1) { int selectResult, i; struct timeval selectMaximumLockTime; // sleep for 1 second! selectMaximumLockTime.tv_sec = 10; selectMaximumLockTime.tv_usec = 0; rset = rsetAll; wset = wsetAll; eset = esetAll; printf("\nServer: Clients connected: %d", ftpData.connectedClients); selectResult = select(maxSocketFD, &rset, NULL, &eset, &selectMaximumLockTime); if (selectResult == 0) { printf("select() timed out!\n"); for (processingSock = 0; processingSock < ftpData.ftpParameters.maxClients; processingSock++) { if (ftpData.clients[processingSock].socketDescriptor < 0 || ftpData.clients[processingSock].socketIsConnected == 0) { continue; } if (ftpData.ftpParameters.maximumIdleInactivity != 0 && (int)time(NULL) - ftpData.clients[processingSock].lastActivityTimeStamp > ftpData.ftpParameters.maximumIdleInactivity) { printf("\nTIME %d\n", (int)time(NULL)); printf("\nftpData.clients[processingSock].lastActivityTimeStamp %d\n", ftpData.clients[processingSock].lastActivityTimeStamp); printf("\nIDLE TIME %d\n", ((int)time(NULL) - ftpData.clients[processingSock].lastActivityTimeStamp)); printf("\nIDLE TIMEOUT, SETTING THE QUIT FLAG!\n"); ftpData.clients[processingSock].closeTheClient = 1; } else { printf("\nIDLE TIME %d\n", ((int)time(NULL) - ftpData.clients[processingSock].lastActivityTimeStamp)); } } } for (processingSock = 0; processingSock < ftpData.ftpParameters.maxClients; processingSock++) { if (ftpData.clients[processingSock].closeTheClient == 1) { printf("\nQUIT FLAG SET!\n"); if (ftpData.clients[processingSock].workerData.threadIsAlive == 1) { void *pReturn; pthread_cancel(ftpData.clients[processingSock].workerData.workerThread); pthread_join(ftpData.clients[processingSock].workerData.workerThread, &pReturn); printf("\nQuit command received the Pasv Thread has been cancelled."); } FD_CLR(ftpData.clients[processingSock].socketDescriptor, &rsetAll); FD_CLR(ftpData.clients[processingSock].socketDescriptor, &wsetAll); FD_CLR(ftpData.clients[processingSock].socketDescriptor, &esetAll); closeSocket(processingSock); printf("\nSocket is closed!\n"); maxSocketFD = ftpData.theSocket+1; maxSocketFD = getMaximumSocketFd(ftpData.theSocket, &ftpData) + 1; continue; } if (FD_ISSET(ftpData.theSocket, &rset)) { int socketIndex, availableSocketIndex; availableSocketIndex = -1; for (socketIndex = 0; socketIndex < ftpData.ftpParameters.maxClients; socketIndex++) { if (ftpData.clients[socketIndex].socketDescriptor < 0 && ftpData.clients[socketIndex].socketIsConnected == 0 ) { availableSocketIndex = socketIndex; break; } } if (availableSocketIndex != -1) { if ((ftpData.clients[availableSocketIndex].socketDescriptor = accept(ftpData.theSocket, (struct sockaddr *)&ftpData.clients[availableSocketIndex].client_sockaddr_in, (socklen_t*)&ftpData.clients[availableSocketIndex].sockaddr_in_size))!=-1) { int error; ftpData.connectedClients++; ftpData.clients[availableSocketIndex].socketIsConnected = 1; error = fcntl(ftpData.clients[availableSocketIndex].socketDescriptor, F_SETFL, O_NONBLOCK); FD_SET(ftpData.clients[availableSocketIndex].socketDescriptor, &rsetAll); FD_SET(ftpData.clients[availableSocketIndex].socketDescriptor, &wsetAll); FD_SET(ftpData.clients[availableSocketIndex].socketDescriptor, &esetAll); maxSocketFD = getMaximumSocketFd(ftpData.theSocket, &ftpData) + 1; error = getsockname(ftpData.clients[availableSocketIndex].socketDescriptor, (struct sockaddr *)&ftpData.clients[availableSocketIndex].server_sockaddr_in, (socklen_t*)&ftpData.clients[availableSocketIndex].sockaddr_in_server_size); inet_ntop(AF_INET, &(ftpData.clients[availableSocketIndex].server_sockaddr_in.sin_addr), ftpData.clients[availableSocketIndex].serverIpAddress, INET_ADDRSTRLEN); printf("\n Server IP: %s", ftpData.clients[availableSocketIndex].serverIpAddress); printf("Server: New client connected with id: %d", availableSocketIndex); printf("\nServer: Clients connected: %d", ftpData.connectedClients); sscanf (ftpData.clients[availableSocketIndex].serverIpAddress,"%d.%d.%d.%d", &ftpData.clients[availableSocketIndex].serverIpAddressInteger[0], &ftpData.clients[availableSocketIndex].serverIpAddressInteger[1], &ftpData.clients[availableSocketIndex].serverIpAddressInteger[2], &ftpData.clients[availableSocketIndex].serverIpAddressInteger[3]); error = inet_ntop(AF_INET, &(ftpData.clients[availableSocketIndex].client_sockaddr_in.sin_addr), ftpData.clients[availableSocketIndex].clientIpAddress, INET_ADDRSTRLEN); printf("\n Client IP: %s", ftpData.clients[availableSocketIndex].clientIpAddress); ftpData.clients[availableSocketIndex].clientPort = (int) ntohs(ftpData.clients[availableSocketIndex].client_sockaddr_in.sin_port); printf("\nClient port is: %d\n", ftpData.clients[availableSocketIndex].clientPort); ftpData.clients[availableSocketIndex].connectionTimeStamp = (int)time(NULL); ftpData.clients[availableSocketIndex].lastActivityTimeStamp = (int)time(NULL); write(ftpData.clients[availableSocketIndex].socketDescriptor, ftpData.welcomeMessage, strlen(ftpData.welcomeMessage)); } else { printf("\nErrno = %d", errno); } } else { int socketRefuseFd, socketRefuse_in_size; socketRefuse_in_size = sizeof(struct sockaddr_in); struct sockaddr_in socketRefuse_sockaddr_in; if ((socketRefuseFd = accept(ftpData.theSocket, (struct sockaddr *)&socketRefuse_sockaddr_in, (socklen_t*)&socketRefuse_in_size))!=-1) { char *messageToWrite = "530 Server reached the maximum number of connection, please try later.\r\n"; write(socketRefuseFd, messageToWrite, strlen(messageToWrite)); shutdown(socketRefuseFd, SHUT_RDWR); close(socketRefuseFd); } else { printf("\nErrno = %d", errno); } } } if (ftpData.clients[processingSock].socketDescriptor < 0 || ftpData.clients[processingSock].socketIsConnected == 0) { continue; } if (FD_ISSET(ftpData.clients[processingSock].socketDescriptor, &rset) || FD_ISSET(ftpData.clients[processingSock].socketDescriptor, &eset)) { printf("\nClient r: %d, e: %d", FD_ISSET(ftpData.clients[processingSock].socketDescriptor, &rset), FD_ISSET(ftpData.clients[processingSock].socketDescriptor, &eset)); //The client is not connected anymore if ((ftpData.clients[processingSock].bufferIndex = read(ftpData.clients[processingSock].socketDescriptor, ftpData.clients[processingSock].buffer, CLIENT_BUFFER_STRING_SIZE)) == 0) { FD_CLR(ftpData.clients[processingSock].socketDescriptor, &rsetAll); FD_CLR(ftpData.clients[processingSock].socketDescriptor, &wsetAll); FD_CLR(ftpData.clients[processingSock].socketDescriptor, &esetAll); closeSocket(processingSock); printf("\nSocket is closed!\n"); maxSocketFD = ftpData.theSocket+1; maxSocketFD = getMaximumSocketFd(ftpData.theSocket, &ftpData) + 1; } if (ftpData.clients[processingSock].bufferIndex < 0) { printf("\nErrno = %d", errno); perror("Error: "); } //Some commands has been received if (ftpData.clients[processingSock].bufferIndex > 0) { int i = 0; int commandProcessStatus = 0; for (i = 0; i < ftpData.clients[processingSock].bufferIndex; i++) { if (ftpData.clients[processingSock].commandIndex < CLIENT_COMMAND_STRING_SIZE) { if (ftpData.clients[processingSock].buffer[i] != '\r' && ftpData.clients[processingSock].buffer[i] != '\n') { ftpData.clients[processingSock].theCommandReceived[ftpData.clients[processingSock].commandIndex++] = ftpData.clients[processingSock].buffer[i]; } if (ftpData.clients[processingSock].buffer[i] == '\n') { ftpData.clients[processingSock].socketCommandReceived = 1; commandProcessStatus = processCommand(processingSock); //Echo unrecognized commands if (commandProcessStatus == 0) { char * theNotSupportedString = "500 Unknown command\r\n"; //write(ftpData.clients[processingSock].socketDescriptor, ftpData.clients[processingSock].buffer, ftpData.clients[processingSock].bufferIndex); //write(ftpData.clients[processingSock].socketDescriptor, theNotSupportedString, strlen(theNotSupportedString)); printf("\n COMMAND NOT SUPPORTED ********* %s", ftpData.clients[processingSock].buffer); } else { ftpData.clients[processingSock].lastActivityTimeStamp = (int)time(NULL); } } } else { //Command overflow can't be processed ftpData.clients[processingSock].commandIndex = 0; memset(ftpData.clients[processingSock].theCommandReceived, 0, CLIENT_COMMAND_STRING_SIZE); //Write some error message to the client break; } } usleep(100); memset(ftpData.clients[processingSock].buffer, 0, CLIENT_BUFFER_STRING_SIZE); } } } } //Server Close closeSocket(ftpData.theSocket); printTimeStamp(); printf("Server: Closed."); ftpData.clients[processingSock].socketIsConnected = 0; return; } /* STATIC FUNCTIONS */ static int createSocket(int port) { printf("\n\n Creating socket on port %d", port); int sock, errorCode; struct sockaddr_in temp; //Socket creation sock = socket(AF_INET, SOCK_STREAM, 0); temp.sin_family = AF_INET; temp.sin_addr.s_addr = INADDR_ANY; temp.sin_port = htons(port); //No blocking socket errorCode = fcntl(sock, F_SETFL, O_NONBLOCK); int reuse = 1; if (setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (const char*)&reuse, sizeof(reuse)) < 0) perror("setsockopt(SO_REUSEADDR) failed"); if (setsockopt(sock, SOL_SOCKET, SO_REUSEPORT, (const char*)&reuse, sizeof(reuse)) < 0) perror("setsockopt(SO_REUSEPORT) failed"); //Bind socket errorCode = bind(sock,(struct sockaddr*) &temp,sizeof(temp)); //Number of client allowed errorCode = listen(sock, ftpData.ftpParameters.maxClients + 1); return sock; } int createPassiveSocket(int port) { int sock, returnCode, flags; struct sockaddr_in temp; //Socket creation sock = socket(AF_INET, SOCK_STREAM, 0); temp.sin_family = AF_INET; temp.sin_addr.s_addr = INADDR_ANY; temp.sin_port = htons(port); // flags = fcntl(sock, F_GETFL, 0); // flags &= ~O_NONBLOCK; // returnCode = fcntl(sock, F_SETFL, flags); int reuse = 1; if (setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (const char*)&reuse, sizeof(reuse)) < 0) perror("setsockopt(SO_REUSEADDR) failed"); if (setsockopt(sock, SOL_SOCKET, SO_REUSEPORT, (const char*)&reuse, sizeof(reuse)) < 0) perror("setsockopt(SO_REUSEPORT) failed"); //Bind socket returnCode = bind(sock,(struct sockaddr*) &temp,sizeof(temp)); //Number of client allowed returnCode = listen(sock, 1); return sock; } int createActiveSocket(int port, char *ipAddress) { int sockfd; struct sockaddr_in serv_addr; struct hostent *hostnm; /* server host name information */ memset(&serv_addr, 0, sizeof(struct sockaddr_in)); serv_addr.sin_family = AF_INET; serv_addr.sin_port = htons(port); if(inet_pton(AF_INET, ipAddress, &serv_addr.sin_addr)<=0) { printf("\n inet_pton error occured\n"); return -1; } if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) { printf("\n Error : Could not create socket \n"); return -1; } else { printf("\n sockfd = %d \n", sockfd); } int reuse = 1; if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, (const char*)&reuse, sizeof(reuse)) < 0) perror("setsockopt(SO_REUSEADDR) failed"); if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEPORT, (const char*)&reuse, sizeof(reuse)) < 0) perror("setsockopt(SO_REUSEPORT) failed"); if(connect(sockfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0) { printf("\n Error : Connect Failed \n"); return -1; } printf("\n Connection socket %d is going to start ip: %s:%d \n",sockfd, ipAddress, port); return sockfd; } static void closeSocket(int processingSocket) { //Close the socket shutdown(ftpData.clients[processingSocket].socketDescriptor, SHUT_RDWR); close(ftpData.clients[processingSocket].socketDescriptor); resetClientData(&ftpData.clients[processingSocket], 0); resetWorkerData(&ftpData.clients[processingSocket].workerData, 0); //Update client connecteds ftpData.connectedClients--; if (ftpData.connectedClients < 0) { ftpData.connectedClients = 0; } printTimeStamp(); printf("Client id: %d disconnected", processingSocket); printf("\nServer: Clients connected:%d", ftpData.connectedClients); return; } static void initFtpData(void) { int i; ftpData.connectedClients = 0; ftpData.clients = (clientDataType *) malloc( sizeof(clientDataType) * ftpData.ftpParameters.maxClients); ftpData.serverIp.ip[0] = 127; ftpData.serverIp.ip[1] = 0; ftpData.serverIp.ip[2] = 0; ftpData.serverIp.ip[3] = 1; memset(ftpData.welcomeMessage, 0, 1024); strcpy(ftpData.welcomeMessage, "220 Hello\r\n"); //Client data reset to zero for (i = 0; i < ftpData.ftpParameters.maxClients; i++) { resetWorkerData(&ftpData.clients[i].workerData, 1); resetClientData(&ftpData.clients[i], 1); ftpData.clients[i].clientProgressiveNumber = i; } return; } static int processCommand(int processingElement) { int toReturn = 0; printTimeStamp(); printf ("Command received from (%d): %s", processingElement, ftpData.clients[processingElement].theCommandReceived); //printf ("\nstrncmp(ftpData.clients[processingElement].theCommandReceived, \"USER\", strlen(\"USER\")) %d", strncmp(ftpData.clients[processingElement].theCommandReceived, "USER", strlen("USER"))); //printf ("\nstrncmp(ftpData.clients[processingElement].theCommandReceived, \"user\", strlen(\"user\")) %d", strncmp(ftpData.clients[processingElement].theCommandReceived, "user", strlen("user"))); //printf ("\nstrncmp(ftpData.clients[processingElement].theCommandReceived, \"PASS\", strlen(\"PASS\")) %d", strncmp(ftpData.clients[processingElement].theCommandReceived, "PASS", strlen("PASS"))); //printf ("\nstrncmp(ftpData.clients[processingElement].theCommandReceived, \"pass\", strlen(\"pass\")) %d", strncmp(ftpData.clients[processingElement].theCommandReceived, "pass", strlen("pass"))); cleanDynamicStringDataType(&ftpData.clients[processingElement].ftpCommand.commandArgs, 0); cleanDynamicStringDataType(&ftpData.clients[processingElement].ftpCommand.commandOps, 0); if (ftpData.clients[processingElement].login.userLoggedIn == 0 && (strncmp(ftpData.clients[processingElement].theCommandReceived, "USER", strlen("USER")) != 0 && strncmp(ftpData.clients[processingElement].theCommandReceived, "user", strlen("user")) != 0 && strncmp(ftpData.clients[processingElement].theCommandReceived, "PASS", strlen("PASS")) != 0 && strncmp(ftpData.clients[processingElement].theCommandReceived, "pass", strlen("pass")) != 0 && strncmp(ftpData.clients[processingElement].theCommandReceived, "QUIT", strlen("QUIT")) != 0 && strncmp(ftpData.clients[processingElement].theCommandReceived, "quit", strlen("quit")) != 0) && strncmp(ftpData.clients[processingElement].theCommandReceived, "AUTH", strlen("AUTH")) != 0 && strncmp(ftpData.clients[processingElement].theCommandReceived, "auth", strlen("auth")) != 0) { toReturn = notLoggedInMessage(&ftpData.clients[processingElement]); return 1; } //Process Command if(strncmp(ftpData.clients[processingElement].theCommandReceived, "USER", strlen("USER")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "user", strlen("user")) == 0) { printf("\nUSER COMMAND RECEIVED"); toReturn = parseCommandUser(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "PASS", strlen("PASS")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "pass", strlen("pass")) == 0) { printf("\nPASS COMMAND RECEIVED"); toReturn = parseCommandPass(&ftpData, processingElement); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "SITE", strlen("SITE")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "site", strlen("site")) == 0) { printf("\nSITE COMMAND RECEIVED"); toReturn = parseCommandSite(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "AUTH", strlen("AUTH")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "auth", strlen("auth")) == 0) { printf("\nAUTH COMMAND RECEIVED"); toReturn = parseCommandAuth(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "PWD", strlen("PWD")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "pwd", strlen("pwd")) == 0) { printf("\nPWD COMMAND RECEIVED"); toReturn = parseCommandPwd(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "SYST", strlen("SYST")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "syst", strlen("syst")) == 0) { printf("\nSYST COMMAND RECEIVED"); toReturn = parseCommandSyst(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "FEAT", strlen("FEAT")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "feat", strlen("feat")) == 0) { printf("\nFEAT COMMAND RECEIVED"); toReturn = parseCommandFeat(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "TYPE I", strlen("TYPE I")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "type i", strlen("type i")) == 0) { printf("\nTYPE I COMMAND RECEIVED"); toReturn = parseCommandTypeI(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "STRU F", strlen("STRU F")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "stru f", strlen("stru f")) == 0) { printf("\nTYPE I COMMAND RECEIVED"); toReturn = parseCommandStruF(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "MODE S", strlen("TMODE S")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "mode s", strlen("mode s")) == 0) { printf("\nMODE S COMMAND RECEIVED"); toReturn = parseCommandModeS(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "TYPE A", strlen("TYPE A")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "type a", strlen("type a")) == 0) { printf("\nTYPE A COMMAND RECEIVED"); toReturn = parseCommandTypeI(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "PASV", strlen("PASV")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "pasv", strlen("pasv")) == 0) { printf("\nPASV COMMAND RECEIVED"); setRandomicPort(&ftpData, processingElement); toReturn = parseCommandPasv(&ftpData, processingElement); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "PORT", strlen("PORT")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "port", strlen("port")) == 0) { printf("\nPORT COMMAND RECEIVED"); toReturn = parseCommandPort(&ftpData, processingElement); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "LIST", strlen("LIST")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "list", strlen("list")) == 0) { printf("\nLIST COMMAND RECEIVED"); toReturn = parseCommandList(&ftpData, processingElement); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "CWD", strlen("CWD")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "cwd", strlen("cwd")) == 0) { printf("\nCWD COMMAND RECEIVED"); toReturn = parseCommandCwd(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "CDUP", strlen("CDUP")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "cdup", strlen("cdup")) == 0) { printf("\nCDUP COMMAND RECEIVED"); toReturn = parseCommandCdup(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "REST", strlen("REST")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "rest", strlen("rest")) == 0) { printf("\nREST COMMAND RECEIVED"); toReturn = parseCommandRest(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "RETR", strlen("RETR")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "retr", strlen("retr")) == 0) { printf("\nRETR COMMAND RECEIVED"); toReturn = parseCommandRetr(&ftpData, processingElement); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "STOR", strlen("STOR")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "stor", strlen("stor")) == 0) { printf("\nSTOR COMMAND RECEIVED"); toReturn = parseCommandStor(&ftpData, processingElement); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "MKD", strlen("MKD")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "mkd", strlen("mkd")) == 0) { printf("\nMKD command received"); toReturn = parseCommandMkd(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "ABOR", strlen("ABOR")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "abor", strlen("abor")) == 0) { printf("\nABOR command received"); toReturn = parseCommandAbor(&ftpData, processingElement); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "DELE", strlen("DELE")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "dele", strlen("dele")) == 0) { printf("\nDELE command received"); toReturn = parseCommandDele(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "OPTS", strlen("OPTS")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "opts", strlen("opts")) == 0) { printf("\nOPTS command received"); toReturn = parseCommandOpts(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "MTDM", strlen("MTDM")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "mtdm", strlen("mtdm")) == 0) { printf("\nMTDM command received"); //To implement } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "NLST", strlen("NLST")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "nlst", strlen("nlst")) == 0) { printf("\nNLST command received"); toReturn = parseCommandNlst(&ftpData, processingElement); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "PORT", strlen("PORT")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "port", strlen("port")) == 0) { printf("\nPORT command received"); //To implement } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "QUIT", strlen("QUIT")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "quit", strlen("quit")) == 0) { printf("\nQUIT command received"); toReturn = parseCommandQuit(&ftpData, processingElement); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "RMD", strlen("RMD")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "rmd", strlen("rmd")) == 0) { printf("\nRMD command received"); toReturn = parseCommandRmd(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "RNFR", strlen("RNFR")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "rnfr", strlen("rnfr")) == 0) { printf("\nRNFR command received"); toReturn = parseCommandRnfr(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "RNTO", strlen("RNTO")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "rnto", strlen("rnto")) == 0) { printf("\nRNTO command received"); toReturn = parseCommandRnto(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "SIZE", strlen("SIZE")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "size", strlen("size")) == 0) { printf("\nSIZE command received"); toReturn = parseCommandSize(&ftpData.clients[processingElement]); } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "APPE", strlen("APPE")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "appe", strlen("appe")) == 0) { printf("\nAPPE command received"); //To implement } else if(strncmp(ftpData.clients[processingElement].theCommandReceived, "NOOP", strlen("NOOP")) == 0 || strncmp(ftpData.clients[processingElement].theCommandReceived, "noop", strlen("noop")) == 0) { printf("\nNOOP command received"); toReturn = parseCommandNoop(&ftpData.clients[processingElement]); } else { //Parse unsupported command } ftpData.clients[processingElement].commandIndex = 0; memset(ftpData.clients[processingElement].theCommandReceived, 0, CLIENT_COMMAND_STRING_SIZE); return toReturn; } static int getMaximumSocketFd(int mainSocket, ftpDataType * data) { int toReturn = mainSocket; int i = 0; for (i = 0; i < data->ftpParameters.maxClients; i++) { if (data->clients[i].socketDescriptor > toReturn) { toReturn = data->clients[i].socketDescriptor; } } return toReturn; }