Merge pull request #20 from Code-Partners/feat-nanotime

Feat nanotime

Author: SergeyCP

common/clock.py

@@ -5,7 +5,7 @@
 class Clock:
     @staticmethod
     def now() -> int:
-        current_time_millis = time.time() * 1000
-        local_timezone_offset_millis = datetime.now(timezone.utc).astimezone().utcoffset().total_seconds() * 1000
-        current_time_micros = int((current_time_millis + local_timezone_offset_millis) * 1000)
+        current_time_micros = time.time_ns() / 1e3
+        local_timezone_offset_micros = datetime.now(timezone.utc).astimezone().utcoffset().total_seconds() * 1e6
+        current_time_micros = int(current_time_micros + local_timezone_offset_micros)
         return current_time_micros

common/clock_resolution.py

@@ -60,4 +60,4 @@ def milliseconds_since_the_first_packet(self) -> int:
 
     @staticmethod
     def _get_nano_time() -> int:
-        return int(time.perf_counter() * 1e9)
+        return int(time.perf_counter_ns())

protocols/cloud/chunk.py

@@ -218,7 +218,7 @@ def _reset(self):
         try:
             self._internal_disconnect()
         finally:
-            self.__reconnect_tick_count = time.time() * 1000
+            self.__reconnect_tick_count = time.time_ns() / 1e6
 
     def _impl_disconnect(self):
         if self._connected:
@@ -417,7 +417,7 @@ def __forward_packet(self, packet: Packet, disconnect: bool) -> None:
 
     def __do_reconnect(self) -> None:
         if self.__reconnect_interval > 0:
-            tick_count = time.time() * 1000
+            tick_count = time.time_ns() / 1e6
             if tick_count - self.__reconnect_tick_count < self.__reconnect_interval:
                 return
 

protocols/protocol.py

@@ -3,7 +3,6 @@
 import typing
 
 from common.clock import Clock
-from common.clock_resolution import ClockResolution
 from common.events.connections_parser_event import ConnectionsParserEvent
 from common.events.control_command_event import ControlCommandEvent
 from common.events.error_event import ErrorEvent
@@ -51,7 +50,6 @@ def __init__(self, appname: str):
         self.__hostname = self.__obtain_hostname()
         self.__listeners = LockedSet()
         self.__sessions = SessionManager()
-        self.__resolution = ClockResolution.STANDARD
         self.__variables = ProtocolVariables()
 
         self.__is_multithreaded = False
@@ -61,13 +59,6 @@ def __init__(self, appname: str):
     def now() -> int:
         return Clock.now()
 
-    def get_resolution(self) -> ClockResolution:
-        return self.__resolution
-
-    def set_resolution(self, resolution: ClockResolution) -> None:
-        if isinstance(resolution, ClockResolution):
-            self.__resolution = resolution
-
     @classmethod
     def get_version(cls) -> str:
         return cls.__VERSION