use client display bar

This commit is contained in:
ubuntu201711081 2020-12-08 15:14:42 +00:00
parent 55f3dc98bb
commit 4eaed57a0c
6 changed files with 103 additions and 81 deletions

1
.gitignore vendored
View File

@ -61,3 +61,4 @@ p-server
server server
client client
slowclient slowclient
slowserver

View File

@ -3,7 +3,8 @@ CFLAGS = -lm -Wall -O2 -pthread
ServerBin = server p-server ServerBin = server p-server
ClientBin = client p-client ClientBin = client p-client
Bin = $(ServerBin) $(ClientBin) Bin = $(ServerBin) $(ClientBin)
ClientObject = display_bar.o socket_wrapper.o
ServerObject = display_bar.o socket_wrapper.o
all: all:
make $(Bin) make $(Bin)
@ -11,19 +12,23 @@ socket_wrapper.o: socket_wrapper.c socket_wrapper.h
$(CC) -c socket_wrapper.c -o socket_wrapper.o $(CFLAGS) $(CC) -c socket_wrapper.c -o socket_wrapper.o $(CFLAGS)
display_bar.o: display_bar.c display_bar.h display_bar.o: display_bar.c display_bar.h
$(CC) -c display_bar.c -o display_bar.o $(CFLAGS) $(CC) -c display_bar.c -o display_bar.o $(CFLAGS)
#client
client: socket_wrapper.o client.c client: client.c $(ClientObject)
$(CC) -o client client.c socket_wrapper.o $(CFLAGS) $(CC) -o client client.c $(ClientObject) $(CFLAGS)
server: socket_wrapper.o server.c display_bar.o p-client: p-client.c $(ClientObject)
$(CC) -o server server.c socket_wrapper.o display_bar.o $(CFLAGS)
p-server: socket_wrapper.o p-server.c
$(CC) -o p-server p-server.c socket_wrapper.o $(CFLAGS)
p-client: socket_wrapper.o p-client.c
$(CC) -o p-client p-client.c socket_wrapper.o $(CFLAGS) $(CC) -o p-client p-client.c socket_wrapper.o $(CFLAGS)
p-mulclient: socket_wrapper.o p-client.c p-mulclient: p-client.c $(ClientObject)
$(CC) -o p-slowclient p-client.c socket_wrapper.o $(CFLAGS) -D MUL_CLIENT=10 $(CC) -o p-slowclient p-client.c $(ClientObject) $(CFLAGS) -D MUL_CLIENT=10
slowclient: socket_wrapper.o client.c slowclient: client.c $(ClientObject)
$(CC) -o slowclient client.c socket_wrapper.o $(CFLAGS) -D SLOW_CLIENT=1000 $(CC) -o slowclient client.c $(ClientObject) $(CFLAGS) -D SLOW_CLIENT=1000
#server
server: server.c $(ServerObject)
$(CC) -o server server.c $(ServerObject) $(CFLAGS)
p-server: p-server.c $(ServerObject)
$(CC) -o p-server p-server.c $(ServerObject) $(CFLAGS)
slowserver: server.c $(ServerObject)
$(CC) -o slowserver server.c $(ServerObject) $(CFLAGS) -D SLOW_SERVER=100000
.PHONY: clean test .PHONY: clean test
clean: clean:

134
client.c
View File

