#define SOCKET_PATH "/var/lock/qemu-nbd-%s"
-int verbose;
+#define NBD_BUFFER_SIZE (1024*1024)
+
+static int verbose;
static void usage(const char *name)
{
" (default '"SOCKET_PATH"')\n"
" -r, --read-only export read-only\n"
" -P, --partition=NUM only expose partition NUM\n"
+" -s, --snapshot use snapshot file\n"
+" -n, --nocache disable host cache\n"
" -c, --connect=DEV connect FILE to the local NBD device DEV\n"
" -d, --disconnect disconnect the specified device\n"
+" -e, --shared=NUM device can be shared by NUM clients (default '1')\n"
+" -t, --persistent don't exit on the last connection\n"
" -v, --verbose display extra debugging information\n"
" -h, --help display this help and exit\n"
" -V, --version output version information and exit\n"
static void version(const char *name)
{
printf(
-"qemu-nbd version 0.0.1\n"
+"%s version 0.0.1\n"
"Written by Anthony Liguori.\n"
"\n"
"This is free software; see the source for copying conditions. There is NO\n"
"warranty; not even for MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.\n"
- );
+ , name);
}
struct partition_record
bool disconnect = false;
const char *bindto = "0.0.0.0";
int port = 1024;
- int sock, csock;
struct sockaddr_in addr;
socklen_t addr_len = sizeof(addr);
off_t fd_size;
char *device = NULL;
char *socket = NULL;
char sockpath[128];
- const char *sopt = "hVbo:p:rsP:c:dvk:";
+ const char *sopt = "hVbo:p:rsnP:c:dvk:e:t";
struct option lopt[] = {
{ "help", 0, 0, 'h' },
{ "version", 0, 0, 'V' },
{ "connect", 1, 0, 'c' },
{ "disconnect", 0, 0, 'd' },
{ "snapshot", 0, 0, 's' },
+ { "nocache", 0, 0, 'n' },
+ { "shared", 1, 0, 'e' },
+ { "persistent", 0, 0, 't' },
{ "verbose", 0, 0, 'v' },
{ NULL, 0, 0, 0 }
};
int opt_ind = 0;
int li;
char *end;
- bool snapshot = false;
+ int flags = 0;
int partition = -1;
- int fd;
int ret;
+ int shared = 1;
+ uint8_t *data;
+ fd_set fds;
+ int *sharing_fds;
+ int fd;
+ int i;
+ int nb_fds = 0;
+ int max_fd;
+ int persistent = 0;
while ((ch = getopt_long(argc, argv, sopt, lopt, &opt_ind)) != -1) {
switch (ch) {
case 's':
- snapshot = true;
+ flags |= BDRV_O_SNAPSHOT;
+ break;
+ case 'n':
+ flags |= BDRV_O_NOCACHE;
break;
case 'b':
bindto = optarg;
case 'c':
device = optarg;
break;
+ case 'e':
+ shared = strtol(optarg, &end, 0);
+ if (*end) {
+ errx(EINVAL, "Invalid shared device number '%s'", optarg);
+ }
+ if (shared < 1) {
+ errx(EINVAL, "Shared device number must be greater than 0\n");
+ }
+ break;
+ case 't':
+ persistent = 1;
+ break;
case 'v':
verbose = 1;
break;
if (bs == NULL)
return 1;
- if (bdrv_open(bs, argv[optind], snapshot) == -1)
+ if (bdrv_open(bs, argv[optind], flags) == -1)
return 1;
fd_size = bs->total_sectors * 512;
errx(errno, "Could not find partition %d", partition);
if (device) {
- pid_t pid;
- if (!verbose)
+ pid_t pid;
+ int sock;
+
+ if (!verbose)
daemon(0, 0); /* detach client and server */
if (socket == NULL) {
/* children */
}
+ sharing_fds = qemu_malloc((shared + 1) * sizeof(int));
+ if (sharing_fds == NULL)
+ errx(ENOMEM, "Cannot allocate sharing fds");
+
if (socket) {
- sock = unix_socket_incoming(socket);
+ sharing_fds[0] = unix_socket_incoming(socket);
} else {
- sock = tcp_socket_incoming(bindto, port);
+ sharing_fds[0] = tcp_socket_incoming(bindto, port);
}
- if (sock == -1)
+ if (sharing_fds[0] == -1)
return 1;
+ max_fd = sharing_fds[0];
+ nb_fds++;
- csock = accept(sock,
- (struct sockaddr *)&addr,
- &addr_len);
- if (csock == -1)
- return 1;
+ data = qemu_memalign(512, NBD_BUFFER_SIZE);
+ if (data == NULL)
+ errx(ENOMEM, "Cannot allocate data buffer");
- /* new fd_size is calculated by find_partition */
- if (nbd_negotiate(bs, csock, fd_size) == -1)
- return 1;
+ do {
+
+ FD_ZERO(&fds);
+ for (i = 0; i < nb_fds; i++)
+ FD_SET(sharing_fds[i], &fds);
- while (nbd_trip(bs, csock, fd_size, dev_offset, &offset, readonly) == 0);
+ ret = select(max_fd + 1, &fds, NULL, NULL, NULL);
+ if (ret == -1)
+ break;
+
+ if (FD_ISSET(sharing_fds[0], &fds))
+ ret--;
+ for (i = 1; i < nb_fds && ret; i++) {
+ if (FD_ISSET(sharing_fds[i], &fds)) {
+ if (nbd_trip(bs, sharing_fds[i], fd_size, dev_offset,
+ &offset, readonly, data, NBD_BUFFER_SIZE) != 0) {
+ close(sharing_fds[i]);
+ nb_fds--;
+ sharing_fds[i] = sharing_fds[nb_fds];
+ i--;
+ }
+ ret--;
+ }
+ }
+ /* new connection ? */
+ if (FD_ISSET(sharing_fds[0], &fds)) {
+ if (nb_fds < shared + 1) {
+ sharing_fds[nb_fds] = accept(sharing_fds[0],
+ (struct sockaddr *)&addr,
+ &addr_len);
+ if (sharing_fds[nb_fds] != -1 &&
+ nbd_negotiate(sharing_fds[nb_fds], fd_size) != -1) {
+ if (sharing_fds[nb_fds] > max_fd)
+ max_fd = sharing_fds[nb_fds];
+ nb_fds++;
+ }
+ }
+ }
+ } while (persistent || nb_fds > 1);
+ qemu_free(data);
- close(csock);
- close(sock);
+ close(sharing_fds[0]);
bdrv_close(bs);
+ qemu_free(sharing_fds);
if (socket)
unlink(socket);
projects / qemu.git / blobdiff