home *** CD-ROM | disk | FTP | other *** search
/ InfoMagic Source Code 1993 July / THE_SOURCE_CODE_CD_ROM.iso / bsd_srcs / usr.bin / talk / invite.c < prev    next >
Encoding:
C/C++ Source or Header  |  1991-04-18  |  5.9 KB  |  189 lines
  1. /*
  2.  * Copyright (c) 1983 Regents of the University of California.
  3.  * All rights reserved.
  4.  *
  5.  * Redistribution and use in source and binary forms, with or without
  6.  * modification, are permitted provided that the following conditions
  7.  * are met:
  8.  * 1. Redistributions of source code must retain the above copyright
  9.  *    notice, this list of conditions and the following disclaimer.
  10.  * 2. Redistributions in binary form must reproduce the above copyright
  11.  *    notice, this list of conditions and the following disclaimer in the
  12.  *    documentation and/or other materials provided with the distribution.
  13.  * 3. All advertising materials mentioning features or use of this software
  14.  *    must display the following acknowledgement:
  15.  *    This product includes software developed by the University of
  16.  *    California, Berkeley and its contributors.
  17.  * 4. Neither the name of the University nor the names of its contributors
  18.  *    may be used to endorse or promote products derived from this software
  19.  *    without specific prior written permission.
  20.  *
  21.  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  22.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  23.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  24.  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  25.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  26.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  27.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  28.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  29.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  30.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  31.  * SUCH DAMAGE.
  32.  */
  33.  
  34. #ifndef lint
  35. static char sccsid[] = "@(#)invite.c    5.8 (Berkeley) 3/1/91";
  36. #endif /* not lint */
  37.  
  38. #include <sys/types.h>
  39. #include <sys/socket.h>
  40. #include <sys/time.h>
  41. #include <signal.h>
  42. #include <netinet/in.h>
  43. #include <protocols/talkd.h>
  44. #include <errno.h>
  45. #include <setjmp.h>
  46. #include "talk_ctl.h"
  47. #include "talk.h"
  48.  
  49. /*
  50.  * There wasn't an invitation waiting, so send a request containing
  51.  * our sockt address to the remote talk daemon so it can invite
  52.  * him 
  53.  */
  54.  
  55. /*
  56.  * The msg.id's for the invitations
  57.  * on the local and remote machines.
  58.  * These are used to delete the 
  59.  * invitations.
  60.  */
  61. int    local_id, remote_id;
  62. void    re_invite();
  63. jmp_buf invitebuf;
  64.  
  65. invite_remote()
  66. {
  67.     int nfd, read_mask, template, new_sockt;
  68.     struct itimerval itimer;
  69.     CTL_RESPONSE response;
  70.  
  71.     itimer.it_value.tv_sec = RING_WAIT;
  72.     itimer.it_value.tv_usec = 0;
  73.     itimer.it_interval = itimer.it_value;
  74.     if (listen(sockt, 5) != 0)
  75.         p_error("Error on attempt to listen for caller");
  76. #ifdef MSG_EOR
  77.     /* copy new style sockaddr to old, swap family (short in old) */
  78.     msg.addr = *(struct osockaddr *)&my_addr;  /* XXX new to old  style*/
  79.     msg.addr.sa_family = htons(my_addr.sin_family);
  80. #else
  81.     msg.addr = *(struct sockaddr *)&my_addr;
  82. #endif
  83.     msg.id_num = htonl(-1);        /* an impossible id_num */
  84.     invitation_waiting = 1;
  85.     announce_invite();
  86.     /*
  87.      * Shut off the automatic messages for a while,
  88.      * so we can use the interupt timer to resend the invitation
  89.      */
  90.     end_msgs();
  91.     setitimer(ITIMER_REAL, &itimer, (struct itimerval *)0);
  92.     message("Waiting for your party to respond");
  93.     signal(SIGALRM, re_invite);
  94.     (void) setjmp(invitebuf);
  95.     while ((new_sockt = accept(sockt, 0, 0)) < 0) {
  96.         if (errno == EINTR)
  97.             continue;
  98.         p_error("Unable to connect with your party");
  99.     }
  100.     close(sockt);
  101.     sockt = new_sockt;
  102.  
  103.     /*
  104.      * Have the daemons delete the invitations now that we
  105.      * have connected.
  106.      */
  107.     current_state = "Waiting for your party to respond";
  108.     start_msgs();
  109.  
  110.     msg.id_num = htonl(local_id);
  111.     ctl_transact(my_machine_addr, msg, DELETE, &response);
  112.     msg.id_num = htonl(remote_id);
  113.     ctl_transact(his_machine_addr, msg, DELETE, &response);
  114.     invitation_waiting = 0;
  115. }
  116.  
  117. /*
  118.  * Routine called on interupt to re-invite the callee
  119.  */
  120. void
  121. re_invite()
  122. {
  123.  
  124.     message("Ringing your party again");
  125.     current_line++;
  126.     /* force a re-announce */
  127.     msg.id_num = htonl(remote_id + 1);
  128.     announce_invite();
  129.     longjmp(invitebuf, 1);
  130. }
  131.  
  132. static    char *answers[] = {
  133.     "answer #0",                    /* SUCCESS */
  134.     "Your party is not logged on",            /* NOT_HERE */
  135.     "Target machine is too confused to talk to us",    /* FAILED */
  136.     "Target machine does not recognize us",        /* MACHINE_UNKNOWN */
  137.     "Your party is refusing messages",        /* PERMISSION_REFUSED */
  138.     "Target machine can not handle remote talk",    /* UNKNOWN_REQUEST */
  139.     "Target machine indicates protocol mismatch",    /* BADVERSION */
  140.     "Target machine indicates protocol botch (addr)",/* BADADDR */
  141.     "Target machine indicates protocol botch (ctl_addr)",/* BADCTLADDR */
  142. };
  143. #define    NANSWERS    (sizeof (answers) / sizeof (answers[0]))
  144.  
  145. /*
  146.  * Transmit the invitation and process the response
  147.  */
  148. announce_invite()
  149. {
  150.     CTL_RESPONSE response;
  151.  
  152.     current_state = "Trying to connect to your party's talk daemon";
  153.     ctl_transact(his_machine_addr, msg, ANNOUNCE, &response);
  154.     remote_id = response.id_num;
  155.     if (response.answer != SUCCESS) {
  156.         if (response.answer < NANSWERS)
  157.             message(answers[response.answer]);
  158.         quit();
  159.     }
  160.     /* leave the actual invitation on my talk daemon */
  161.     ctl_transact(my_machine_addr, msg, LEAVE_INVITE, &response);
  162.     local_id = response.id_num;
  163. }
  164.  
  165. /*
  166.  * Tell the daemon to remove your invitation
  167.  */
  168. send_delete()
  169. {
  170.  
  171.     msg.type = DELETE;
  172.     /*
  173.      * This is just a extra clean up, so just send it
  174.      * and don't wait for an answer
  175.      */
  176.     msg.id_num = htonl(remote_id);
  177.     daemon_addr.sin_addr = his_machine_addr;
  178.     if (sendto(ctl_sockt, &msg, sizeof (msg), 0,
  179.         (struct sockaddr *)&daemon_addr,
  180.         sizeof (daemon_addr)) != sizeof(msg))
  181.         perror("send_delete (remote)");
  182.     msg.id_num = htonl(local_id);
  183.     daemon_addr.sin_addr = my_machine_addr;
  184.     if (sendto(ctl_sockt, &msg, sizeof (msg), 0,
  185.         (struct sockaddr *)&daemon_addr,
  186.         sizeof (daemon_addr)) != sizeof (msg))
  187.         perror("send_delete (local)");
  188. }
  189.