fumiama/simple-kanban
1
0
Fork 0
mirror of https://github.com/fumiama/simple-kanban.git synced 2026-06-29 07:30:26 +08:00
Code Activity

增加log

Browse Source
This commit is contained in:
fumiama
2021-05-04 16:12:30 +08:00
parent 914e77d197
commit 98995ac85b
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
server.c
View File

@@ -53,7 +53,6 @@ int bind_server(uint16_t port, u_int try_times);
int check_buffer(THREADTIMER *timer); int check_buffer(THREADTIMER *timer);
void close_file(FILE *fp); void close_file(FILE *fp);
int close_file_and_send(THREADTIMER *timer, char *data, size_t numbytes); int close_file_and_send(THREADTIMER *timer, char *data, size_t numbytes);
int free_after_send(int accept_fd, char *data, size_t length);
void handle_accept(void *accept_fd_p); void handle_accept(void *accept_fd_p);
void handle_pipe(int signo); void handle_pipe(int signo);
void handle_quit(int signo); void handle_quit(int signo);
@@ -101,12 +100,6 @@ int listen_socket(u_int try_times) {
} }
} }
int free_after_send(int accept_fd, char *data, size_t length) {
int re = send_data(accept_fd, data, length);
free(data);\
return re;
}
int send_data(int accept_fd, char *data, size_t length) { int send_data(int accept_fd, char *data, size_t length) {
if(!~send(accept_fd, data, length, 0)) { if(!~send(accept_fd, data, length, 0)) {
puts("Send data error"); puts("Send data error");
@@ -274,7 +267,7 @@ void accept_timer(void *p) {
puts("Call kill thread"); puts("Call kill thread");
kill_thread(timer); kill_thread(timer);
puts("Free timer"); puts("Free timer");
free(p); free(timer);
puts("Finish checking accept status"); puts("Finish checking accept status");
break; break;
} }
@@ -282,6 +275,7 @@ void accept_timer(void *p) {
} }
void kill_thread(THREADTIMER* timer) { void kill_thread(THREADTIMER* timer) {
puts("Start killing.");
if(*(timer->thread)) { if(*(timer->thread)) {
pthread_kill(*(timer->thread), SIGQUIT); pthread_kill(*(timer->thread), SIGQUIT);
*(timer->thread) = 0; *(timer->thread) = 0;
@@ -290,6 +284,7 @@ void kill_thread(THREADTIMER* timer) {
if(timer->accept_fd) { if(timer->accept_fd) {
close(timer->accept_fd); close(timer->accept_fd);
timer->accept_fd = 0; timer->accept_fd = 0;
puts("Close accept.");
} }
if(timer->data) { if(timer->data) {
free(timer->data); free(timer->data);
@@ -301,6 +296,7 @@ void kill_thread(THREADTIMER* timer) {
timer->is_open = 0; timer->is_open = 0;
puts("Close file."); puts("Close file.");
} }
puts("Finish killing.");
} }
void handle_pipe(int signo) { void handle_pipe(int signo) {