Changeset 658:f198d16fa7f4 in freeDiameter for libfdcore/events.c
- Timestamp:
- Jan 14, 2011, 3:15:23 PM (13 years ago)
- Branch:
- default
- Phase:
- public
- File:
-
- 1 moved
Legend:
- Unmodified
- Added
- Removed
-
libfdcore/events.c
r82 r658 34 34 *********************************************************************************************************/ 35 35 36 #include "fD.h" 36 #include "fdcore-internal.h" 37 38 /* Events are a subset of fifo queues, with a known type */ 37 39 38 40 int fd_event_send(struct fifo *queue, int code, size_t datasz, void * data) … … 110 112 case_str(FDEV_DUMP_CONFIG); 111 113 case_str(FDEV_DUMP_PEERS); 114 case_str(FDEV_TRIGGER); 112 115 113 116 default: … … 117 120 } 118 121 122 /**********************************************************************/ 123 /* Trigged events */ 124 /* This allows extensions to register for / send triggers to other extensions */ 125 /* It is used for example for users interactions (through signals or ...) */ 126 127 /* Because the number of triggers is not expected to grow, we use a simple ordered chained list */ 128 static pthread_rwlock_t trig_rwl = PTHREAD_RWLOCK_INITIALIZER; 129 static struct fd_list trig_list = FD_LIST_INITIALIZER(trig_list); /* The list of triggers ordered by trigger value */ 130 struct trig_item { 131 struct fd_list chain; 132 int trig_value; 133 const char * trig_module; 134 void (*cb)(void); 135 }; 136 137 /* Add a new entry in the trigger list */ 138 int fd_event_trig_regcb(int trigger_val, const char * module, void (*cb)(void)) 139 { 140 struct trig_item * ti; 141 struct fd_list * li; 142 143 TRACE_ENTRY("%d %p %p", trigger_val, module, cb); 144 CHECK_PARAMS( trigger_val && cb ); 145 146 /* Create a new trig_item */ 147 CHECK_MALLOC( ti = malloc(sizeof(struct trig_item)) ); 148 memset(ti, 0, sizeof(struct trig_item)); 149 fd_list_init(&ti->chain, ti); 150 ti->trig_value = trigger_val; 151 ti->trig_module = module; 152 ti->cb = cb; 153 154 /* Now insert in the list */ 155 CHECK_POSIX( pthread_rwlock_wrlock(&trig_rwl) ); 156 157 for (li = trig_list.next; li != &trig_list; li = li->next) { 158 struct trig_item *t = li->o; 159 if (t->trig_value >= trigger_val) 160 break; 161 } 162 163 fd_list_insert_before(li, &ti->chain); 164 165 CHECK_POSIX( pthread_rwlock_unlock(&trig_rwl) ); 166 167 return 0; 168 } 169 170 void fd_event_trig_dump() 171 { 172 struct fd_list * li; 173 if (!TRACE_BOOL(FULL)) 174 return; 175 176 CHECK_POSIX_DO( pthread_rwlock_rdlock(&trig_rwl), ); 177 178 for (li = trig_list.next; li != &trig_list; li = li->next) { 179 struct trig_item *t = li->o; 180 fd_log_debug(" Trigger %d, module '%s': %p\n", t->trig_value, t->trig_module, t->cb); 181 } 182 183 CHECK_POSIX_DO( pthread_rwlock_unlock(&trig_rwl), ); 184 } 185 186 static void *call_cb_detached(void * arg) 187 { 188 void (*cb)(void) = arg; 189 fd_log_threadname("Trig'd callback thread"); 190 TRACE_ENTRY("%p", arg); 191 (*cb)(); 192 TRACE_DEBUG(ANNOYING, "Callback %p completed", cb); 193 } 194 195 int fd_event_trig_call_cb(int trigger_val) 196 { 197 struct fd_list * li; 198 pthread_attr_t detached; 199 pthread_t th; 200 201 CHECK_POSIX( pthread_attr_init(&detached) ); 202 CHECK_POSIX( pthread_attr_setdetachstate(&detached, PTHREAD_CREATE_DETACHED) ); 203 204 CHECK_POSIX( pthread_rwlock_rdlock(&trig_rwl) ); 205 206 for (li = trig_list.next; li != &trig_list; li = li->next) { 207 struct trig_item *t = li->o; 208 if (t->trig_value == trigger_val) { 209 TRACE_DEBUG(FULL, "Trigger %d: Calling %p in %s", t->trig_value, t->cb, t->trig_module); 210 CHECK_POSIX_DO( pthread_create( &th, &detached, call_cb_detached, t->cb ), break ); 211 } 212 if (t->trig_value > trigger_val) 213 break; 214 } 215 216 CHECK_POSIX( pthread_rwlock_unlock(&trig_rwl) ); 217 218 return 0; 219 } 220 221 int fd_event_trig_fini(void) { 222 223 TRACE_ENTRY(""); 224 225 CHECK_POSIX( pthread_rwlock_wrlock(&trig_rwl) ); 226 227 while (!FD_IS_LIST_EMPTY(&trig_list)) { 228 struct fd_list * li = trig_list.next; 229 fd_list_unlink(li); 230 free(li); 231 } 232 233 CHECK_POSIX( pthread_rwlock_unlock(&trig_rwl) ); 234 235 return 0; 236 }
Note: See TracChangeset
for help on using the changeset viewer.