ACE 调试 异常
程序在调用open时抛出异常，我找不到错误，请哪位好心人帮忙看看
#include"stdafx.h"
#include"ace/Auto_Ptr.h"
#include"ace/Log_Msg.h"
#include"ace/INET_Addr.h"
#include"ace/SOCK_Acceptor.h"
#include"ace/Reactor.h"
#include"ace/Message_Block.h"
#include"ace/Message_Queue.h"
#include"ace/SOCK_Stream.h"
#include "ace/Synch.h"
class ClientAcceptor:public ACE_Event_Handler
{
public:
virtual ~ClientAcceptor();
int open(const ACE_INET_Addr &listen_addr);
virtual ACE_HANDLE get_handle(void)const{return this->acceptor_.get_handle();}
virtual int handle_input(ACE_HANDLE fd=ACE_INVALID_HANDLE);
virtual int handle_close(ACE_HANDLE handle,ACE_Reactor_Mask close_mask);
protected:
ACE_SOCK_Acceptor acceptor_;
};
class ClientService:public ACE_Event_Handler
{
public:
ACE_SOCK_Stream &peer(){return this->sock_;};
int open();
virtual ACE_HANDLE get_handle()const{return this->sock_.get_handle();}
virtual int handle_input(ACE_HANDLE fd=ACE_INVALID_HANDLE);
virtual int handle_output(ACE_HANDLE fd=ACE_INVALID_HANDLE);
virtual int handle_close(ACE_HANDLE handle,ACE_Reactor_Mask close_mask);
private:
ACE_SOCK_Stream sock_;
ACE_Message_Queue<ACE_NULL_SYNCH>output_queue_;
};
#include"stdafx.h"
#include"ClientAcceptor.h"
#define MAXHOSTNAMELEN 128
int ClientAcceptor::open(const ACE_INET_Addr &listen_port)
{
if(this->acceptor_.open(listen_port,1)==-1)
ACE_ERROR_RETURN((LM_ERROR,ACE_TEXT("%p\n"),ACE_TEXT("acceptor.open")),-1);
return this->reactor()->register_handler(this,ACE_Event_Handler::ACCEPT_MASK);
}
int ClientAcceptor::handle_input(ACE_HANDLE)
{
ClientService *client;
ACE_NEW_RETURN(client, ClientService,-1);
auto_ptr<ClientService>p(client);
if(this->acceptor_.accept(client->peer())==-1)
ACE_ERROR_RETURN((LM_ERROR,ACE_TEXT("(%p|%t)%p\n"),ACE_TEXT("Failed to accept")ACE_TEXT("client connection")),-1);
p.release();
client->reactor(this->reactor());
if(client->open()==-1)
client->handle_close(ACE_INVALID_HANDLE,0);
return 0;
}
int ClientService::open(void)
{
ACE_TCHAR peer_name[MAXHOSTNAMELEN];
ACE_INET_Addr peer_addr;
if(this->sock_.get_remote_addr(peer_addr)==0&&peer_addr.addr_to_string(peer_name,MAXHOSTNAMELEN)==0)
ACE_DEBUG((LM_DEBUG,ACE_TEXT("(%p|%t)Connection from %s\n"),peer_name));
return this->reactor()->register_handler(this,ACE_Event_Handler::READ_MASK);
}
int ClientAcceptor::handle_close(ACE_HANDLE,ACE_Reactor_Mask)
{
if(this->acceptor_.get_handle()!=ACE_INVALID_HANDLE)
{
ACE_Reactor_Mask m=ACE_Event_Handler::ACCEPT_MASK|ACE_Event_Handler::DONT_CALL;
this->reactor()->remove_handler(this,m);
}
return 0;
}
ClientAcceptor::~ClientAcceptor()
{
this->handle_close(ACE_INVALID_HANDLE,0);
}
int ClientService::handle_input(ACE_HANDLE)
{
const size_t INPUT_SIZE=4096;
char buffer[INPUT_SIZE];
ssize_t recv_cnt,send_cnt;
if((recv_cnt=this->sock_.recv(buffer,sizeof(buffer)))<=0)
{
ACE_DEBUG((LM_DEBUG,ACE_TEXT("(%p|%t)Connection closed\n")));
return -1;
}
send_cnt=this->sock_.send(buffer,static_cast<size_t>(recv_cnt));
if(send_cnt==recv_cnt)
return 0;
if(send_cnt==-1&&ACE_OS::last_error()!=EWOULDBLOCK)
ACE_ERROR_RETURN((LM_ERROR,ACE_TEXT("(%p|%t)%p\n"),ACE_TEXT("send")),0);
if(send_cnt==-1)
send_cnt=0;
ACE_Message_Block *mb;
size_t remaining=static_cast<size_t>(recv_cnt-send_cnt);
ACE_NEW_RETURN(mb,ACE_Message_Block(&buffer[send_cnt],remaining),-1);
int output_off=this->output_queue_.is_empty();
ACE_Time_Value nowait(ACE_OS::gettimeofday());
if(this->output_queue_.enqueue_tail(mb,&nowait)==-1)
{
ACE_ERROR((LM_ERROR,ACE_TEXT("(%p|%t)%p;discarding data\n"),ACE_TEXT("enqueue failed")));
mb->release();
return 0;
}
if(output_off)
{
return this->reactor()->register_handler(this,ACE_Event_Handler::WRITE_MASK);
}
return 0;
}
int ClientService::handle_output(ACE_HANDLE)
{
ACE_Message_Block *mb;
ACE_Time_Value nowait(ACE_OS::gettimeofday());
while(0==this->output_queue_.dequeue_head(mb,&nowait))
{
ssize_t send_cnt=this->sock_.send(mb->rd_ptr(),mb->length());
if(send_cnt==-1)
ACE_ERROR((LM_ERROR,ACE_TEXT("(%p|%t)%p\n"),ACE_TEXT("send")));
else
mb->rd_ptr(static_cast<size_t>(send_cnt));
if(mb->length()>0)
{
this->output_queue_.enqueue_head(mb);break;
}
mb->release();
}
return (this->output_queue_.is_empty())?-1:0;
}
int ClientService::handle_close(ACE_HANDLE,ACE_Reactor_Mask mask)
{
if(mask==ACE_Event_Handler::WRITE_MASK)return 0;
mask=ACE_Event_Handler::ALL_EVENTS_MASK|ACE_Event_Handler::DONT_CALL;
this->reactor()->remove_handler(this,mask);
this->sock_.close();
this->output_queue_.flush();
delete this;
return 0;
}
int main(int,char*[])
{
ACE_INET_Addr listen_port;
listen_port.set("HAStatus");
ClientAcceptor acceptor;
if(acceptor.open(listen_port)==-1)
return 1;
ACE_Reactor::instance()->run_reactor_event_loop();
//ACE_Reactor::run_event_loop();
return 0;
}
int ClientAcceptor::open(const ACE_INET_Addr &listen_port)
{
if(this->acceptor_.open(listen_port,1)==-1)
ACE_ERROR_RETURN((LM_ERROR,ACE_TEXT("%p\n"),ACE_TEXT("acceptor.open")),-1);
// 加了下面两行就好了，不知道是不是这个原因
if (this->reactor() == 0)
this->reactor(new ACE_Reactor);
return this->reactor()->register_handler(this,ACE_Event_Handler::ACCEPT_MASK);
}
