netnatm/api/cc_sig.c

90 sig_alloc(struct ccdata *cc, u_int type, void *target, u_int has_msg,
95 	if ((s = TAILQ_FIRST(&cc->free_sigs)) == NULL) {
98 			cc_log(cc, "signal %u/%u lost - ENOMEM", type, sig);
102 		TAILQ_REMOVE(&cc->free_sigs, s, link);
122 	s = sig_alloc(user->cc, SIG_USER, user, 0, sig, arg1, arg2);
125 	TAILQ_INSERT_TAIL(&user->cc->sigs, s, link);
126 	cc_sig_log(user->cc, "queuing sig %s to user %p", cc_user_sigtab[sig],
137 	s = sig_alloc(user->cc, SIG_USER, user, msg != NULL, sig, msg, 0);
140 	TAILQ_INSERT_TAIL(&user->cc->sigs, s, link);
141 	cc_sig_log(user->cc, "queuing sig %s to user %p", cc_user_sigtab[sig],
155 	s = sig_alloc(conn->cc, SIG_CONN, conn, has_msg, sig, arg, 0);
166 		TAILQ_INSERT_TAIL(&conn->cc->sigs, s, link);
167 		cc_sig_log(conn->cc, "queuing sig %s to conn %p",
170 		TAILQ_INSERT_TAIL(&conn->cc->def_sigs, s, link);
171 		cc_sig_log(conn->cc, "queuing defered sig %s to conn %p",
202 	s = sig_alloc(conn->cc, SIG_CONN, conn, (msg != NULL), sig, msg, 0);
206 	TAILQ_INSERT_TAIL(&conn->cc->sigs, s, link);
207 	cc_sig_log(conn->cc, "queuing sig %s to conn %p",
222 	s = sig_alloc(conn->cc, SIG_CONN, conn, 0, sig, NULL,
227 	TAILQ_INSERT_TAIL(&conn->cc->sigs, s, link);
229 	cc_sig_log(conn->cc, "queuing response %s to conn %p",
232 	s1 = TAILQ_FIRST(&conn->cc->def_sigs);
236 			TAILQ_REMOVE(&conn->cc->def_sigs, s1, link);
237 			TAILQ_INSERT_AFTER(&conn->cc->sigs, s, s1, link);
238 			cc_sig_log(conn->cc, "undefering sig %s to conn %p",
252 sig_flush(struct ccdata *cc, u_int type, void *target)
256 	s = TAILQ_FIRST(&cc->sigs);
262 			TAILQ_REMOVE(&cc->sigs, s, link);
263 			TAILQ_INSERT_HEAD(&cc->free_sigs, s, link);
268 	s = TAILQ_FIRST(&cc->def_sigs);
274 			TAILQ_REMOVE(&cc->def_sigs, s, link);
275 			TAILQ_INSERT_HEAD(&cc->free_sigs, s, link);
288 	cc_sig_log(user->cc, "flushing signals to user %p", user);
289 	sig_flush(user->cc, SIG_USER, user);
299 	cc_sig_log(conn->cc, "flushing signals to conn %p", conn);
300 	sig_flush(conn->cc, SIG_CONN, conn);
307 cc_work(struct ccdata *cc)
311 	cc_sig_log(cc, "start %s", "work");
312 	while ((s = TAILQ_FIRST(&cc->sigs)) != NULL) {
313 		TAILQ_REMOVE(&cc->sigs, s, link);
321 		TAILQ_INSERT_HEAD(&cc->free_sigs, s, link);
323 	cc_sig_log(cc, "end %s", "work");
330 cc_sig_flush_all(struct ccdata *cc)
334 	while ((s = TAILQ_FIRST(&cc->sigs)) != NULL) {
337 		TAILQ_REMOVE(&cc->sigs, s, link);
340 	while ((s = TAILQ_FIRST(&cc->def_sigs)) != NULL) {
343 		TAILQ_REMOVE(&cc->def_sigs, s, link);
346 	while ((s = TAILQ_FIRST(&cc->free_sigs)) != NULL) {
347 		TAILQ_REMOVE(&cc->free_sigs, s, link);