[질문]ACE WRITE_MASK와 handle_output 호출관계
글쓴이: Fe.head / 작성시간: 화, 2009/10/27 - 6:36오후
제가 ACE Reactor부분을 공부하고 있는데
이상한 부분이 있어 질문드립니다.
보낼데이터가 있으면 바로 send하지 않고
Queue에 넣어 놓고(ClientService::send 호출)
reactor()->register_handler( this, ACE_Event_Handler::WRITE_MASK );
이렇게 handle_output을 호출하는데요.
이상하게 handle_output 함수가 딱 한번만 호출되고 다음부터 호출되지 않습니다.
다시 Queue에넣어 놓고
reactor()->register_handler( this, ACE_Event_Handler::WRITE_MASK );
를 호출해도 소용이 없네요.
코드는 대략 아래와 같습니다.
class ClientService : public ACE_Event_Handler
{
private:
ACE_SOCK_Stream peer_;
ACE_Message_Queue<ACE_NULL_SYNCH> queue_;
public:
virtual int handle_input(ACE_HANDLE fd = ACE_INVALID_HANDLE);
virtual int handle_output(ACE_HANDLE fd = ACE_INVALID_HANDLE);
int send(const char * data, ssize_t len );
};
int ClientService::send(const char * data, ssize_t len )
{
ACE_Message_Block * mb = 0;
ACE_NEW_RETURN( mb, ACE_Message_Block(len), -1 );
mb->copy( data, len );
ACE_Time_Value nowait(ACE_OS::gettimeofday());
bool outputoff = queue_.is_empty();
if( queue_.enqueue_tail( mb, &nowait ) == -1 )
{
// ERROR MESSAGE 출력
mb->release();
return 0;
}
// --> 이부분 <--
if( outputoff )
return reactor()->register_handler( this, ACE_Event_Handler::WRITE_MASK );
return 0;
}
int ClientService::handle_output(ACE_HANDLE)
{
ACE_Message_Block * mb = 0;
ACE_Time_Value timeout(ACE_OS::gettimeofday());
while( queue_.dequeue_head( mb, &timeout ) == 0 )
{
ssize_t sendlen = peer_.send( mb->rd_ptr(), mb->length() );
// 에러 처리 코드 생략.
mb->release();
}
return (queue_.is_empty()) ? -1 : 0;
}Forums:
댓글 달기