d/freebsd-dev
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

GEOM Gate network client and control utility.

Browse Source
This commit is contained in:
Pawel Jakub Dawidek 2004-04-30 16:18:01 +00:00
parent 72a840f9a6
commit 2041034c3d
Notes: svn2git 2020-12-20 02:59:44 +00:00 
svn path=/head/; revision=128765
3 changed files with 708 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
sbin/ggate/ggatec/Makefile Normal file
View File

@ -0,0 +1,15 @@
# $FreeBSD$
.PATH: ../shared
BINDIR= /sbin
PROG= ggatec
SRCS= ggatec.c ggate.c
MAN= ggatec.8
DPADD= ${LIBGEOM} ${LIBSBUF} ${LIBBSDXML}
LDADD= -lgeom -lsbuf -lbsdxml
WARNS= 6
CFLAGS+=-I../shared
CFLAGS+=-DLIBGEOM
.include <bsd.prog.mk>

183
sbin/ggate/ggatec/ggatec.8 Normal file
View File

@ -0,0 +1,183 @@
.\" Copyright (c) 2004 Pawel Jakub Dawidek <pjd@FreeBSD.org>
.\" All rights reserved.
.\"
.\" Redistribution and use in source and binary forms, with or without
.\" modification, are permitted provided that the following conditions
.\" are met:
.\" 1. Redistributions of source code must retain the above copyright
.\" notice, this list of conditions and the following disclaimer.
.\" 2. Redistributions in binary form must reproduce the above copyright
.\" notice, this list of conditions and the following disclaimer in the
.\" documentation and/or other materials provided with the distribution.
.\"
.\" THIS SOFTWARE IS PROVIDED BY THE AUTHORS AND CONTRIBUTORS ``AS IS'' AND
.\" ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
.\" IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
.\" ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHORS OR CONTRIBUTORS BE LIABLE
.\" FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
.\" DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
.\" OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
.\" HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
.\" LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
.\" OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
.\" SUCH DAMAGE.
.\"
.\" $FreeBSD$
.\"
.Dd April 26, 2004
.Dt GGATEC 8
.Os
.Sh NAME
.Nm ggatec
.Nd "GEOM Gate network client and control utility"
.Sh SYNOPSIS
.Nm
.Ar create
.Op Fl n
.Op Fl v
.Op Fl o Ar ro | wo | rw
.Op Fl p Ar port
.Op Fl q Ar queue_size
.Op Fl R Ar rcvbuf
.Op Fl S Ar sndbuf
.Op Fl s Ar sectorsize
.Op Fl t Ar timeout
.Op Fl u Ar unit
.Ar host
.Ar path
.Nm
.Ar attach
.Op Fl n
.Op Fl v
.Op Fl o Ar ro | wo | rw
.Op Fl p Ar port
.Op Fl R Ar rcvbuf
.Op Fl S Ar sndbuf
.Fl u Ar unit
.Ar host
.Ar path
.Nm
.Ar destroy
.Op Fl f
.Fl u Ar unit
.Nm
.Ar list
.Op Fl v
.Op Fl u Ar unit
.Sh DESCRIPTION
The
.Nm
utility is a network client for GEOM Gate class.
It is responsible for creation of
.Nm ggate
devices and forwarding I/O requests between
.Nm geom_gate.ko
kernel module and
.Nm ggated
network daemon.
Available commands:
.Bl -tag -width ".Ar destroy"
.It Ar create
Connect to given
.Nm ggated
daemon and create a
.Nm ggate
provider related to the given remote file or device.
.It Ar attach
Attach a worker process to an existing
.Nm ggate
provider (create a new connection to the
.Nm ggated
daemon).
.It Ar destroy
Destroy the given
.Nm ggate
provider.
.It Ar list
List
.Nm ggate
providers.
.El
.Pp
Available options:
.Bl -tag -width ".Fl s Ar ro | wo | rw"
.It Fl f
Forcibly destroy
.Nm ggate
provider (cancels all pending requests).
.It Fl n
Do not use TCP_NODELAY option on TCP sockets.
.It Fl o Ar ro | wo | rw
Specify permission to use when opening the file or device: read\-only
.Ar ( ro ) ,
write\-only
.Ar ( wo ) ,
or read\-write
.Ar ( rw ) .
Default is
.Ar rw .
.It Fl p Ar port
Port to connect to on the remote host.
Default is 3080.
.It Fl q Ar queue_size
Number of pending I/O requests that can be queued before they will
start to be canceled.
Default is 1024.
.It Fl R Ar rcvbuf
Size of receive buffer to use.
Default is 131072 (128kB).
.It Fl S Ar sndbuf
Size of send buffer to use.
Default is 131072 (128kB).
.It Fl s Ar sectorsize
Sector size for
.Nm ggate
provider.
If not specified, it is taken from device or set to 512 bytes for files.
.It Fl t Ar timeout
Number of seconds to wait before an I/O request will be canceled.
0 means no timeout.
Default is 30.
.It Fl u Ar unit
Unit number to use.
.It Fl v
Do not fork, run in foreground and print debug informations on standard
output.
.It Ar host
Remote host to connect to.
.It Ar path
Path to a regular file or device.
.El
.Pp
.Sh EXAMPLES
Made use of CD\-ROM device from remote host.
.Pp
.Bd -literal -offset indent
server# cat /etc/gg.exports
client RO /dev/acd0
server# ggated
client# ggatec -o ro server /dev/acd0
ggate0
client# mount_cd9660 /dev/ggate0 /cdrom
.Ed
.Pp
.Sh DIAGNOSTICS
Exit status is 0 on success, or 1 if the command fails.
To get details about the failure,
.Nm
should be called with the
.Fl v
option.
.Sh SEE ALSO
.Xr geom 4 ,
.Xr ggated 8 ,
.Xr ggatel 8 ,
.Xr mount_cd9660 8
.Sh AUTHORS
The
.Nm
utility as well as this manual page was written by
.An -split
.An Pawel Jakub Dawidek Aq pjd@FreeBSD.org .
.An -nosplit

