[완료]ACE Reactor에서 handle_output 반환값
글쓴이: Fe.head / 작성시간: 화, 2010/01/12 - 9:08오후
안녕하세요.
ACE 질문 하나 하겠습니다.
ACE_Reactor를 사용할때
ACE_Svc_Handler를 상속받아.
이중 handle_output 가상함수를 구현했습니다.
제가 알기로는 handle_output이 -1를 반환하면 접속이 끊기는걸로 알고 있고
0을 반환하면 다시 handle_output 이 호출되는걸로 알고 있는데요.
0을 반환하면 다시 호출이 되지 않습니다.
혹시나 해서 1을 반환해 보았는데
1을 반환했을때는 다시 호출되는것은 맞는데..
전송되는 양이 많아 지면 호출되다가 "peer().send: Resource temporarily unavailable"메세지를 내놓고 끝나버립니다.
이증상은 왜 그럴까요?
OS : windows xp,
ACE Version 5.6.9
int FileTransClient::handle_output(ACE_HANDLE fd /* = ACE_INVALID_HANDLE */)
{
// 현재 파일 offset값을 얻음
ACE_OFF_T cur_offset = m_fileIo.tell();
// 전송할 내용을 파일에서 읽어들임
char buf[16];
ssize_t recv_len = m_fileIo.recv( buf, sizeof buf );
if( recv_len == 0 || recv_len == -1 )
{
reactor()->end_reactor_event_loop();
return -1;
}
// 데이터를 전송
ssize_t send_len = peer().send( buf, recv_len );
if( send_len == -1 )
{
ACE_ERROR_RETURN( (LM_ERROR,
ACE_TEXT("%p\n"), ACE_TEXT("peer().send") ),
-1 );
}
// 다 전송하지 못했다면 보낸 크기만큼 파일 위치 변경
if( send_len != recv_len )
m_fileIo.seek( cur_offset + static_cast<ACE_OFF_T>(send_len), SEEK_SET );
return 0; // <-- 0을 반환하면 다시 호출되지 않음, 1을 반환하면 호출은되나 에러가 나옴.
}혹시 모르니 소스를 첨부합니다.
File attachments:
| 첨부 | 파일 크기 |
|---|---|
 ACE_Reactor_Ftp.zip | 3.85 KB |
Forums:
자답입니다.
자답입니다^^
Windows에서는 Reactor가 기본으로 ACE_WFMO_Reactor가 되고
이 ACE_WFMO_Reactor에서 WRITE 이벤트는
send를 호출할때 EWOULDBLOCK오류가 나거나 접속이 끊기기 전까지 계속 보내야 한다고 합니다.
수정된 코드.
int FileTransClient::handle_output(ACE_HANDLE fd /* = ACE_INVALID_HANDLE */) { for( ;; ) { // 현재 파일 offset값을 얻음 ACE_OFF_T cur_offset = m_fileIo.tell(); // 전송한 내용을 파일에서 읽어들임 char buf[16]; ssize_t recv_len = m_fileIo.recv( buf, sizeof buf ); if( recv_len == 0 || recv_len == -1 ) { reactor()->end_reactor_event_loop(); return -1; } // 파일에서 읽어들인 데이터를 전송 ssize_t send_len = peer().send( buf, recv_len ); if( send_len == -1 && ACE_OS::last_error() == EWOULDBLOCK ) { // 다 전송하지 못했다면 보낸 크기만큼 파일 위치 변경 if( send_len != recv_len ) m_fileIo.seek( cur_offset + static_cast<ACE_OFF_T>(send_len), SEEK_SET ); break; } if( send_len == -1 ) { ACE_ERROR_RETURN( (LM_ERROR, ACE_TEXT("%p\n"), ACE_TEXT("peer().send") ), -1 ); } } return 0; }아니면 ACE_Select_Reactor를 쓰면된다고 하네요^^
-----------------------
과거를 알고 싶거든 오늘의 네 모습을 보아라. 그것이 과거의 너니라.
그리고 내일을 알고 싶으냐? 그러면 오늘의 너를 보아라. 그것이 바로 미래의 너니라.
-----------------------
내가 쓰는 글은 틀릴 수 있습니다.
고작 블로킹 하나, 고작 25점 중에 1점, 고작 부활동
"만약 그 순간이 온다면 그때가 네가 배구에 빠지는 순간이야"
댓글 달기