diff options
Diffstat (limited to 'src/poller_base.cpp')
| -rw-r--r-- | src/poller_base.cpp | 44 | 
1 files changed, 44 insertions, 0 deletions
diff --git a/src/poller_base.cpp b/src/poller_base.cpp new file mode 100644 index 0000000..f1de7e9 --- /dev/null +++ b/src/poller_base.cpp @@ -0,0 +1,44 @@ +/* +    Copyright (c) 2007-2010 iMatix Corporation + +    This file is part of 0MQ. + +    0MQ is free software; you can redistribute it and/or modify it under +    the terms of the Lesser GNU General Public License as published by +    the Free Software Foundation; either version 3 of the License, or +    (at your option) any later version. + +    0MQ is distributed in the hope that it will be useful, +    but WITHOUT ANY WARRANTY; without even the implied warranty of +    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the +    Lesser GNU General Public License for more details. + +    You should have received a copy of the Lesser GNU General Public License +    along with this program.  If not, see <http://www.gnu.org/licenses/>. +*/ + +#include "poller_base.hpp" +#include "err.hpp" + +zmq::poller_base_t::poller_base_t () +{ +} + +zmq::poller_base_t::~poller_base_t () +{ +    //  Make sure there are no fds registered on shutdown. +    zmq_assert (get_load () == 0); +} + +int zmq::poller_base_t::get_load () +{ +    return load.get (); +} + +void zmq::poller_base_t::adjust_load (int amount_) +{ +    if (amount_ > 0) +        load.add (amount_); +    else if (amount_ < 0) +        load.sub (-amount_); +}  | 
