mirror of
https://github.com/kingk85/uFTP.git
synced 2025-07-15 16:26:10 +03:00
594 lines
22 KiB
C
594 lines
22 KiB
C
/*
|
|
* To change this license header, choose License Headers in Project Properties.
|
|
* To change this template file, choose Tools | Templates
|
|
* and open the template in the editor.
|
|
*/
|
|
|
|
#include <sys/types.h>
|
|
#include <sys/socket.h>
|
|
#include <netinet/in.h>
|
|
#include <fcntl.h>
|
|
#include <string.h>
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <unistd.h>
|
|
#include <pthread.h>
|
|
|
|
|
|
/* FTP LIBS */
|
|
#include "ftpServer.h"
|
|
#include "ftpData.h"
|
|
#include "ftpCommandsElaborate.h"
|
|
#include "fileManagement.h"
|
|
#include "logFunctions.h"
|
|
#define SERVER_PORT 21
|
|
|
|
static ftpDataType ftpData;
|
|
|
|
static int createSocket(int port);
|
|
static void closeSocket(int processingSocket);
|
|
static void initFtpData(void);
|
|
static int processCommand(int processingElement);
|
|
|
|
void *pasvThreadHandler(void * socketId)
|
|
{
|
|
|
|
int theSocketId = *(int *)socketId;
|
|
ftpData.clients[theSocketId].pasvData.passiveSocket = createPassiveSocket(ftpData.clients[theSocketId].pasvData.passivePort);
|
|
|
|
//Endless loop ftp process
|
|
while (1)
|
|
{
|
|
usleep(1000);
|
|
|
|
if (ftpData.clients[theSocketId].pasvData.passiveSocketIsConnected == 0)
|
|
{
|
|
printTimeStamp();
|
|
printf("Waiting for pasv client connection on port: %d", ftpData.clients[theSocketId].pasvData.passivePort);
|
|
|
|
//Wait for sockets
|
|
if ((ftpData.clients[theSocketId].pasvData.passiveSocketConnection = accept(ftpData.clients[theSocketId].pasvData.passiveSocket, 0, 0))!=-1)
|
|
{
|
|
printTimeStamp();
|
|
printf("Pasv connection initialized");
|
|
int error;
|
|
ftpData.clients[theSocketId].pasvData.passiveSocketIsConnected = 1;
|
|
error = fcntl(ftpData.clients[theSocketId].pasvData.passiveSocketConnection, F_SETFL, O_NONBLOCK);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
printTimeStamp();
|
|
printf("Pasv waiting..");
|
|
|
|
//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].socketCommandReceived == 1 &&
|
|
strncmp(ftpData.clients[theSocketId].pasvData.theCommandReceived, "STOR", strlen("STOR")) == 0 &&
|
|
ftpData.clients[theSocketId].pasvData.theFileNameToStorIndex > 0)
|
|
{
|
|
char theResponse[FTP_COMMAND_ELABORATE_CHAR_BUFFER];
|
|
memset(theResponse, 0, FTP_COMMAND_ELABORATE_CHAR_BUFFER);
|
|
|
|
char theAbsoluteFileNamePath[FTP_COMMAND_ELABORATE_CHAR_BUFFER];
|
|
memset(theAbsoluteFileNamePath, 0, FTP_COMMAND_ELABORATE_CHAR_BUFFER);
|
|
|
|
strcpy(theAbsoluteFileNamePath, ftpData.clients[theSocketId].login.absolutePath);
|
|
|
|
if (theAbsoluteFileNamePath[strlen(theAbsoluteFileNamePath)-1] != '/')
|
|
strcat(theAbsoluteFileNamePath, "/");
|
|
|
|
strcat(theAbsoluteFileNamePath, ftpData.clients[theSocketId].pasvData.theFileNameToStor);
|
|
|
|
strcpy(theResponse, "150 Accepted data connection\r\n");
|
|
write(ftpData.clients[theSocketId].socketDescriptor, theResponse, strlen(theResponse));
|
|
|
|
|
|
while(1)
|
|
{
|
|
if ((ftpData.clients[theSocketId].pasvData.bufferIndex = read(ftpData.clients[theSocketId].pasvData.passiveSocketConnection, ftpData.clients[theSocketId].pasvData.buffer, CLIENT_BUFFER_STRING_SIZE)) == 0)
|
|
{
|
|
//Client is disconnected!
|
|
break;
|
|
}
|
|
|
|
if (ftpData.clients[theSocketId].pasvData.bufferIndex > 0)
|
|
{
|
|
int i = 0;
|
|
for (i = 0; i < ftpData.clients[theSocketId].pasvData.bufferIndex; i++)
|
|
{
|
|
;
|
|
}
|
|
usleep(100);
|
|
}
|
|
}
|
|
|
|
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].socketCommandReceived == 1 &&
|
|
strncmp(ftpData.clients[theSocketId].pasvData.theCommandReceived, "LIST", strlen("LIST")) == 0)
|
|
{
|
|
DYNV_VectorGenericDataType directoryInfo;
|
|
DYNV_VectorGeneric_Init(&directoryInfo);
|
|
|
|
//printf("directoryInfo address: %lX", &directoryInfo);
|
|
int i;
|
|
getListDataInfo(ftpData.clients[theSocketId].login.absolutePath.text, &directoryInfo);
|
|
|
|
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].pasvData.passiveSocketConnection, 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
|
|
,((ftpListDataType *) directoryInfo.Data[i])->numberOfSubDirectories
|
|
,((ftpListDataType *) directoryInfo.Data[i])->owner
|
|
,((ftpListDataType *) directoryInfo.Data[i])->groupOwner
|
|
,((ftpListDataType *) directoryInfo.Data[i])->fileSize
|
|
,((ftpListDataType *) directoryInfo.Data[i])->lastModifiedDataString
|
|
,((ftpListDataType *) directoryInfo.Data[i])->fileNameNoPath);
|
|
//printf("%s", theBufferWrite);
|
|
write(ftpData.clients[theSocketId].pasvData.passiveSocketConnection, 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);
|
|
}
|
|
|
|
break;
|
|
}
|
|
else if (ftpData.clients[theSocketId].socketCommandReceived == 1 &&
|
|
strncmp(ftpData.clients[theSocketId].pasvData.theCommandReceived, "RETR", strlen("RETR")) == 0)
|
|
{
|
|
char theResponse[FTP_COMMAND_ELABORATE_CHAR_BUFFER];
|
|
printTimeStamp();
|
|
printf("The pasvData Command: %s", ftpData.clients[theSocketId].pasvData.theCommandReceived);
|
|
|
|
int i;
|
|
char theFileName[CLIENT_COMMAND_STRING_SIZE];
|
|
int theFileNameCursor = 0;
|
|
memset(theFileName, 0, CLIENT_COMMAND_STRING_SIZE);
|
|
char *theFullFileName;
|
|
char *theFullFileContent;
|
|
|
|
for (i = strlen("RETR") + 1; i < CLIENT_COMMAND_STRING_SIZE; i++)
|
|
{
|
|
if (ftpData.clients[theSocketId].pasvData.theCommandReceived[i] == '\r' ||
|
|
ftpData.clients[theSocketId].pasvData.theCommandReceived[i] == '\n' ||
|
|
ftpData.clients[theSocketId].pasvData.theCommandReceived[i] == '\0') {
|
|
break;
|
|
}
|
|
|
|
if (theFileNameCursor < CLIENT_COMMAND_STRING_SIZE)
|
|
{
|
|
theFileName[theFileNameCursor++] = ftpData.clients[theSocketId].pasvData.theCommandReceived[i];
|
|
}
|
|
}
|
|
printTimeStamp();
|
|
printf("The File to retrieve is: %s", theFileName);
|
|
|
|
theFullFileName = (char *) malloc(ftpData.clients[theSocketId].login.absolutePath.textLen+1);
|
|
strcpy(theFullFileName, ftpData.clients[theSocketId].login.absolutePath.text);
|
|
FILE_AppendToString(&theFullFileName, "/");
|
|
FILE_AppendToString(&theFullFileName, theFileName);
|
|
printTimeStamp();
|
|
printf("The File to retrieve is: %s", theFullFileName);
|
|
|
|
int theFileSize = FILE_GetStringFromFile(theFullFileName, &theFullFileContent);
|
|
printTimeStamp();
|
|
printf("The File size is: %d", theFileSize);
|
|
memset(theResponse, 0, FTP_COMMAND_ELABORATE_CHAR_BUFFER);
|
|
strcpy(theResponse, "150 Accepted data connection\r\n");
|
|
write(ftpData.clients[theSocketId].socketDescriptor, theResponse, strlen(theResponse));
|
|
|
|
write(ftpData.clients[theSocketId].pasvData.passiveSocketConnection, theFullFileContent, theFileSize);
|
|
|
|
|
|
free(theFullFileName);
|
|
free(theFullFileContent);
|
|
//226-File successfully transferred
|
|
//226 0.013 seconds (measured here), 105.22 Kbytes per second
|
|
|
|
memset(theResponse, 0, FTP_COMMAND_ELABORATE_CHAR_BUFFER);
|
|
sprintf(theResponse, "226-File successfully transferred\r\n226 done\r\n");
|
|
write(ftpData.clients[theSocketId].socketDescriptor, theResponse, strlen(theResponse));
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
printTimeStamp();
|
|
printf("Closing pasv socket (%d) ok!", theSocketId);
|
|
shutdown(ftpData.clients[theSocketId].pasvData.passiveSocketConnection, SHUT_RDWR);
|
|
shutdown(ftpData.clients[theSocketId].pasvData.passiveSocket, SHUT_RDWR);
|
|
close(ftpData.clients[theSocketId].pasvData.passiveSocketConnection);
|
|
close(ftpData.clients[theSocketId].pasvData.passiveSocket);
|
|
resetPasvData(&ftpData.clients[theSocketId].pasvData);
|
|
fflush(0);
|
|
return NULL;
|
|
}
|
|
|
|
void runFtpServer(void)
|
|
{
|
|
static int processingSock = 0;
|
|
|
|
|
|
//Initialize all ftp data
|
|
initFtpData();
|
|
|
|
/*
|
|
DYNV_VectorGenericDataType directoryInfo;
|
|
DYNV_VectorGeneric_Init(&directoryInfo);
|
|
|
|
printf("\ndirectoryInfo address: %lX", &directoryInfo);
|
|
int i;
|
|
getListDataInfo("/home/ugo", &directoryInfo);
|
|
|
|
int theSize = directoryInfo.Size;
|
|
|
|
char ** lastToDestroy = NULL;
|
|
directoryInfo.Destroy(&directoryInfo, deleteListDataInfoVector);
|
|
|
|
if (theSize > 0)
|
|
{
|
|
//lastToDestroy = ((ftpListDataType *)directoryInfo.Data[0])->fileList;
|
|
//free(lastToDestroy);
|
|
}
|
|
|
|
exit(0);
|
|
*/
|
|
|
|
|
|
|
|
|
|
//Socket main creator
|
|
ftpData.theSocket = createSocket(SERVER_PORT);
|
|
printTimeStamp();
|
|
printf("uFTP server starting..");
|
|
printf("\n Server: Clients connected: %d", ftpData.connectedClients);
|
|
printf("\nServer: Max Client Allowed: %d", ftpData.maxClients);
|
|
|
|
|
|
//Endless loop ftp process
|
|
while (1)
|
|
{
|
|
usleep(100000);
|
|
|
|
for (processingSock = 0; processingSock < ftpData.maxClients; processingSock++)
|
|
{
|
|
if (ftpData.clients[processingSock].socketIsConnected == 0)
|
|
{
|
|
//Wait for sockets
|
|
if ((ftpData.clients[processingSock].socketDescriptor = accept(ftpData.theSocket,0 ,0 ))!=-1)
|
|
{
|
|
int error;
|
|
ftpData.connectedClients++;
|
|
ftpData.clients[processingSock].socketIsConnected = 1;
|
|
error = fcntl(ftpData.clients[processingSock].socketDescriptor, F_SETFL, O_NONBLOCK);
|
|
printTimeStamp();
|
|
printf("Server: New client connected with id: %d", processingSock);
|
|
printf("\nServer: Clients connected: %d", ftpData.connectedClients);
|
|
write(ftpData.clients[processingSock].socketDescriptor, ftpData.welcomeMessage, strlen(ftpData.welcomeMessage));
|
|
}
|
|
}
|
|
else
|
|
{
|
|
//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)
|
|
{
|
|
closeSocket(processingSock);
|
|
}
|
|
|
|
//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)
|
|
{
|
|
write(ftpData.clients[processingSock].socketDescriptor, ftpData.clients[processingSock].buffer, ftpData.clients[processingSock].bufferIndex);
|
|
}
|
|
}
|
|
}
|
|
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)
|
|
{
|
|
int sock, errore;
|
|
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
|
|
errore = 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
|
|
errore = bind(sock,(struct sockaddr*) &temp,sizeof(temp));
|
|
|
|
//Number of client allowed
|
|
errore = listen(sock, ftpData.maxClients);
|
|
|
|
return sock;
|
|
}
|
|
|
|
int createPassiveSocket(int port)
|
|
{
|
|
int sock, errore, 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;
|
|
errore = 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
|
|
errore = bind(sock,(struct sockaddr*) &temp,sizeof(temp));
|
|
|
|
//Number of client allowed
|
|
errore = listen(sock, 1);
|
|
|
|
return sock;
|
|
}
|
|
|
|
static void closeSocket(int processingSocket)
|
|
{
|
|
//Close the socket
|
|
close(ftpData.clients[processingSocket].socketDescriptor);
|
|
|
|
resetClientData(&ftpData.clients[processingSocket], 0);
|
|
resetPasvData(&ftpData.clients[processingSocket].pasvData);
|
|
//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.maxClients = 10;
|
|
ftpData.clients = (clientDataType *) malloc( sizeof(clientDataType) * ftpData.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.maxClients; i++)
|
|
{
|
|
resetPasvData(&ftpData.clients[i].pasvData);
|
|
resetClientData(&ftpData.clients[i], 1);
|
|
}
|
|
|
|
return;
|
|
}
|
|
|
|
static int processCommand(int processingElement)
|
|
{
|
|
int toReturn = 0;
|
|
printTimeStamp();
|
|
printf ("Command received from (%d): %s", processingElement, ftpData.clients[processingElement].theCommandReceived);
|
|
|
|
//Process Command
|
|
if(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)
|
|
{
|
|
printf("\nPASS COMMAND RECEIVED");
|
|
toReturn = parseCommandPass(&ftpData.clients[processingElement]);
|
|
}
|
|
else if(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)
|
|
{
|
|
printf("\nPWD COMMAND RECEIVED");
|
|
toReturn = parseCommandPwd(&ftpData.clients[processingElement]);
|
|
}
|
|
else if(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)
|
|
{
|
|
printf("\nSYST COMMAND RECEIVED");
|
|
toReturn = parseCommandFeat(&ftpData.clients[processingElement]);
|
|
}
|
|
else if(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, "PASV", strlen("PASV")) == 0)
|
|
{
|
|
printf("\nPASV COMMAND RECEIVED");
|
|
setRandomicPort(&ftpData, processingElement);
|
|
toReturn = parseCommandPasv(&ftpData, processingElement);
|
|
}
|
|
else if(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)
|
|
{
|
|
printf("\nCWD COMMAND RECEIVED");
|
|
toReturn = parseCommandCwd(&ftpData.clients[processingElement]);
|
|
}
|
|
else if(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)
|
|
{
|
|
printf("\nREST COMMAND RECEIVED");
|
|
toReturn = parseCommandRest(&ftpData.clients[processingElement]);
|
|
}
|
|
else if(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)
|
|
{
|
|
printf("\nSTOR COMMAND RECEIVED");
|
|
toReturn = parseCommandStor(&ftpData, processingElement);
|
|
}
|
|
|
|
//REST COMMAND
|
|
//REST 0
|
|
//350 Restarting at 0
|
|
|
|
//RETR info.php
|
|
//150 Accepted data connection
|
|
//226-File successfully transferred
|
|
//226 0.013 seconds (measured here), 105.22 Kbytes per second
|
|
|
|
|
|
//227 Entering Passive Mode (192,185,16,65,182,64)
|
|
//STOR testUgo.txt
|
|
//150 Accepted data connection
|
|
//226-File successfully transferred
|
|
//226 21.350 seconds (measured here), 3.33 bytes per second
|
|
|
|
ftpData.clients[processingElement].commandIndex = 0;
|
|
memset(ftpData.clients[processingElement].theCommandReceived, 0, CLIENT_COMMAND_STRING_SIZE);
|
|
|
|
return toReturn;
|
|
}
|
|
|