]> git.ipfire.org Git - thirdparty/kea.git/commitdiff
[2252] moved timings of starting and stopping the statistics timer
authorNaoki Kambe <kambe@jprs.co.jp>
Mon, 1 Oct 2012 05:17:41 +0000 (14:17 +0900)
committerNaoki Kambe <kambe@jprs.co.jp>
Thu, 28 Feb 2013 10:45:06 +0000 (19:45 +0900)
timer is started before XFRIN_IXFR_TRANSFER_SUCCESS and stopped after
XFRIN_TRANSFER_SUCCESS

src/bin/xfrin/xfrin.py.in

index a5f71421b31618731547680e42d709b822fc10fe..ace9d127a1ed11dcce39e12f26ed0f7ed5718c0e 100755 (executable)
@@ -956,15 +956,15 @@ class XfrinConnection(asyncore.dispatcher):
                 if not self.connect_to_master():
                     raise XfrinException('Unable to reconnect to master')
 
+            # start statistics timer
+            getattr(counter,
+                    'start_time_to_%s' % req_str.lower())(self._zone_name)
             logger.info(XFRIN_XFR_TRANSFER_STARTED, req_str, self.zone_str())
             self._send_query(self._request_type)
             # count (A|X)IXFR requests for statistics
             getattr(counter,
                     'inc_%sreq%s' % (req_str.lower(), self.get_ipver_str()))\
                     (self._zone_name)
-            # start statistics timer
-            getattr(counter,
-                    'start_time_to_%s' % req_str.lower())(self._zone_name)
             self.__state = XfrinInitialSOA()
             self._handle_xfrin_responses()
             # Depending what data was found, we log different status reports
@@ -990,6 +990,9 @@ class XfrinConnection(asyncore.dispatcher):
                             "%.3f" % self._transfer_stats.get_running_time(),
                             "%.f" % self._transfer_stats.get_bytes_per_second()
                            )
+            # stop start timer
+            getattr(counter,
+                    'stop_time_to_%s' % req_str.lower())(self._zone_name)
 
         except XfrinZoneUptodate:
             # Eventually we'll probably have to treat this case as a trigger
@@ -1033,10 +1036,6 @@ class XfrinConnection(asyncore.dispatcher):
             if ret == XFRIN_OK:
                 # count successful xfer requests
                 counter.inc_xfrsuccess(self._zone_name)
-                # stop timer
-                getattr(counter,
-                        'stop_time_to_%s' % req_str.lower())\
-                        (self._zone_name)
             elif ret == XFRIN_FAIL:
                 # count failed xfer requests
                 counter.inc_xfrfail(self._zone_name)