minix/commands/talkd/net.c

189 lines
4.7 KiB
C
Raw Normal View History

2005-04-21 16:53:53 +02:00
/* net.c Copyright Michael Temari 07/22/1996 All Rights Reserved */
#include <sys/types.h>
#include <sys/ioctl.h>
#include <stdio.h>
#include <stdlib.h>
#include <fcntl.h>
#include <string.h>
#include <unistd.h>
#include <errno.h>
#include <net/netlib.h>
#include <net/hton.h>
#include <net/gen/netdb.h>
#include <net/gen/in.h>
#include <net/gen/udp.h>
#include <net/gen/udp_io.h>
#include <net/gen/udp_hdr.h>
#include "talk.h"
#include "talkd.h"
#include "net.h"
static unsigned char buffer[8192];
static int udp_in;
static int udp_out;
static udpport_t ntalk_port;
int NetInit()
{
int s;
struct servent *servent;
char *udp_device;
nwio_udpopt_t udpopt;
if((udp_device = getenv("UDP_DEVICE")) == (char *)NULL)
udp_device = UDP_DEVICE;
if((udp_in = open(udp_device, O_RDWR)) < 0) {
fprintf(stderr, "talkd: Could not open %s: %s\n",
udp_device, strerror(errno));
return(-1);
}
if((udp_out = open(udp_device, O_RDWR)) < 0) {
fprintf(stderr, "talkd: Could not open %s: %s\n",
udp_device, strerror(errno));
close(udp_in);
return(-1);
}
if((servent = getservbyname("ntalk", "udp")) == (struct servent *)NULL) {
fprintf(stderr, "talkd: Could not find ntalk udp service\n");
close(udp_in);
close(udp_out);
return(-1);
}
ntalk_port = (udpport_t)servent->s_port;
udpopt.nwuo_flags = NWUO_NOFLAGS;
udpopt.nwuo_flags |= NWUO_COPY | NWUO_LP_SET | NWUO_EN_LOC;
udpopt.nwuo_flags |= NWUO_DI_BROAD | NWUO_RP_ANY | NWUO_RA_ANY;
udpopt.nwuo_flags |= NWUO_RWDATALL | NWUO_DI_IPOPT;
udpopt.nwuo_locport = ntalk_port;
s = ioctl(udp_in, NWIOSUDPOPT, &udpopt);
if(s < 0) {
perror("talkd: ioctl NWIOSUDPOPT");
close(udp_in);
close(udp_out);
return(-1);
}
s = ioctl(udp_in, NWIOGUDPOPT, &udpopt);
if(s < 0) {
perror("talkd: ioctl NWIOGUDPOPT");
close(udp_in);
close(udp_out);
return(-1);
}
return(0);
}
int getrequest(request)
struct talk_request *request;
{
int s;
udp_io_hdr_t *udp_io_hdr;
s = read(udp_in, buffer, sizeof(buffer));
if(s < 0) {
perror("talkd: Read error in getrequest");
return(-1);
}
if(s < sizeof(udp_io_hdr_t)) {
fprintf(stderr, "talkd: Packet size read %d is smaller the udp_io_hdr\n", s);
return(-1);
}
udp_io_hdr = (udp_io_hdr_t *)buffer;
s = s - sizeof(udp_io_hdr_t);
/* why is uih_data_len already in host order??? */
if(udp_io_hdr->uih_data_len != s) {
fprintf(stderr, "talkd: Size mismatch Packet %d Udp Data %d\n",
s, udp_io_hdr->uih_data_len);
return(-1);
}
if(s != sizeof(struct talk_request)) {
fprintf(stderr, "talkd: Size mismatch in request %d %d\n",
s, sizeof(struct talk_request));
return(-1);
}
memcpy((char *)request, buffer + sizeof(udp_io_hdr_t), s);
if(opt_d) {
fprintf(stderr, "Request: ");
fprintf(stderr, "%02x %02x %02x %02x ",
request->version, request->type, request->answer, request->junk);
fprintf(stderr, "%08lx ", request->id);
fprintf(stderr, "%04x %08lx:%04x\n",
request->addr.sa_family, request->addr.sin_addr, request->addr.sin_port);
fprintf(stderr, " %08lx ", request->pid);
fprintf(stderr, "%04x %08lx:%04x\n",
request->ctl_addr.sa_family, request->ctl_addr.sin_addr, request->ctl_addr.sin_port);
fprintf(stderr, " %-12.12s %-12.12s %-16.16s\n",
request->luser, request->ruser, request->rtty);
}
return(0);
}
int sendreply(request, reply)
struct talk_request *request;
struct talk_reply *reply;
{
int s;
nwio_udpopt_t udpopt;
udp_io_hdr_t *udp_io_hdr;
udpopt.nwuo_flags = NWUO_NOFLAGS;
udpopt.nwuo_flags |= NWUO_COPY | NWUO_LP_SET | NWUO_EN_LOC;
udpopt.nwuo_flags |= NWUO_DI_BROAD | NWUO_RP_SET | NWUO_RA_SET;
udpopt.nwuo_flags |= NWUO_RWDATONLY | NWUO_DI_IPOPT;
udpopt.nwuo_locport = ntalk_port;
udpopt.nwuo_remaddr = request->ctl_addr.sin_addr;
udpopt.nwuo_remport = request->ctl_addr.sin_port;
s = ioctl(udp_out, NWIOSUDPOPT, &udpopt);
if(s < 0) {
perror("talkd: ioctl NWIOSUDPOPT");
return(-1);
}
s = ioctl(udp_out, NWIOGUDPOPT, &udpopt);
if(s < 0) {
perror("talkd: ioctl NWIOGUDPOPT");
return(-1);
}
if(opt_d) {
fprintf(stderr, "Reply: ");
fprintf(stderr, "%02x %02x %02x %02x ",
reply->version, reply->type, reply->answer, reply->junk);
fprintf(stderr, "%08lx ", reply->id);
fprintf(stderr, "%04x %08lx:%04x",
reply->addr.sa_family, reply->addr.sin_addr, reply->addr.sin_port);
fprintf(stderr, "\n");
}
s = write(udp_out, reply, sizeof(struct talk_reply));
if(s < 0) {
perror("talkd: write");
return(-1);
}
if(s != sizeof(struct talk_reply)) {
fprintf(stderr, "talkd: write size mismatch %d %d\n",
s, sizeof(struct talk_reply));
return(-1);
}
return(0);
}