@ -16,21 +16,26 @@
#include <pthread.h> #include <pthread.h>
#include "socket_wrapper.h" #include "socket_wrapper.h"
#include "timerhelper.h" #include "timerhelper.h"
#include "display_bar.h"
#ifndef DEFAULT_TIMEOUT #ifndef DEFAULT_TIMEOUT
static const int TIMEOUT = 5; static const int TIMEOUT = 5;
#else #else
static const int TIMEOUT = DEFAULT_TIMEOUT; static const int TIMEOUT = DEFAULT_TIMEOUT;
#endif #endif
#ifndef DEFAULT_PROGRESS_BAR_WIDTH
static const int PROGRESS_BAR_WIDTH = 30;
#else
static const int PROGRESS_BAR_WIDTH = DEFAULT_PROGRESS_BAR_WIDTH;
#endif
enum{ enum{
FILENAME_BUF_SIZE = 1024 FILENAME_BUF_SIZE = 1024
}; };
static bool DisplayProgress = true;
static inline void server_perror(const char * msg){
if(DisplayProgress)
myd_perror(msg);
else
perror(msg);
}
/*======== /*========
*Operation *Operation
*========*/ *========*/
@ -40,93 +45,63 @@ int sendReadOp(int sock,const char * filename){
op.file_url_size = strlen(filename); op.file_url_size = strlen(filename);
op.padding0 = 0; op.padding0 = 0;
if(send(sock,&op,sizeof(op),0)<0){ if(send(sock,&op,sizeof(op),0)<0){
perror("readop send fail"); server_perror("readop send fail");
return -1; return -1;
} }
#ifdef MUL_CLIENT #ifdef MUL_CLIENT
sleep(MUL_CLIENT); sleep(MUL_CLIENT);
#endif #endif
if(send(sock,filename,op.file_url_size,0)<0){ if(send(sock,filename,op.file_url_size,0)<0){
perror("readop filename send fail"); server_perror("readop filename send fail");
return -1; return -1;
} }
return 0; return 0;
} }
/**
* @arg cur_progress : it is percentage.
*/
bool isProgressBarNeedUpdate(size_t offset,size_t total,double cur_progress){
return ((double)offset / (double)total) > (cur_progress / 100.0);
}
void DisplayProgressBar(size_t offset,size_t total,double cur_progress){
char buf[PROGRESS_BAR_WIDTH];
size_t i;
size_t cur_pos = (cur_progress / 100.0 * PROGRESS_BAR_WIDTH); //must be less than SIZE_MAX. other value is undefined behavior.
for (i = 0; i < PROGRESS_BAR_WIDTH; i++)
{
if (i < cur_pos)
buf[i] = '=';
else if(i == cur_pos)
buf[i] = '>';
else buf[i] = '.';
}
printf("\r[%s]: %.2f%% bytes: %ld/%ld bytes",buf,cur_progress,total,offset);
}
void DisplayProgressBar100Percent(size_t total){
size_t i;
char buf[PROGRESS_BAR_WIDTH+1];
for (i = 0; i < PROGRESS_BAR_WIDTH; i++){
buf[i] = '=';
}
buf[PROGRESS_BAR_WIDTH] = '\0';
printf("\r[%s]: 100%% bytes: %ld/%ld bytes\n",buf,total,total);
}
static bool DisplayProgress = true;
int recvFile(int sock, const char * filename,size_t file_size){ int recvFile(int sock, const char * filename,size_t file_size){
int fd; int fd;
size_t count = 0; size_t count = 0;
int i; int i;
double cur_progress = 1;
int return_value = 0; int return_value = 0;
int buf_sz = getBufferSizeFrom(sock); int buf_sz = getBufferSizeFrom(sock);
progress_bar_t pbar;
uint8_t * buf = malloc(buf_sz*sizeof(*buf)); uint8_t * buf = malloc(buf_sz*sizeof(*buf));
if (buf == NULL){ if (buf == NULL){
return -1; return -1;
} }
fd = open(filename,O_WRONLY|O_CREAT|O_TRUNC,S_IRWXU|S_IRWXG|S_IROTH); fd = open(filename,O_WRONLY|O_CREAT|O_TRUNC,S_IRWXU|S_IRWXG|S_IROTH);
if (fd < 0) if (fd < 0){
{ server_perror("file open fail");
perror("file open fail");
return -1; return -1;
} }
if(DisplayProgress){
init_progress_bar(&pbar,10);
}
while (file_size - count > 0) while (file_size - count > 0)
{ {
int readed = buf_sz < file_size - count ? buf_sz : file_size - count; int readed = buf_sz < file_size - count ? buf_sz : file_size - count;
if(DisplayProgress){
DisplayProgressBar(&pbar,count,file_size,filename,false);
}
if((i = recv_until_byte(sock,buf,readed,TIMEOUT)) < 0){ if((i = recv_until_byte(sock,buf,readed,TIMEOUT)) < 0){
if(i == -2) if(i == -2)
fprintf(stderr,"recv file failed : timeout connetion lost\n"); fprintf(stderr,"recv file failed : timeout connetion lost\n");
else perror("recv file failed"); else server_perror("recv file failed");
return_value = -1; return_value = -1;
goto END; goto END;
} }
if(write(fd,buf,readed)<0){ if(write(fd,buf,readed)<0){
perror("file write failed"); server_perror("file write failed");
return_value = -1; return_value = -1;
goto END; goto END;
} }
if( DisplayProgress && isProgressBarNeedUpdate(count,file_size,cur_progress) ){
DisplayProgressBar(count,file_size,cur_progress);
cur_progress = (int)((((double)count / (double)file_size)) * 100.0 + 1.0);
fflush(stdout);
}
count += readed; count += readed;
#ifdef SLOW_CLIENT #ifdef SLOW_CLIENT
usleep(SLOW_CLIENT); usleep(SLOW_CLIENT);
#endif #endif
} }
if(DisplayProgress) if(DisplayProgress)
DisplayProgressBar100Percent(file_size); DisplayProgressBar(&pbar,count,file_size,filename,true);
END: END:
free(buf); free(buf);
close(fd); close(fd);
@ -137,29 +112,56 @@ int recvData(int sock,const char * filename){
struct TransferResult res; struct TransferResult res;
int i=0; int i=0;
if((i=recv_until_byte(sock,&res,sizeof(res),TIMEOUT)) < 0){ if((i=recv_until_byte(sock,&res,sizeof(res),TIMEOUT)) < 0){
if (i == -2) fprintf(stderr,"timeout\n"); if (i == -2) {
else perror("recv fail"); if(DisplayProgress && isatty_file(stderr)){
lock_scrolled();
add_scrolled_unlocked(1);
fprintf(stderr,"timeout\n");
unlock_scrolled();
}
else fprintf(stderr,"timeout\n");
}
else server_perror("recv fail");
return -1; return -1;
} }
char error_meesage_buf[80] = ""; char error_meesage_buf[256] = "";
switch(res.res){ switch(res.res){
case RES_ERR: case RES_ERR:
fprintf(stderr,"Server Fail: %s\n", strerror(res.err_number)); strerror_r(res.err_number,error_meesage_buf,sizeof(error_meesage_buf));
if(DisplayProgress && isatty_file(stderr)){
lock_scrolled();
add_scrolled_unlocked(1);
fprintf(stderr,"Server Fail: %s\n", error_meesage_buf);
unlock_scrolled();
}
else fprintf(stderr,"Server Fail: %s\n", error_meesage_buf);
return -1; return -1;
case RES_USR_ERR: case RES_USR_ERR:
assert(res.error_msg_size < 80);/*todo : fix*/ assert(res.error_msg_size < 80);/*todo : fix*/
if((i=recv_until_byte(sock,error_meesage_buf,res.error_msg_size,TIMEOUT)) < 0){ if((i=recv_until_byte(sock,error_meesage_buf,res.error_msg_size,TIMEOUT)) < 0){
if (i == -2) fprintf(stderr,"timeout\n"); if (i == -2) fprintf(stderr,"timeout\n");
else perror("recv fail"); else server_perror("recv fail");
return -1; return -1;
} }
if(DisplayProgress && isatty_file(stderr)){
lock_scrolled();
add_scrolled_unlocked(1);
fprintf(stderr,"Error Message From Server: %s\n",error_meesage_buf); fprintf(stderr,"Error Message From Server: %s\n",error_meesage_buf);
unlock_scrolled();
}
else fprintf(stderr,"Error Message From Server: %s\n",error_meesage_buf);
return -1; return -1;
case RES_OK: case RES_OK:
return recvFile(sock,filename,res.file_size); return recvFile(sock,filename,res.file_size);
break; break;
default: default:
if(DisplayProgress && isatty_file(stderr)){
lock_scrolled();
add_scrolled_unlocked(1);
fprintf(stderr,"unknown value!\n"); fprintf(stderr,"unknown value!\n");
unlock_scrolled();
}
else fprintf(stderr,"unknown value!\n");
return -1; return -1;
} }
@ -170,17 +172,23 @@ static bool quiet_mode = false;
int SendOpAndReceiveFile(const char * filename, struct sockaddr const * addr){ int SendOpAndReceiveFile(const char * filename, struct sockaddr const * addr){
int sock; int sock;
int ret = -1; int ret = -1;
if(!quiet_mode) if(!quiet_mode){
if(DisplayProgress && isatty_file(stdout)){
lock_scrolled();
add_scrolled_unlocked(1);
fprintf(stdout,"request %s\n",filename); fprintf(stdout,"request %s\n",filename);
unlock_scrolled();
}
else fprintf(stdout,"request %s\n",filename);
}
sock = socket(AF_INET,SOCK_STREAM,0); sock = socket(AF_INET,SOCK_STREAM,0);
if(sock < 0){ if(sock < 0){
perror("sock create fail"); server_perror("sock create fail");
return -1; return -1;
} }
if(connect(sock,(struct sockaddr *)addr,sizeof(*addr)) < 0){ if(connect(sock,(struct sockaddr *)addr,sizeof(*addr)) < 0){
perror("connect failed"); server_perror("connect failed");
return -1; return -1;
} }
if(sendReadOp(sock,filename) == 0){ if(sendReadOp(sock,filename) == 0){
@ -343,6 +351,7 @@ static const char * show_help_message(FILE * file,const char * argv0){
"Options and arguments: \n" "Options and arguments: \n"
"-b or --benchmark\t:benchmark mode\n" "-b or --benchmark\t:benchmark mode\n"
"-nv or --no-verbose\t:no progress bar\n" "-nv or --no-verbose\t:no progress bar\n"
"-q or --quiet\t:show no message\n"
"-h\t:print help message.\n"; "-h\t:print help message.\n";
fprintf(file,msg,argv0); fprintf(file,msg,argv0);
return msg; return msg;
@ -389,6 +398,7 @@ static int parse_arg(int argc,const char *argv[]){
else if(strcmp("-q",argv[cur]) == 0 || strcmp("--quiet",argv[cur]) == 0){ else if(strcmp("-q",argv[cur]) == 0 || strcmp("--quiet",argv[cur]) == 0){
cmd_args.quiet_mode = true; cmd_args.quiet_mode = true;
quiet_mode = true; quiet_mode = true;
DisplayProgress = false;
} }
else break; else break;
} }
@ -413,7 +423,13 @@ int main(int argc, const char *argv[]){
err = getsockaddrbyname(AF_INET,SOCK_STREAM,0,cmd_args.server_name,(struct sockaddr *)&addr); err = getsockaddrbyname(AF_INET,SOCK_STREAM,0,cmd_args.server_name,(struct sockaddr *)&addr);
if (err != 0){ if (err != 0){
int check; int check;
if(DisplayProgress && isatty_file(stderr)){
lock_scrolled();
add_scrolled_unlocked(1);
fprintf(stderr,"netdb fail: %s\n",gai_strerror(err)); fprintf(stderr,"netdb fail: %s\n",gai_strerror(err));
unlock_scrolled();
}
else fprintf(stderr,"netdb fail: %s\n",gai_strerror(err));
//assume that sernmae is *.*.*.* and try to parse addr //assume that sernmae is *.*.*.* and try to parse addr
check = inet_pton(AF_INET,cmd_args.server_name,&addr.sin_addr); check = inet_pton(AF_INET,cmd_args.server_name,&addr.sin_addr);
assert(check != -1); assert(check != -1);

View File

@ -108,7 +108,7 @@ void DisplayProgressBar(progress_bar_t * bar,size_t offset,size_t total,const ch
clock_gettime(CLOCK_REALTIME,&ts); clock_gettime(CLOCK_REALTIME,&ts);
if (!sync){ if (!sync){
dif = timespec_sub(ts,bar->last_update); dif = timespec_sub(ts,bar->last_update);
diff = dif.tv_nsec / 1000000 + dif.tv_sec; diff = dif.tv_nsec / 1000000 + dif.tv_sec*1000;
if (diff < bar->update_rate){ if (diff < bar->update_rate){
return; return;
} }

View File

@ -29,7 +29,7 @@ typedef struct {
int update_rate; int update_rate;
struct timespec last_update; struct timespec last_update;
} progress_bar_t; } progress_bar_t;
//update rate is millsecond unit
void init_progress_bar(progress_bar_t * bar,int update_rate); void init_progress_bar(progress_bar_t * bar,int update_rate);
void DisplayProgressBar(progress_bar_t * bar,size_t offset,size_t total,const char * filename, bool sync); void DisplayProgressBar(progress_bar_t * bar,size_t offset,size_t total,const char * filename, bool sync);

View File

@ -229,6 +229,8 @@ int send_response(int sock,int fd, uint8_t * buf, size_t bufsize){
#else #else
while (offset < r.file_size) while (offset < r.file_size)
{ {
if(use_gui)
DisplayProgressBar(&pbar,offset,r.file_size,"",false);
readed = bufsize < (r.file_size - offset) ? bufsize : r.file_size - offset; readed = bufsize < (r.file_size - offset) ? bufsize : r.file_size - offset;
if(read(fd,buf,readed)<0){ if(read(fd,buf,readed)<0){
server_perror("send response read fail"); server_perror("send response read fail");
@ -239,8 +241,6 @@ int send_response(int sock,int fd, uint8_t * buf, size_t bufsize){
return -1; return -1;
} }
offset += readed; offset += readed;
if(use_gui)
DisplayProgressBar(&pbar,offset,r.file_size,"",false);
#ifdef SLOW_SERVER #ifdef SLOW_SERVER
usleep(SLOW_SERVER_TIME); usleep(SLOW_SERVER_TIME);
#endif #endif