Files
2024-03-10 17:15:47 +05:30

93 lines
2.1 KiB
C

/*
* =====================================================================================
*
* Filename: notif.c
*
* Description:
*
* Version: 1.0
* Created: 10/03/24 12:00:51 PM IST
* Revision: none
* Compiler: gcc
*
* Author: YOUR NAME (),
* Organization:
*
* =====================================================================================
*/
#include <stdlib.h>
#include <memory.h>
#include <assert.h>
#include "notif.h"
notif_chain_t *
nfc_create_new_notif_chain(char *notif_chain_name) {
notif_chain_t *nfc = calloc(1, sizeof(notif_chain_t));
if(notif_chain_name) {
strncpy(nfc->nfc_name, notif_chain_name,
sizeof(nfc->nfc_name));
}
init_glthread(&nfc->notif_chain_head);
return nfc;
}
void
nfc_register_notif_chain(notif_chain_t *nfc,
notif_chain_elem_t *nfce){
notif_chain_elem_t *new_nfce = calloc(1, sizeof(notif_chain_elem_t));
memcpy(new_nfce, nfce, sizeof(notif_chain_elem_t));
init_glthread(&new_nfce->glue);
glthread_add_next(&nfc->notif_chain_head, &new_nfce->glue);
}
void
nfc_delete_all_nfce(notif_chain_t *nfc){
glthread_t *curr;
notif_chain_elem_t *nfce;
ITERATE_GLTHREAD_BEGIN(&nfc->notif_chain_head, curr){
nfce = glthread_glue_to_notif_chain_elem(curr);
remove_glthread(&nfce->glue);
free(nfce);
} ITERATE_GLTHREAD_END(&nfc->notif_chain_head, curr);
}
void
nfc_invoke_notif_chain(notif_chain_t *nfc,
void *arg, size_t arg_size,
char *key, size_t key_size,
nfc_op_t nfc_op_code){
glthread_t *curr;
notif_chain_elem_t *nfce;
if(IS_GLTHREAD_LIST_EMPTY(&nfc->notif_chain_head)) {
return;
}
assert(key_size <= MAX_NOTIF_KEY_SIZE);
ITERATE_GLTHREAD_BEGIN(&nfc->notif_chain_head, curr){
nfce = glthread_glue_to_notif_chain_elem(curr);
if(!(key && key_size &&
nfce->is_key_set && (key_size == nfce->key_size))){
nfce->app_cb(arg, arg_size, nfc_op_code, nfce->subs_id);
}
else {
if(memcmp(key, nfce->key, key_size) == 0) {
nfce->app_cb(arg, arg_size, nfc_op_code, nfce->subs_id);
}
}
}ITERATE_GLTHREAD_END(&nfc->notif_chain_head, curr);
}