systemd-python: some python3 and bug fixes

diff --git a/src/python-systemd/_reader.c b/src/python-systemd/_reader.c
index 06bdf1694e90291d5413763e73ad29482c25fee0..ae3d77cfe9ef2fdc678d010ebd1e903dffd11f0f 100644 (file)
--- a/src/python-systemd/_reader.c
+++ b/src/python-systemd/_reader.c
@@ -383,7 +383,7 @@ Journal_seek(Journal *self, PyObject *args, PyObject *keywds)
                                       &offset, &whence))
         return NULL;
 
                                       &offset, &whence))
         return NULL;
 

-    PyObject *arg;
+    PyObject *result=NULL;

     if (whence == SEEK_SET){
         int r;
         Py_BEGIN_ALLOW_THREADS
     if (whence == SEEK_SET){
         int r;
         Py_BEGIN_ALLOW_THREADS


@@ -394,10 +394,10 @@ Journal_seek(Journal *self, PyObject *args, PyObject *keywds)
             return NULL;
         }
         if (offset > 0LL) {
             return NULL;
         }
         if (offset > 0LL) {

-            Py_DECREF(PyObject_CallMethod((PyObject *)self, "get_next", "L", offset));
+            result = PyObject_CallMethod((PyObject *)self, "get_next", "L", offset);

         }
     }else if (whence == SEEK_CUR){
         }
     }else if (whence == SEEK_CUR){

-        Py_DECREF(PyObject_CallMethod((PyObject *)self, "get_next", "L", offset));
+        result = PyObject_CallMethod((PyObject *)self, "get_next", "L", offset);

     }else if (whence == SEEK_END){
         int r;
         Py_BEGIN_ALLOW_THREADS
     }else if (whence == SEEK_END){
         int r;
         Py_BEGIN_ALLOW_THREADS


@@ -407,14 +407,19 @@ Journal_seek(Journal *self, PyObject *args, PyObject *keywds)
             PyErr_SetString(PyExc_RuntimeError, "Error seeking to tail");
             return NULL;
         }
             PyErr_SetString(PyExc_RuntimeError, "Error seeking to tail");
             return NULL;
         }

-        Py_DECREF(PyObject_CallMethod((PyObject *)self, "get_next", "L", -1LL));

         if (offset < 0LL) {
         if (offset < 0LL) {

-            Py_DECREF(PyObject_CallMethod((PyObject *)self, "get_next", "L", offset));
+            result = PyObject_CallMethod((PyObject *)self, "get_next", "L", offset);
+        }else{
+            result = PyObject_CallMethod((PyObject *)self, "get_next", "L", -1LL);

         }
     }else{
         PyErr_SetString(PyExc_ValueError, "Invalid value for whence");
         }
     }else{
         PyErr_SetString(PyExc_ValueError, "Invalid value for whence");

-        return NULL;

     }
     }

+
+    if (result)
+        Py_DECREF(result);
+    if (PyErr_Occurred())
+        return NULL;

     Py_RETURN_NONE;
 }
 
     Py_RETURN_NONE;
 }
 


@@ -607,7 +612,7 @@ Journal_iter(PyObject *self)
 static PyObject *
 Journal_iternext(PyObject *self)
 {
 static PyObject *
 Journal_iternext(PyObject *self)
 {

-    PyObject *dict, *arg;
+    PyObject *dict;

     Py_ssize_t dict_size;
 
     dict = PyObject_CallMethod(self, "get_next", "");
     Py_ssize_t dict_size;
 
     dict = PyObject_CallMethod(self, "get_next", "");

diff --git a/src/python-systemd/journal.py b/src/python-systemd/journal.py
index 533a8754a4f8ca6b09d7fb5fcc6322b222415af4..6e82a460b57d81712918d2a7c35700997b0e8db4 100644 (file)
--- a/src/python-systemd/journal.py
+++ b/src/python-systemd/journal.py
@@ -26,6 +26,8 @@ import uuid
 import traceback as _traceback
 import os as _os
 import logging as _logging
 import traceback as _traceback
 import os as _os
 import logging as _logging

+if sys.version_info >= (3,):
+    from collections import ChainMap

 from syslog import (LOG_EMERG, LOG_ALERT, LOG_CRIT, LOG_ERR,
                     LOG_WARNING, LOG_NOTICE, LOG_INFO, LOG_DEBUG)
 from ._journal import sendv, stream_fd
 from syslog import (LOG_EMERG, LOG_ALERT, LOG_CRIT, LOG_ERR,
                     LOG_WARNING, LOG_NOTICE, LOG_INFO, LOG_DEBUG)
 from ._journal import sendv, stream_fd


@@ -90,7 +92,7 @@ class Journal(_Journal):
     def _convert_field(self, key, value):
         try:
             result = self.converters[key](value)
     def _convert_field(self, key, value):
         try:
             result = self.converters[key](value)

-        except KeyError:
+        except:

             # Default conversion in unicode
             try:
                 result = _convert_unicode(value)
             # Default conversion in unicode
             try:
                 result = _convert_unicode(value)


@@ -101,13 +103,18 @@ class Journal(_Journal):
 
     def _convert_entry(self, entry):
         result = {}
 
     def _convert_entry(self, entry):
         result = {}

-        for key, value in entry.iteritems():
+        for key, value in entry.items():

             if isinstance(value, list):
                 result[key] = [self._convert_field(key, val) for val in value]
             else:
                 result[key] = self._convert_field(key, value)
         return result
 
             if isinstance(value, list):
                 result[key] = [self._convert_field(key, val) for val in value]
             else:
                 result[key] = self._convert_field(key, value)
         return result
 

+    def add_match(self, *args, **kwargs):
+        args = list(args)
+        args.extend(_make_line(key, val) for key, val in kwargs.items())
+        super(Journal, self).add_match(*args)
+

     def get_next(self, *args, **kwargs):
         return self._convert_entry(
             super(Journal, self).get_next(*args, **kwargs))
     def get_next(self, *args, **kwargs):
         return self._convert_entry(
             super(Journal, self).get_next(*args, **kwargs))