c언어 thread이용하여 파일 읽을 때 파일 디스크립터 설정 질문

Question

서버가 있고,클라이언트 1,2,3 가 있는데서버는 똑같은 파일을 클라이언트 1,2,3에게 각각 다른 속도로 보내고, 각각의 클라이언트는 받기만 하는 기능을 제작하고 있습니다.현제까지 1명한테는 보내지는데 한 명이 읽은 후에는 어째서인지 보내지지가 않습니다....pthread_mutex_lock() 이랑 pthread_mutex_unlock()함수를 모두 사용해보았지만 사용하는 위치가 잘 못된건지 잘 안되더군요..파일 디스크립터 선언 위치가 잘못된건가요? 어제부터 계속 붙잡고 있는데 안되니 코드도 뒤죽박죽 되고 제 머리도 뒤죽박죽 되는 것 같습니다....server의 main 내부 while 문 while (1) { clnt_adr_sz = sizeof(clnt_adr); clnt_sock = accept(serv_sock, (struct sockaddr *)&clnt_adr, &clnt_adr_sz); pthread_mutex_lock(&mutx); clnt_socks[clnt_cnt++] = clnt_sock; pthread_mutex_unlock(&mutx); printf("Connected client IP: %s, clnt_sock= %d ", inet_ntoa(clnt_adr.sin_addr), clnt_sock); pthread_create(&t_id, NULL, handle_clnt, (void *)&clnt_sock); pthread_detach(t_id); } server의 thread가 실행하는 함수 void *handle_clnt(void *arg) { PACKET packet; int clnt_sock = *((int *)arg); int packet_len, i; int str_len; int fp; int sum = 0; while ((packet_len = read(clnt_sock, &packet, sizeof(packet))) != 0) { // 파일 요청이 왔는지 확인 if (packet.command == FILE_REQ) { // 클라이언트로부터 파일요청이 왔음. // 사용자의 가입자 유형에 따라 다른 속도로 영상 전송 // 클라이언트에서 이미 가입자 유형에 따라 속도 분류해서 받아옴. // 동영상 파일이기 때문에 2진파일로 읽기모드. fp = open("hw09.mp4", O_RDONLY); // 클라이언트마다 파일 열기 pthread_mutex_lock(&mutx); if (packet.type == BASIC) { while ((str_len = read(fp, packet.buf, BASIC_BUF)) > 0) { pthread_mutex_lock(&mutx); packet.command = FILE_SENDING; packet.len = str_len; if (packet.len < BASIC_BUF) { packet.command = FILE_END; packet.len = str_len; sum += packet.len; write(clnt_sock, &packet, sizeof(packet)); close(fp); break; } else { sum += packet.len; write(clnt_sock, &packet, sizeof(packet)); } pthread_mutex_unlock(&mutx); } } else if (packet.type == STANDARD) { while ((str_len = read(fp, packet.buf, STANDARD_BUF)) > 0) { pthread_mutex_lock(&mutx); packet.command = FILE_SENDING; packet.len = str_len; if (packet.len < STANDARD_BUF) { packet.command = FILE_END; packet.len = str_len; sum += packet.len; write(clnt_sock, &packet, sizeof(packet)); close(fp); break; } else { sum += packet.len; write(clnt_sock, &packet, sizeof(packet)); } pthread_mutex_unlock(&mutx); } } else if (packet.type == PREMIUM) { while ((str_len = read(fp, packet.buf, PREMIUM_BUF)) > 0) { pthread_mutex_lock(&mutx); packet.command = FILE_SENDING; packet.len = str_len; if (packet.len < PREMIUM_BUF) { packet.command = FILE_END; sum += packet.len; write(clnt_sock, &packet, sizeof(packet)); close(fp); fp = -1; break; } else { sum += packet.len; write(clnt_sock, &packet, sizeof(packet)); } pthread_mutex_unlock(&mutx); } } pthread_mutex_lock(&mutx); } else if (packet.command == FILE_END_ACK) { // 종료 해야함. printf("Total Tx BYTES : %d to Client %d (%s) ", sum, clnt_sock, typename[packet.type - 1]); printf("[Rx] FILE_END_ACK from Client %d => clnt_sock: %d closed. ", clnt_sock, clnt_sock); pthread_mutex_lock(&mutx); for (i = 0; i < clnt_cnt; i++) // remove disconnected client { printf(" "); if (clnt_sock == clnt_socks[i]) { while (i < clnt_cnt) { clnt_socks[i] = clnt_socks[i + 1]; i++; // 클라이언트 종료시점에 무한루프 발생 문제점 수정 } break; } } pthread_mutex_unlock(&mutx); clnt_cnt--; close(clnt_sock); return NULL; } else { break; } } return NULL; }

mirheeoj · Answer

뮤텍스로 보호하시려는 게 뭔가요? 파일은 공유모드로 열면 동시 액세스 가능하고 소켓이나 스레드 나머지 부분은 어차피 클라이언트마다 별개일 텐데요. 그 부분 컨셉트가 잘 이해가 안 됩니다.그리고 속도제어는 버퍼 사이즈로 하기보단 단위시간당 송신되는 데이터량을 보고 그 이상으로 나갔을 땐 강제로 sleep등의 인터벌을 주는 식으로 조절하셔야 될 것 같습니다. 버퍼 사이즈로 제한해봤자 루프로 계속 읽어서 뿌리면 속도에 영향이 없겠죠. 저라면 단위시간당 속도를 지정할 수 있는 형태의 송신함수를 따로 만들고 가입자 구별 부분은 switch문 등으로 간단히 쓰고 말 것 같습니다. 거의 동일한 루틴을 세 번 반복해서 넣을 이유가 없어 보여요.

c언어 thread이용하여 파일 읽을 때 파일 디스크립터 설정 질문

1개의 답변

Q&A 목록