X-Git-Url: http://git.alex.org.uk diff --git a/nbd-client.c b/nbd-client.c index ba244ae..2456c59 100644 --- a/nbd-client.c +++ b/nbd-client.c @@ -37,14 +37,14 @@ #include #include -#ifndef __GNUC__ -#error I need GCC to work -#endif - #include #define MY_NAME "nbd_client" #include "cliserv.h" +#ifdef WITH_SDP +#include +#endif + int check_conn(char* devname, int do_print) { char buf[256]; char* p; @@ -150,20 +150,25 @@ void negotiate(int sock, u64 *rsize64, u32 *flags, char* name) { if(read(sock, &tmp, sizeof(uint16_t)) < 0) { err("Failed reading flags: %m"); } - *flags = ((u32)ntohs(tmp)) << 16; + *flags = ((u32)ntohs(tmp)); /* reserved for future use*/ - write(sock, &reserved, sizeof(reserved)); + if (write(sock, &reserved, sizeof(reserved)) < 0) + err("Failed/2.1: %m"); /* Write the export name that we're after */ magic = ntohll(opts_magic); - write(sock, &magic, sizeof(magic)); + if (write(sock, &magic, sizeof(magic)) < 0) + err("Failed/2.2: %m"); opt = ntohl(NBD_OPT_EXPORT_NAME); - write(sock, &opt, sizeof(opt)); + if (write(sock, &opt, sizeof(opt)) < 0) + err("Failed/2.3: %m"); namesize = (u32)strlen(name); namesize = ntohl(namesize); - write(sock, &namesize, sizeof(namesize)); - write(sock, name, strlen(name)); + if (write(sock, &namesize, sizeof(namesize)) < 0) + err("Failed/2.4: %m"); + if (write(sock, name, strlen(name)) < 0) + err("Failed/2.4: %m"); } else { if (magic != cliserv_magic) err("Not enough cliserv_magic"); @@ -175,11 +180,11 @@ void negotiate(int sock, u64 *rsize64, u32 *flags, char* name) { size64 = ntohll(size64); #ifdef NBD_SET_SIZE_BLOCKS - if ((size64>>10) > (~0UL >> 1)) { + if ((size64>>12) > (uint64_t)~0UL) { printf("size = %luMB", (unsigned long)(size64>>20)); err("Exported device is too big for me. Get 64-bit machine :-(\n"); } else - printf("size = %luKB", (unsigned long)(size64>>10)); + printf("size = %luMB", (unsigned long)(size64>>20)); #else if (size64 > (~0UL >> 1)) { printf("size = %luKB", (unsigned long)(size64>>10)); @@ -210,16 +215,18 @@ void setsizes(int nbd, u64 size64, int blocksize, u32 flags) { int read_only = (flags & NBD_FLAG_READ_ONLY) ? 1 : 0; #ifdef NBD_SET_SIZE_BLOCKS - if (size64/blocksize > (~0UL >> 1)) + if (size64>>12 > (uint64_t)~0UL) err("Device too large.\n"); else { int er; - if (ioctl(nbd, NBD_SET_BLKSIZE, (unsigned long)blocksize) < 0) + if (ioctl(nbd, NBD_SET_BLKSIZE, 4096UL) < 0) err("Ioctl/1.1a failed: %m\n"); - size = (unsigned long)(size64/blocksize); + size = (unsigned long)(size64>>12); if ((er = ioctl(nbd, NBD_SET_SIZE_BLOCKS, size)) < 0) err("Ioctl/1.1b failed: %m\n"); - fprintf(stderr, "bs=%d, sz=%lu\n", blocksize, size); + if (ioctl(nbd, NBD_SET_BLKSIZE, (unsigned long)blocksize) < 0) + err("Ioctl/1.1c failed: %m\n"); + fprintf(stderr, "bs=%d, sz=%llu bytes\n", blocksize, 4096ULL*size); } #else if (size64 > (~0UL >> 1)) { @@ -233,6 +240,9 @@ void setsizes(int nbd, u64 size64, int blocksize, u32 flags) { ioctl(nbd, NBD_CLEAR_SOCK); + /* ignore error as kernel may not support */ + ioctl(nbd, NBD_SET_FLAGS, (unsigned long) flags); + if (ioctl(nbd, BLKROSET, (unsigned long) &read_only) < 0) err("Unable to set read-only attribute for device"); } @@ -268,7 +278,8 @@ void usage(char* errmsg, ...) { } else { fprintf(stderr, "nbd-client version %s\n", PACKAGE_VERSION); } - fprintf(stderr, "Usage: nbd-client host port nbd_device [-block-size|-b block size] [-timeout|-t timeout] [-swap|-s] [-sdp|-S] [-persist|-p] [-nofork|-n] [-name|-N name]\n"); + fprintf(stderr, "Usage: nbd-client host port nbd_device [-block-size|-b block size] [-timeout|-t timeout] [-swap|-s] [-sdp|-S] [-persist|-p] [-nofork|-n]\n"); + fprintf(stderr, "Or : nbd-client -name|-N name host [port] nbd_device [-block-size|-b block size] [-timeout|-t timeout] [-swap|-s] [-sdp|-S] [-persist|-p] [-nofork|-n]\n"); fprintf(stderr, "Or : nbd-client -d nbd_device\n"); fprintf(stderr, "Or : nbd-client -c nbd_device\n"); fprintf(stderr, "Or : nbd-client -h|--help\n"); @@ -276,6 +287,7 @@ void usage(char* errmsg, ...) { fprintf(stderr, "Allowed values for blocksize are 512,1024,2048,4096\n"); /* will be checked in kernel :) */ fprintf(stderr, "Note, that kernel 2.4.2 and older ones do not work correctly with\n"); fprintf(stderr, "blocksizes other than 1024 without patches\n"); + fprintf(stderr, "Default value for port with -N is 10809. Note that port must always be numeric\n"); } void disconnect(char* device) { @@ -310,7 +322,7 @@ int main(int argc, char *argv[]) { int cont=0; int timeout=0; int sdp=0; - int nofork=0; + int G_GNUC_UNUSED nofork=0; // if -dNOFORK u64 size64; u32 flags; int c; @@ -364,10 +376,6 @@ int main(int argc, char *argv[]) { nonspecial++; } else { port = optarg; - if(name) { - usage("port and name specified at the same time. This is not supported."); - exit(EXIT_FAILURE); - } } break; case 2: @@ -396,11 +404,9 @@ int main(int argc, char *argv[]) { break; case 'N': name=optarg; - if(port) { - usage("port and name specified at the same time. This is not supported."); - exit(EXIT_FAILURE); + if(!port) { + port = NBD_DEFAULT_PORT; } - port = NBD_DEFAULT_PORT; break; case 'p': cont=1; @@ -441,7 +447,10 @@ int main(int argc, char *argv[]) { /* Go daemon */ #ifndef NOFORK - if(!nofork) daemon(0,0); + if(!nofork) { + if (daemon(0,0) < 0) + err("Cannot detach from terminal"); + } #endif do { #ifndef NOFORK