제가 소켓프로그램 하면서 send를 쓰레드 폴링을 하면서 send를 합니다. 문제는 send 해야 할 데이트가 크면 다 보내지 못하고 다른 send를 처리를 합니다. 이것 어떻게 해야하나요?
스레드폴링이 멀티쓰레드 환경을 예기하는 건가요?? 뭔지 잘몰라서 죄성... ^^;; 질문이?? send하는동안에 다른 스레드에서 동일한 fd로 send를 한다는 말인지?? 질문이 넘 어려워요.. ^^;; 데이터가 커서 못보내는 상황이 아닌듯한데... 만약에 이거라면 send를 하는 함수를 하나 만드시고 거기에 mutex를 사용하세요... 그리고나서 여러 스레드에서 send하는 부분에 그 함수를 호출하게 하면 됩니다...
pthread_mutex_lock(&send_mutex); pthread_cond_signal(&send_cond); pthread_mutex_unlock(&send_mutex);
while(1) { pthread_mutex_lock(&send_mutex); clientsocket = g_sned_struct.socket; pthread_cond_wait(&send_cond, &send_mutex); // pthread_detach(pthread_self());
t_buffer_obj * sendobj; sendobj = pUser->outbuf.top(); while(1) { addlen = send(pUser->socket, sendobj->buf + sendobj->location, sendobj->buflen - sendobj->location, 0); if (addlen<0) { if(errno == EAGAIN) { continue; } if (errno==EINTR) { continue; } else { break; } } if (addlen==0) { break; } if (addlen==sendobj->buflen - sendobj->location) { free(sendobj->buf); pUser->outbuf.pop(); break; } else { sendobj->location+=addlen; } } } pthread_mutex_unlock(&send_mutex); 이렇게 했습니다. 클라이언트가 한명만 접속하면 이상없이 데이타를 다 보냅니다. 문제는 클라이언트가 동시에 접속하면..먼전 접속한 클라이언트는 다 보내지 못하네요..
스레드폴링이 멀티쓰레드 환경을 예기하는 건가요?? 뭔지 잘몰라서 죄성..
스레드폴링이 멀티쓰레드 환경을 예기하는 건가요?? 뭔지 잘몰라서 죄성... ^^;;
질문이?? send하는동안에 다른 스레드에서 동일한 fd로 send를 한다는 말인지?? 질문이 넘 어려워요.. ^^;; 데이터가 커서 못보내는 상황이 아닌듯한데... 만약에 이거라면 send를 하는 함수를 하나 만드시고 거기에 mutex를 사용하세요... 그리고나서 여러 스레드에서 send하는 부분에 그 함수를 호출하게 하면 됩니다...
제가 만든 send 쓰레드입니다.
pthread_mutex_lock(&send_mutex);
pthread_cond_signal(&send_cond);
pthread_mutex_unlock(&send_mutex);
while(1)
{
pthread_mutex_lock(&send_mutex);
clientsocket = g_sned_struct.socket;
pthread_cond_wait(&send_cond, &send_mutex);
// pthread_detach(pthread_self());
t_buffer_obj * sendobj;
sendobj = pUser->outbuf.top();
while(1)
{
addlen = send(pUser->socket,
sendobj->buf + sendobj->location,
sendobj->buflen - sendobj->location, 0);
if (addlen<0)
{
if(errno == EAGAIN)
{
continue;
}
if (errno==EINTR)
{
continue;
}
else
{
break;
}
}
if (addlen==0)
{
break;
}
if (addlen==sendobj->buflen - sendobj->location)
{
free(sendobj->buf);
pUser->outbuf.pop();
break;
}
else
{
sendobj->location+=addlen;
}
}
}
pthread_mutex_unlock(&send_mutex);
이렇게 했습니다.
클라이언트가 한명만 접속하면 이상없이 데이타를 다 보냅니다.
문제는 클라이언트가 동시에 접속하면..먼전 접속한 클라이언트는 다 보내지 못하네요..