注册 登录  
 加关注
   显示下一条  |  关闭
温馨提示!由于新浪微博认证机制调整,您的新浪微博帐号绑定已过期,请重新绑定!立即重新绑定新浪微博》  |  关闭

多多的爹

 
 
 

日志

 
 

神啊,handle_input竟被调用了两次  

2009-10-10 16:03:29|  分类: 默认分类 |  标签: |举报 |字号 订阅

  下载LOFTER 我的照片书  |
最近在研究ACE。这个框架给我的感觉非常不舒服。因为接触不长,就先少说几句坏话,省得以后自己打自己耳光。不过,还是有个东西让我觉得非常不爽,有必要说一说。
我创建了一个客户处理器:
class ClientHandler
    :   public ACE_Svc_Handler
{
public:
    virtual int open(void* p = 0)
    {
        return reactor()->register_handler(this, ACE_Event_Handler::READ_MASK);
    }

    virtual int handle_input(ACE_HANDLE fd = ACE_INVALID_HANDLE);
};
在有客户连接进来,ACE_SOCK_Acceptor会创建这个对象,并调用ClientHandler的open函数。
我在open中向reactor注册了自己,希望收到READ的消息,这样可以简单的在handle_input中处理了。
结果却非常奇怪,客户程序向服务器发了一条简单的字符串后然后退出。这时候服务器应该只接收到一次handle_input才对。我突然发现handle_input进来了两次。这是怎么回事呢?
在第一次进去handle_input后,我在wfmo_reactor.cpp找到了函数ACE_WFMO_Reactor::event_handling,在下面这段代码上加上断点:
DWORD wait_status = this->wait_for_multiple_events (timeout, alertable);
result = this->safe_dispatch (wait_status);
但是断点被没有进来,直接又进了handle_input。
直接找到handle_input的上层调用函数upcall,我终于发现了原因:
  if (ACE_BIT_ENABLED (actual_events, FD_READ))
    {
      action = event_handler->handle_input (io_handle);    //第一次进入
      if (action <= 0)
        {
          ACE_CLR_BITS (actual_events, FD_READ);
          if (action == -1)
            ACE_SET_BITS (problems, ACE_Event_Handler::READ_MASK);
        }
    }

  if (ACE_BIT_ENABLED (actual_events, FD_CLOSE)
      && ACE_BIT_DISABLED (problems, ACE_Event_Handler::READ_MASK))
    {
      action = event_handler->handle_input (io_handle);    //第二次进入
      if (action <= 0)
        {
          ACE_CLR_BITS (actual_events, FD_CLOSE);
          if (action == -1)
            ACE_SET_BITS (problems, ACE_Event_Handler::READ_MASK);
        }
    }
在第一次进入后,upcall又判断了是否注册了FD_CLOSE,如果有,则会再进入一次。我明明只注册了READ_MASK,怎么会跑出来一个FD_CLOSE呢?
只能继续翻register_handler的代码,在ACE_WFMO_Reactor_Handler_Repository::bit_ops中,找到下面这段代码:
      if (ACE_BIT_ENABLED (change_masks, ACE_Event_Handler::READ_MASK))
        {
          ACE_CLR_BITS (existing_masks, FD_READ);
          ACE_CLR_BITS (existing_masks, FD_CLOSE);
        }

郁闷啊!!!
  评论这张
 
阅读(138)| 评论(0)
推荐 转载

历史上的今天

评论

<#--最新日志,群博日志--> <#--推荐日志--> <#--引用记录--> <#--博主推荐--> <#--随机阅读--> <#--首页推荐--> <#--历史上的今天--> <#--被推荐日志--> <#--上一篇,下一篇--> <#-- 热度 --> <#-- 网易新闻广告 --> <#--右边模块结构--> <#--评论模块结构--> <#--引用模块结构--> <#--博主发起的投票-->
 
 
 
 
 
 
 
 
 
 
 
 
 
 

页脚

网易公司版权所有 ©1997-2017