diff --git a/app/service/subscriber_client.py b/app/service/subscriber_client.py index b81ec71..525e3bd 100644 --- a/app/service/subscriber_client.py +++ b/app/service/subscriber_client.py @@ -1,6 +1,6 @@ from app.common.subscriber.entry import Subscriber, Device from pyfastocloud.subscriber_client import SubscriberClient -from pyfastocloud.client import make_utc_timestamp +from pyfastocloud.client import make_utc_timestamp_seconds import pyfastocloud.socket.gevent as gsocket @@ -10,7 +10,7 @@ class SubscriberConnection(SubscriberClient): self._info = None self._current_stream_id = str() self._device = None - self._last_ping_ts = make_utc_timestamp() / 1000 + self._last_ping_ts = make_utc_timestamp_seconds() self._request_id = 0 @property diff --git a/app/service/subscribers_service_manager.py b/app/service/subscribers_service_manager.py index fffa067..66196ce 100644 --- a/app/service/subscribers_service_manager.py +++ b/app/service/subscribers_service_manager.py @@ -6,7 +6,7 @@ from app.service.subscriber_client import SubscriberConnection from app.common.subscriber.entry import Subscriber, Device from app.common.constants import PlayerMessage from pyfastocloud.subscriber_client import Commands -from pyfastocloud.client import make_utc_timestamp +from pyfastocloud.client import make_utc_timestamp_seconds from pyfastocloud.client_handler import IClientHandler, Request, Response, ClientStatus import pyfastocloud.socket.gevent as gsocket @@ -66,7 +66,7 @@ class SubscribersServiceManager(ServiceManager, IClientHandler): server.recv_data() break - ts_sec = make_utc_timestamp() / 1000 + ts_sec = make_utc_timestamp_seconds() copy_subsc = list(self._subscribers) for client in copy_subsc: if ts_sec - client.last_ping_ts > SubscribersServiceManager.PING_SUBSCRIBERS_SEC: