]>
Commit | Line | Data |
---|---|---|
6dd844db PB |
1 | /* |
2 | * Serving QEMU block devices via NBD | |
3 | * | |
4 | * Copyright (c) 2012 Red Hat, Inc. | |
5 | * | |
6 | * Author: Paolo Bonzini <pbonzini@redhat.com> | |
7 | * | |
8 | * This work is licensed under the terms of the GNU GPL, version 2 or | |
9 | * later. See the COPYING file in the top-level directory. | |
10 | */ | |
11 | ||
9c17d615 | 12 | #include "sysemu/blockdev.h" |
e140177d | 13 | #include "sysemu/block-backend.h" |
0d09e41a | 14 | #include "hw/block/block.h" |
7b1b5d19 | 15 | #include "qapi/qmp/qerror.h" |
9c17d615 | 16 | #include "sysemu/sysemu.h" |
6dd844db PB |
17 | #include "qmp-commands.h" |
18 | #include "trace.h" | |
737e150e | 19 | #include "block/nbd.h" |
1de7afc9 | 20 | #include "qemu/sockets.h" |
6dd844db PB |
21 | |
22 | static int server_fd = -1; | |
23 | ||
24 | static void nbd_accept(void *opaque) | |
25 | { | |
26 | struct sockaddr_in addr; | |
27 | socklen_t addr_len = sizeof(addr); | |
28 | ||
29 | int fd = accept(server_fd, (struct sockaddr *)&addr, &addr_len); | |
ee7d7aab FZ |
30 | if (fd >= 0) { |
31 | nbd_client_new(NULL, fd, nbd_client_put); | |
6dd844db PB |
32 | } |
33 | } | |
34 | ||
35 | void qmp_nbd_server_start(SocketAddress *addr, Error **errp) | |
36 | { | |
37 | if (server_fd != -1) { | |
38 | error_setg(errp, "NBD server already running"); | |
39 | return; | |
40 | } | |
41 | ||
42 | server_fd = socket_listen(addr, errp); | |
43 | if (server_fd != -1) { | |
82e1cc4b | 44 | qemu_set_fd_handler(server_fd, nbd_accept, NULL, NULL); |
6dd844db PB |
45 | } |
46 | } | |
47 | ||
6dd844db PB |
48 | void qmp_nbd_server_add(const char *device, bool has_writable, bool writable, |
49 | Error **errp) | |
50 | { | |
e140177d | 51 | BlockBackend *blk; |
6dd844db | 52 | NBDExport *exp; |
6dd844db | 53 | |
17b6be4a PB |
54 | if (server_fd == -1) { |
55 | error_setg(errp, "NBD server not running"); | |
56 | return; | |
57 | } | |
58 | ||
6dd844db PB |
59 | if (nbd_export_find(device)) { |
60 | error_setg(errp, "NBD server already exporting device '%s'", device); | |
61 | return; | |
62 | } | |
63 | ||
e140177d HR |
64 | blk = blk_by_name(device); |
65 | if (!blk) { | |
75158ebb MA |
66 | error_set(errp, ERROR_CLASS_DEVICE_NOT_FOUND, |
67 | "Device '%s' not found", device); | |
6dd844db PB |
68 | return; |
69 | } | |
e140177d | 70 | if (!blk_is_inserted(blk)) { |
c6bd8c70 | 71 | error_setg(errp, QERR_DEVICE_HAS_NO_MEDIUM, device); |
60fe4fac HB |
72 | return; |
73 | } | |
6dd844db | 74 | |
e6444734 | 75 | if (!has_writable) { |
f3313d23 | 76 | writable = false; |
e6444734 | 77 | } |
e140177d | 78 | if (blk_is_read_only(blk)) { |
e6444734 PB |
79 | writable = false; |
80 | } | |
81 | ||
98f44bbe HR |
82 | exp = nbd_export_new(blk, 0, -1, writable ? 0 : NBD_FLAG_READ_ONLY, NULL, |
83 | errp); | |
84 | if (!exp) { | |
85 | return; | |
86 | } | |
6dd844db PB |
87 | |
88 | nbd_export_set_name(exp, device); | |
6dd844db | 89 | |
741cc431 HR |
90 | /* The list of named exports has a strong reference to this export now and |
91 | * our only way of accessing it is through nbd_export_find(), so we can drop | |
92 | * the strong reference that is @exp. */ | |
93 | nbd_export_put(exp); | |
6dd844db PB |
94 | } |
95 | ||
96 | void qmp_nbd_server_stop(Error **errp) | |
97 | { | |
741cc431 | 98 | nbd_export_close_all(); |
6dd844db | 99 | |
fc6467ea | 100 | if (server_fd != -1) { |
82e1cc4b | 101 | qemu_set_fd_handler(server_fd, NULL, NULL, NULL); |
fc6467ea PB |
102 | close(server_fd); |
103 | server_fd = -1; | |
104 | } | |
6dd844db | 105 | } |