3 * vmhsbr.c -- routines to help vmh along
10 * INI: include width of windows
17 static char *types[] = {
19 "INI", "ACK", "ERR", "CMD", "QRY", "TTY", "WIN", "DATA", "EOF", "FIN",
23 static FILE *fp = NULL;
25 static int PEERrfd = NOTOK;
26 static int PEERwfd = NOTOK;
31 static int rclose (struct record *, char *, ...);
35 rcinit (int rfd, int wfd)
37 char *cp, buffer[BUFSIZ];
42 if ((cp = getenv ("MHVDEBUG")) && *cp) {
43 snprintf (buffer, sizeof(buffer), "%s.out", invo_name);
44 if ((fp = fopen (buffer, "w"))) {
45 fseek (fp, 0L, SEEK_END);
46 fprintf (fp, "%d: rcinit (%d, %d)\n", (int) getpid(), rfd, wfd);
72 rc2rc (char code, int len, char *data, struct record *rc)
74 if (rc2peer (code, len, data) == NOTOK)
82 str2rc (char code, char *str, struct record *rc)
84 return rc2rc (code, str ? strlen (str) : 0, str, rc);
89 peer2rc (struct record *rc)
94 if (read (PEERrfd, (char *) rc_head (rc), RHSIZE (rc)) != RHSIZE (rc))
95 return rclose (rc, "read from peer lost(1)");
97 if ((rc->rc_data = malloc ((unsigned) rc->rc_len + 1)) == NULL)
98 return rclose (rc, "malloc of %d lost", rc->rc_len + 1);
99 if (read (PEERrfd, rc->rc_data, rc->rc_len) != rc->rc_len)
100 return rclose (rc, "read from peer lost(2)");
101 rc->rc_data[rc->rc_len] = 0;
107 fseek (fp, 0L, SEEK_END);
108 fprintf (fp, "%d: <--- %s %d: \"%*.*s\"\n", (int) getpid(),
109 types[rc->rc_type], rc->rc_len,
110 rc->rc_len, rc->rc_len, rc->rc_data);
119 rc2peer (char code, int len, char *data)
122 register struct record *rc = &rcs;
128 fseek (fp, 0L, SEEK_END);
129 fprintf (fp, "%d: ---> %s %d: \"%*.*s\"\n", (int) getpid(),
130 types[rc->rc_type], rc->rc_len,
131 rc->rc_len, rc->rc_len, data);
135 if (write (PEERwfd, (char *) rc_head (rc), RHSIZE (rc)) != RHSIZE (rc))
136 return rclose (rc, "write to peer lost(1)");
139 if (write (PEERwfd, data, rc->rc_len) != rc->rc_len)
140 return rclose (rc, "write to peer lost(2)");
147 str2peer (char code, char *str)
149 return rc2peer (code, str ? strlen (str) : 0, str);
154 fmt2peer (char code, char *fmt, ...)
159 return verr2peer (code, NULL, fmt, ap);
165 err2peer (char code, char *what, char *fmt, ...)
170 verr2peer(code, what, fmt, ap);
176 verr2peer (char code, char *what, char *fmt, va_list ap)
180 char *bp, *s, buffer[BUFSIZ * 2];
182 /* Get buffer ready to go */
184 buflen = sizeof(buffer);
186 vsnprintf (bp, buflen, fmt, ap);
193 snprintf (bp, buflen, " %s: ", what);
198 if ((s = strerror (eindex)))
199 strncpy (bp, s, buflen);
201 snprintf (bp, buflen, "unknown error %d", eindex);
207 return rc2peer (code, bp - buffer, buffer);
212 rclose (struct record *rc, char *fmt, ...)
215 static char buffer[BUFSIZ * 2];
218 vsnprintf (buffer, sizeof(buffer), fmt, ap);
221 rc->rc_len = strlen (rc->rc_data = getcpy (buffer));
222 return (rc->rc_type = RC_XXX);