* 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.
- * 3. All advertising materials mentioning features or use of this software
- * must display the following acknowledgement:
- * This product includes software developed by the University of
- * California, Berkeley and its contributors.
- * 4. Neither the name of the University nor the names of its contributors
+ * 3. Neither the name of the University nor the names of its contributors
* may be used to endorse or promote products derived from this software
* without specific prior written permission.
*
#ifndef lint
static const char rcsid[] =
- "$Id: rmt.c,v 1.22 2003/01/10 14:42:51 stelian Exp $";
+ "$Id: rmt.c,v 1.29 2010/06/11 11:19:18 stelian Exp $";
#endif /* not linux */
/*
#define MTS_FLAGS 'f'
#define MTS_BF 'b'
-char *checkbuf __P((char *, int));
-void error __P((int));
-void getstring __P((char *));
+static char *checkbuf __P((char *, int));
+static void error __P((int));
+static void getstring __P((char *));
+static unsigned long swaplong __P((unsigned long inv));
+#ifdef ERMT
+char *cipher __P((char *, int, int));
+void decrypt __P((void));
+#endif
int
main(int argc, char *argv[])
{
- int rval = 0;
+ OFF_T rval = 0;
char c;
int n, i, cc, oflags;
unsigned long block = 0;
+ char *cp;
+
+ int magtape = 0;
+#ifdef ERMT
+ if (argc > 1 && strcmp(argv[1], "-d") == 0)
+ decrypt(); /* decrypt stdin to stdout, and exit() */
+#endif
+ /* Skip "-c /etc/rmt", which appears when rmt is used as a shell */
+ if (argc > 2 && strcmp(argv[1], "-c") == 0)
+ argc -= 2, argv += 2;
argc--, argv++;
if (argc > 0) {
debug = fopen(*argv, "w");
if (tape < 0)
goto ioerror;
block = 0;
+ {
+ struct mtget mt_stat;
+ magtape = ioctl(tape, MTIOCGET, (char *)&mt_stat) == 0;
+ }
goto respond;
case 'C':
block = 0;
goto respond;
+#ifdef USE_QFA
+#define LSEEK_GET_TAPEPOS 10
+#define LSEEK_GO2_TAPEPOS 11
+#endif
+
case 'L':
getstring(count);
getstring(pos);
DEBUG2("rmtd: L %s %s\n", count, pos);
- rval = LSEEK(tape, (OFF_T)atoll(count), atoi(pos));
+ if (!magtape) { /* traditional */
+ switch (atoi(pos)) {
+ case SEEK_SET:
+ case SEEK_CUR:
+ case SEEK_END:
+ rval = LSEEK(tape, (OFF_T)atoll(count), atoi(pos));
+ break;
+#ifdef USE_QFA
+ case LSEEK_GET_TAPEPOS:
+ rval = LSEEK(tape, (OFF_T)0, SEEK_CUR);
+ break;
+ case LSEEK_GO2_TAPEPOS:
+ rval = LSEEK(tape, (OFF_T)atoll(count), SEEK_SET);
+ break;
+#endif /* USE_QFA */
+ default:
+ errno = EINVAL;
+ goto ioerror;
+ break;
+ }
+ }
+ else {
+ switch (atoi(pos)) {
+ case SEEK_SET:
+ case SEEK_CUR:
+ case SEEK_END:
+ rval = LSEEK(tape, (OFF_T)atoll(count), atoi(pos));
+ break;
+#ifdef USE_QFA
+ case LSEEK_GET_TAPEPOS: /* QFA */
+ case LSEEK_GO2_TAPEPOS:
+ {
+ struct mtop buf;
+ long mtpos;
+
+ buf.mt_op = MTSETDRVBUFFER;
+ buf.mt_count = MT_ST_BOOLEANS | MT_ST_SCSI2LOGICAL;
+ if (ioctl(tape, MTIOCTOP, &buf) < 0) {
+ goto ioerror;
+ }
+
+ if (atoi(pos) == LSEEK_GET_TAPEPOS) { /* get tapepos */
+ if (ioctl(tape, MTIOCPOS, &mtpos) < 0) {
+ goto ioerror;
+ }
+ rval = (OFF_T)mtpos;
+ } else {
+ buf.mt_op = MTSEEK;
+ buf.mt_count = atoi(count);
+ if (ioctl(tape, MTIOCTOP, &buf) < 0) {
+ goto ioerror;
+ }
+ rval = (OFF_T)buf.mt_count;
+ }
+ }
+ break;
+#endif /* USE_QFA */
+ default:
+ errno = EINVAL;
+ goto ioerror;
+ }
+ }
if (rval < 0)
goto ioerror;
goto respond;
case 'W':
getstring(count);
n = atoi(count);
+ if (n < 1)
+ exit(2);
DEBUG2("rmtd: W %s (block = %lu)\n", count, block);
record = checkbuf(record, n);
for (i = 0; i < n; i += cc) {
exit(2);
}
}
- rval = write(tape, record, n);
+#ifdef ERMT
+ if ((cp = cipher(record, n, 1)) == NULL)
+ goto ioerror;
+#else
+ cp = record;
+#endif
+ rval = write(tape, cp, n);
if (rval < 0)
goto ioerror;
block += n >> 10;
rval = read(tape, record, n);
if (rval < 0)
goto ioerror;
- (void)sprintf(resp, "A%d\n", rval);
- (void)write(1, resp, strlen(resp));
- (void)write(1, record, rval);
+#ifdef ERMT
+ if ((cp = cipher(record, rval, 0)) == NULL)
+ goto ioerror;
+#else
+ cp = record;
+#endif
+ (void)sprintf(resp, "A%lld\n", (long long)rval);
+ if (write(1, resp, strlen(resp)) != strlen(resp))
+ goto ioerror;
+ if (write(1, cp, rval) != rval)
+ goto ioerror;
block += n >> 10;
goto top;
struct mtop mtop;
mtop.mt_op = -1;
if (rmt_version) {
- /* rmt version 1, assume UNIX client */
+ /* rmt version 1, assume UNIX/Solaris/Mac OS X client */
switch (atoi(op)) {
#ifdef MTWEOF
case 0:
case 7:
mtop.mt_op = MTNOP;
break;
+#endif
+#ifdef MTRETEN
+ case 8:
+ mtop.mt_op = MTRETEN;
+ break;
+#endif
+#ifdef MTERASE
+ case 9:
+ mtop.mt_op = MTERASE;
+ break;
+#endif
+#ifdef MTEOM
+ case 10:
+ mtop.mt_op = MTEOM;
+ break;
#endif
}
if (mtop.mt_op == -1) {
mtop.mt_op = atoi(op);
}
mtop.mt_count = atoi(count);
- if (ioctl(tape, MTIOCTOP, (char *)&mtop) < 0)
+ if (ioctl(tape, MTIOCTOP, (char *)&mtop) < 0) {
goto ioerror;
+ }
rval = mtop.mt_count;
}
goto respond;
goto ioerror;
}
mtop.mt_count = atoi (count);
- if (ioctl (tape, MTIOCTOP, (char *) &mtop) < 0)
+ if (ioctl (tape, MTIOCTOP, (char *) &mtop) < 0) {
goto ioerror;
+ }
rval = mtop.mt_count;
case 'S': /* status */
DEBUG("rmtd: S\n");
{ struct mtget mtget;
- if (ioctl(tape, MTIOCGET, (char *)&mtget) < 0)
+
+ if (ioctl(tape, MTIOCGET, (char *)&mtget) < 0) {
goto ioerror;
- rval = sizeof (mtget);
- (void)sprintf(resp, "A%d\n", rval);
- (void)write(1, resp, strlen(resp));
- (void)write(1, (char *)&mtget, sizeof (mtget));
+ }
+
+ if (rmt_version) {
+ rval = sizeof(mtget);
+ /* assume byte order:
+ Linux on Intel (little), Solaris on SPARC (big), Mac OS X on PPC (big)
+ thus need byte swapping from little to big
+ */
+ mtget.mt_type = swaplong(mtget.mt_type);
+ mtget.mt_resid = swaplong(mtget.mt_resid);
+ mtget.mt_dsreg = swaplong(mtget.mt_dsreg);
+ mtget.mt_gstat = swaplong(mtget.mt_gstat);
+ mtget.mt_erreg = swaplong(mtget.mt_erreg);
+ mtget.mt_fileno = swaplong(mtget.mt_fileno);
+ mtget.mt_blkno = swaplong(mtget.mt_blkno);
+ (void)sprintf(resp, "A%lld\n", (long long)rval);
+ if (write(1, resp, strlen(resp)) != strlen(resp))
+ goto ioerror;
+ if (write(1, (char *)&mtget, sizeof (mtget)) != sizeof(mtget))
+ goto ioerror;
+ } else {
+ rval = sizeof (mtget);
+ (void)sprintf(resp, "A%lld\n", (long long)rval);
+ if (write(1, resp, strlen(resp)) != strlen(resp))
+ goto ioerror;
+ if (write(1, (char *)&mtget, sizeof (mtget)) != sizeof(mtget))
+ goto ioerror;
+ }
goto top;
}
{ char s;
struct mtget mtget;
+ DEBUG ("rmtd: s\n");
+
if (read (0, &s, 1) != 1)
goto top;
+ DEBUG1 ("rmtd: s %d\n", s);
- if (ioctl (tape, MTIOCGET, (char *) &mtget) < 0)
+ if (ioctl (tape, MTIOCGET, (char *) &mtget) < 0) {
goto ioerror;
+ }
switch (s) {
case MTS_TYPE:
goto respond;
}
- case 'V': /* version */
- getstring(op);
- DEBUG1("rmtd: V %s\n", op);
- rval = 2;
- goto respond;
+ case 'V': /* version */
+ getstring(op);
+ DEBUG1("rmtd: V %s\n", op);
+ rval = 2;
+ goto respond;
default:
DEBUG1("rmtd: garbage command %c\n", c);
exit(3);
}
respond:
- DEBUG1("rmtd: A %d\n", rval);
- (void)sprintf(resp, "A%d\n", rval);
- (void)write(1, resp, strlen(resp));
+ DEBUG1("rmtd: A %lld\n", (long long)rval);
+ (void)sprintf(resp, "A%lld\n", (long long)rval);
+ if (write(1, resp, strlen(resp)) != strlen(resp))
+ goto ioerror;
goto top;
ioerror:
error(errno);
goto top;
}
-void getstring(char *bp)
+static void getstring(char *bp)
{
int i;
char *cp = bp;
- for (i = 0; i < SSIZE; i++) {
+ for (i = 0; i < SSIZE - 1; i++) {
if (read(0, cp+i, 1) != 1)
exit(0);
if (cp[i] == '\n')
cp[i] = '\0';
}
-char *
+static char *
checkbuf(char *record, int size)
{
return (record);
}
-void
+static void
error(int num)
{
DEBUG2("rmtd: E %d (%s)\n", num, strerror(num));
(void)snprintf(resp, sizeof(resp), "E%d\n%s\n", num, strerror(num));
- (void)write(1, resp, strlen(resp));
+ if (write(1, resp, strlen(resp)) != strlen(resp))
+ DEBUG("rmtd: write error\n");
+}
+
+static unsigned long
+swaplong(unsigned long inv)
+{
+ union lconv {
+ unsigned long ul;
+ unsigned char uc[4];
+ } *inp, outv;
+
+ inp = (union lconv *)&inv;
+
+ outv.uc[0] = inp->uc[3];
+ outv.uc[1] = inp->uc[2];
+ outv.uc[2] = inp->uc[1];
+ outv.uc[3] = inp->uc[0];
+
+ return (outv.ul);
}
git.wh0rd.org / dump.git / blobdiff