Ignore:
Timestamp:
Jan 9, 2017, 11:09:38 AM (2 years ago)
Author:
jrpelegrina
Message:

Update new version: 3.15.02

File:
1 edited

Legend:

Unmodified
Added
Removed
  • filezilla/trunk/fuentes/src/engine/ratelimiter.cpp

    r130 r3185  
    22#include "ratelimiter.h"
    33
    4 #include "event_loop.h"
     4#include <libfilezilla/event_handler.hpp>
    55
    66static int const tickDelay = 250;
    77
    8 CRateLimiter::CRateLimiter(CEventLoop& loop, COptionsBase& options)
    9         : CEventHandler(loop)
     8CRateLimiter::CRateLimiter(fz::event_loop& loop, COptionsBase& options)
     9        : event_handler(loop)
    1010        , options_(options)
    1111{
     
    2020CRateLimiter::~CRateLimiter()
    2121{
    22         RemoveHandler();
     22        remove_handler();
    2323}
    2424
     
    3535void CRateLimiter::AddObject(CRateLimiterObject* pObject)
    3636{
    37         scoped_lock lock(sync_);
     37        fz::scoped_lock lock(sync_);
    3838
    3939        m_objectList.push_back(pObject);
     
    5959
    6060                        if (!m_timer)
    61                                 m_timer = AddTimer(duration::from_milliseconds(tickDelay), false);
     61                                m_timer = add_timer(fz::duration::from_milliseconds(tickDelay), false);
    6262                }
    6363                else {
     
    6969void CRateLimiter::RemoveObject(CRateLimiterObject* pObject)
    7070{
    71         scoped_lock lock(sync_);
     71        fz::scoped_lock lock(sync_);
    7272
    7373        for (auto iter = m_objectList.begin(); iter != m_objectList.end(); ++iter) {
     
    9898}
    9999
    100 void CRateLimiter::OnTimer(timer_id)
    101 {
    102         scoped_lock lock(sync_);
     100void CRateLimiter::OnTimer(fz::timer_id)
     101{
     102        fz::scoped_lock lock(sync_);
    103103
    104104        int64_t const limits[2] = { GetLimit(inbound), GetLimit(outbound) };
     
    180180        if (m_objectList.empty() || (limits[inbound] == 0 && limits[outbound] == 0)) {
    181181                if (m_timer) {
    182                         StopTimer(m_timer);
     182                        stop_timer(m_timer);
    183183                        m_timer = 0;
    184184                }
     
    186186}
    187187
    188 void CRateLimiter::WakeupWaitingObjects(scoped_lock & l)
     188void CRateLimiter::WakeupWaitingObjects(fz::scoped_lock & l)
    189189{
    190190        for (int i = 0; i < 2; ++i) {
     
    225225}
    226226
    227 void CRateLimiter::operator()(CEventBase const& ev)
    228 {
    229         if (Dispatch<CTimerEvent>(ev, this, &CRateLimiter::OnTimer)) {
    230                 return;
    231         }
    232         Dispatch<CRateLimitChangedEvent>(ev, this, &CRateLimiter::OnRateChanged);
     227void CRateLimiter::operator()(fz::event_base const& ev)
     228{
     229        fz::dispatch<fz::timer_event, CRateLimitChangedEvent>(ev, this,
     230                &CRateLimiter::OnTimer,
     231                &CRateLimiter::OnRateChanged);
    233232}
    234233
    235234void CRateLimiter::OnRateChanged()
    236235{
    237         scoped_lock lock(sync_);
     236        fz::scoped_lock lock(sync_);
    238237        if (GetLimit(inbound) > 0 || GetLimit(outbound) > 0) {
    239238                if (!m_timer)
    240                         m_timer = AddTimer(duration::from_milliseconds(tickDelay), false);
     239                        m_timer = add_timer(fz::duration::from_milliseconds(tickDelay), false);
    241240        }
    242241}
     
    244243void CRateLimiter::OnOptionsChanged(changed_options_t const&)
    245244{
    246         SendEvent<CRateLimitChangedEvent>();
     245        send_event<CRateLimitChangedEvent>();
    247246}
    248247
Note: See TracChangeset for help on using the changeset viewer.