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

推荐订阅源

TaoSecurity Blog
TaoSecurity Blog
博客园 - 司徒正美
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
博客园 - 【当耐特】
M
MIT News - Artificial intelligence
罗磊的独立博客
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
Stack Overflow Blog
Stack Overflow Blog
The GitHub Blog
The GitHub Blog
Google DeepMind News
Google DeepMind News
Security Archives - TechRepublic
Security Archives - TechRepublic
宝玉的分享
宝玉的分享
N
News and Events Feed by Topic
The Hacker News
The Hacker News
Google DeepMind News
Google DeepMind News
C
CERT Recently Published Vulnerability Notes
F
Full Disclosure
Threat Intelligence Blog | Flashpoint
Threat Intelligence Blog | Flashpoint
S
Security @ Cisco Blogs
H
Hacker News: Front Page
L
LangChain Blog
Microsoft Security Blog
Microsoft Security Blog
Y
Y Combinator Blog
B
Blog RSS Feed
H
Heimdal Security Blog
Google Online Security Blog
Google Online Security Blog
Apple Machine Learning Research
Apple Machine Learning Research
博客园 - 三生石上(FineUI控件)
V2EX - 技术
V2EX - 技术
V
Vulnerabilities – Threatpost
Help Net Security
Help Net Security
Hacker News - Newest:
Hacker News - Newest: "LLM"
T
Tailwind CSS Blog
W
WeLiveSecurity
T
Tenable Blog
D
DataBreaches.Net
Martin Fowler
Martin Fowler
Cyberwarzone
Cyberwarzone
Cisco Talos Blog
Cisco Talos Blog
S
Secure Thoughts
O
OpenAI News
L
LINUX DO - 热门话题
Vercel News
Vercel News
阮一峰的网络日志
阮一峰的网络日志
Jina AI
Jina AI
J
Java Code Geeks
Know Your Adversary
Know Your Adversary
IT之家
IT之家
Latest news
Latest news
Cloudbric
Cloudbric

博客园 - 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则需要调用。