You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@trafficserver.apache.org by jp...@apache.org on 2016/06/23 05:16:12 UTC
[trafficserver] branch master updated: Improve NetAccept code
formatting.
This is an automated email from the ASF dual-hosted git repository.
jpeach pushed a commit to branch master
in repository https://git-dual.apache.org/repos/asf/trafficserver.git
The following commit(s) were added to refs/heads/master by this push:
new 890f169 Improve NetAccept code formatting.
890f169 is described below
commit 890f169fe29914206182c3b88c319717aac914b9
Author: James Peach <jp...@apache.org>
AuthorDate: Wed Jun 22 22:14:40 2016 -0700
Improve NetAccept code formatting.
---
iocore/net/UnixNetAccept.cc | 25 ++++++++++++++++++-------
1 file changed, 18 insertions(+), 7 deletions(-)
diff --git a/iocore/net/UnixNetAccept.cc b/iocore/net/UnixNetAccept.cc
index b39b7e5..d70a276 100644
--- a/iocore/net/UnixNetAccept.cc
+++ b/iocore/net/UnixNetAccept.cc
@@ -167,8 +167,10 @@ NetAccept::init_accept(EThread *t, bool isTransparent)
action_->continuation->mutex = t->mutex;
action_->mutex = t->mutex;
}
+
if (do_listen(NON_BLOCKING, isTransparent))
return;
+
SET_HANDLER((NetAcceptHandler)&NetAccept::acceptEvent);
period = -HRTIME_MSECONDS(net_accept_period);
t->schedule_every(this, period, etype);
@@ -181,23 +183,30 @@ NetAccept::init_accept_per_thread(bool isTransparent)
if (do_listen(NON_BLOCKING, isTransparent))
return;
+
if (accept_fn == net_accept)
SET_HANDLER((NetAcceptHandler)&NetAccept::acceptFastEvent);
else
SET_HANDLER((NetAcceptHandler)&NetAccept::acceptEvent);
+
period = -HRTIME_MSECONDS(net_accept_period);
+ n = eventProcessor.n_threads_for_type[ET_NET];
- NetAccept *a;
- n = eventProcessor.n_threads_for_type[ET_NET];
for (i = 0; i < n; i++) {
- if (i < n - 1)
+ NetAccept *a;
+
+ if (i < n - 1) {
a = clone();
- else
- a = this;
+ } else {
+ a = this;
+ }
+
EThread *t = eventProcessor.eventthread[ET_NET][i];
PollDescriptor *pd = get_PollDescriptor(t);
+
if (a->ep.start(pd, a, EVENTIO_READ) < 0)
Warning("[NetAccept::init_accept_per_thread]:error starting EventIO");
+
a->mutex = get_NetHandler(t)->mutex;
t->schedule_every(a, period, etype);
}
@@ -276,12 +285,14 @@ NetAccept::do_blocking_accept(EThread *t)
con.close();
return -1;
}
+
vc->con = con;
+ vc->id = net_next_connection_number();
+ vc->from_accept_thread = true;
vc->options.packet_mark = packet_mark;
vc->options.packet_tos = packet_tos;
+
vc->apply_options();
- vc->from_accept_thread = true;
- vc->id = net_next_connection_number();
check_emergency_throttle(con);
--
To stop receiving notification emails like this one, please contact
['"commits@trafficserver.apache.org" <co...@trafficserver.apache.org>'].