惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

P
Privacy International News Feed
T
The Exploit Database - CXSecurity.com
Cisco Talos Blog
Cisco Talos Blog
Schneier on Security
Schneier on Security
C
CXSECURITY Database RSS Feed - CXSecurity.com
Simon Willison's Weblog
Simon Willison's Weblog
P
Privacy & Cybersecurity Law Blog
Know Your Adversary
Know Your Adversary
NISL@THU
NISL@THU
Scott Helme
Scott Helme
cs.CL updates on arXiv.org
cs.CL updates on arXiv.org
Latest news
Latest news
P
Proofpoint News Feed
P
Palo Alto Networks Blog
K
Kaspersky official blog
I
Intezer
The Last Watchdog
The Last Watchdog
Google DeepMind News
Google DeepMind News
钛媒体:引领未来商业与生活新知
钛媒体:引领未来商业与生活新知
K
KPMG report finds enterprise disconnect between AI and its ROI | CIO
小众软件
小众软件
G
GRAHAM CLULEY
Last Week in AI
Last Week in AI
量子位
IT之家
IT之家
F
Full Disclosure
T
Threatpost
Hacker News: Ask HN
Hacker News: Ask HN
W
WeLiveSecurity
Y
Y Combinator Blog
V
V2EX
L
LINUX DO - 热门话题
Martin Fowler
Martin Fowler
月光博客
月光博客
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
D
Docker
Google DeepMind News
Google DeepMind News
博客园 - Franky
M
MIT News - Artificial intelligence
爱范儿
爱范儿
I
InfoQ
C
Cisco Blogs
L
LangChain Blog
J
Java Code Geeks
N
News | PayPal Newsroom
Threat Intelligence Blog | Flashpoint
Threat Intelligence Blog | Flashpoint
Vercel News
Vercel News
Hugging Face - Blog
Hugging Face - Blog
S
Secure Thoughts
A
About on SuperTechFans

博客园 - cpunion

使用dpkt和pcap抓包 [收藏] jfwan实现的一个C++委托类 [c++] c++0x中的auto和typeof ACE_TP_Reactor的限制 ACE_SOCK_Stream send和recv超时设置 哀悼18位在车祸中死去的人 C++编写“异步调用代理组件”的一点想法 有趣的东西:Test () () () () () () () () () (); - cpunion VC2005 Beta 2 模板偏特化有些问题 [python] and or 表达式陷阱一则。 Media Player Classic外挂字幕时间调整脚本 我们的标准化委员会网站在哪? 不就是个座嘛 answers.com真是个不错的网站 《星际之门》和《亚特兰蒂斯》总算是更新了 生成gb2312码表 - cpunion - 博客园 [假如设计一个新语言] 哪些语言特性是我想要的 写一个CopyOnWrite的通用实现(C++) - cpunion - 博客园 Python写的一个适配器类。
对ACE_TP_Reactor定时器处理机制做一点修改。
cpunion · 2005-08-09 · via 博客园 - cpunion

ACE_TP_Reactor保证同一处理器(Handle)的SOCKET事件,在同一时间不会由多个线程同时调用,但并没有保证多个线程不在同一时间分别处理同一处理器(Handle)的SOCKET和定时器,而且如果在定时器处理中超过定时器间隔,将会有另一线程再次调用定时器处理函数,带来不必要的线程同步工作。

通过查看源码(TP_Reactor.cpp)可以看出,当处理一个SOCK事件时,TP_Reactor会调用suspend_i函数把这个句柄从处理列表里暂时移掉,处理完以后再调用resume_handler函数把它放入列表,所以可以保证不会有2个线程同时处理同一处理器的SOCK事件。

所以我们只要在处理定时器前一样处理就可以了。注意,在处理SOCK事件时,suspend_i处理的是SOCK的句柄,所以我们也要获得处理器的SOCK句柄。直接调用handler->peer().get_handler()是不可取的,比较好的做法是直接调用handler->get_handler(),这是个虚函数,默认返回ACE_INVALID_HANDLER,值为0,我们可以重载这个函数,让它返回SOCK句柄。

以下是修改的部分(TP_Reactpor.cpp文件):

int
ACE_TP_Reactor::handle_timer_events (
int & /*event_count*/,
                                     ACE_TP_Token_Guard 
&guard)
{
  
// Get the current time
  ACE_Time_Value cur_time (this->timer_queue_->gettimeofday () +
                           
this->timer_queue_->timer_skew ());// Look for a node in the timer queue whose timer <= the present
  
// time.
  ACE_Timer_Node_Dispatch_Info info;if (this->timer_queue_->dispatch_info (cur_time,
                                         info))
    {
        
// ******** fixed by lijie ***********
        if (info.type_->get_handle () != ACE_INVALID_HANDLE)
        {
            
if (this->is_suspended_i (info.type_->get_handle ()))
                
return 0;this->suspend_handler (info.type_->get_handle ());
        }
        
// ******** end **********************

      
const void *upcall_act = 0;// Preinvoke.
      this->timer_queue_->preinvoke (info,
                                     cur_time,
                                     upcall_act);
// Release the token before dispatching notifies
      guard.release_token ();// call the functor
      this->timer_queue_->upcall (info,
                                  cur_time);
// Postinvoke
      this->timer_queue_->postinvoke (info,
                                      cur_time,
                                      upcall_act);
// We have dispatched a timer
      return 1;
    }
return 0;
}

由于计时器处理函数是分给一个线程调用的,当调用结束以后,我们suspend过的SOCK句柄还没有恢复,我找了一下,还真不好找地方放这一句,只好暂时放在handle_timer处理完以后,返回以前:
this->reactor ()->resume_handler (this->get_handle ());
这一行必须加上,否则不会再激发SOCK和TIMER事件。

当然别忘了为Handler编写get_handle()函数:

ACE_HANDLE Test_Handler::get_handle () const
{
    
return this->peer ().get_handle ();
}

补充一点:假如在handle_timeout中返回-1的话,则不要调用resume_handler ,否则可能会段错误,因为返回-1会导致处理器被析构,但resume_handler却把对象重新放入列表。如果handle_timeout返回0则需要调用。