| 1982 | } |
| 1983 | |
| 1984 | static void dm_push_queue(aaa_message *msg, struct dm_cond *cond) |
| 1985 | { |
| 1986 | struct dm_message *dm = (struct dm_message *)(msg->avpair); |
| 1987 | dm->reply_cond = cond; |
| 1988 | msg->last_found = DM_MSG_SENT; |
| 1989 | |
| 1990 | pthread_mutex_lock(msg_send_lk); |
| 1991 | |
| 1992 | list_add_tail(&dm->list, msg_send_queue); |
| 1993 | pthread_cond_signal(msg_send_cond); |
| 1994 | |
| 1995 | pthread_mutex_unlock(msg_send_lk); |
| 1996 | } |
| 1997 | |
| 1998 | int _dm_send_message_async(aaa_conn *_, aaa_message *req, int *fd, struct dm_cond **cond) |
| 1999 | { |
no test coverage detected