Lines Matching refs:pgsql_notify
1185 PGnotify *pgsql_notify; in pgsqlGetNotify_internal() local
1221 pgsql_notify = PQnotifies(H->server); in pgsqlGetNotify_internal()
1223 if (ms_timeout && !pgsql_notify) { in pgsqlGetNotify_internal()
1231 pgsql_notify = PQnotifies(H->server); in pgsqlGetNotify_internal()
1234 if (!pgsql_notify) { in pgsqlGetNotify_internal()
1240 add_index_string(return_value, 0, pgsql_notify->relname); in pgsqlGetNotify_internal()
1241 add_index_long(return_value, 1, pgsql_notify->be_pid); in pgsqlGetNotify_internal()
1242 if (pgsql_notify->extra && pgsql_notify->extra[0]) { in pgsqlGetNotify_internal()
1243 add_index_string(return_value, 2, pgsql_notify->extra); in pgsqlGetNotify_internal()
1247 add_assoc_string(return_value, "message", pgsql_notify->relname); in pgsqlGetNotify_internal()
1248 add_assoc_long(return_value, "pid", pgsql_notify->be_pid); in pgsqlGetNotify_internal()
1249 if (pgsql_notify->extra && pgsql_notify->extra[0]) { in pgsqlGetNotify_internal()
1250 add_assoc_string(return_value, "payload", pgsql_notify->extra); in pgsqlGetNotify_internal()
1254 PQfreemem(pgsql_notify); in pgsqlGetNotify_internal()
