Skip to content

Commit

Permalink
Fix formatting.
Browse files Browse the repository at this point in the history
  • Loading branch information
ricnewton authored and hintjens committed Nov 9, 2013
1 parent fef24a8 commit f33bdcf
Show file tree
Hide file tree
Showing 11 changed files with 14 additions and 14 deletions.
8 changes: 4 additions & 4 deletions src/ctx.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -40,8 +40,8 @@

int clipped_maxsocket(int max_requested)
{
if (max_requested >= zmq::poller_t::max_fds() && zmq::poller_t::max_fds() != -1)
max_requested = zmq::poller_t::max_fds() - 1; // -1 because we need room for the repear mailbox.
if (max_requested >= zmq::poller_t::max_fds () && zmq::poller_t::max_fds () != -1)
max_requested = zmq::poller_t::max_fds () - 1; // -1 because we need room for the repear mailbox.

return max_requested;
}
Expand All @@ -53,7 +53,7 @@ zmq::ctx_t::ctx_t () :
reaper (NULL),
slot_count (0),
slots (NULL),
max_sockets(clipped_maxsocket(ZMQ_MAX_SOCKETS_DFLT)),
max_sockets (clipped_maxsocket (ZMQ_MAX_SOCKETS_DFLT)),
io_thread_count (ZMQ_IO_THREADS_DFLT),
ipv6 (false)
{
Expand Down Expand Up @@ -169,7 +169,7 @@ int zmq::ctx_t::shutdown ()
int zmq::ctx_t::set (int option_, int optval_)
{
int rc = 0;
if (option_ == ZMQ_MAX_SOCKETS && optval_ >= 1 && optval_ == clipped_maxsocket(optval_)) {
if (option_ == ZMQ_MAX_SOCKETS && optval_ >= 1 && optval_ == clipped_maxsocket (optval_)) {
opt_sync.lock ();
max_sockets = optval_;
opt_sync.unlock ();
Expand Down
2 changes: 1 addition & 1 deletion src/devpoll.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -133,7 +133,7 @@ void zmq::devpoll_t::stop ()
stopping = true;
}

int zmq::devpoll_t::max_fds()
int zmq::devpoll_t::max_fds ()
{
return -1;
}
Expand Down
2 changes: 1 addition & 1 deletion src/devpoll.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ namespace zmq
void start ();
void stop ();

static int max_fds();
static int max_fds ();

private:

Expand Down
2 changes: 1 addition & 1 deletion src/epoll.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -126,7 +126,7 @@ void zmq::epoll_t::stop ()
stopping = true;
}

int zmq::epoll_t::max_fds()
int zmq::epoll_t::max_fds ()
{
return -1;
}
Expand Down
2 changes: 1 addition & 1 deletion src/epoll.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ namespace zmq
void start ();
void stop ();

static int max_fds();
static int max_fds ();

private:

Expand Down
2 changes: 1 addition & 1 deletion src/kqueue.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -152,7 +152,7 @@ void zmq::kqueue_t::stop ()
stopping = true;
}

int zmq::kqueue_t::max_fds()
int zmq::kqueue_t::max_fds ()
{
return -1;
}
Expand Down
2 changes: 1 addition & 1 deletion src/kqueue.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ namespace zmq
void start ();
void stop ();

static int max_fds();
static int max_fds ();

private:

Expand Down
2 changes: 1 addition & 1 deletion src/poll.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -114,7 +114,7 @@ void zmq::poll_t::stop ()
stopping = true;
}

int zmq::poll_t::max_fds()
int zmq::poll_t::max_fds ()
{
return -1;
}
Expand Down
2 changes: 1 addition & 1 deletion src/poll.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ namespace zmq
void start ();
void stop ();

static int max_fds();
static int max_fds ();

private:

Expand Down
2 changes: 1 addition & 1 deletion src/select.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -144,7 +144,7 @@ void zmq::select_t::stop ()
stopping = true;
}

int zmq::select_t::max_fds()
int zmq::select_t::max_fds ()
{
return FD_SETSIZE;
}
Expand Down
2 changes: 1 addition & 1 deletion src/select.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ namespace zmq
void start ();
void stop ();

static int max_fds();
static int max_fds ();

private:

Expand Down

0 comments on commit f33bdcf

Please sign in to comment.