| 390 | } |
| 391 | |
| 392 | static void |
| 393 | check_local_notify(int bcast_id) |
| 394 | { |
| 395 | cib_local_notify_t *notify = NULL; |
| 396 | |
| 397 | if (!local_notify_queue) { |
| 398 | return; |
| 399 | } |
| 400 | |
| 401 | notify = g_hash_table_lookup(local_notify_queue, GINT_TO_POINTER(bcast_id)); |
| 402 | |
| 403 | if (notify) { |
| 404 | do_local_notify(notify->notify_src, notify->client_id, notify->sync_reply, notify->from_peer); |
| 405 | g_hash_table_remove(local_notify_queue, GINT_TO_POINTER(bcast_id)); |
| 406 | } |
| 407 | } |
| 408 | |
| 409 | static void |
| 410 | queue_local_notify(xmlNode * notify_src, const char *client_id, gboolean sync_reply, gboolean from_peer) |
no test coverage detected