| … | |
… | |
| 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 | { |
