X-Git-Url: https://git.wh0rd.org/?p=dump.git;a=blobdiff_plain;f=rmt%2Frmt.c;h=863f12651c68bd103a1972fd52a2078a889ead97;hp=7f93f57cf32991dd70d96fa329d05ab867db7cb5;hb=HEAD;hpb=900bffdb4fb7cf14ada66e3a0c81b1275cc7571f

diff --git a/rmt/rmt.c b/rmt/rmt.c
index 7f93f57..863f126 100644
--- a/rmt/rmt.c
+++ b/rmt/rmt.c
@@ -18,11 +18,7 @@
  * 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.
  *
@@ -41,7 +37,7 @@
 
 #ifndef lint
 static const char rcsid[] =
-	"$Id: rmt.c,v 1.23 2003/02/12 11:02:31 stelian Exp $";
+	"$Id: rmt.c,v 1.29 2010/06/11 11:19:18 stelian Exp $";
 #endif /* not linux */
 
 /*
@@ -115,9 +111,14 @@ static int	rmt_version = 0;
 #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[])
@@ -126,7 +127,17 @@ main(int argc, char *argv[])
 	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");
@@ -168,6 +179,10 @@ top:
 		if (tape < 0)
 			goto ioerror;
 		block = 0;
+		{
+		struct mtget mt_stat;
+		magtape = ioctl(tape, MTIOCGET, (char *)&mt_stat) == 0;
+		}
 		goto respond;
 
 	case 'C':
@@ -179,11 +194,77 @@ top:
 		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;
@@ -191,6 +272,8 @@ top:
 	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) {
@@ -200,7 +283,13 @@ top:
 				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;
@@ -214,9 +303,17 @@ top:
 		rval = read(tape, record, n);
 		if (rval < 0)
 			goto ioerror;
+#ifdef ERMT
+		if ((cp = cipher(record, rval, 0)) == NULL)
+			goto ioerror;
+#else
+		cp = record;
+#endif
 		(void)sprintf(resp, "A%lld\n", (long long)rval);
-		(void)write(1, resp, strlen(resp));
-		(void)write(1, record, rval);
+		if (write(1, resp, strlen(resp)) != strlen(resp))
+			goto ioerror;
+		if (write(1, cp, rval) != rval)
+			goto ioerror;
 		block += n >> 10;
 		goto top;
 
@@ -232,7 +329,7 @@ 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:
@@ -273,6 +370,21 @@ top:
 					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) {
@@ -285,8 +397,9 @@ top:
 				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;
@@ -333,8 +446,9 @@ top:
 				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;
 
@@ -344,12 +458,37 @@ top:
 	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%lld\n", (long long)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;
 		}
 
@@ -357,11 +496,15 @@ 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:
@@ -396,11 +539,11 @@ top:
 		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);
@@ -409,19 +552,20 @@ top:
 respond:
 	DEBUG1("rmtd: A %lld\n", (long long)rval);
 	(void)sprintf(resp, "A%lld\n", (long long)rval);
-	(void)write(1, resp, strlen(resp));
+	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')
@@ -430,7 +574,7 @@ void getstring(char *bp)
 	cp[i] = '\0';
 }
 
-char *
+static char *
 checkbuf(char *record, int size)
 {
 
@@ -450,11 +594,30 @@ 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);
 }