/********************************************************************** * Copyright (c) Digital Equipment Corporation 1984, 1985, 1986. * * All Rights Reserved. * * Reference "/usr/src/COPYRIGHT" for applicable restrictions. * **********************************************************************/ static char *Sccsid = "@(#)announce.c 3.0 (ULTRIX-11) 4/22/86"; #include "ctl.h" #include <sys/stat.h> #include <sgtty.h> #include <sys/ioctl.h> #ifdef vax #include <sys/time.h> #else pdp11 #include <time.h> #endif vax #include <stdio.h> #ifdef vax #include <sys/wait.h> #endif vax #include <errno.h> #ifdef pdp11 #define announce_proc annXproc #endif pdp11 char *sprintf(); extern int errno; extern char hostname[]; int nofork = 0; /* to be set from the debugger */ /* * Because the tty driver insists on attaching a terminal-less * process to any terminal that it writes on, we must fork a child * to protect ourselves */ announce(request, remote_machine) CTL_MSG *request; char *remote_machine; { int pid, val, status; if (nofork) { return(announce_proc(request, remote_machine)); } if ( pid = fork() ) { /* we are the parent, so wait for the child */ if (pid == -1) { /* the fork failed */ return(FAILED); } do { val = wait(&status); if (val == -1) { if (errno == EINTR) { continue; } else { /* shouldn't happen */ print_error("wait"); return(FAILED); } } } while (val != pid); if (status&0377 > 0) { /* we were killed by some signal */ return(FAILED); } /* Get the second byte, this is the exit/return code */ return((status>>8)&0377); } else { /* we are the child, go and do it */ _exit(announce_proc(request, remote_machine)); } } /* See if the user is accepting messages. If so, announce that a talk is requested. */ announce_proc(request, remote_machine) CTL_MSG *request; char *remote_machine; { int pid, status; char full_tty[32]; FILE *tf; struct stat stbuf; (void) sprintf(full_tty, "/dev/%s", request->r_tty); if (access(full_tty, 0) != 0) { return(FAILED); } if ((tf = fopen(full_tty, "w")) == NULL) { return(PERMISSION_DENIED); } /* open gratuitously attaches the talkd to any tty it opens, so disconnect us from the tty before we catch a signal */ #ifdef vax ioctl(fileno(tf), TIOCNOTTY, (struct sgttyb *) 0); #else pdp11 zaptty(); #endif pdp11 if (fstat(fileno(tf), &stbuf) < 0) { return(PERMISSION_DENIED); } if ((stbuf.st_mode&02) == 0) { return(PERMISSION_DENIED); } print_mesg(tf, request, remote_machine); fclose(tf); return(SUCCESS); } #define max(a,b) ( (a) > (b) ? (a) : (b) ) #define N_LINES 5 #define N_CHARS 120 /* * build a block of characters containing the message. * It is sent blank filled and in a single block to * try to keep the message in one piece if the recipient * in in vi at the time */ print_mesg(tf, request, remote_machine) FILE *tf; CTL_MSG *request; char *remote_machine; { #ifdef vax struct timeval clock; struct timezone zone; #else pdp11 long clock; #endif struct tm *localtime(); struct tm *localclock; char line_buf[N_LINES][N_CHARS]; int sizes[N_LINES]; char big_buf[N_LINES*N_CHARS]; char *bptr, *lptr; int i, j, max_size; i = 0; max_size = 0; #ifdef vax gettimeofday(&clock, &zone); localclock = localtime( &clock.tv_sec ); #else pdp11 time(&clock); localclock = localtime(&clock); #endif sprintf(line_buf[i], " "); sizes[i] = strlen(line_buf[i]); max_size = max(max_size, sizes[i]); i++; sprintf(line_buf[i], "Message from Talk_Daemon@%s at %d:%02d ...", hostname, localclock->tm_hour , localclock->tm_min ); sizes[i] = strlen(line_buf[i]); max_size = max(max_size, sizes[i]); i++; sprintf(line_buf[i], "talk: connection requested by %s@%s.", request->l_name, remote_machine); sizes[i] = strlen(line_buf[i]); max_size = max(max_size, sizes[i]); i++; sprintf(line_buf[i], "talk: respond with: talk %s@%s", request->l_name, remote_machine); sizes[i] = strlen(line_buf[i]); max_size = max(max_size, sizes[i]); i++; sprintf(line_buf[i], " "); sizes[i] = strlen(line_buf[i]); max_size = max(max_size, sizes[i]); i++; bptr = big_buf; *(bptr++) = ''; /* send something to wake them up */ *(bptr++) = '\r'; /* add a \r in case of raw mode */ *(bptr++) = '\n'; for(i = 0; i < N_LINES; i++) { /* copy the line into the big buffer */ lptr = line_buf[i]; while (*lptr != '\0') { *(bptr++) = *(lptr++); } /* pad out the rest of the lines with blanks */ for(j = sizes[i]; j < max_size + 2; j++) { *(bptr++) = ' '; } *(bptr++) = '\r'; /* add a \r in case of raw mode */ *(bptr++) = '\n'; } *bptr = '\0'; fprintf(tf, "%s", big_buf); fflush(tf); #ifdef vax ioctl(fileno(tf), TIOCNOTTY, (struct sgttyb *) 0); #else pdp11 zaptty(); #endif }