| 6294 | pthread_mutex_unlock(&upstream->write_mu); |
| 6295 | return rc; |
| 6296 | } |
| 6297 | |
| 6298 | static int dist_worker_upstream_send_work_error( |
| 6299 | ds4_dist_worker_upstream *upstream, |
| 6300 | uint64_t request_id, |
| 6301 | const char *msg) { |
| 6302 | pthread_mutex_lock(&upstream->write_mu); |
| 6303 | int rc = dist_send_work_error(upstream->fd, request_id, msg); |
| 6304 | pthread_mutex_unlock(&upstream->write_mu); |
| 6305 | return rc; |
| 6306 | } |
| 6307 | |
| 6308 | static void dist_worker_upstream_init( |
no outgoing calls
no test coverage detected