Complete

C.c

@@ -0,0 +1,216 @@
+#include "function.h"
+
+char buffer_read[BUFFERSIZE];
+char buffer_write[BUFFERSIZE];
+char large_buff[BUFFERSIZE];
+char hostname[100];
+int sockfd; // control socket
+int data_sock; // data socket
+int new_port = -1;
+struct sockaddr_in serv_addr; // socket info
+
+void error(const char *msg, int i){
+    perror(msg);
+    exit(i);
+}
+
+void change_type(char t){
+	bzero(buffer_write, BUFFERSIZE);
+	sprintf(buffer_write ,"TYPE %c\r\n", t);
+	send( sockfd, buffer_write, (int)strlen(buffer_write), 0);
+	parse();
+	bzero(buffer_write, BUFFERSIZE);
+}
+
+int parse() {
+	int flag = 0;	
+	while(flag == 0){
+		bzero(large_buff, BUFFERSIZE);	
+		int result = recv( sockfd, large_buff, BUFFERSIZE, 0);
+		if (result < 0)  error("Error read", 5);
+		char *p = strtok(large_buff, "\n");
+		while (p != 0 ) {
+			char *command;
+			command = p;
+			printf("%s\n",command);
+			if(command[3] == ' '){
+				char type[4];
+				strncpy(type, command, 4);
+				type[4] = 0;
+//				printf("\nInst type = %d\n", atoi(type));
+				flag = -1;
+				return atoi(type);
+			}
+			p = strtok(NULL,"\n");
+		}
+	}
+	return 0;
+}
+
+void pasv(){
+	int type;
+	bzero(buffer_read, BUFFERSIZE);		 
+	recv( sockfd, buffer_read, BUFFERSIZE, 0);
+	printf("%s\n",buffer_read);
+	if(buffer_read[3] == ' '){
+		char ctype[4];
+		strncpy(ctype, buffer_read, 4);
+		ctype[4] = 0;
+		type = atoi(ctype);	
+	} else type = 0;
+
+	if( type == 227){
+		if(strcmp(hostname, "localhost") != 0){
+			new_port = get_port(buffer_read);
+		}else 
+			new_port = get_port2(buffer_read);
+
+		data_sock = socket(AF_INET, SOCK_STREAM, 0);
+		if (data_sock < 0) error("ERROR opening data socket\n", 2);
+		serv_addr.sin_port = htons(new_port);
+		if(strcmp( hostname, "localhost") != 0) change_type('i');
+	}else new_port = -1;
+}
+
+
+int main(int argc, char const *argv[])
+{
+	if(argc != 3) error("argument error!", 0);
+
+	struct hostent *host;		  // host info
+	int i;
+
+	//create socket
+	sockfd = socket(AF_INET, SOCK_STREAM, 0);
+	if (sockfd < 0) error("ERROR opening socket\n", 2);
+
+	//get host
+	serv_addr.sin_family = AF_INET;
+	host = gethostbyname(argv[1]);
+	strcpy(hostname, argv[1]);
+	if (host == NULL) error("ERROR, no such host\n", 0);
+	memcpy(&serv_addr.sin_addr.s_addr, host->h_addr, host->h_length); 
+
+	//get port
+	serv_addr.sin_port = htons(atoi(argv[2]));
+	bzero(&(serv_addr.sin_zero), 8);
+
+	//connect
+	if(connect(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0)
+		error("ERROR connecting! \n", 3);
+
+	parse();
+
+	while(strcmp(buffer_write, "BYE\r\n") != 0){
+		printf("ftp:$");
+		bzero(buffer_write, BUFFERSIZE);
+		fgets(buffer_write, BUFFERSIZE, stdin);
+
+		for(i = 0; buffer_write[i] != '\n'; i++); buffer_write[i] = '\0';
+		strcat(buffer_write, "\r\n");
+
+		int result = send( sockfd, buffer_write, (int)strlen(buffer_write), 0);
+		if (result < 0) error("Error write to serVer!\n", 4);
+
+		if(strncmp(buffer_write, "STOR ", 5) == 0){
+			if(new_port != -1){
+				sleep(1);
+				if(connect(data_sock, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0)
+					printf("Error connecting data socket! \n");
+			}
+			int type = parse();
+		    if(type == 150){
+				// receive files
+				char filename[100]; int j = 0;
+				for(i = 0; buffer_write[i] != ' '; i++); i++;
+				for(; buffer_write[i] != '\r'; i++){
+					filename[j++] = buffer_write[i];
+				}filename[j] = 0;
+
+				sleep(1);
+				ftp_put(data_sock, filename);
+				type = parse();
+				close(data_sock);
+			}else if(type == 500){
+					parse(); 
+			}
+			new_port = -1;
+
+		}else if(strcmp(buffer_write, "PASV\r\n") == 0){
+			pasv();
+
+		}else if(strcmp(buffer_write, "NLST\r\n") == 0){
+			if(strcmp(hostname, "localhost") != 0){
+				if(new_port != -1){
+					sleep(1);
+					if(connect(data_sock, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0)
+						printf("Error connecting data socket! \n");
+				}
+				int type = parse(); 
+				if(type == 150){
+					int readCount;
+					do{
+						readCount = read(data_sock, buffer_read, BUFFERSIZE);
+						buffer_read[readCount] = 0; // !!!
+						printf("%s",buffer_read);
+					} while(readCount != 0);
+					close(data_sock);
+					parse(); 
+				}else if(type == 500){
+					parse(); 
+				}
+				new_port = -1;
+
+			}else {
+				result = recv( sockfd, buffer_read, BUFFERSIZE, 0);
+				if (result < 0)  error("Error read", 5);
+				printf("%s\n",buffer_read);
+			}
+		}else if(strncmp(buffer_write, "RETR ", 5) == 0){
+
+			if(new_port != -1){
+				sleep(1);
+				if(connect(data_sock, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0)
+					printf("Error connecting data socket! \n");
+			}
+			int type = parse();
+		    if(type == 150){
+				// receive files
+				char filename[100]; int j = 0;
+				for(i = 0; buffer_write[i] != ' '; i++); i++;
+				for(; buffer_write[i] != '\r'; i++){
+					filename[j++] = buffer_write[i];
+				}filename[j] = 0;
+				sleep(1);
+				ftp_get(data_sock, filename);	
+				type = parse(); 
+				if(type == 550){
+					unlink(filename);
+					close(data_sock);
+					//continue;
+				}
+				else if(type == 226)
+					close(data_sock);
+			}else {
+				continue;
+			}
+			new_port = -1;
+
+		}else if(strncmp(buffer_write, "PASS", 4) == 0){
+
+		    if(parse() == 230)
+		    	continue;
+
+		}else if(strncmp(buffer_write, "BYE\r\n", 4) == 0){
+			parse();
+			break;
+
+		}else{
+			parse();
+		}
+
+	}
+
+	close(sockfd);
+	return 0;
+}

Makefile

@@ -0,0 +1,32 @@
+CC = gcc
+CFLAGS = -g -I./
+SRCCLIENT = .
+SRCSERVER = .
+BINCLIENT = bin/client
+BINSERVER = bin/server
+OBJCLIENT = obj
+OBJSERVER = obj
+OBJECTSCLIENT =  ${OBJCLIENT}/function.o ${OBJCLIENT}/C.o
+OBJECTSSERVER =  ${OBJSERVER}/function.o ${OBJSERVER}/S.o 
+EXECUTABLECLIENT = ${BINCLIENT}/C
+EXECUTABLESERVER = ${BINSERVER}/S
+
+all:	clean client server
+
+client:	${OBJECTSCLIENT}
+	${CC} ${CFLAGS} $^ -o ${EXECUTABLECLIENT}
+
+server:	${OBJECTSSERVER}
+	${CC} ${CFLAGS} $^ -o ${EXECUTABLESERVER}
+
+${OBJCLIENT}/%.o:	${SRCCLIENT}/%.c
+	${CC} ${CFLAGS} -c $< -o $@
+
+${OBJSERVER}/%.o:	${SRCSERVER}/%.c
+	${CC} ${CFLAGS} -c $< -o $@
+
+clean:
+	rm -f ${OBJCLIENT}/*.o
+	rm -f ${OBJSERVER}/*.o
+	rm -f ${BINCLIENT}/*.out
+	rm -f ${BINSERVER}/*.out