mirror of
https://github.com/psycopg/psycopg2.git
synced 2024-11-25 10:23:43 +03:00
replication_cursor_type: solved cpychecker false positives
This commit is contained in:
parent
86d460e80b
commit
bcd7fca543
|
@ -130,6 +130,9 @@ psyco_repl_curs_consume_stream(replicationCursorObject *self,
|
||||||
res = Py_None;
|
res = Py_None;
|
||||||
Py_INCREF(res);
|
Py_INCREF(res);
|
||||||
}
|
}
|
||||||
|
else {
|
||||||
|
FAKE_RAISE();
|
||||||
|
}
|
||||||
|
|
||||||
self->consuming = 0;
|
self->consuming = 0;
|
||||||
|
|
||||||
|
@ -150,6 +153,7 @@ psyco_repl_curs_read_message(replicationCursorObject *self, PyObject *dummy)
|
||||||
EXC_IF_TPC_PREPARED(self->cur.conn, read_message);
|
EXC_IF_TPC_PREPARED(self->cur.conn, read_message);
|
||||||
|
|
||||||
if (pq_read_replication_message(self, &msg) < 0) {
|
if (pq_read_replication_message(self, &msg) < 0) {
|
||||||
|
FAKE_RAISE();
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
if (msg) {
|
if (msg) {
|
||||||
|
@ -188,6 +192,7 @@ psyco_repl_curs_send_feedback(replicationCursorObject *self,
|
||||||
self->apply_lsn = apply_lsn;
|
self->apply_lsn = apply_lsn;
|
||||||
|
|
||||||
if (pq_send_replication_feedback(self, reply) < 0) {
|
if (pq_send_replication_feedback(self, reply) < 0) {
|
||||||
|
FAKE_RAISE();
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user