510
sbin/ggate/ggatec/ggatec.c Normal file
View File

@ -0,0 +1,510 @@
/*-
* Copyright (c) 2004 Pawel Jakub Dawidek <pjd@FreeBSD.org>
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
*
* THIS SOFTWARE IS PROVIDED BY THE AUTHORS AND CONTRIBUTORS ``AS IS'' AND
* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHORS OR CONTRIBUTORS BE LIABLE
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
*
* $FreeBSD$
*/
#include <stdio.h>
#include <stdlib.h>
#include <stdint.h>
#include <fcntl.h>
#include <unistd.h>
#include <string.h>
#include <ctype.h>
#include <libgen.h>
#include <err.h>
#include <errno.h>
#include <sys/param.h>
#include <sys/ioctl.h>
#include <sys/socket.h>
#include <sys/sysctl.h>
#include <sys/syslog.h>
#include <sys/time.h>
#include <sys/bio.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <arpa/inet.h>
#include <geom/gate/g_gate.h>
#include "ggate.h"
enum { UNSET, ATTACH, CREATE, DESTROY, LIST } action = UNSET;
static const char *path = NULL;
static const char *host = NULL;
static int unit = -1;
static unsigned flags = 0;
static int force = 0;
static int nagle = 1;
static unsigned queue_size = G_GATE_QUEUE_SIZE;
static unsigned port = G_GATE_PORT;
static off_t mediasize;
static unsigned sectorsize = 0;
static unsigned timeout = G_GATE_TIMEOUT;
static unsigned rcvbuf = G_GATE_RCVBUF;
static unsigned sndbuf = G_GATE_SNDBUF;
static void
usage(void)
{
fprintf(stderr, "usage: %s create [-nv] [-o <ro|wo|rw>] [-p port] "
"[-q queue_size] [-R rcvbuf] [-S sndbuf] [-s sectorsize] "
"[-t timeout] [-u unit] <host> <path>\n", getprogname());
fprintf(stderr, " %s attach [-nv] [-o <ro|wo|rw>] [-p port] "
"[-R rcvbuf] [-S sndbuf] <-u unit> <host> <path>\n", getprogname());
fprintf(stderr, " %s destroy [-f] <-u unit>\n", getprogname());
fprintf(stderr, " %s list [-v] [-u unit]\n", getprogname());
exit(EXIT_FAILURE);
}
static int
handshake(void)
{
struct g_gate_cinit cinit;
struct g_gate_sinit sinit;
struct sockaddr_in serv;
struct timeval tv;
size_t bsize;
int sfd;
/*
* Do the network stuff.
*/
bzero(&serv, sizeof(serv));
serv.sin_family = AF_INET;
serv.sin_addr.s_addr = g_gate_str2ip(host);
if (serv.sin_addr.s_addr == INADDR_NONE) {
g_gate_log(LOG_ERR, "Invalid IP/host name: %s.", host);
return (-1);
}
serv.sin_port = htons(port);
sfd = socket(AF_INET, SOCK_STREAM, 0);
if (sfd < 0)
g_gate_xlog("Can't open socket: %s.", strerror(errno));
/*
* Some trivial network optimalization.
* This should be much more advanced.
*/
if (nagle) {
int on = 1;
if (setsockopt(sfd, IPPROTO_TCP, TCP_NODELAY, &on,
sizeof(on)) < 0) {
g_gate_xlog("setsockopt() error: %s.", strerror(errno));
}
}
bsize = rcvbuf;
if (setsockopt(sfd, SOL_SOCKET, SO_RCVBUF, &bsize, sizeof(bsize)))
g_gate_xlog("setsockopt() error: %s.", strerror(errno));
bsize = sndbuf;
if (setsockopt(sfd, SOL_SOCKET, SO_SNDBUF, &bsize, sizeof(bsize)))
g_gate_xlog("setsockopt() error: %s.", strerror(errno));
tv.tv_sec = timeout;
tv.tv_usec = 0;
if (setsockopt(sfd, SOL_SOCKET, SO_SNDTIMEO, &tv, sizeof(tv)) ||
setsockopt(sfd, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv)) < 0) {
g_gate_xlog("setsockopt() error: %s.", strerror(errno));
}
if (connect(sfd, (struct sockaddr *)&serv, sizeof(serv)) < 0) {
g_gate_log(LOG_ERR, "Can't connect to server: %s.",
strerror(errno));
return (-1);
}
g_gate_log(LOG_INFO, "Connected to the server: %s:%d.", host, port);
/*
* Creating and sending initial packet.
*/
if (strlcpy(cinit.gc_path, path, sizeof(cinit.gc_path)) >=
sizeof(cinit.gc_path)) {
g_gate_xlog("Path name too long.");
}
cinit.gc_flags = flags;
g_gate_log(LOG_DEBUG, "Sending initial packet.");
g_gate_swap2n_cinit(&cinit);
if (send(sfd, &cinit, sizeof(cinit), 0) == -1) {
g_gate_log(LOG_ERR, "Error while sending initial packet: %s.",
strerror(errno));
return (-1);
}
g_gate_swap2h_cinit(&cinit);
/*
* Receiving initial packet from server.
*/
g_gate_log(LOG_DEBUG, "Receiving initial packet.");
if (recv(sfd, &sinit, sizeof(sinit), MSG_WAITALL) == -1) {
g_gate_log(LOG_ERR, "Error while receiving data: %s.",
strerror(errno));
return (-1);
}
g_gate_swap2h_sinit(&sinit);
if (sinit.gs_error != 0)
g_gate_xlog("Error from server: %s.", strerror(sinit.gs_error));
mediasize = sinit.gs_mediasize;
if (sectorsize == 0)
sectorsize = sinit.gs_sectorsize;
return (sfd);
}
static int
serve(int sfd)
{
struct g_gate_ctl_io ggio;
size_t bsize;
char *buf;
bsize = G_GATE_BUFSIZE_START;
buf = malloc(bsize);
if (buf == NULL) {
if (action == CREATE)
g_gate_destroy(unit, 1);
g_gate_xlog("No enough memory");
}
ggio.gctl_version = G_GATE_VERSION;
ggio.gctl_unit = unit;
bsize = sectorsize;
ggio.gctl_data = malloc(bsize);
for (;;) {
struct g_gate_hdr hdr;
int data, error;
once_again:
ggio.gctl_length = bsize;
ggio.gctl_error = 0;
g_gate_ioctl(G_GATE_CMD_START, &ggio);
error = ggio.gctl_error;
switch (error) {
case 0:
break;
case ECANCELED:
/* Exit gracefully. */
free(ggio.gctl_data);
g_gate_close_device();
close(sfd);
exit(EXIT_SUCCESS);
case ENOMEM:
/* Buffer too small. */
ggio.gctl_data = realloc(ggio.gctl_data,
ggio.gctl_length);
if (ggio.gctl_data != NULL) {
bsize = ggio.gctl_length;
goto once_again;
}
/* FALLTHROUGH */
case ENXIO:
default:
g_gate_xlog("ioctl(/dev/%s): %s.", G_GATE_CTL_NAME,
strerror(error));
}
hdr.gh_cmd = ggio.gctl_cmd;
hdr.gh_offset = ggio.gctl_offset;
hdr.gh_length = ggio.gctl_length;
hdr.gh_error = 0;
g_gate_swap2n_hdr(&hdr);
data = send(sfd, &hdr, sizeof(hdr), 0);
g_gate_log(LOG_DEBUG, "Sent hdr packet.");
g_gate_swap2h_hdr(&hdr);
if (data != sizeof(hdr)) {
ggio.gctl_error = EAGAIN;
goto done;
}
if (ggio.gctl_cmd == BIO_DELETE || ggio.gctl_cmd == BIO_WRITE) {
data = send(sfd, ggio.gctl_data, ggio.gctl_length, 0);
g_gate_log(LOG_DEBUG, "Sent data packet.");
if (data != ggio.gctl_length) {
ggio.gctl_error = EAGAIN;
goto done;
}
g_gate_log(LOG_DEBUG, "Sent %d bytes (offset=%llu, "
"size=%u).", data, hdr.gh_offset, hdr.gh_length);
}
data = recv(sfd, &hdr, sizeof(hdr), MSG_WAITALL);
g_gate_log(LOG_DEBUG, "Received hdr packet.");
g_gate_swap2h_hdr(&hdr);
if (data != sizeof(hdr)) {
ggio.gctl_error = EIO;
goto done;
}
if (ggio.gctl_cmd == BIO_READ) {
if (bsize < ggio.gctl_length) {
ggio.gctl_data = realloc(ggio.gctl_data,
ggio.gctl_length);
if (ggio.gctl_data != NULL)
bsize = ggio.gctl_length;
else
g_gate_xlog("No memory.");
}
data = recv(sfd, ggio.gctl_data, ggio.gctl_length,
MSG_WAITALL);
g_gate_log(LOG_DEBUG, "Received data packet.");
if (data != ggio.gctl_length) {
ggio.gctl_error = EAGAIN;
goto done;
}
g_gate_log(LOG_DEBUG, "Received %d bytes (offset=%ju, "
"size=%zu).", data, (uintmax_t)hdr.gh_offset,
(size_t)hdr.gh_length);
}
done:
g_gate_ioctl(G_GATE_CMD_DONE, &ggio);
if (ggio.gctl_error == EAGAIN)
return (ggio.gctl_error);
}
/* NOTREACHED */
return (0);
}
static void
serve_loop(int sfd)
{
for (;;) {
int error;
sfd = handshake();
if (sfd < 0) {
sleep(2);
continue;
}
error = serve(sfd);
close(sfd);
if (error != EAGAIN)
g_gate_xlog("%s.", strerror(error));
}
}
static void
mydaemon(void)
{
if (g_gate_verbose > 0)
return;
if (daemon(0, 0) == 0)
return;
if (action == CREATE)
g_gate_destroy(unit, 1);
err(EXIT_FAILURE, "Cannot daemonize");
}
static void
g_gatec_attach(void)
{
int sfd;
sfd = handshake();
g_gate_log(LOG_DEBUG, "Worker created: %u.", getpid());
mydaemon();
serve_loop(sfd);
}
static void
g_gatec_create(void)
{
struct g_gate_ctl_create ggioc;
int sfd;
sfd = handshake();
if (sfd < 0)
exit(EXIT_FAILURE);
ggioc.gctl_version = G_GATE_VERSION;
ggioc.gctl_mediasize = mediasize;
ggioc.gctl_sectorsize = sectorsize;
ggioc.gctl_flags = flags;
ggioc.gctl_maxcount = queue_size;
ggioc.gctl_timeout = timeout;
ggioc.gctl_unit = unit;
snprintf(ggioc.gctl_info, sizeof(ggioc.gctl_info), "%s:%u %s", host,
port, path);
g_gate_ioctl(G_GATE_CMD_CREATE, &ggioc);
g_gate_log(LOG_DEBUG, "Worker created: %u.", getpid());
if (unit == -1)
printf("%s%u\n", G_GATE_PROVIDER_NAME, ggioc.gctl_unit);
unit = ggioc.gctl_unit;
mydaemon();
serve_loop(sfd);
}
int
main(int argc, char *argv[])
{
if (argc < 2)
usage();
if (strcasecmp(argv[1], "attach") == 0)
action = ATTACH;
else if (strcasecmp(argv[1], "create") == 0)
action = CREATE;
else if (strcasecmp(argv[1], "destroy") == 0)
action = DESTROY;
else if (strcasecmp(argv[1], "list") == 0)
action = LIST;
else
usage();
argc -= 1;
argv += 1;
for (;;) {
int ch;
ch = getopt(argc, argv, "fno:p:q:R:S:s:t:u:v");
if (ch == -1)
break;
switch (ch) {
case 'f':
if (action != DESTROY)
usage();
force = 1;
break;
case 'n':
if (action != ATTACH && action != CREATE)
usage();
nagle = 0;
break;
case 'o':
if (action != ATTACH && action != CREATE)
usage();
if (strcasecmp("ro", optarg) == 0)
flags = G_GATE_FLAG_READONLY;
else if (strcasecmp("wo", optarg) == 0)
flags = G_GATE_FLAG_WRITEONLY;
else if (strcasecmp("rw", optarg) == 0)
flags = 0;
else {
errx(EXIT_FAILURE,
"Invalid argument for '-o' option.");
}
break;
case 'p':
if (action != ATTACH && action != CREATE)
usage();
errno = 0;
port = strtoul(optarg, NULL, 10);
if (port == 0 && errno != 0)
errx(EXIT_FAILURE, "Invalid port.");
break;
case 'q':
if (action != CREATE)
usage();
errno = 0;
queue_size = strtoul(optarg, NULL, 10);
if (queue_size == 0 && errno != 0)
errx(EXIT_FAILURE, "Invalid queue_size.");
break;
case 'R':
if (action != ATTACH && action != CREATE)
usage();
errno = 0;
rcvbuf = strtoul(optarg, NULL, 10);
if (rcvbuf == 0 && errno != 0)
errx(EXIT_FAILURE, "Invalid rcvbuf.");
break;
case 'S':
if (action != ATTACH && action != CREATE)
usage();
errno = 0;
sndbuf = strtoul(optarg, NULL, 10);
if (sndbuf == 0 && errno != 0)
errx(EXIT_FAILURE, "Invalid sndbuf.");
break;
case 's':
if (action != CREATE)
usage();
errno = 0;
sectorsize = strtoul(optarg, NULL, 10);
if (sectorsize == 0 && errno != 0)
errx(EXIT_FAILURE, "Invalid sectorsize.");
break;
case 't':
if (action != CREATE)
usage();
errno = 0;
timeout = strtoul(optarg, NULL, 10);
if (timeout == 0 && errno != 0)
errx(EXIT_FAILURE, "Invalid timeout.");
break;
case 'u':
errno = 0;
unit = strtol(optarg, NULL, 10);
if (unit == 0 && errno != 0)
errx(EXIT_FAILURE, "Invalid unit number.");
break;
case 'v':
if (action == DESTROY)
usage();
g_gate_verbose++;
break;
default:
usage();
}
}
argc -= optind;
argv += optind;
switch (action) {
case ATTACH:
if (argc != 2)
usage();
if (unit == -1) {
fprintf(stderr, "Required unit number.\n");
usage();
}
g_gate_open_device();
host = argv[0];
path = argv[1];
g_gatec_attach();
break;
case CREATE:
if (argc != 2)
usage();
g_gate_load_module();
g_gate_open_device();
host = argv[0];
path = argv[1];
g_gatec_create();
break;
case DESTROY:
if (unit == -1) {
fprintf(stderr, "Required unit number.\n");
usage();
}
g_gate_verbose = 1;
g_gate_open_device();
g_gate_destroy(unit, force);
break;
case LIST:
g_gate_list(unit, g_gate_verbose);
break;
case UNSET:
default:
usage();
}
g_gate_close_device();
exit(EXIT_SUCCESS);
}