Mercurial > hg > freeDiameter
annotate libfdcore/events.c @ 882:ae96ae28f3dd 1.1.5
Limit python version to avoid using python3 (not compatible)
| author | Sebastien Decugis <sdecugis@freediameter.net> |
|---|---|
| date | Sat, 03 Nov 2012 18:45:41 +0100 |
| parents | 4a9f08d6b6ba |
| children | 2091bf698fb1 |
| rev | line source |
|---|---|
| 82 | 1 /********************************************************************************************************* |
| 2 * Software License Agreement (BSD License) * | |
|
740
4a9f08d6b6ba
Updated my mail address
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
664
diff
changeset
|
3 * Author: Sebastien Decugis <sdecugis@freediameter.net> * |
| 82 | 4 * * |
|
662
2e94ef0515d7
Updated copyright information
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
658
diff
changeset
|
5 * Copyright (c) 2011, WIDE Project and NICT * |
| 82 | 6 * All rights reserved. * |
| 7 * * | |
| 8 * Redistribution and use of this software in source and binary forms, with or without modification, are * | |
| 9 * permitted provided that the following conditions are met: * | |
| 10 * * | |
| 11 * * Redistributions of source code must retain the above * | |
| 12 * copyright notice, this list of conditions and the * | |
| 13 * following disclaimer. * | |
| 14 * * | |
| 15 * * Redistributions in binary form must reproduce the above * | |
| 16 * copyright notice, this list of conditions and the * | |
| 17 * following disclaimer in the documentation and/or other * | |
| 18 * materials provided with the distribution. * | |
| 19 * * | |
| 20 * * Neither the name of the WIDE Project or NICT nor the * | |
| 21 * names of its contributors may be used to endorse or * | |
| 22 * promote products derived from this software without * | |
| 23 * specific prior written permission of WIDE Project and * | |
| 24 * NICT. * | |
| 25 * * | |
| 26 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED * | |
| 27 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A * | |
| 28 * PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR * | |
| 29 * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT * | |
| 30 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * | |
| 31 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR * | |
| 32 * TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF * | |
| 33 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. * | |
| 34 *********************************************************************************************************/ | |
| 35 | |
|
658
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
36 #include "fdcore-internal.h" |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
37 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
38 /* Events are a subset of fifo queues, with a known type */ |
| 82 | 39 |
| 40 int fd_event_send(struct fifo *queue, int code, size_t datasz, void * data) | |
| 41 { | |
| 42 struct fd_event * ev; | |
| 43 CHECK_MALLOC( ev = malloc(sizeof(struct fd_event)) ); | |
| 44 ev->code = code; | |
| 45 ev->size = datasz; | |
| 46 ev->data = data; | |
| 47 CHECK_FCT( fd_fifo_post(queue, &ev) ); | |
| 48 return 0; | |
| 49 } | |
| 50 | |
| 51 int fd_event_get(struct fifo *queue, int *code, size_t *datasz, void ** data) | |
| 52 { | |
| 53 struct fd_event * ev; | |
| 54 CHECK_FCT( fd_fifo_get(queue, &ev) ); | |
| 55 if (code) | |
| 56 *code = ev->code; | |
| 57 if (datasz) | |
| 58 *datasz = ev->size; | |
| 59 if (data) | |
| 60 *data = ev->data; | |
| 61 free(ev); | |
| 62 return 0; | |
| 63 } | |
| 64 | |
| 65 int fd_event_timedget(struct fifo *queue, struct timespec * timeout, int timeoutcode, int *code, size_t *datasz, void ** data) | |
| 66 { | |
| 67 struct fd_event * ev; | |
| 68 int ret = 0; | |
| 69 ret = fd_fifo_timedget(queue, &ev, timeout); | |
| 70 if (ret == ETIMEDOUT) { | |
| 71 if (code) | |
| 72 *code = timeoutcode; | |
| 73 if (datasz) | |
| 74 *datasz = 0; | |
| 75 if (data) | |
| 76 *data = NULL; | |
| 77 } else { | |
| 78 CHECK_FCT( ret ); | |
| 79 if (code) | |
| 80 *code = ev->code; | |
| 81 if (datasz) | |
| 82 *datasz = ev->size; | |
| 83 if (data) | |
| 84 *data = ev->data; | |
| 85 free(ev); | |
| 86 } | |
| 87 return 0; | |
| 88 } | |
| 89 | |
| 90 void fd_event_destroy(struct fifo **queue, void (*free_cb)(void * data)) | |
| 91 { | |
| 92 struct fd_event * ev; | |
| 93 /* Purge all events, and free the associated data if any */ | |
| 94 while (fd_fifo_tryget( *queue, &ev ) == 0) { | |
| 95 (*free_cb)(ev->data); | |
| 96 free(ev); | |
| 97 } | |
| 98 CHECK_FCT_DO( fd_fifo_del(queue), /* continue */ ); | |
| 99 return ; | |
| 100 } | |
| 101 | |
| 102 const char * fd_ev_str(int event) | |
| 103 { | |
| 104 switch (event) { | |
| 105 #define case_str( _val )\ | |
| 106 case _val : return #_val | |
| 107 case_str(FDEV_TERMINATE); | |
| 108 case_str(FDEV_DUMP_DICT); | |
| 109 case_str(FDEV_DUMP_EXT); | |
| 110 case_str(FDEV_DUMP_SERV); | |
| 111 case_str(FDEV_DUMP_QUEUES); | |
| 112 case_str(FDEV_DUMP_CONFIG); | |
| 113 case_str(FDEV_DUMP_PEERS); | |
|
658
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
114 case_str(FDEV_TRIGGER); |
| 82 | 115 |
| 116 default: | |
| 117 TRACE_DEBUG(FULL, "Unknown event : %d", event); | |
| 118 return "Unknown event"; | |
| 119 } | |
| 120 } | |
| 121 | |
|
658
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
122 /**********************************************************************/ |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
123 /* Trigged events */ |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
124 /* This allows extensions to register for / send triggers to other extensions */ |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
125 /* It is used for example for users interactions (through signals or ...) */ |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
126 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
127 /* Because the number of triggers is not expected to grow, we use a simple ordered chained list */ |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
128 static pthread_rwlock_t trig_rwl = PTHREAD_RWLOCK_INITIALIZER; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
129 static struct fd_list trig_list = FD_LIST_INITIALIZER(trig_list); /* The list of triggers ordered by trigger value */ |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
130 struct trig_item { |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
131 struct fd_list chain; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
132 int trig_value; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
133 const char * trig_module; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
134 void (*cb)(void); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
135 }; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
136 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
137 /* Add a new entry in the trigger list */ |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
138 int fd_event_trig_regcb(int trigger_val, const char * module, void (*cb)(void)) |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
139 { |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
140 struct trig_item * ti; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
141 struct fd_list * li; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
142 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
143 TRACE_ENTRY("%d %p %p", trigger_val, module, cb); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
144 CHECK_PARAMS( trigger_val && cb ); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
145 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
146 /* Create a new trig_item */ |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
147 CHECK_MALLOC( ti = malloc(sizeof(struct trig_item)) ); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
148 memset(ti, 0, sizeof(struct trig_item)); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
149 fd_list_init(&ti->chain, ti); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
150 ti->trig_value = trigger_val; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
151 ti->trig_module = module; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
152 ti->cb = cb; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
153 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
154 /* Now insert in the list */ |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
155 CHECK_POSIX( pthread_rwlock_wrlock(&trig_rwl) ); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
156 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
157 for (li = trig_list.next; li != &trig_list; li = li->next) { |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
158 struct trig_item *t = li->o; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
159 if (t->trig_value >= trigger_val) |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
160 break; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
161 } |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
162 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
163 fd_list_insert_before(li, &ti->chain); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
164 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
165 CHECK_POSIX( pthread_rwlock_unlock(&trig_rwl) ); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
166 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
167 return 0; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
168 } |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
169 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
170 void fd_event_trig_dump() |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
171 { |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
172 struct fd_list * li; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
173 if (!TRACE_BOOL(FULL)) |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
174 return; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
175 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
176 CHECK_POSIX_DO( pthread_rwlock_rdlock(&trig_rwl), ); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
177 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
178 for (li = trig_list.next; li != &trig_list; li = li->next) { |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
179 struct trig_item *t = li->o; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
180 fd_log_debug(" Trigger %d, module '%s': %p\n", t->trig_value, t->trig_module, t->cb); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
181 } |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
182 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
183 CHECK_POSIX_DO( pthread_rwlock_unlock(&trig_rwl), ); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
184 } |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
185 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
186 static void *call_cb_detached(void * arg) |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
187 { |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
188 void (*cb)(void) = arg; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
189 fd_log_threadname("Trig'd callback thread"); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
190 TRACE_ENTRY("%p", arg); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
191 (*cb)(); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
192 TRACE_DEBUG(ANNOYING, "Callback %p completed", cb); |
|
664
c1ef1c39e8a5
Fix compilation warning
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
662
diff
changeset
|
193 return NULL; |
|
658
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
194 } |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
195 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
196 int fd_event_trig_call_cb(int trigger_val) |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
197 { |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
198 struct fd_list * li; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
199 pthread_attr_t detached; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
200 pthread_t th; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
201 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
202 CHECK_POSIX( pthread_attr_init(&detached) ); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
203 CHECK_POSIX( pthread_attr_setdetachstate(&detached, PTHREAD_CREATE_DETACHED) ); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
204 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
205 CHECK_POSIX( pthread_rwlock_rdlock(&trig_rwl) ); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
206 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
207 for (li = trig_list.next; li != &trig_list; li = li->next) { |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
208 struct trig_item *t = li->o; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
209 if (t->trig_value == trigger_val) { |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
210 TRACE_DEBUG(FULL, "Trigger %d: Calling %p in %s", t->trig_value, t->cb, t->trig_module); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
211 CHECK_POSIX_DO( pthread_create( &th, &detached, call_cb_detached, t->cb ), break ); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
212 } |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
213 if (t->trig_value > trigger_val) |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
214 break; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
215 } |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
216 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
217 CHECK_POSIX( pthread_rwlock_unlock(&trig_rwl) ); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
218 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
219 return 0; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
220 } |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
221 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
222 int fd_event_trig_fini(void) { |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
223 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
224 TRACE_ENTRY(""); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
225 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
226 CHECK_POSIX( pthread_rwlock_wrlock(&trig_rwl) ); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
227 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
228 while (!FD_IS_LIST_EMPTY(&trig_list)) { |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
229 struct fd_list * li = trig_list.next; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
230 fd_list_unlink(li); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
231 free(li); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
232 } |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
233 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
234 CHECK_POSIX( pthread_rwlock_unlock(&trig_rwl) ); |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
235 |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
236 return 0; |
|
f198d16fa7f4
Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
82
diff
changeset
|
237 } |