안녕하세요 네트워크 프로그래밍을 과제로 짜보다 막히는 부분이 있어서 올립니다

ksj1016의 이미지

#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이 나오네요...
이거 뭐가 잘못된건지 알수가 없네요 ㅠㅠ
도와주세요~ㅠ

IsExist의 이미지

pthread_create 호출시 넘겨주는 &clnt_sock 를 주소로 넘기지 말고 그냥 값으로
넘기세요. clnt_sock 는 메인 스레드에서 stack에 auto 변수로 잡혀 있습니다.

이 변수는 스레드가 넘어 가는 시점에 메인 스레드가 다른 값으로 채워져 있을수
있으니 공유로 넘기기엔 적당하지 않습니다.

넘길때 값으로 넘기면 받을때도 값으로 받으면 이상이 없습니다.

pthread_create(... , (void *)clnt_sock);

스레드 함수에서 받을때는
int clnt_sock = (int)arg; // 인자로 받아온 소켓값을 sock에 저장

---------
간디가 말한 우리를 파괴시키는 7가지 요소

첫째, 노동 없는 부(富)/둘째, 양심 없는 쾌락
셋째, 인격 없는 지! 식/넷째, 윤리 없는 비지니스

이익추구를 위해서라면..

다섯째, 인성(人性)없는 과학
여섯째, 희생 없는 종교/일곱째, 신념 없는 정치

ksj1016의 이미지

감사합니다 이제야 잘되네요^^

댓글 달기

Filtered HTML

  • 텍스트에 BBCode 태그를 사용할 수 있습니다. URL은 자동으로 링크 됩니다.
  • 사용할 수 있는 HTML 태그: <p><div><span><br><a><em><strong><del><ins><b><i><u><s><pre><code><cite><blockquote><ul><ol><li><dl><dt><dd><table><tr><td><th><thead><tbody><h1><h2><h3><h4><h5><h6><img><embed><object><param><hr>
  • 다음 태그를 이용하여 소스 코드 구문 강조를 할 수 있습니다: <code>, <blockcode>, <apache>, <applescript>, <autoconf>, <awk>, <bash>, <c>, <cpp>, <css>, <diff>, <drupal5>, <drupal6>, <gdb>, <html>, <html5>, <java>, <javascript>, <ldif>, <lua>, <make>, <mysql>, <perl>, <perl6>, <php>, <pgsql>, <proftpd>, <python>, <reg>, <spec>, <ruby>. 지원하는 태그 형식: <foo>, [foo].
  • web 주소와/이메일 주소를 클릭할 수 있는 링크로 자동으로 바꿉니다.

BBCode

  • 텍스트에 BBCode 태그를 사용할 수 있습니다. URL은 자동으로 링크 됩니다.
  • 다음 태그를 이용하여 소스 코드 구문 강조를 할 수 있습니다: <code>, <blockcode>, <apache>, <applescript>, <autoconf>, <awk>, <bash>, <c>, <cpp>, <css>, <diff>, <drupal5>, <drupal6>, <gdb>, <html>, <html5>, <java>, <javascript>, <ldif>, <lua>, <make>, <mysql>, <perl>, <perl6>, <php>, <pgsql>, <proftpd>, <python>, <reg>, <spec>, <ruby>. 지원하는 태그 형식: <foo>, [foo].
  • 사용할 수 있는 HTML 태그: <p><div><span><br><a><em><strong><del><ins><b><i><u><s><pre><code><cite><blockquote><ul><ol><li><dl><dt><dd><table><tr><td><th><thead><tbody><h1><h2><h3><h4><h5><h6><img><embed><object><param>
  • web 주소와/이메일 주소를 클릭할 수 있는 링크로 자동으로 바꿉니다.

Textile

  • 다음 태그를 이용하여 소스 코드 구문 강조를 할 수 있습니다: <code>, <blockcode>, <apache>, <applescript>, <autoconf>, <awk>, <bash>, <c>, <cpp>, <css>, <diff>, <drupal5>, <drupal6>, <gdb>, <html>, <html5>, <java>, <javascript>, <ldif>, <lua>, <make>, <mysql>, <perl>, <perl6>, <php>, <pgsql>, <proftpd>, <python>, <reg>, <spec>, <ruby>. 지원하는 태그 형식: <foo>, [foo].
  • You can use Textile markup to format text.
  • 사용할 수 있는 HTML 태그: <p><div><span><br><a><em><strong><del><ins><b><i><u><s><pre><code><cite><blockquote><ul><ol><li><dl><dt><dd><table><tr><td><th><thead><tbody><h1><h2><h3><h4><h5><h6><img><embed><object><param><hr>

Markdown

  • 다음 태그를 이용하여 소스 코드 구문 강조를 할 수 있습니다: <code>, <blockcode>, <apache>, <applescript>, <autoconf>, <awk>, <bash>, <c>, <cpp>, <css>, <diff>, <drupal5>, <drupal6>, <gdb>, <html>, <html5>, <java>, <javascript>, <ldif>, <lua>, <make>, <mysql>, <perl>, <perl6>, <php>, <pgsql>, <proftpd>, <python>, <reg>, <spec>, <ruby>. 지원하는 태그 형식: <foo>, [foo].
  • Quick Tips:
    • Two or more spaces at a line's end = Line break
    • Double returns = Paragraph
    • *Single asterisks* or _single underscores_ = Emphasis
    • **Double** or __double__ = Strong
    • This is [a link](http://the.link.example.com "The optional title text")
    For complete details on the Markdown syntax, see the Markdown documentation and Markdown Extra documentation for tables, footnotes, and more.
  • web 주소와/이메일 주소를 클릭할 수 있는 링크로 자동으로 바꿉니다.
  • 사용할 수 있는 HTML 태그: <p><div><span><br><a><em><strong><del><ins><b><i><u><s><pre><code><cite><blockquote><ul><ol><li><dl><dt><dd><table><tr><td><th><thead><tbody><h1><h2><h3><h4><h5><h6><img><embed><object><param><hr>

Plain text

  • HTML 태그를 사용할 수 없습니다.
  • web 주소와/이메일 주소를 클릭할 수 있는 링크로 자동으로 바꿉니다.
  • 줄과 단락은 자동으로 분리됩니다.
댓글 첨부 파일
이 댓글에 이미지나 파일을 업로드 합니다.
파일 크기는 8 MB보다 작아야 합니다.
허용할 파일 형식: txt pdf doc xls gif jpg jpeg mp3 png rar zip.
CAPTCHA
이것은 자동으로 스팸을 올리는 것을 막기 위해서 제공됩니다.