… | |
… | |
2097 | { |
2097 | { |
2098 | sometype data; |
2098 | sometype data; |
2099 | |
2099 | |
2100 | // no locking etc. |
2100 | // no locking etc. |
2101 | queue_put (data); |
2101 | queue_put (data); |
2102 | ev_async_send (DEFAULT_LOOP, &mysig); |
2102 | ev_async_send (DEFAULT_ &mysig); |
2103 | } |
2103 | } |
2104 | |
2104 | |
2105 | static void |
2105 | static void |
2106 | mysig_cb (EV_P_ ev_async *w, int revents) |
2106 | mysig_cb (EV_P_ ev_async *w, int revents) |
2107 | { |
2107 | { |
… | |
… | |
2138 | // only need to lock the actual queueing operation |
2138 | // only need to lock the actual queueing operation |
2139 | pthread_mutex_lock (&mymutex); |
2139 | pthread_mutex_lock (&mymutex); |
2140 | queue_put (data); |
2140 | queue_put (data); |
2141 | pthread_mutex_unlock (&mymutex); |
2141 | pthread_mutex_unlock (&mymutex); |
2142 | |
2142 | |
2143 | ev_async_send (DEFAULT_LOOP, &mysig); |
2143 | ev_async_send (DEFAULT_ &mysig); |
2144 | } |
2144 | } |
2145 | |
2145 | |
2146 | static void |
2146 | static void |
2147 | mysig_cb (EV_P_ ev_async *w, int revents) |
2147 | mysig_cb (EV_P_ ev_async *w, int revents) |
2148 | { |
2148 | { |