안녕하세요 네트워크 프로그래밍을 과제로 짜보다 막히는 부분이 있어서 올립니다
#include
#include
#include
#include
#include
#include
#include
#include
#include
#define BUF_SIZE 220
void error_handling(char *message);
void *handle_client (void *arg);
int client_count = 0;
int client_socket[10];
int client_result[10]={0};
pthread_mutex_t mutx;
static sem_t sema;
int count = 0;
int main(int argc, char *argv[])
{
int serv_sock, clnt_sock;
char message[BUF_SIZE] = "";
char str[BUF_SIZE];
int str_len, i;
int a, b, c;
int flag;
int winner[5] = {0};
void* thr_ret;
pthread_t thread_id; // 쓰레드 아이디를 저장할 pthread_id형변수
struct sockaddr_in serv_adr;
struct sockaddr_in clnt_adr;
socklen_t clnt_adr_sz;
if(argc!=2) {
printf("Usage : %s \n", argv[0]);
exit(1);
}
pthread_mutex_init (&mutx, NULL);
sem_init (&sema, 0, 5);
serv_sock=socket(PF_INET, SOCK_STREAM, 0);
if(serv_sock==-1)
error_handling("socket() error");
memset(&serv_adr, 0, sizeof(serv_adr));
serv_adr.sin_family=AF_INET;
serv_adr.sin_addr.s_addr=htonl(INADDR_ANY);
serv_adr.sin_port=htons(atoi(argv[1]));
if(bind(serv_sock, (struct sockaddr*)&serv_adr, sizeof(serv_adr))==-1)
error_handling("bind() error");
if(listen(serv_sock, 5)==-1)
error_handling("listen() error");
clnt_adr_sz=sizeof(clnt_adr);
count = 1;
printf ("before count : %d\n", count);
clnt_sock=accept(serv_sock, (struct sockaddr*)&clnt_adr, &clnt_adr_sz); // 메인 스레드에서는 계속 클라이언트로부터의 요청을 받아들이고 클라이언트와의 통신은 스레드가 한다
if(clnt_sock==-1)
error_handling("accept() error");
else
printf("Connected client %d \n", clnt_sock);
pthread_mutex_lock (&mutx);
client_socket[client_count] = clnt_sock;
client_count++;
pthread_mutex_unlock (&mutx);
//pthread_create()
pthread_create (&thread_id, NULL, handle_client, (void*) &clnt_sock);
pthread_join (thread_id, &thr_ret);
//pthread_detach (thread_id);
flag = fcntl (serv_sock, F_GETFL, 0);
fcntl (serv_sock, F_SETFL, flag|O_NONBLOCK);
while (1)
{
//sem_wait (&sema);
clnt_sock=accept(serv_sock, (struct sockaddr*)&clnt_adr, &clnt_adr_sz); // 메인 스레드에서는 계속 클라이언트로부터의 요청을 받아들이고 클라이언트와의 통신은 스레드가 한다
/*if(clnt_sock==-1)
error_handling("accept() error");
else
printf("Connected client %d \n", clnt_sock);*/
if (clnt_sock != -1) { //클라이언트 소켓값이 -1이 아닐때 스레드를 하나 생성하게 됩니다!!!!!!!!!!!!!!!!!
pthread_mutex_lock (&mutx);
client_socket[client_count] = clnt_sock;
client_count++;
pthread_mutex_unlock (&mutx);
//pthread_create()
pthread_create (&thread_id, NULL, handle_client, (void*) &clnt_sock); // 쓰레드 아이디를 받아올 변수, 옵션, 함수이름, 앞의 함수에 넘겨줄 인자를 인자로 넘겨주어 스레드를 생성한다 생성된 스레드는 인자로 넘겨준 함수를 실행한다
pthread_mutex_lock (&mutx);
count++;
pthread_mutex_unlock (&mutx);
printf ("before count : %d\n", count);
pthread_detach (thread_id); // 인자값으로 넘겨준 쓰레드값 에 해당하는 스레드가 종료되는 것을 도와준다
}
if (count < 1) break;
//sem_post (&sema);
}
a = 0, b = 0, c = 0;
//write(clnt_sock, message, str_len); // 클라이언트소켓이 닫힐때까지 보내온 값을 읽어 다시보내는 일을 계속 한다
for (i = 0; i < client_count; i++)
{
if (client_result[i] == 1) a = 1; // 가위
if (client_result[i] == 2) b = 1; // 바위
if (client_result[i] == 3) c = 1; // 보
}
if ((a == b == c == 1) || ( (a == 1) && (b == 0) && (c == 0) ) || ( (b == 1) && (c == 0) && (a == 0) ) || ( (c == 1) && (a == 0) && (b == 0) )) sprintf (message ,"draw\n");
else {
if ((a == b) && (c == 0)) {
for (i = 0; i < client_count; i++)
{
if (client_result[i] == 2) winner[i] = 1;
}
}
else if ((b == c) && (a == 0)){
for (i = 0; i < client_count; i++)
{
if (client_result[i] == 3) winner[i] = 1;
}
}
else if ((c == a) && (b == 0)){
for (i = 0; i < client_count; i++)
{
if (client_result[i] == 1) winner[i] = 1;
}
}
for (i = 0; i < client_count; i++)
{
if (winner[i] == 1) {
sprintf (str, "%dth ", client_socket[i]);
strcat (message, str);
}
}
strcat (message, "client winner\n");
}
for (i = 0; i < client_count; i++)
{
write(client_socket[i], message, strlen(message));
}
for (i = 0; i < client_count; i++)
{
printf ("sock : %d\n",client_socket[i]);
close(client_socket[i]);
}
close(serv_sock);
pthread_mutex_destroy (&mutx);
sem_destroy (&sema);
return 0;
}
void error_handling(char *message)
{
fputs(message, stderr);
fputc('\n', stderr);
exit(1);
}
void *handle_client (void *arg)
{
int clnt_sock = *((int*) arg); //인자로 받아온 소켓값을 sock에 저장
int str_len;
int i;
char message[BUF_SIZE];
printf ("clnt_sock = %d\n", clnt_sock); // 여기에서 클라이언트 소켓값을 출력해보면 -1이 나오네요...!!!!!!
sprintf (message, "you're %d client\n", clnt_sock);
write(clnt_sock, message, sizeof (message));
while (1) {
str_len = read(clnt_sock, message, BUF_SIZE);
if (str_len > 0 ) break;
}
pthread_mutex_lock (&mutx);
for (i = 0; i < client_count; i++)
{
if (client_socket[i] == clnt_sock) client_result[i] = atoi(message);
}
pthread_mutex_unlock (&mutx);
pthread_mutex_lock (&mutx);
count--;
pthread_mutex_unlock (&mutx);
printf ("after count : %d\n", count);
/*//sem_wait (&sema);
pthread_mutex_lock (&mutx);
for (i = 0; i < client_count; i++)
{
if (client_socket[i] == clnt_sock) break;
}
for (; i < client_count - 1; i++)
{
client_socket[i] = client_socket[i+1];
}
client_count--;
pthread_mutex_unlock (&mutx);*/
//sem_post (&sema);
//close(clnt_sock);
}
다른 부분은 참고만 하시구요
주석에 !!!!! 많이 달아놓은 부분이 문제인데 accept를 받아서 소켓값이 -1이 아닐 때만 스레드를 생성하여서 소켓값을 넘겨주게 됩니다
그런데 생성한 스레드에서 받은 소켓값을 출력해보면 -1이 나오네요...
이거 뭐가 잘못된건지 알수가 없네요 ㅠㅠ
도와주세요~ㅠ
pthread_create 호출시 넘겨주는
pthread_create 호출시 넘겨주는 &clnt_sock 를 주소로 넘기지 말고 그냥 값으로
넘기세요. clnt_sock 는 메인 스레드에서 stack에 auto 변수로 잡혀 있습니다.
이 변수는 스레드가 넘어 가는 시점에 메인 스레드가 다른 값으로 채워져 있을수
있으니 공유로 넘기기엔 적당하지 않습니다.
넘길때 값으로 넘기면 받을때도 값으로 받으면 이상이 없습니다.
pthread_create(... , (void *)clnt_sock);
스레드 함수에서 받을때는
int clnt_sock = (int)arg; // 인자로 받아온 소켓값을 sock에 저장
---------
간디가 말한 우리를 파괴시키는 7가지 요소
첫째, 노동 없는 부(富)/둘째, 양심 없는 쾌락
셋째, 인격 없는 지! 식/넷째, 윤리 없는 비지니스
이익추구를 위해서라면..
다섯째, 인성(人性)없는 과학
여섯째, 희생 없는 종교/일곱째, 신념 없는 정치
감사합니다 이제야 잘되네요^^
감사합니다 이제야 잘되네요^^
댓글 달기