source: trunk/minix/commands/talk/proto.c@ 10

Last change on this file since 10 was 9, checked in by Mattia Monga, 13 years ago

Minix 3.1.2a

File size: 3.2 KB
Line 
1/* proto.c Copyright Michael Temari 08/01/1996 All Rights Reserved */
2
3#include <sys/types.h>
4#include <sys/stat.h>
5#include <stdio.h>
6#include <string.h>
7#include <unistd.h>
8#include <net/hton.h>
9#include <net/gen/socket.h>
10#include <net/gen/in.h>
11#include <net/gen/inet.h>
12#include <net/gen/tcp.h>
13#include <net/gen/udp.h>
14
15#include "talk.h"
16#include "proto.h"
17#include "net.h"
18#include "screen.h"
19
20_PROTOTYPE(static int TalkChk, (int gotreply, struct talk_reply *reply, char *msg));
21_PROTOTYPE(static int TalkTrans, (int type, long id, struct talk_reply *reply, int here));
22
23static char *AnswerMsgs[] = {
24 "Success",
25 "User Not Logged In",
26 "Failure",
27 "Remote Does Not Know who we are",
28 "User is not accepting calls",
29 "Are request was not know",
30 "Incorrect Version",
31 "Bad Address",
32 "Bad Control Address"
33};
34
35static int TalkChk(gotreply, reply, msg)
36int gotreply;
37struct talk_reply *reply;
38char *msg;
39{
40 if(!gotreply) {
41 ScreenMsg(msg);
42 return(-1);
43 }
44 if(reply->answer == SUCCESS) return(0);
45 if(reply->answer < (sizeof(AnswerMsgs) / sizeof(AnswerMsgs[0])))
46 ScreenMsg(AnswerMsgs[reply->answer]);
47 else
48 ScreenMsg("Bad Answer");
49
50 return(-1);
51}
52
53static int TalkTrans(type, id, reply, here)
54int type;
55long id;
56struct talk_reply *reply;
57int here;
58{
59struct talk_request request;
60int tries;
61int gotreply;
62
63 memset(&request, 0, sizeof(request));
64
65 request.version = TALK_VERSION;
66 request.type = type;
67 request.id = id;
68 request.addr.sa_family = htons(AF_INET);
69 request.addr.sin_port = dataport;
70 request.addr.sin_addr = laddr;
71 request.ctl_addr.sa_family = htons(AF_INET);
72 request.ctl_addr.sin_port = ctlport;
73 request.ctl_addr.sin_addr = laddr;
74 request.pid = getpid();
75 strncpy(request.luser, luser, USER_SIZE);
76 strncpy(request.ruser, ruser, USER_SIZE);
77 strncpy(request.rtty, rtty, TTY_SIZE);
78
79 tries = 0;
80 gotreply = 0;
81 while(!ScreenDone && tries++ < 3 && !gotreply) {
82 if(!sendrequest(&request, here))
83 if(!getreply(reply, 5))
84 gotreply = 1;
85 if(!gotreply) continue;
86 if(reply->version != request.version ||
87 reply->type != request.type)
88 gotreply = 0;
89 }
90 return(gotreply);
91}
92
93int TalkInit()
94{
95struct talk_reply reply;
96long id = 0;
97long rid;
98int s;
99int ring;
100char buff[32];
101
102 /* Check if someone was calling us */
103 ScreenMsg("Initiating Talk Protocol");
104
105 /* Check is someone was calling us */
106 s = TalkTrans(LOOK_UP, ++id, &reply, 0);
107
108 /* Someone was calling us */
109 if(s && reply.answer == SUCCESS) {
110 s = NetConnect(reply.addr.sin_port);
111 if(s == 1) {
112 ScreenMsg("Your party has hung up");
113 TalkTrans(DELETE, reply.id, &reply, 0);
114 }
115 return(s == 0 ? 0 : -1);
116 }
117
118 ScreenMsg("Ringing User");
119
120 ring = 0;
121 while(!ScreenDone && ring++ < 5) {
122 if(TalkChk(TalkTrans(ANNOUNCE, -1, &reply, 0),
123 &reply, "No response to are ring"))
124 return(-1);
125 rid = reply.id;
126 sprintf(buff, "Ring #%d", ring);
127 ScreenMsg(buff);
128 if(ring == 1) {
129 if(TalkChk(TalkTrans(LEAVE_INVITE, ++id, &reply, 1),
130 &reply, "Could not leave are invitaion locally"))
131 return(-1);
132 }
133 s = NetListen(RING_WAIT);
134 if(s <= 0) {
135 TalkTrans(DELETE, reply.id, &reply, 1);
136 TalkTrans(DELETE, rid, &reply, 0);
137 return(s);
138 }
139 }
140
141 return(-1);
142}
Note: See TracBrowser for help on using the repository browser.