Add readine-like behaviour for \x17, \x04 in input layer.
[screen-lua.git] / src / window.c
bloba244bd4f059deb17f463baff426c08c670653e04
1 /* Copyright (c) 1993-2002
2 * Juergen Weigert (jnweiger@immd4.informatik.uni-erlangen.de)
3 * Michael Schroeder (mlschroe@immd4.informatik.uni-erlangen.de)
4 * Copyright (c) 1987 Oliver Laumann
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2, or (at your option)
9 * any later version.
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
16 * You should have received a copy of the GNU General Public License
17 * along with this program (see the file COPYING); if not, write to the
18 * Free Software Foundation, Inc.,
19 * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA
21 ****************************************************************
24 #include <sys/types.h>
25 #include <sys/stat.h>
26 #include <signal.h>
27 #include <fcntl.h>
28 #ifndef sun
29 # include <sys/ioctl.h>
30 #endif
32 #include "config.h"
34 #include "screen.h"
35 #include "extern.h"
36 #include "logfile.h" /* logfopen() */
38 extern struct display *displays, *display;
39 extern struct win *windows, *fore, *wtab[], *console_window;
40 extern char *ShellArgs[];
41 extern char *ShellProg;
42 extern char screenterm[];
43 extern char *screenlogfile;
44 extern char HostName[];
45 extern int TtyMode;
46 extern int SilenceWait;
47 extern int real_uid, real_gid, eff_uid, eff_gid;
48 extern char Termcap[];
49 extern char **NewEnv;
50 extern int visual_bell, maxwin;
51 extern struct event logflushev;
52 extern int log_flush, logtstamp_after;
53 extern int ZombieKey_destroy, ZombieKey_resurrect, ZombieKey_onerror;
54 extern struct layer *flayer;
55 extern int maxusercount;
56 extern int pty_preopen;
57 #ifdef ZMODEM
58 extern int zmodem_mode;
59 extern struct mchar mchar_blank;
60 extern char *zmodem_sendcmd;
61 extern char *zmodem_recvcmd;
62 #endif
64 #if defined(TIOCSWINSZ) || defined(TIOCGWINSZ)
65 extern struct winsize glwz;
66 #endif
68 #ifdef O_NOCTTY
69 extern int separate_sids;
70 #endif
72 static void WinProcess __P((char **, int *));
73 static void WinRedisplayLine __P((int, int, int, int));
74 static void WinClearLine __P((int, int, int, int));
75 static int WinRewrite __P((int, int, int, struct mchar *, int));
76 static int WinResize __P((int, int));
77 static void WinRestore __P((void));
78 static int DoAutolf __P((char *, int *, int));
79 static void ZombieProcess __P((char **, int *));
80 static void win_readev_fn __P((struct event *, char *));
81 static void win_writeev_fn __P((struct event *, char *));
82 static int muchpending __P((struct win *, struct event *));
83 #ifdef COPY_PASTE
84 static void paste_slowev_fn __P((struct event *, char *));
85 #endif
86 #ifdef PSEUDOS
87 static void pseu_readev_fn __P((struct event *, char *));
88 static void pseu_writeev_fn __P((struct event *, char *));
89 #endif
90 static void win_silenceev_fn __P((struct event *, char *));
92 static int OpenDevice __P((char **, int, int *, char **));
93 static int ForkWindow __P((struct win *, char **, char *));
94 #ifdef ZMODEM
95 static void zmodem_found __P((struct win *, int, char *, int));
96 static void zmodem_fin __P((char *, int, char *));
97 static int zmodem_parse __P((struct win *, char *, int));
98 #endif
102 int VerboseCreate = 0; /* XXX move this to user.h */
104 char DefaultShell[] = "/bin/sh";
105 static char DefaultPath[] = ":/usr/ucb:/bin:/usr/bin";
107 /* keep this in sync with the structure definition in window.h */
108 struct NewWindow nwin_undef =
110 -1, /* StartAt */
111 (char *)0, /* aka */
112 (char **)0, /* args */
113 (char *)0, /* dir */
114 (char *)0, /* term */
115 -1, /* aflag */
116 -1, /* flowflag */
117 -1, /* lflag */
118 -1, /* histheight */
119 -1, /* monitor */
120 -1, /* wlock */
121 -1, /* silence */
122 -1, /* wrap */
123 -1, /* logging */
124 -1, /* slowpaste */
125 -1, /* gr */
126 -1, /* c1 */
127 -1, /* bce */
128 -1, /* encoding */
129 (char *)0, /* hstatus */
130 (char *)0 /* charset */
133 struct NewWindow nwin_default =
135 0, /* StartAt */
136 0, /* aka */
137 ShellArgs, /* args */
138 0, /* dir */
139 screenterm, /* term */
140 0, /* aflag */
141 1*FLOW_NOW, /* flowflag */
142 LOGINDEFAULT, /* lflag */
143 DEFAULTHISTHEIGHT, /* histheight */
144 MON_OFF, /* monitor */
145 WLOCK_OFF, /* wlock */
146 0, /* silence */
147 1, /* wrap */
148 0, /* logging */
149 0, /* slowpaste */
150 0, /* gr */
151 1, /* c1 */
152 0, /* bce */
153 0, /* encoding */
154 (char *)0, /* hstatus */
155 (char *)0 /* charset */
158 struct NewWindow nwin_options;
160 static int const_IOSIZE = IOSIZE;
161 static int const_one = 1;
163 void
164 nwin_compose(def, new, res)
165 struct NewWindow *def, *new, *res;
167 #define COMPOSE(x) res->x = new->x != nwin_undef.x ? new->x : def->x
168 COMPOSE(StartAt);
169 COMPOSE(aka);
170 COMPOSE(args);
171 COMPOSE(dir);
172 COMPOSE(term);
173 COMPOSE(aflag);
174 COMPOSE(flowflag);
175 COMPOSE(lflag);
176 COMPOSE(histheight);
177 COMPOSE(monitor);
178 COMPOSE(wlock);
179 COMPOSE(silence);
180 COMPOSE(wrap);
181 COMPOSE(Lflag);
182 COMPOSE(slow);
183 COMPOSE(gr);
184 COMPOSE(c1);
185 COMPOSE(bce);
186 COMPOSE(encoding);
187 COMPOSE(hstatus);
188 COMPOSE(charset);
189 #undef COMPOSE
192 /*****************************************************************
194 * The window layer functions
197 struct LayFuncs WinLf =
199 WinProcess,
201 WinRedisplayLine,
202 WinClearLine,
203 WinRewrite,
204 WinResize,
205 WinRestore
208 static int
209 DoAutolf(buf, lenp, fr)
210 char *buf;
211 int *lenp;
212 int fr;
214 char *p;
215 int len = *lenp;
216 int trunc = 0;
218 for (p = buf; len > 0; p++, len--)
220 if (*p != '\r')
221 continue;
222 if (fr-- <= 0)
224 trunc++;
225 len--;
227 if (len == 0)
228 break;
229 bcopy(p, p + 1, len++);
230 p[1] = '\n';
232 *lenp = p - buf;
233 return trunc;
236 static void
237 WinProcess(bufpp, lenp)
238 char **bufpp;
239 int *lenp;
241 int l2 = 0, f, *ilen, l = *lenp, trunc;
242 char *ibuf;
244 debug1("WinProcess: %d bytes\n", *lenp);
245 fore = (struct win *)flayer->l_data;
247 if (fore->w_type == W_TYPE_GROUP)
249 *bufpp += *lenp;
250 *lenp = 0;
251 return;
253 if (fore->w_ptyfd < 0) /* zombie? */
255 ZombieProcess(bufpp, lenp);
256 return;
258 #ifdef MULTIUSER
259 /* a pending writelock is this:
260 * fore->w_wlock == WLOCK_AUTO, fore->w_wlockuse = NULL
261 * The user who wants to use this window next, will get the lock, if he can.
263 if (display && fore->w_wlock == WLOCK_AUTO &&
264 !fore->w_wlockuser && !AclCheckPermWin(D_user, ACL_WRITE, fore))
266 fore->w_wlockuser = D_user;
267 debug2("window %d: pending writelock grabbed by user %s\n",
268 fore->w_number, fore->w_wlockuser->u_name);
270 /* if w_wlock is set, only one user may write, else we check acls */
271 if (display && ((fore->w_wlock == WLOCK_OFF) ?
272 AclCheckPermWin(D_user, ACL_WRITE, fore) :
273 (D_user != fore->w_wlockuser)))
275 debug2("window %d, user %s: ", fore->w_number, D_user->u_name);
276 debug2("writelock %d (wlockuser %s)\n", fore->w_wlock,
277 fore->w_wlockuser ? fore->w_wlockuser->u_name : "NULL");
278 /* XXX FIXME only display !*/
279 WBell(fore, visual_bell);
280 *bufpp += *lenp;
281 *lenp = 0;
282 return;
284 #endif /* MULTIUSER */
286 #ifdef BUILTIN_TELNET
287 if (fore->w_type == W_TYPE_TELNET && TelIsline(fore) && *bufpp != fore->w_telbuf)
289 TelProcessLine(bufpp, lenp);
290 return;
292 #endif
294 #ifdef PSEUDOS
295 if (W_UWP(fore))
297 /* we send the user input to our pseudowin */
298 ibuf = fore->w_pwin->p_inbuf; ilen = &fore->w_pwin->p_inlen;
299 f = sizeof(fore->w_pwin->p_inbuf) - *ilen;
301 else
302 #endif /* PSEUDOS */
304 /* we send the user input to the window */
305 ibuf = fore->w_inbuf; ilen = &fore->w_inlen;
306 f = sizeof(fore->w_inbuf) - *ilen;
309 if (l > f)
310 l = f;
311 #ifdef BUILTIN_TELNET
312 while (l > 0)
313 #else
314 if (l > 0)
315 #endif
317 l2 = l;
318 bcopy(*bufpp, ibuf + *ilen, l2);
319 if (fore->w_autolf && (trunc = DoAutolf(ibuf + *ilen, &l2, f - l2)))
320 l -= trunc;
321 #ifdef BUILTIN_TELNET
322 if (fore->w_type == W_TYPE_TELNET && (trunc = DoTelnet(ibuf + *ilen, &l2, f - l2)))
324 l -= trunc;
325 if (fore->w_autolf)
326 continue; /* need exact value */
328 #endif
329 *ilen += l2;
330 *bufpp += l;
331 *lenp -= l;
332 return;
336 static void
337 ZombieProcess(bufpp, lenp)
338 char **bufpp;
339 int *lenp;
341 int l = *lenp;
342 char *buf = *bufpp, b1[10], b2[10];
344 debug1("ZombieProcess: %d bytes\n", *lenp);
345 fore = (struct win *)flayer->l_data;
347 ASSERT(fore->w_ptyfd < 0);
348 *bufpp += *lenp;
349 *lenp = 0;
350 for (; l-- > 0; buf++)
352 if (*(unsigned char *)buf == ZombieKey_destroy)
354 debug1("Turning undead: %d\n", fore->w_number);
355 KillWindow(fore);
356 return;
358 if (*(unsigned char *)buf == ZombieKey_resurrect)
360 debug1("Resurrecting Zombie: %d\n", fore->w_number);
361 WriteString(fore, "\r\n", 2);
362 RemakeWindow(fore);
363 return;
366 b1[AddXChar(b1, ZombieKey_destroy)] = '\0';
367 b2[AddXChar(b2, ZombieKey_resurrect)] = '\0';
368 Msg(0, "Press %s to destroy or %s to resurrect window", b1, b2);
371 static void
372 WinRedisplayLine(y, from, to, isblank)
373 int y, from, to, isblank;
375 debug3("WinRedisplayLine %d %d %d\n", y, from, to);
376 if (y < 0)
377 return;
378 fore = (struct win *)flayer->l_data;
379 if (from == 0 && y > 0 && fore->w_mlines[y - 1].image[fore->w_width] == 0)
380 LCDisplayLineWrap(&fore->w_layer, &fore->w_mlines[y], y, from, to, isblank);
381 else
382 LCDisplayLine(&fore->w_layer, &fore->w_mlines[y], y, from, to, isblank);
385 static int
386 WinRewrite(y, x1, x2, rend, doit)
387 int y, x1, x2, doit;
388 struct mchar *rend;
390 register int cost, dx;
391 register unsigned char *p, *i;
392 #ifdef FONT
393 register unsigned char *f;
394 #endif
395 #ifdef COLOR
396 register unsigned char *c;
397 # ifdef COLORS256
398 register unsigned char *cx;
399 # endif
400 #endif
402 debug3("WinRewrite %d, %d-%d\n", y, x1, x2);
403 fore = (struct win *)flayer->l_data;
404 dx = x2 - x1 + 1;
405 if (doit)
407 i = fore->w_mlines[y].image + x1;
408 while (dx-- > 0)
409 PUTCHAR(*i++);
410 return 0;
412 p = fore->w_mlines[y].attr + x1;
413 #ifdef FONT
414 f = fore->w_mlines[y].font + x1;
415 # ifdef DW_CHARS
416 if (is_dw_font(rend->font))
417 return EXPENSIVE;
418 # endif
419 # ifdef UTF8
420 if (fore->w_encoding && fore->w_encoding != UTF8 && D_encoding == UTF8 && ContainsSpecialDeffont(fore->w_mlines + y, x1, x2, fore->w_encoding))
421 return EXPENSIVE;
422 # endif
423 #endif
424 #ifdef COLOR
425 c = fore->w_mlines[y].color + x1;
426 # ifdef COLORS256
427 cx = fore->w_mlines[y].colorx + x1;
428 # endif
429 #endif
431 cost = dx = x2 - x1 + 1;
432 while(dx-- > 0)
434 if (*p++ != rend->attr)
435 return EXPENSIVE;
436 #ifdef FONT
437 if (*f++ != rend->font)
438 return EXPENSIVE;
439 #endif
440 #ifdef COLOR
441 if (*c++ != rend->color)
442 return EXPENSIVE;
443 # ifdef COLORS256
444 if (*cx++ != rend->colorx)
445 return EXPENSIVE;
446 # endif
447 #endif
449 return cost;
452 static void
453 WinClearLine(y, xs, xe, bce)
454 int y, xs, xe, bce;
456 fore = (struct win *)flayer->l_data;
457 debug3("WinClearLine %d %d-%d\n", y, xs, xe);
458 LClearLine(flayer, y, xs, xe, bce, &fore->w_mlines[y]);
461 static int
462 WinResize(wi, he)
463 int wi, he;
465 fore = (struct win *)flayer->l_data;
466 ChangeWindowSize(fore, wi, he, fore->w_histheight);
467 return 0;
470 static void
471 WinRestore()
473 struct canvas *cv;
474 fore = (struct win *)flayer->l_data;
475 debug1("WinRestore: win %p\n", fore);
476 for (cv = flayer->l_cvlist; cv; cv = cv->c_next)
478 display = cv->c_display;
479 if (cv != D_forecv)
480 continue;
481 /* ChangeScrollRegion(fore->w_top, fore->w_bot); */
482 KeypadMode(fore->w_keypad);
483 CursorkeysMode(fore->w_cursorkeys);
484 SetFlow(fore->w_flow & FLOW_NOW);
485 InsertMode(fore->w_insert);
486 ReverseVideo(fore->w_revvid);
487 CursorVisibility(fore->w_curinv ? -1 : fore->w_curvvis);
488 MouseMode(fore->w_mouse);
492 /*****************************************************************/
496 * DoStartLog constructs a path for the "want to be logfile" in buf and
497 * attempts logfopen.
499 * returns 0 on success.
502 DoStartLog(w, buf, bufsize)
503 struct win *w;
504 char *buf;
505 int bufsize;
507 int n;
508 if (!w || !buf)
509 return -1;
511 strncpy(buf, MakeWinMsg(screenlogfile, w, '%'), bufsize - 1);
512 buf[bufsize - 1] = 0;
514 debug2("DoStartLog: win %d, file %s\n", w->w_number, buf);
516 if (w->w_log != NULL)
517 logfclose(w->w_log);
519 if ((w->w_log = logfopen(buf, islogfile(buf) ? NULL : secfopen(buf, "a"))) == NULL)
520 return -2;
521 if (!logflushev.queued)
523 n = log_flush ? log_flush : (logtstamp_after + 4) / 5;
524 if (n)
526 SetTimeout(&logflushev, n * 1000);
527 evenq(&logflushev);
530 return 0;
534 * Umask & wlock are set for the user of the display,
535 * The display d (if specified) switches to that window.
538 MakeWindow(newwin)
539 struct NewWindow *newwin;
541 register struct win **pp, *p;
542 register int n, i;
543 int f = -1;
544 struct NewWindow nwin;
545 int type, startat;
546 char *TtyName;
547 #ifdef MULTIUSER
548 extern struct acluser *users;
549 #endif
551 debug1("NewWindow: StartAt %d\n", newwin->StartAt);
552 debug1("NewWindow: aka %s\n", newwin->aka?newwin->aka:"NULL");
553 debug1("NewWindow: dir %s\n", newwin->dir?newwin->dir:"NULL");
554 debug1("NewWindow: term %s\n", newwin->term?newwin->term:"NULL");
556 nwin_compose(&nwin_default, newwin, &nwin);
557 debug1("NWin: aka %s\n", nwin.aka ? nwin.aka : "NULL");
558 debug1("NWin: wlock %d\n", nwin.wlock);
559 debug1("NWin: Lflag %d\n", nwin.Lflag);
561 startat = nwin.StartAt < maxwin ? nwin.StartAt : 0;
562 pp = wtab + startat;
566 if (*pp == 0)
567 break;
568 if (++pp == wtab + maxwin)
569 pp = wtab;
571 while (pp != wtab + startat);
572 if (*pp)
574 Msg(0, "No more windows.");
575 return -1;
578 #if defined(USRLIMIT) && defined(UTMPOK)
580 * Count current number of users, if logging windows in.
582 if (nwin.lflag && CountUsers() >= USRLIMIT)
584 Msg(0, "User limit reached. Window will not be logged in.");
585 nwin.lflag = 0;
587 #endif
588 n = pp - wtab;
589 debug1("Makewin creating %d\n", n);
591 if ((f = OpenDevice(nwin.args, nwin.lflag, &type, &TtyName)) < 0)
592 return -1;
593 if (type == W_TYPE_GROUP)
594 f = -1;
596 if ((p = (struct win *)malloc(sizeof(struct win))) == 0)
598 close(f);
599 Msg(0, strnomem);
600 return -1;
602 bzero((char *)p, (int)sizeof(struct win));
604 #ifdef UTMPOK
605 if (type != W_TYPE_PTY)
606 nwin.lflag = 0;
607 #endif
609 p->w_type = type;
611 /* save the command line so that zombies can be resurrected */
612 for (i = 0; nwin.args[i] && i < MAXARGS - 1; i++)
613 p->w_cmdargs[i] = SaveStr(nwin.args[i]);
614 p->w_cmdargs[i] = 0;
615 if (nwin.dir)
616 p->w_dir = SaveStr(nwin.dir);
617 if (nwin.term)
618 p->w_term = SaveStr(nwin.term);
620 p->w_number = n;
621 p->w_group = 0;
622 if (p->w_type != W_TYPE_GROUP && fore && fore->w_type == W_TYPE_GROUP)
623 p->w_group = fore;
624 else if (p->w_type != W_TYPE_GROUP && fore && fore->w_group)
625 p->w_group = fore->w_group;
626 #ifdef MULTIUSER
628 * This is dangerous: without a display we use creators umask
629 * This is intended to be usefull for detached startup.
630 * But is still better than default bits with a NULL user.
632 if (NewWindowAcl(p, display ? D_user : users))
634 free((char *)p);
635 close(f);
636 Msg(0, strnomem);
637 return -1;
639 #endif
640 p->w_layer.l_next = 0;
641 p->w_layer.l_bottom = &p->w_layer;
642 p->w_layer.l_layfn = &WinLf;
643 p->w_layer.l_data = (char *)p;
644 p->w_savelayer = &p->w_layer;
645 p->w_pdisplay = 0;
646 p->w_lastdisp = 0;
648 #ifdef MULTIUSER
649 if (display && !AclCheckPermWin(D_user, ACL_WRITE, p))
650 p->w_wlockuser = D_user;
651 p->w_wlock = nwin.wlock;
652 #endif
653 p->w_ptyfd = f;
654 p->w_aflag = nwin.aflag;
655 p->w_flow = nwin.flowflag | ((nwin.flowflag & FLOW_AUTOFLAG) ? (FLOW_AUTO|FLOW_NOW) : FLOW_AUTO);
656 if (!nwin.aka)
657 nwin.aka = Filename(nwin.args[0]);
658 strncpy(p->w_akabuf, nwin.aka, sizeof(p->w_akabuf) - 1);
659 if ((nwin.aka = rindex(p->w_akabuf, '|')) != NULL)
661 p->w_autoaka = 0;
662 *nwin.aka++ = 0;
663 p->w_title = nwin.aka;
664 p->w_akachange = nwin.aka + strlen(nwin.aka);
666 else
667 p->w_title = p->w_akachange = p->w_akabuf;
668 if (nwin.hstatus)
669 p->w_hstatus = SaveStr(nwin.hstatus);
670 p->w_monitor = nwin.monitor;
671 #ifdef MULTIUSER
672 if (p->w_monitor == MON_ON)
674 /* always tell all users */
675 for (i = 0; i < maxusercount; i++)
676 ACLBYTE(p->w_mon_notify, i) |= ACLBIT(i);
678 #endif
680 * defsilence by Lloyd Zusman (zusman_lloyd@jpmorgan.com)
682 p->w_silence = nwin.silence;
683 p->w_silencewait = SilenceWait;
684 #ifdef MULTIUSER
685 if (p->w_silence == SILENCE_ON)
687 /* always tell all users */
688 for (i = 0; i < maxusercount; i++)
689 ACLBYTE(p->w_lio_notify, i) |= ACLBIT(i);
691 #endif
692 #ifdef COPY_PASTE
693 p->w_slowpaste = nwin.slow;
694 #else
695 nwin.histheight = 0;
696 #endif
698 p->w_norefresh = 0;
699 strncpy(p->w_tty, TtyName, MAXSTR - 1);
701 #if 0
702 /* XXX Fixme display resize */
703 if (ChangeWindowSize(p, display ? D_defwidth : 80,
704 display ? D_defheight : 24,
705 nwin.histheight))
707 FreeWindow(p);
708 return -1;
710 #else
711 if (ChangeWindowSize(p, display ? D_forecv->c_xe - D_forecv->c_xs + 1: 80,
712 display ? D_forecv->c_ye - D_forecv->c_ys + 1 : 24,
713 nwin.histheight))
715 FreeWindow(p);
716 return -1;
718 #endif
720 p->w_encoding = nwin.encoding;
721 ResetWindow(p); /* sets w_wrap, w_c1, w_gr, w_bce */
723 #ifdef FONT
724 if (nwin.charset)
725 SetCharsets(p, nwin.charset);
726 #endif
728 if (VerboseCreate && type != W_TYPE_GROUP)
730 struct display *d = display; /* WriteString zaps display */
732 WriteString(p, ":screen (", 9);
733 WriteString(p, p->w_title, strlen(p->w_title));
734 WriteString(p, "):", 2);
735 for (f = 0; p->w_cmdargs[f]; f++)
737 WriteString(p, " ", 1);
738 WriteString(p, p->w_cmdargs[f], strlen(p->w_cmdargs[f]));
740 WriteString(p, "\r\n", 2);
741 display = d;
744 p->w_deadpid = 0;
745 p->w_pid = 0;
746 #ifdef PSEUDOS
747 p->w_pwin = 0;
748 #endif
750 #ifdef BUILTIN_TELNET
751 if (type == W_TYPE_TELNET)
753 if (TelConnect(p))
755 FreeWindow(p);
756 return -1;
759 else
760 #endif
761 if (type == W_TYPE_PTY)
763 p->w_pid = ForkWindow(p, nwin.args, TtyName);
764 if (p->w_pid < 0)
766 FreeWindow(p);
767 return -1;
772 * Place the new window at the head of the most-recently-used list.
774 if (display && D_fore)
775 D_other = D_fore;
776 *pp = p;
777 p->w_next = windows;
778 windows = p;
780 if (type == W_TYPE_GROUP)
782 SetForeWindow(p);
783 Activate(p->w_norefresh);
784 WindowChanged((struct win*)0, 'w');
785 WindowChanged((struct win*)0, 'W');
786 WindowChanged((struct win*)0, 0);
787 return n;
790 p->w_lflag = nwin.lflag;
791 #ifdef UTMPOK
792 p->w_slot = (slot_t)-1;
793 # ifdef LOGOUTOK
794 debug1("MakeWindow will %slog in.\n", nwin.lflag?"":"not ");
795 if (nwin.lflag & 1)
796 # else /* LOGOUTOK */
797 debug1("MakeWindow will log in, LOGOUTOK undefined in config.h%s.\n",
798 nwin.lflag?"":" (although lflag=0)");
799 # endif /* LOGOUTOK */
801 p->w_slot = (slot_t)0;
802 if (display || (p->w_lflag & 2))
803 SetUtmp(p);
805 # ifdef CAREFULUTMP
806 CarefulUtmp(); /* If all 've been zombies, we've had no slot */
807 # endif
808 #endif /* UTMPOK */
810 if (nwin.Lflag)
812 char buf[1024];
813 DoStartLog(p, buf, sizeof(buf));
816 p->w_readev.fd = p->w_writeev.fd = p->w_ptyfd;
817 p->w_readev.type = EV_READ;
818 p->w_writeev.type = EV_WRITE;
819 p->w_readev.data = p->w_writeev.data = (char *)p;
820 p->w_readev.handler = win_readev_fn;
821 p->w_writeev.handler = win_writeev_fn;
822 p->w_writeev.condpos = &p->w_inlen;
823 evenq(&p->w_readev);
824 evenq(&p->w_writeev);
825 #ifdef COPY_PASTE
826 p->w_paster.pa_slowev.type = EV_TIMEOUT;
827 p->w_paster.pa_slowev.data = (char *)&p->w_paster;
828 p->w_paster.pa_slowev.handler = paste_slowev_fn;
829 #endif
830 p->w_silenceev.type = EV_TIMEOUT;
831 p->w_silenceev.data = (char *)p;
832 p->w_silenceev.handler = win_silenceev_fn;
833 if (p->w_silence > 0)
835 debug("New window has silence enabled.\n");
836 SetTimeout(&p->w_silenceev, p->w_silencewait * 1000);
837 evenq(&p->w_silenceev);
840 SetForeWindow(p);
841 Activate(p->w_norefresh);
842 WindowChanged((struct win*)0, 'w');
843 WindowChanged((struct win*)0, 'W');
844 WindowChanged((struct win*)0, 0);
845 return n;
849 * Resurrect a window from Zombie state.
850 * The command vector is therefore stored in the window structure.
851 * Note: The terminaltype defaults to screenterm again, the current
852 * working directory is lost.
855 RemakeWindow(p)
856 struct win *p;
858 char *TtyName;
859 int lflag, f;
861 lflag = nwin_default.lflag;
862 if ((f = OpenDevice(p->w_cmdargs, lflag, &p->w_type, &TtyName)) < 0)
863 return -1;
865 strncpy(p->w_tty, *TtyName ? TtyName : p->w_title, MAXSTR - 1);
866 p->w_ptyfd = f;
867 p->w_readev.fd = f;
868 p->w_writeev.fd = f;
869 evenq(&p->w_readev);
870 evenq(&p->w_writeev);
872 if (VerboseCreate)
874 struct display *d = display; /* WriteString zaps display */
876 WriteString(p, ":screen (", 9);
877 WriteString(p, p->w_title, strlen(p->w_title));
878 WriteString(p, "):", 2);
879 for (f = 0; p->w_cmdargs[f]; f++)
881 WriteString(p, " ", 1);
882 WriteString(p, p->w_cmdargs[f], strlen(p->w_cmdargs[f]));
884 WriteString(p, "\r\n", 2);
885 display = d;
888 p->w_deadpid = 0;
889 p->w_pid = 0;
890 #ifdef BUILTIN_TELNET
891 if (p->w_type == W_TYPE_TELNET)
893 if (TelConnect(p))
894 return -1;
896 else
897 #endif
898 if (p->w_type == W_TYPE_PTY)
900 p->w_pid = ForkWindow(p, p->w_cmdargs, TtyName);
901 if (p->w_pid < 0)
902 return -1;
905 #ifdef UTMPOK
906 if (p->w_slot == (slot_t)0 && (display || (p->w_lflag & 2)))
907 SetUtmp(p);
908 # ifdef CAREFULUTMP
909 CarefulUtmp(); /* If all 've been zombies, we've had no slot */
910 # endif
911 #endif
912 WindowChanged(p, 'f');
913 return p->w_number;
916 void
917 CloseDevice(wp)
918 struct win *wp;
920 if (wp->w_ptyfd < 0)
921 return;
922 if (wp->w_type == W_TYPE_PTY)
924 /* pty 4 SALE */
925 (void)chmod(wp->w_tty, 0666);
926 (void)chown(wp->w_tty, 0, 0);
928 close(wp->w_ptyfd);
929 wp->w_ptyfd = -1;
930 wp->w_tty[0] = 0;
931 evdeq(&wp->w_readev);
932 evdeq(&wp->w_writeev);
933 #ifdef BUILTIN_TELNET
934 evdeq(&wp->w_telconnev);
935 #endif
936 wp->w_readev.fd = wp->w_writeev.fd = -1;
939 void
940 FreeWindow(wp)
941 struct win *wp;
943 struct display *d;
944 int i;
945 struct canvas *cv, *ncv;
946 struct layer *l;
948 debug1("FreeWindow %d\n", wp ? wp->w_number: -1);
949 #ifdef PSEUDOS
950 if (wp->w_pwin)
951 FreePseudowin(wp);
952 #endif
953 #ifdef UTMPOK
954 RemoveUtmp(wp);
955 #endif
956 CloseDevice(wp);
958 if (wp == console_window)
960 TtyGrabConsole(-1, -1, "free");
961 console_window = 0;
963 if (wp->w_log != NULL)
964 logfclose(wp->w_log);
965 ChangeWindowSize(wp, 0, 0, 0);
967 if (wp->w_hstatus)
968 free(wp->w_hstatus);
969 for (i = 0; wp->w_cmdargs[i]; i++)
970 free(wp->w_cmdargs[i]);
971 if (wp->w_dir)
972 free(wp->w_dir);
973 if (wp->w_term)
974 free(wp->w_term);
975 for (d = displays; d; d = d->d_next)
977 if (d->d_other == wp)
978 d->d_other = d->d_fore && d->d_fore->w_next != wp ? d->d_fore->w_next : wp->w_next;
979 if (d->d_fore == wp)
980 d->d_fore = NULL;
981 for (cv = d->d_cvlist; cv; cv = cv->c_next)
983 for (l = cv->c_layer; l; l = l->l_next)
984 if (l->l_layfn == &WinLf)
985 break;
986 if (!l)
987 continue;
988 if ((struct win *)l->l_data != wp)
989 continue;
990 if (cv->c_layer == wp->w_savelayer)
991 wp->w_savelayer = 0;
992 KillLayerChain(cv->c_layer);
995 if (wp->w_savelayer)
996 KillLayerChain(wp->w_savelayer);
997 for (cv = wp->w_layer.l_cvlist; cv; cv = ncv)
999 ncv = cv->c_lnext;
1000 cv->c_layer = &cv->c_blank;
1001 cv->c_blank.l_cvlist = cv;
1002 cv->c_lnext = 0;
1003 cv->c_xoff = cv->c_xs;
1004 cv->c_yoff = cv->c_ys;
1005 RethinkViewportOffsets(cv);
1007 wp->w_layer.l_cvlist = 0;
1008 if (flayer == &wp->w_layer)
1009 flayer = 0;
1011 #ifdef MULTIUSER
1012 FreeWindowAcl(wp);
1013 #endif /* MULTIUSER */
1014 evdeq(&wp->w_readev); /* just in case */
1015 evdeq(&wp->w_writeev); /* just in case */
1016 evdeq(&wp->w_silenceev);
1017 #ifdef COPY_PASTE
1018 FreePaster(&wp->w_paster);
1019 #endif
1020 free((char *)wp);
1023 static int
1024 OpenDevice(args, lflag, typep, namep)
1025 char **args;
1026 int lflag;
1027 int *typep;
1028 char **namep;
1030 char *arg = args[0];
1031 struct stat st;
1032 int f;
1034 if (!arg)
1035 return -1;
1036 if (strcmp(arg, "//group") == 0)
1038 *typep = W_TYPE_GROUP;
1039 *namep = "telnet";
1040 return 0;
1042 #ifdef BUILTIN_TELNET
1043 if (strcmp(arg, "//telnet") == 0)
1045 f = TelOpen(args + 1);
1046 lflag = 0;
1047 *typep = W_TYPE_TELNET;
1048 *namep = "telnet";
1050 else
1051 #endif
1052 if ((stat(arg, &st)) == 0 && S_ISCHR(st.st_mode))
1054 if (access(arg, R_OK | W_OK) == -1)
1056 Msg(errno, "Cannot access line '%s' for R/W", arg);
1057 return -1;
1059 debug("OpenDevice: OpenTTY\n");
1060 if ((f = OpenTTY(arg, args[1])) < 0)
1061 return -1;
1062 lflag = 0;
1063 *typep = W_TYPE_PLAIN;
1064 *namep = arg;
1066 else
1068 *typep = W_TYPE_PTY;
1069 f = OpenPTY(namep);
1070 if (f == -1)
1072 Msg(0, "No more PTYs.");
1073 return -1;
1075 #ifdef TIOCPKT
1077 int flag = 1;
1078 if (ioctl(f, TIOCPKT, (char *)&flag))
1080 Msg(errno, "TIOCPKT ioctl");
1081 close(f);
1082 return -1;
1085 #endif /* TIOCPKT */
1087 debug1("fcntl(%d, F_SETFL, FNBLOCK)\n", f);
1088 (void) fcntl(f, F_SETFL, FNBLOCK);
1089 #ifdef linux
1091 * Tenebreux (zeus@ns.acadiacom.net) has Linux 1.3.70 where select
1092 * gets confused in the following condition:
1093 * Open a pty-master side, request a flush on it, then set packet
1094 * mode and call select(). Select will return a possible read, where
1095 * the one byte response to the flush can be found. Select will
1096 * thereafter return a possible read, which yields I/O error.
1098 * If we request another flush *after* switching into packet mode,
1099 * this I/O error does not occur. We receive a single response byte
1100 * although we send two flush requests now.
1102 * Maybe we should not flush at all.
1104 * 10.5.96 jw.
1106 if (*typep == W_TYPE_PTY || *typep == W_TYPE_PLAIN)
1107 tcflush(f, TCIOFLUSH);
1108 #endif
1110 if (*typep != W_TYPE_PTY)
1111 return f;
1113 #ifndef PTYROFS
1114 #ifdef PTYGROUP
1115 if (chown(*namep, real_uid, PTYGROUP) && !eff_uid)
1116 #else
1117 if (chown(*namep, real_uid, real_gid) && !eff_uid)
1118 #endif
1120 Msg(errno, "chown tty");
1121 close(f);
1122 return -1;
1124 #ifdef UTMPOK
1125 if (chmod(*namep, lflag ? TtyMode : (TtyMode & ~022)) && !eff_uid)
1126 #else
1127 if (chmod(*namep, TtyMode) && !eff_uid)
1128 #endif
1130 Msg(errno, "chmod tty");
1131 close(f);
1132 return -1;
1134 #endif
1135 return f;
1139 * Fields w_width, w_height, aflag, number (and w_tty)
1140 * are read from struct win *win. No fields written.
1141 * If pwin is nonzero, filedescriptors are distributed
1142 * between win->w_tty and open(ttyn)
1145 static int
1146 ForkWindow(win, args, ttyn)
1147 struct win *win;
1148 char **args, *ttyn;
1150 int pid;
1151 char tebuf[25];
1152 char ebuf[20];
1153 char shellbuf[7 + MAXPATHLEN];
1154 char *proc;
1155 #ifndef TIOCSWINSZ
1156 char libuf[20], cobuf[20];
1157 #endif
1158 int newfd;
1159 int w = win->w_width;
1160 int h = win->w_height;
1161 #ifdef PSEUDOS
1162 int i, pat, wfdused;
1163 struct pseudowin *pwin = win->w_pwin;
1164 #endif
1165 int slave = -1;
1167 #ifdef O_NOCTTY
1168 if (pty_preopen)
1170 debug("pre-opening slave...\n");
1171 if ((slave = open(ttyn, O_RDWR|O_NOCTTY)) == -1)
1173 Msg(errno, "ttyn");
1174 return -1;
1177 #endif
1178 debug("forking...\n");
1179 proc = *args;
1180 if (proc == 0)
1182 args = ShellArgs;
1183 proc = *args;
1185 fflush(stdout);
1186 fflush(stderr);
1187 switch (pid = fork())
1189 case -1:
1190 Msg(errno, "fork");
1191 break;
1192 case 0:
1193 signal(SIGHUP, SIG_DFL);
1194 signal(SIGINT, SIG_DFL);
1195 signal(SIGQUIT, SIG_DFL);
1196 signal(SIGTERM, SIG_DFL);
1197 #ifdef BSDJOBS
1198 signal(SIGTTIN, SIG_DFL);
1199 signal(SIGTTOU, SIG_DFL);
1200 #endif
1201 #ifdef SIGPIPE
1202 signal(SIGPIPE, SIG_DFL);
1203 #endif
1204 #ifdef SIGXFSZ
1205 signal(SIGXFSZ, SIG_DFL);
1206 #endif
1208 displays = 0; /* beware of Panic() */
1209 if (setgid(real_gid) || setuid(real_uid))
1210 Panic(errno, "Setuid/gid");
1211 eff_uid = real_uid;
1212 eff_gid = real_gid;
1213 #ifdef PSEUDOS
1214 if (!pwin) /* ignore directory if pseudo */
1215 #endif
1216 if (win->w_dir && *win->w_dir && chdir(win->w_dir))
1217 Panic(errno, "Cannot chdir to %s", win->w_dir);
1219 if (display)
1221 brktty(D_userfd);
1222 freetty();
1224 else
1225 brktty(-1);
1226 #ifdef DEBUG
1227 if (dfp && dfp != stderr)
1228 fclose(dfp);
1229 #endif
1230 if (slave != -1)
1232 close(0);
1233 dup(slave);
1234 close(slave);
1235 closeallfiles(win->w_ptyfd);
1236 slave = dup(0);
1238 else
1239 closeallfiles(win->w_ptyfd);
1240 #ifdef DEBUG
1241 if (dfp) /* do not produce child debug, when debug is "off" */
1243 char buf[256];
1245 sprintf(buf, "%s/screen.child", DEBUGDIR);
1246 if ((dfp = fopen(buf, "a")) == 0)
1247 dfp = stderr;
1248 else
1249 (void) chmod(buf, 0666);
1251 debug1("=== ForkWindow: pid %d\n", (int)getpid());
1252 #endif
1253 /* Close the three /dev/null descriptors */
1254 close(0);
1255 close(1);
1256 close(2);
1257 newfd = -1;
1259 * distribute filedescriptors between the ttys
1261 #ifdef PSEUDOS
1262 pat = pwin ? pwin->p_fdpat :
1263 ((F_PFRONT<<(F_PSHIFT*2)) | (F_PFRONT<<F_PSHIFT) | F_PFRONT);
1264 debug1("Using window pattern 0x%x\n", pat);
1265 wfdused = 0;
1266 for(i = 0; i < 3; i++)
1268 if (pat & F_PFRONT << F_PSHIFT * i)
1270 if (newfd < 0)
1272 # ifdef O_NOCTTY
1273 if (separate_sids)
1274 newfd = open(ttyn, O_RDWR);
1275 else
1276 newfd = open(ttyn, O_RDWR|O_NOCTTY);
1277 # else
1278 newfd = open(ttyn, O_RDWR);
1279 # endif
1280 if (newfd < 0)
1281 Panic(errno, "Cannot open %s", ttyn);
1283 else
1284 dup(newfd);
1286 else
1288 dup(win->w_ptyfd);
1289 wfdused = 1;
1292 if (wfdused)
1295 * the pseudo window process should not be surprised with a
1296 * nonblocking filedescriptor. Poor Backend!
1298 debug1("Clearing NBLOCK on window-fd(%d)\n", win->w_ptyfd);
1299 if (fcntl(win->w_ptyfd, F_SETFL, 0))
1300 Msg(errno, "Warning: clear NBLOCK fcntl failed");
1302 #else /* PSEUDOS */
1303 # ifdef O_NOCTTY
1304 if (separate_sids)
1305 newfd = open(ttyn, O_RDWR);
1306 else
1307 newfd = open(ttyn, O_RDWR|O_NOCTTY);
1308 # else
1309 newfd = open(ttyn, O_RDWR);
1310 # endif
1311 if (newfd != 0)
1312 Panic(errno, "Cannot open %s", ttyn);
1313 dup(0);
1314 dup(0);
1315 #endif /* PSEUDOS */
1316 close(win->w_ptyfd);
1317 if (slave != -1)
1318 close(slave);
1319 if (newfd >= 0)
1321 struct mode fakemode, *modep;
1322 InitPTY(newfd);
1323 if (fgtty(newfd))
1324 Msg(errno, "fgtty");
1325 if (display)
1327 debug("ForkWindow: using display tty mode for new child.\n");
1328 modep = &D_OldMode;
1330 else
1332 debug("No display - creating tty setting\n");
1333 modep = &fakemode;
1334 InitTTY(modep, 0);
1335 #ifdef DEBUG
1336 DebugTTY(modep);
1337 #endif
1339 /* We only want echo if the users input goes to the pseudo
1340 * and the pseudo's stdout is not send to the window.
1342 #ifdef PSEUDOS
1343 if (pwin && (!(pat & F_UWP) || (pat & F_PBACK << F_PSHIFT)))
1345 debug1("clearing echo on pseudywin fd (pat %x)\n", pat);
1346 # if defined(POSIX) || defined(TERMIO)
1347 modep->tio.c_lflag &= ~ECHO;
1348 modep->tio.c_iflag &= ~ICRNL;
1349 # else
1350 modep->m_ttyb.sg_flags &= ~ECHO;
1351 # endif
1353 #endif
1354 SetTTY(newfd, modep);
1355 #ifdef TIOCSWINSZ
1356 glwz.ws_col = w;
1357 glwz.ws_row = h;
1358 (void) ioctl(newfd, TIOCSWINSZ, (char *)&glwz);
1359 #endif
1360 /* Always turn off nonblocking mode */
1361 (void)fcntl(newfd, F_SETFL, 0);
1363 #ifndef TIOCSWINSZ
1364 sprintf(libuf, "LINES=%d", h);
1365 sprintf(cobuf, "COLUMNS=%d", w);
1366 NewEnv[5] = libuf;
1367 NewEnv[6] = cobuf;
1368 #endif
1369 #ifdef MAPKEYS
1370 NewEnv[2] = MakeTermcap(display == 0 || win->w_aflag);
1371 #else
1372 if (win->w_aflag)
1373 NewEnv[2] = MakeTermcap(1);
1374 else
1375 NewEnv[2] = Termcap;
1376 #endif
1377 strcpy(shellbuf, "SHELL=");
1378 strncpy(shellbuf + 6, ShellProg + (*ShellProg == '-'), sizeof(shellbuf) - 7);
1379 shellbuf[sizeof(shellbuf) - 1] = 0;
1380 NewEnv[4] = shellbuf;
1381 debug1("ForkWindow: NewEnv[4] = '%s'\n", shellbuf);
1382 if (win->w_term && *win->w_term && strcmp(screenterm, win->w_term) &&
1383 (strlen(win->w_term) < 20))
1385 char *s1, *s2, tl;
1387 sprintf(tebuf, "TERM=%s", win->w_term);
1388 debug2("Makewindow %d with %s\n", win->w_number, tebuf);
1389 tl = strlen(win->w_term);
1390 NewEnv[1] = tebuf;
1391 if ((s1 = index(NewEnv[2], '|')))
1393 if ((s2 = index(++s1, '|')))
1395 if (strlen(NewEnv[2]) - (s2 - s1) + tl < 1024)
1397 bcopy(s2, s1 + tl, strlen(s2) + 1);
1398 bcopy(win->w_term, s1, tl);
1403 sprintf(ebuf, "WINDOW=%d", win->w_number);
1404 NewEnv[3] = ebuf;
1406 if (*proc == '-')
1407 proc++;
1408 if (!*proc)
1409 proc = DefaultShell;
1410 debug1("calling execvpe %s\n", proc);
1411 execvpe(proc, args, NewEnv);
1412 debug1("exec error: %d\n", errno);
1413 Panic(errno, "Cannot exec '%s'", proc);
1414 default:
1415 break;
1417 if (slave != -1)
1418 close(slave);
1419 return pid;
1422 void
1423 execvpe(prog, args, env)
1424 char *prog, **args, **env;
1426 register char *path = NULL, *p;
1427 char buf[1024];
1428 char *shargs[MAXARGS + 1];
1429 register int i, eaccess = 0;
1431 if (rindex(prog, '/'))
1432 path = "";
1433 if (!path && !(path = getenv("PATH")))
1434 path = DefaultPath;
1437 for (p = buf; *path && *path != ':'; path++)
1438 if (p - buf < (int)sizeof(buf) - 2)
1439 *p++ = *path;
1440 if (p > buf)
1441 *p++ = '/';
1442 if (p - buf + strlen(prog) >= sizeof(buf) - 1)
1443 continue;
1444 strcpy(p, prog);
1445 execve(buf, args, env);
1446 switch (errno)
1448 case ENOEXEC:
1449 shargs[0] = DefaultShell;
1450 shargs[1] = buf;
1451 for (i = 1; (shargs[i + 1] = args[i]) != NULL; ++i)
1453 execve(DefaultShell, shargs, env);
1454 return;
1455 case EACCES:
1456 eaccess = 1;
1457 break;
1458 case ENOMEM:
1459 case E2BIG:
1460 case ETXTBSY:
1461 return;
1463 } while (*path++);
1464 if (eaccess)
1465 errno = EACCES;
1468 #ifdef PSEUDOS
1471 winexec(av)
1472 char **av;
1474 char **pp;
1475 char *p, *s, *t;
1476 int i, r = 0, l = 0;
1477 struct win *w;
1478 extern struct display *display;
1479 extern struct win *windows;
1480 struct pseudowin *pwin;
1481 int type;
1483 if ((w = display ? fore : windows) == NULL)
1484 return -1;
1485 if (!*av || w->w_pwin)
1487 Msg(0, "Filter running: %s", w->w_pwin ? w->w_pwin->p_cmd : "(none)");
1488 return -1;
1490 if (w->w_ptyfd < 0)
1492 Msg(0, "You feel dead inside.");
1493 return -1;
1495 if (!(pwin = (struct pseudowin *)malloc(sizeof(struct pseudowin))))
1497 Msg(0, strnomem);
1498 return -1;
1500 bzero((char *)pwin, (int)sizeof(*pwin));
1502 /* allow ^a:!!./ttytest as a short form for ^a:exec !.. ./ttytest */
1503 for (s = *av; *s == ' '; s++)
1505 for (p = s; *p == ':' || *p == '.' || *p == '!'; p++)
1507 if (*p != '|')
1508 while (*p && p > s && p[-1] == '.')
1509 p--;
1510 if (*p == '|')
1512 l = F_UWP;
1513 p++;
1515 if (*p)
1516 av[0] = p;
1517 else
1518 av++;
1520 t = pwin->p_cmd;
1521 for (i = 0; i < 3; i++)
1523 *t = (s < p) ? *s++ : '.';
1524 switch (*t++)
1526 case '.':
1527 case '|':
1528 l |= F_PFRONT << (i * F_PSHIFT);
1529 break;
1530 case '!':
1531 l |= F_PBACK << (i * F_PSHIFT);
1532 break;
1533 case ':':
1534 l |= F_PBOTH << (i * F_PSHIFT);
1535 break;
1539 if (l & F_UWP)
1541 *t++ = '|';
1542 if ((l & F_PMASK) == F_PFRONT)
1544 *pwin->p_cmd = '!';
1545 l ^= F_PFRONT | F_PBACK;
1548 if (!(l & F_PBACK))
1549 l |= F_UWP;
1550 *t++ = ' ';
1551 pwin->p_fdpat = l;
1552 debug1("winexec: '%#x'\n", pwin->p_fdpat);
1554 l = MAXSTR - 4;
1555 for (pp = av; *pp; pp++)
1557 p = *pp;
1558 while (*p && l-- > 0)
1559 *t++ = *p++;
1560 if (l <= 0)
1561 break;
1562 *t++ = ' ';
1564 *--t = '\0';
1565 debug1("%s\n", pwin->p_cmd);
1567 if ((pwin->p_ptyfd = OpenDevice(av, 0, &type, &t)) < 0)
1569 free((char *)pwin);
1570 return -1;
1572 strncpy(pwin->p_tty, t, MAXSTR - 1);
1573 w->w_pwin = pwin;
1574 if (type != W_TYPE_PTY)
1576 FreePseudowin(w);
1577 Msg(0, "Cannot only use commands as pseudo win.");
1578 return -1;
1580 if (!(pwin->p_fdpat & F_PFRONT))
1581 evdeq(&w->w_readev);
1582 #ifdef TIOCPKT
1584 int flag = 0;
1586 if (ioctl(pwin->p_ptyfd, TIOCPKT, (char *)&flag))
1588 Msg(errno, "TIOCPKT pwin ioctl");
1589 FreePseudowin(w);
1590 return -1;
1592 if (w->w_type == W_TYPE_PTY && !(pwin->p_fdpat & F_PFRONT))
1594 if (ioctl(w->w_ptyfd, TIOCPKT, (char *)&flag))
1596 Msg(errno, "TIOCPKT win ioctl");
1597 FreePseudowin(w);
1598 return -1;
1602 #endif /* TIOCPKT */
1604 pwin->p_readev.fd = pwin->p_writeev.fd = pwin->p_ptyfd;
1605 pwin->p_readev.type = EV_READ;
1606 pwin->p_writeev.type = EV_WRITE;
1607 pwin->p_readev.data = pwin->p_writeev.data = (char *)w;
1608 pwin->p_readev.handler = pseu_readev_fn;
1609 pwin->p_writeev.handler = pseu_writeev_fn;
1610 pwin->p_writeev.condpos = &pwin->p_inlen;
1611 if (pwin->p_fdpat & (F_PFRONT << F_PSHIFT * 2 | F_PFRONT << F_PSHIFT))
1612 evenq(&pwin->p_readev);
1613 evenq(&pwin->p_writeev);
1614 r = pwin->p_pid = ForkWindow(w, av, t);
1615 if (r < 0)
1616 FreePseudowin(w);
1617 return r;
1620 void
1621 FreePseudowin(w)
1622 struct win *w;
1624 struct pseudowin *pwin = w->w_pwin;
1626 ASSERT(pwin);
1627 if (fcntl(w->w_ptyfd, F_SETFL, FNBLOCK))
1628 Msg(errno, "Warning: FreePseudowin: NBLOCK fcntl failed");
1629 #ifdef TIOCPKT
1630 if (w->w_type == W_TYPE_PTY && !(pwin->p_fdpat & F_PFRONT))
1632 int flag = 1;
1633 if (ioctl(w->w_ptyfd, TIOCPKT, (char *)&flag))
1634 Msg(errno, "Warning: FreePseudowin: TIOCPKT win ioctl");
1636 #endif
1637 /* should be able to use CloseDevice() here */
1638 (void)chmod(pwin->p_tty, 0666);
1639 (void)chown(pwin->p_tty, 0, 0);
1640 if (pwin->p_ptyfd >= 0)
1641 close(pwin->p_ptyfd);
1642 evdeq(&pwin->p_readev);
1643 evdeq(&pwin->p_writeev);
1644 if (w->w_readev.condneg == &pwin->p_inlen)
1645 w->w_readev.condpos = w->w_readev.condneg = 0;
1646 evenq(&w->w_readev);
1647 free((char *)pwin);
1648 w->w_pwin = NULL;
1651 #endif /* PSEUDOS */
1654 #ifdef MULTIUSER
1656 * returns 0, if the lock really has been released
1659 ReleaseAutoWritelock(dis, w)
1660 struct display *dis;
1661 struct win *w;
1663 debug2("ReleaseAutoWritelock: user %s, window %d\n",
1664 dis->d_user->u_name, w->w_number);
1666 /* release auto writelock when user has no other display here */
1667 if (w->w_wlock == WLOCK_AUTO && w->w_wlockuser == dis->d_user)
1669 struct display *d;
1671 for (d = displays; d; d = d->d_next)
1672 if (( d != dis) && (d->d_fore == w) && (d->d_user == dis->d_user))
1673 break;
1674 debug3("%s %s autolock on win %d\n",
1675 dis->d_user->u_name, d ? "keeps" : "releases", w->w_number);
1676 if (!d)
1678 w->w_wlockuser = NULL;
1679 return 0;
1682 return 1;
1686 * returns 0, if the lock really could be obtained
1689 ObtainAutoWritelock(d, w)
1690 struct display *d;
1691 struct win *w;
1693 if ((w->w_wlock == WLOCK_AUTO) &&
1694 !AclCheckPermWin(d->d_user, ACL_WRITE, w) &&
1695 !w->w_wlockuser)
1697 debug2("%s obtained auto writelock for exported window %d\n",
1698 d->d_user->u_name, w->w_number);
1699 w->w_wlockuser = d->d_user;
1700 return 0;
1702 return 1;
1705 #endif /* MULTIUSER */
1709 /********************************************************************/
1711 #ifdef COPY_PASTE
1712 static void
1713 paste_slowev_fn(ev, data)
1714 struct event *ev;
1715 char *data;
1717 struct paster *pa = (struct paster *)data;
1718 struct win *p;
1720 int l = 1;
1721 flayer = pa->pa_pastelayer;
1722 if (!flayer)
1723 pa->pa_pastelen = 0;
1724 if (!pa->pa_pastelen)
1725 return;
1726 p = Layer2Window(flayer);
1727 DoProcess(p, &pa->pa_pasteptr, &l, pa);
1728 pa->pa_pastelen -= 1 - l;
1729 if (pa->pa_pastelen > 0)
1731 SetTimeout(&pa->pa_slowev, p->w_slowpaste);
1732 evenq(&pa->pa_slowev);
1735 #endif
1738 static int
1739 muchpending(p, ev)
1740 struct win *p;
1741 struct event *ev;
1743 struct canvas *cv;
1744 for (cv = p->w_layer.l_cvlist; cv; cv = cv->c_lnext)
1746 display = cv->c_display;
1747 if (D_status == STATUS_ON_WIN && !D_status_bell)
1749 /* wait 'til status is gone */
1750 debug("BLOCKING because of status\n");
1751 ev->condpos = &const_one;
1752 ev->condneg = &D_status;
1753 return 1;
1755 debug2("muchpending %s %d: ", D_usertty, D_blocked);
1756 debug3("%d %d %d\n", D_obufp - D_obuf, D_obufmax, D_blocked_fuzz);
1757 if (D_blocked)
1758 continue;
1759 if (D_obufp - D_obuf > D_obufmax + D_blocked_fuzz)
1761 if (D_nonblock == 0)
1763 debug1("obuf is full, stopping output to display %s\n", D_usertty);
1764 D_blocked = 1;
1765 continue;
1767 debug("BLOCKING because of full obuf\n");
1768 ev->condpos = &D_obuffree;
1769 ev->condneg = &D_obuflenmax;
1770 if (D_nonblock > 0 && !D_blockedev.queued)
1772 debug1("created timeout of %g secs\n", D_nonblock/1000.);
1773 SetTimeout(&D_blockedev, D_nonblock);
1774 evenq(&D_blockedev);
1776 return 1;
1779 return 0;
1782 static void
1783 win_readev_fn(ev, data)
1784 struct event *ev;
1785 char *data;
1787 struct win *p = (struct win *)data;
1788 char buf[IOSIZE], *bp;
1789 int size, len;
1790 #ifdef PSEUDOS
1791 int wtop;
1792 #endif
1794 bp = buf;
1795 size = IOSIZE;
1797 #ifdef PSEUDOS
1798 wtop = p->w_pwin && W_WTOP(p);
1799 if (wtop)
1801 ASSERT(sizeof(p->w_pwin->p_inbuf) == IOSIZE);
1802 size = IOSIZE - p->w_pwin->p_inlen;
1803 if (size <= 0)
1805 ev->condpos = &const_IOSIZE;
1806 ev->condneg = &p->w_pwin->p_inlen;
1807 return;
1810 #endif
1811 if (p->w_layer.l_cvlist && muchpending(p, ev))
1812 return;
1813 #ifdef ZMODEM
1814 if (!p->w_zdisplay)
1815 #endif
1816 if (p->w_blocked)
1818 ev->condpos = &const_one;
1819 ev->condneg = &p->w_blocked;
1820 return;
1822 if (ev->condpos)
1823 ev->condpos = ev->condneg = 0;
1825 if ((len = p->w_outlen))
1827 p->w_outlen = 0;
1828 WriteString(p, p->w_outbuf, len);
1829 return;
1832 debug1("going to read from window fd %d\n", ev->fd);
1833 if ((len = read(ev->fd, buf, size)) < 0)
1835 if (errno == EINTR || errno == EAGAIN)
1836 return;
1837 #if defined(EWOULDBLOCK) && (EWOULDBLOCK != EAGAIN)
1838 if (errno == EWOULDBLOCK)
1839 return;
1840 #endif
1841 debug2("Window %d: read error (errno %d) - killing window\n", p->w_number, errno);
1842 WindowDied(p, 0, 0);
1843 return;
1845 if (len == 0)
1847 debug1("Window %d: EOF - killing window\n", p->w_number);
1848 WindowDied(p, 0, 0);
1849 return;
1851 debug1(" -> %d bytes\n", len);
1852 #ifdef TIOCPKT
1853 if (p->w_type == W_TYPE_PTY)
1855 if (buf[0])
1857 debug1("PAKET %x\n", buf[0]);
1858 if (buf[0] & TIOCPKT_NOSTOP)
1859 WNewAutoFlow(p, 0);
1860 if (buf[0] & TIOCPKT_DOSTOP)
1861 WNewAutoFlow(p, 1);
1863 bp++;
1864 len--;
1866 #endif
1867 #ifdef BUILTIN_TELNET
1868 if (p->w_type == W_TYPE_TELNET)
1869 len = TelIn(p, bp, len, buf + sizeof(buf) - (bp + len));
1870 #endif
1871 if (len == 0)
1872 return;
1873 #ifdef ZMODEM
1874 if (zmodem_mode && zmodem_parse(p, bp, len))
1875 return;
1876 #endif
1877 #ifdef PSEUDOS
1878 if (wtop)
1880 debug("sending input to pwin\n");
1881 bcopy(bp, p->w_pwin->p_inbuf + p->w_pwin->p_inlen, len);
1882 p->w_pwin->p_inlen += len;
1884 #endif
1885 WriteString(p, bp, len);
1886 return;
1890 static void
1891 win_writeev_fn(ev, data)
1892 struct event *ev;
1893 char *data;
1895 struct win *p = (struct win *)data;
1896 int len;
1897 if (p->w_inlen)
1899 debug2("writing %d bytes to win %d\n", p->w_inlen, p->w_number);
1900 if ((len = write(ev->fd, p->w_inbuf, p->w_inlen)) <= 0)
1901 len = p->w_inlen; /* dead window */
1902 if ((p->w_inlen -= len))
1903 bcopy(p->w_inbuf + len, p->w_inbuf, p->w_inlen);
1905 #ifdef COPY_PASTE
1906 if (p->w_paster.pa_pastelen && !p->w_slowpaste)
1908 struct paster *pa = &p->w_paster;
1909 flayer = pa->pa_pastelayer;
1910 if (flayer)
1911 DoProcess(p, &pa->pa_pasteptr, &pa->pa_pastelen, pa);
1913 #endif
1914 return;
1919 #ifdef PSEUDOS
1921 static void
1922 pseu_readev_fn(ev, data)
1923 struct event *ev;
1924 char *data;
1926 struct win *p = (struct win *)data;
1927 char buf[IOSIZE];
1928 int size, ptow, len;
1930 size = IOSIZE;
1932 ptow = W_PTOW(p);
1933 if (ptow)
1935 ASSERT(sizeof(p->w_inbuf) == IOSIZE);
1936 size = IOSIZE - p->w_inlen;
1937 if (size <= 0)
1939 ev->condpos = &const_IOSIZE;
1940 ev->condneg = &p->w_inlen;
1941 return;
1944 if (p->w_layer.l_cvlist && muchpending(p, ev))
1945 return;
1946 if (p->w_blocked)
1948 ev->condpos = &const_one;
1949 ev->condneg = &p->w_blocked;
1950 return;
1952 if (ev->condpos)
1953 ev->condpos = ev->condneg = 0;
1955 if ((len = p->w_outlen))
1957 p->w_outlen = 0;
1958 WriteString(p, p->w_outbuf, len);
1959 return;
1962 if ((len = read(ev->fd, buf, size)) <= 0)
1964 if (errno == EINTR || errno == EAGAIN)
1965 return;
1966 #if defined(EWOULDBLOCK) && (EWOULDBLOCK != EAGAIN)
1967 if (errno == EWOULDBLOCK)
1968 return;
1969 #endif
1970 debug2("Window %d: pseudowin read error (errno %d) -- removing pseudowin\n", p->w_number, len ? errno : 0);
1971 FreePseudowin(p);
1972 return;
1974 /* no packet mode on pseudos! */
1975 if (ptow)
1977 bcopy(buf, p->w_inbuf + p->w_inlen, len);
1978 p->w_inlen += len;
1980 WriteString(p, buf, len);
1981 return;
1984 static void
1985 pseu_writeev_fn(ev, data)
1986 struct event *ev;
1987 char *data;
1989 struct win *p = (struct win *)data;
1990 struct pseudowin *pw = p->w_pwin;
1991 int len;
1993 ASSERT(pw);
1994 if (pw->p_inlen == 0)
1995 return;
1996 if ((len = write(ev->fd, pw->p_inbuf, pw->p_inlen)) <= 0)
1997 len = pw->p_inlen; /* dead pseudo */
1998 if ((p->w_pwin->p_inlen -= len))
1999 bcopy(p->w_pwin->p_inbuf + len, p->w_pwin->p_inbuf, p->w_pwin->p_inlen);
2003 #endif /* PSEUDOS */
2005 static void
2006 win_silenceev_fn(ev, data)
2007 struct event *ev;
2008 char *data;
2010 struct win *p = (struct win *)data;
2011 struct canvas *cv;
2012 debug1("FOUND silence win %d\n", p->w_number);
2013 for (display = displays; display; display = display->d_next)
2015 for (cv = D_cvlist; cv; cv = cv->c_next)
2016 if (cv->c_layer->l_bottom == &p->w_layer)
2017 break;
2018 if (cv)
2019 continue; /* user already sees window */
2020 #ifdef MULTIUSER
2021 if (!(ACLBYTE(p->w_lio_notify, D_user->u_id) & ACLBIT(D_user->u_id)))
2022 continue;
2023 #endif
2024 Msg(0, "Window %d: silence for %d seconds", p->w_number, p->w_silencewait);
2028 #ifdef ZMODEM
2030 static int
2031 zmodem_parse(p, bp, len)
2032 struct win *p;
2033 char *bp;
2034 int len;
2036 int i;
2037 char *b2 = bp;
2038 for (i = 0; i < len; i++, b2++)
2040 if (p->w_zauto == 0)
2042 for (; i < len; i++, b2++)
2043 if (*b2 == 030)
2044 break;
2045 if (i == len)
2046 break;
2047 if (i > 1 && b2[-1] == '*' && b2[-2] == '*')
2048 p->w_zauto = 3;
2049 continue;
2051 if (p->w_zauto > 5 || *b2 == "**\030B00"[p->w_zauto] || (p->w_zauto == 5 && *b2 == '1') || (p->w_zauto == 5 && p->w_zdisplay && *b2 == '8'))
2053 if (++p->w_zauto < 6)
2054 continue;
2055 if (p->w_zauto == 6)
2056 p->w_zauto = 0;
2057 if (!p->w_zdisplay)
2059 if (i > 6)
2060 WriteString(p, bp, i + 1 - 6);
2061 WriteString(p, "\r\n", 2);
2062 zmodem_found(p, *b2 == '1', b2 + 1, len - i - 1);
2063 return 1;
2065 else if (p->w_zauto == 7 || *b2 == '8')
2067 int se = p->w_zdisplay->d_blocked == 2 ? 'O' : '\212';
2068 for (; i < len; i++, b2++)
2069 if (*b2 == se)
2070 break;
2071 if (i < len)
2073 zmodem_abort(p, 0);
2074 D_blocked = 0;
2075 D_readev.condpos = D_readev.condneg = 0;
2076 while (len-- > 0)
2077 AddChar(*bp++);
2078 Flush();
2079 Activate(D_fore ? D_fore->w_norefresh : 0);
2080 return 1;
2082 p->w_zauto = 6;
2085 else
2086 p->w_zauto = *b2 == '*' ? (p->w_zauto == 2 ? 2 : 1) : 0;
2088 if (p->w_zauto == 0 && bp[len - 1] == '*')
2089 p->w_zauto = len > 1 && bp[len - 2] == '*' ? 2 : 1;
2090 if (p->w_zdisplay)
2092 display = p->w_zdisplay;
2093 while (len-- > 0)
2094 AddChar(*bp++);
2095 return 1;
2097 return 0;
2100 static void
2101 zmodem_fin(buf, len, data)
2102 char *buf;
2103 int len;
2104 char *data;
2106 char *s;
2107 int n;
2109 if (len)
2110 RcLine(buf, strlen(buf) + 1);
2111 else
2113 s = "\030\030\030\030\030\030\030\030\030\030";
2114 n = strlen(s);
2115 LayProcess(&s, &n);
2119 static void
2120 zmodem_found(p, send, bp, len)
2121 struct win *p;
2122 int send;
2123 char *bp;
2124 int len;
2126 char *s;
2127 int i, n;
2128 extern int zmodem_mode;
2130 /* check for abort sequence */
2131 n = 0;
2132 for (i = 0; i < len ; i++)
2133 if (bp[i] != 030)
2134 n = 0;
2135 else if (++n > 4)
2136 return;
2137 if (zmodem_mode == 3 || (zmodem_mode == 1 && p->w_type != W_TYPE_PLAIN))
2139 struct display *d, *olddisplay;
2141 olddisplay = display;
2142 d = p->w_lastdisp;
2143 if (!d || d->d_fore != p)
2144 for (d = displays; d; d = d->d_next)
2145 if (d->d_fore == p)
2146 break;
2147 if (!d && p->w_layer.l_cvlist)
2148 d = p->w_layer.l_cvlist->c_display;
2149 if (!d)
2150 d = displays;
2151 if (!d)
2152 return;
2153 display = d;
2154 RemoveStatus();
2155 p->w_zdisplay = display;
2156 D_blocked = 2 + send;
2157 flayer = &p->w_layer;
2158 ZmodemPage();
2159 display = d;
2160 evdeq(&D_blockedev);
2161 D_readev.condpos = &const_IOSIZE;
2162 D_readev.condneg = &p->w_inlen;
2163 ClearAll();
2164 GotoPos(0, 0);
2165 SetRendition(&mchar_blank);
2166 AddStr("Zmodem active\r\n\r\n");
2167 AddStr(send ? "**\030B01" : "**\030B00");
2168 while (len-- > 0)
2169 AddChar(*bp++);
2170 display = olddisplay;
2171 return;
2173 flayer = &p->w_layer;
2174 Input(":", 100, INP_COOKED, zmodem_fin, NULL, 0);
2175 s = send ? zmodem_sendcmd : zmodem_recvcmd;
2176 n = strlen(s);
2177 LayProcess(&s, &n);
2180 void
2181 zmodem_abort(p, d)
2182 struct win *p;
2183 struct display *d;
2185 struct display *olddisplay = display;
2186 struct layer *oldflayer = flayer;
2187 if (p)
2189 if (p->w_savelayer && p->w_savelayer->l_next)
2191 if (oldflayer == p->w_savelayer)
2192 oldflayer = flayer->l_next;
2193 flayer = p->w_savelayer;
2194 ExitOverlayPage();
2196 p->w_zdisplay = 0;
2197 p->w_zauto = 0;
2198 LRefreshAll(&p->w_layer, 0);
2200 if (d)
2202 display = d;
2203 D_blocked = 0;
2204 D_readev.condpos = D_readev.condneg = 0;
2205 Activate(D_fore ? D_fore->w_norefresh : 0);
2207 display = olddisplay;
2208 flayer = oldflayer;
2211 #endif