digiyudi

Special Thanks to:
Danu Kurniawan n Even

#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <time.h>
#include <errno.h>

#define SERVER_PORT_ID 6081
#define CLIENT_PORT_ID 6086
#define SERVER_HOST_ADDR “127.0.0.1″
#define MAXSIZE 512
#define ACK 2
#define NACK 3
#define REQUESTFILE 100
#define COMMANDNOTSUPPORTED 150
#define COMMANDSUPPORTED 160
#define BADFILENAME 200
#define FILENAMEOK 400
#define STARTTRANSFER 500

int readn(int sd,char *ptr,int size);
int writen(int sd,char *ptr,int size);

main(int argc,char *argv[]){
int sockid, newsockid, i, getfile;
int ack, msg, msg_2, c, len;
int no_writen,start_xfer, num_blks,num_last_blk;
struct sockaddr_in my_addr, server_addr;
FILE *fp;
char in_buf[MAXSIZE];

if(argc != 2){
printf(”error: usage : ftp filename\n”);
exit(0);
}

no_writen = 0;
num_blks = 0;
num_last_blk = 0;
len = strlen(argv[1]);
printf(”client: creating socket\n”);

if((sockid=socket(AF_INET,SOCK_STREAM,0))< 0){
printf("client: socket error : %d\n", errno);
exit(0);
}

printf("client: binding my local socket\n");
bzero((char *) &my_addr,sizeof(my_addr));
my_addr.sin_family = AF_INET;
my_addr.sin_addr.s_addr = htonl(INADDR_ANY);
my_addr.sin_port = htons(CLIENT_PORT_ID);

if(bind(sockid ,(struct sockaddr *) &my_addr, sizeof(my_addr)) < 0){
printf("client: bind error :%d\n", errno);
exit(0);
}

printf("client: starting connect\n");
bzero((char *)&server_addr,sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr=inet_addr(SERVER_HOST_ADDR);
server_addr.sin_port = htons(SERVER_PORT_ID);

if(connect(sockid ,(struct sockaddr *) &server_addr,sizeof(server_addr)) < 0){
printf("client: connect error :%d\n", errno);
exit(0);
}

getfile = htons(REQUESTFILE);
printf("sending command request to ftp server\n");

if((writen(sockid,(char *)&getfile,sizeof(getfile))) < 0){
printf("write error:%d\n", errno); exit(0);
}
msg = 0;

if((readn(sockid,(char *)&msg,sizeof(msg)))< 0){
printf("read error:%d\n", errno); exit(0);
}

msg = ntohs(msg);

if(msg==COMMANDNOTSUPPORTED){
printf("server refused command\n"); exit(0);
}
else
printf("server replied %d, command supported\n",msg);

printf("client: sending filename\n");

if((writen(sockid,argv[1],len))< 0){
printf("write error:%d\n", errno);
exit(0);
}

msg_2 = 0;

if((readn(sockid,(char *)&msg_2, sizeof(msg_2)))< 0){
printf("read error:%d\n", errno); exit(0);
}

msg_2 = ntohs(msg_2);

if(msg_2 == BADFILENAME){
printf("server reported bad file name\n");
exit(0);
}
else
printf("server replied filename OK\n");

printf("sending start transfer command\n");
start_xfer = STARTTRANSFER;
start_xfer = htons(start_xfer);

if((writen(sockid,(char *)&start_xfer,sizeof(start_xfer)))< 0){
printf("write error:%d\n", errno);
exit(0);
}

if((fp = fopen(argv[1],"w")) == NULL){
printf("local open file error\n");
exit(0);
}

if((readn(sockid,(char *)&num_blks,sizeof(num_blks))) < 0){
printf("read error on nblocks :%d\n",errno);
exit(0);
}

num_blks = ntohs(num_blks);
printf("server responded: %d blocks in file\n",num_blks);
ack = ACK;
ack = htons(ack);

if((writen(sockid,(char*)&ack,sizeof(ack)))<0){
printf("ack write error :%d\n",errno);
exit(0);
}

if((readn(sockid,(char *)&num_last_blk, sizeof(num_last_blk))) < 0){
printf("read error:%d on nbytes\n",errno);
exit(0);
}

num_last_blk = ntohs(num_last_blk);
printf("server responded: %d bytes last blk\n", num_last_blk);

if((writen(sockid,(char *)&ack,sizeof(ack)))<0){
printf("write error:%d\n",errno);
exit(0);
}

printf("client: starting to get file contents\n");

for(i= 0; i < num_blks; i ++) {
if((readn(sockid,in_buf,MAXSIZE)) < 0){
printf("block error read: %d\n",errno);
exit(0);
}

no_writen=fwrite(in_buf,sizeof(char),MAXSIZE,fp);

if(no_writen == 0){
printf("file write error\n");
exit(0);
}

if (no_writen != MAXSIZE){
printf("write error: no_writen is less\n");
exit(0);
}

if((writen(sockid,(char *)&ack,sizeof(ack))) < 0){
printf("ack write error :%d\n",errno);exit(0);
}

printf(" %d...",i);
}

if(num_last_blk > 0){
printf(”%d\n”,num_blks);

if((readn(sockid,in_buf,num_last_blk)) < 0){
printf("last block error read :%d\n",errno);
exit(0);
}

no_writen=fwrite(in_buf,sizeof(char),num_last_blk,fp);

if(no_writen == 0){
printf("last block file write err :%d\n",errno);
exit(0);
}

if(no_writen != num_last_blk){
printf("file write error : no_writen is less 2\n");
exit(0);
}

if((writen(sockid,(char *)&ack,sizeof(ack))) < 0){
printf("ack write error:%d\n",errno); exit(0);
}
}

else printf("\n");

fclose(fp);
printf("FILE TRANSFER COMPLETE\n");
close(sockid);
}
int writen(int sd, char *ptr,int size){
int no_left, no_written;
no_left = size;

while(no_left > 0){
no_written=write(sd, ptr,no_left);

if(no_written <=0)
return(no_written);

no_left -= no_written;
ptr += no_written;
}
return(size - no_left);
}

int readn(int sd,char *ptr,int size){
int no_left,no_read;
no_left = size;

while (no_left > 0){
no_read = read(sd,ptr,no_left);

if(no_read <0)
return(no_read);
if(no_read == 0)
break;

no_left -= no_read;
ptr += no_read;
}

return(size – no_left);
}

Special Thanks to:
Danu Kurniawan n Even

#define SERVER_PORT_ID 6081
#define CLIENT_PORT_ID 6086
#define SERVER_HOST_ADDR “127.0.0.1″ //IP localhost, atau ip dari komputer yang bisa dibind

#define MAXSIZE 512
#define ACK 2
#define NACK 3
#define REQUESTFILE 100
#define COMMANDNOTSUPPORTED 150
#define COMMANDSUPPORTED 160
#define BADFILENAME 200
#define FILENAMEOK 400
#define STARTTRANSFER 500

#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <time.h>
#include <errno.h>

#define MY_PORT_ID 6081
#define MAXLINE 256
#define MAXSIZE 512

#define ACK 2
#define NACK 3
#define REQUESTFILE 100
#define COMMANDNOTSUPPORTED 150
#define COMMANDSUPPORTED 160
#define BADFILENAME 200
#define FILENAMEOK 400

int writen(int sd,char *ptr,int size);
int readn(int sd,char *ptr,int size);
int len;

main(){
int sockid, newsd, pid, clilen;
struct sockaddr_in my_addr, client_addr;

printf(”server: creating socket\n”);
sockid = socket(AF_INET,SOCK_STREAM,0);

if(sockid < 0){
printf("socket error: %d\n", errno);
exit(0);
}

printf("binding my local socket\n");
bzero((char *) &my_addr,sizeof(my_addr));
my_addr.sin_family = AF_INET;
my_addr.sin_port = htons(MY_PORT_ID);
my_addr.sin_addr.s_addr=inet_addr(SERVER_HOST_ADDR); //menset IP sesuai SERVER_HOST_ADDR agar client bisa connect

if(bind(sockid ,(struct sockaddr *) &my_addr,sizeof(my_addr)) < 0){
perror("bind error...");
printf("bind error:%d\n", errno);
exit(0);
}

printf("server: starting listen \n");
if(listen(sockid,5) < 0){
printf("listen error :%d\n",errno);
exit(0);
}

while(1){
printf("server: starting accept\n");

if((newsd=accept(sockid,(struct sockaddr*) &client_addr,&clilen))<0){
printf("accept error:%d\n", errno);
exit(0);
}

doftp(newsd);
}
}

doftp(int newsd){
int i,fsize,fd,msg_ok,fail;
int fail1,req,c,ack;
int no_read ,num_blks;
int num_blks1,num_last_blk;
int num_last_blk1,tmp;
char fname[MAXLINE];
char out_buf[MAXSIZE];
FILE *fp;

no_read = 0;
num_blks = 0;
num_last_blk = 0;
req = 0;

if((readn(newsd,(char *)&req,sizeof(req))) < 0){
printf("read error %d\n",errno);
exit(0);
}

req = ntohs(req);
printf("client request code is: %d\n",req);

if(req!=REQUESTFILE){
printf("unsupported operation. goodbye\n");
msg_ok = COMMANDNOTSUPPORTED;
msg_ok = htons(msg_ok);

if((writen(newsd,(char *)&msg_ok,sizeof(msg_ok)))<0){
printf("write error :%d\n",errno);
exit(0);
}

exit(0);
}

msg_ok = COMMANDSUPPORTED;
msg_ok = htons(msg_ok);

if((writen(newsd,(char *) &msg_ok,sizeof(msg_ok))) < 0){
printf("write error :%d\n",errno);
exit(0);
}

fail = FILENAMEOK;

if((len=read(newsd,fname,MAXLINE)) < 0) {
printf("filename read error :%d\n",errno);
fail = BADFILENAME ;
}

fname[len]='\0';

if((fp=fopen(fname,"r"))==NULL)fail= BADFILENAME;
tmp = htons(fail);

if((writen(newsd,(char *)&tmp,sizeof(tmp))) < 0){
printf("write error :%d\n",errno);exit(0);
}

if(fail==BADFILENAME){
printf("server cant open file\n");
close(newsd);
exit(0);
}

printf("filename is %s\n",fname);
req = 0;

if((readn(newsd,(char *)&req,sizeof(req)))<0){
printf("read error :%d\n",errno);
exit(0);
}

printf("start transfer,%d, received\n",ntohs(req));
printf("starting transfer\n");
fsize = 0;ack = 0;

while((c=getc(fp))!=EOF) fsize++;

num_blks = fsize / MAXSIZE;
num_blks1 = htons(num_blks);
num_last_blk = fsize % MAXSIZE;
num_last_blk1 = htons(num_last_blk);

if((writen(newsd,(char *)&num_blks1, sizeof(num_blks1)))< 0){
printf("write error :%d\n",errno);
exit(0);
}

printf("told client there are %d blocks\n", num_blks);

if((readn(newsd,(char *)&ack,sizeof(ack))) < 0){
printf("ack read error :%d\n",errno);
exit(0);
}

if(ntohs(ack) != ACK){
printf("ACK not received on file size\n");
exit(0);
}

if((writen(newsd,(char *)&num_last_blk1, sizeof(num_last_blk1))) < 0){
printf("write error :%d\n",errno);
exit(0);
}

printf("told client %d bytes in last block\n",num_last_blk);

if((readn(newsd,(char *)&ack,sizeof(ack))) < 0){
printf("ack read error :%d\n",errno);
exit(0);
}

if(ntohs(ack) != ACK){
printf("ACK not received on file size\n");
exit(0);
}

rewind(fp);

for(i= 0; i < num_blks; i ++){
no_read = fread(out_buf,sizeof(char),MAXSIZE,fp);
if (no_read == 0){
printf("file read error\n"); exit(0);
}

if (no_read != MAXSIZE){
printf("file read error\n"); exit(0);
}

if((writen(newsd,out_buf,MAXSIZE)) < 0){
printf("error sending block:%d\n",errno);exit(0);
}

if((readn(newsd,(char *)&ack,sizeof(ack))) < 0){
printf("ack read error :%d\n",errno);exit(0);
}

if (ntohs(ack) != ACK){
printf("ACK not received for block %d\n",i);
exit(0);
}

printf("%d\r",i);
}

if(num_last_blk > 0){
printf(”%d\n”,num_blks);
no_read = fread(out_buf,sizeof(char),num_last_blk,fp);

if (no_read == 0){
printf(”server: file read error\n”);
exit(0);
}

if (no_read != num_last_blk){
printf(”file read error : no_read is less 2\n”);
exit(0);
}

if((writen(newsd,out_buf,num_last_blk)) < 0){
printf("server: file transfer error %d\n",errno);
exit(0);
}

if((readn(newsd,(char *)&ack,sizeof(ack))) < 0){
printf("server: ack read error %d\n",errno);
exit(0);
}

if(ntohs(ack) != ACK) {
printf("server: ACK not received last block\n");
exit(0);
}
}

else printf("\n");

printf("FILE TRANSFER COMPLETE on socket %d\n",newsd);
fclose(fp);
close(newsd);
}

int writen(int sd, char *ptr,int size){
int no_left, no_written;
no_left = size;

while(no_left > 0){
no_written=write(sd, ptr,no_left);

if(no_written <=0)
return(no_written);

no_left -= no_written;
ptr += no_written;
}
return(size - no_left);
}

int readn(int sd,char *ptr,int size){
int no_left,no_read;
no_left = size;

while (no_left > 0){
no_read = read(sd,ptr,no_left);

if(no_read <0)
return(no_read);
if(no_read == 0)
break;

no_left -= no_read;
ptr += no_read;
}

return(size – no_left);
}

Special Thanks to:
Danu Kurniawan n Even

#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#define MAXLINE 100

int main(int argc, char **argv)
{
int sockfd, n;
char recvline[MAXLINE + 1];
struct sockaddr_in servaddr;

if(argc != 2){
printf(”usage: client “);
exit(1);
}
if((sockfd=socket(AF_INET,SOCK_STREAM,0)) < 0){
perror("socket error");
exit(1);
}

bzero(&servaddr, sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_port = htons(2000);

if(inet_pton(AF_INET, argv[1],&servaddr.sin_addr) <= 0){
printf("inet_pton error for %s", argv[1]);
exit(1);
}
if(connect(sockfd, (struct sockaddr *) &servaddr, sizeof(servaddr)) < 0){
perror("connect error");
exit(1);
}

while((n=read(sockfd,recvline, MAXLINE)) > 0){
recvline[n] = 0; /* null terminate */
if(fputs(recvline,stdout)==EOF)
perror(”fputs error”);
}
if(n < 0) perror(”read error”);
close(sockfd);
return(0);
}