Revision f2e5dca4 block/nbd.c
b/block/nbd.c | ||
---|---|---|
334 | 334 |
|
335 | 335 |
qemu_co_mutex_lock(&s->send_mutex); |
336 | 336 |
s->send_coroutine = qemu_coroutine_self(); |
337 |
qemu_aio_set_fd_handler(s->sock, nbd_reply_ready, nbd_restart_write, |
|
338 |
NULL, s); |
|
337 |
qemu_aio_set_fd_handler(s->sock, nbd_reply_ready, nbd_restart_write, s); |
|
339 | 338 |
if (qiov) { |
340 | 339 |
if (!s->is_unix) { |
341 | 340 |
socket_set_cork(s->sock, 1); |
... | ... | |
354 | 353 |
} else { |
355 | 354 |
rc = nbd_send_request(s->sock, request); |
356 | 355 |
} |
357 |
qemu_aio_set_fd_handler(s->sock, nbd_reply_ready, NULL, |
|
358 |
NULL, s); |
|
356 |
qemu_aio_set_fd_handler(s->sock, nbd_reply_ready, NULL, s); |
|
359 | 357 |
s->send_coroutine = NULL; |
360 | 358 |
qemu_co_mutex_unlock(&s->send_mutex); |
361 | 359 |
return rc; |
... | ... | |
431 | 429 |
/* Now that we're connected, set the socket to be non-blocking and |
432 | 430 |
* kick the reply mechanism. */ |
433 | 431 |
qemu_set_nonblock(sock); |
434 |
qemu_aio_set_fd_handler(sock, nbd_reply_ready, NULL, |
|
435 |
NULL, s); |
|
432 |
qemu_aio_set_fd_handler(sock, nbd_reply_ready, NULL, s); |
|
436 | 433 |
|
437 | 434 |
s->sock = sock; |
438 | 435 |
s->size = size; |
... | ... | |
452 | 449 |
request.len = 0; |
453 | 450 |
nbd_send_request(s->sock, &request); |
454 | 451 |
|
455 |
qemu_aio_set_fd_handler(s->sock, NULL, NULL, NULL, NULL);
|
|
452 |
qemu_aio_set_fd_handler(s->sock, NULL, NULL, NULL); |
|
456 | 453 |
closesocket(s->sock); |
457 | 454 |
} |
458 | 455 |
|
Also available in: Unified diff