X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fpython.c;h=110a8e024a4ea8bcdd25a76dd80892de3e40f6c3;hb=addc746565334182a816790d3073d5da86aad16e;hp=10d283d95b1c7a6ee1938a1cc40fdcbcc70fa60b;hpb=acee3e5ef13384b24d83da25a12f72e4e32c60ab;p=collectd.git diff --git a/src/python.c b/src/python.c index 10d283d9..110a8e02 100644 --- a/src/python.c +++ b/src/python.c @@ -292,21 +292,34 @@ void cpy_log_exception(const char *context) { list = PyObject_CallFunction(cpy_format_exception, "NNN", type, value, traceback); /* New reference. Steals references from "type", "value" and "traceback". */ if (list) l = PyObject_Length(list); + for (i = 0; i < l; ++i) { - char *s; PyObject *line; - + char const *msg; + char *cpy; + line = PyList_GET_ITEM(list, i); /* Borrowed reference. */ Py_INCREF(line); - s = strdup(cpy_unicode_or_bytes_to_string(&line)); + + msg = cpy_unicode_or_bytes_to_string(&line); Py_DECREF(line); - if (s[strlen(s) - 1] == '\n') - s[strlen(s) - 1] = 0; + if (msg == NULL) + continue; + + cpy = strdup(msg); + if (cpy == NULL) + continue; + + if (cpy[strlen(cpy) - 1] == '\n') + cpy[strlen(cpy) - 1] = 0; + Py_BEGIN_ALLOW_THREADS - ERROR("%s", s); + ERROR("%s", cpy); Py_END_ALLOW_THREADS - free(s); + + free(cpy); } + Py_XDECREF(list); PyErr_Clear(); } @@ -373,7 +386,7 @@ static int cpy_write_callback(const data_set_t *ds, const value_list_t *value_li } dict = PyDict_New(); /* New reference. */ if (value_list->meta) { - int i, num; + int num; char **table; meta_data_t *meta = value_list->meta; @@ -753,7 +766,7 @@ static PyObject *cpy_unregister_generic(cpy_callback_t **list_head, PyObject *ar for (tmp = *list_head; tmp; prev = tmp, tmp = tmp->next) if (strcmp(name, tmp->name) == 0) break; - + Py_DECREF(arg); if (tmp == NULL) { PyErr_Format(PyExc_RuntimeError, "Unable to unregister %s callback '%s'.", desc, name); @@ -1004,7 +1017,7 @@ PyMODINIT_FUNC PyInit_collectd(void) { } #endif -static int cpy_init_python() { +static int cpy_init_python(void) { char *argv = ""; PyObject *sys; PyObject *module;