From d9c9a8e7044331cb668b109b36ee82b7117cfda4 Mon Sep 17 00:00:00 2001 From: Mosquito Date: Mon, 16 Nov 2020 13:10:31 +0300 Subject: [PATCH] double precision for seconds (#33) * double precision for seconds * fix asyncio example --- cysystemd/__init__.py | 2 +- cysystemd/reader.pyx | 8 +++++--- examples/asyncio_reader.py | 5 +++++ 3 files changed, 11 insertions(+), 4 deletions(-) diff --git a/cysystemd/__init__.py b/cysystemd/__init__.py index ccc17dd..4d486dc 100644 --- a/cysystemd/__init__.py +++ b/cysystemd/__init__.py @@ -1,5 +1,5 @@ package_info = "SystemD wrapper in Cython" -version_info = (1, 4, 4) +version_info = (1, 4, 5) author_info = (("Dmitry Orlov", "me@mosquito.su"),) diff --git a/cysystemd/reader.pyx b/cysystemd/reader.pyx index 7774cc4..935d4be 100644 --- a/cysystemd/reader.pyx +++ b/cysystemd/reader.pyx @@ -253,10 +253,12 @@ cdef class JournalEntry: def cursor(self): return self.cursor - def get_realtime_sec(self): - return self.realtime_usec / 1000000. + cpdef double get_realtime_sec(self): + cdef double result = self.realtime_usec / 1000000. + return result - def get_monotonic_sec(self): + cpdef double get_monotonic_sec(self): + cdef double result = self.monotonic_usec / 1000000. return self.monotonic_usec / 1000000. cpdef uint64_t get_realtime_usec(self): diff --git a/examples/asyncio_reader.py b/examples/asyncio_reader.py index 46b6e79..0411439 100644 --- a/examples/asyncio_reader.py +++ b/examples/asyncio_reader.py @@ -11,6 +11,11 @@ async def main(): await reader.seek_head() # await reader.previous(10) + # read all from cursor immediately + async for record in reader: + print(json.dumps(record.data, indent=1, sort_keys=True)) + + # waiting for new events and print them while await reader.wait(): async for record in reader: print(json.dumps(record.data, indent=1, sort_keys=True))