102 lines
2.5 KiB
C
102 lines
2.5 KiB
C
/* This file is part of the Project Athena Zephyr Notification System.
|
|
* It contains the hostmanager <--> client interaction routines.
|
|
*
|
|
* Created by: David C. Jedlinsky
|
|
*
|
|
* $Id$
|
|
*
|
|
* Copyright (c) 1987 by the Massachusetts Institute of Technology.
|
|
* For copying and distribution information, see the file
|
|
* "mit-copyright.h".
|
|
*/
|
|
|
|
#include "zhm.h"
|
|
|
|
#ifndef lint
|
|
#ifndef SABER
|
|
static const char rcsid_hm_client_c[] = "$Id$";
|
|
#endif /* SABER */
|
|
#endif /* lint */
|
|
|
|
void transmission_tower(ZNotice_t *notice,
|
|
char *packet,
|
|
int pak_len)
|
|
{
|
|
ZNotice_t gack;
|
|
Code_t ret;
|
|
struct sockaddr_in gsin;
|
|
|
|
nclt++;
|
|
if (notice->z_kind == HMCTL) {
|
|
if (!strcmp(notice->z_opcode, CLIENT_FLUSH)) {
|
|
if (noflushflag)
|
|
syslog(LOG_INFO, "Client requested hm flush (disabled).");
|
|
else {
|
|
send_flush_notice(HM_FLUSH);
|
|
deactivated = 1;
|
|
}
|
|
} else if (!strcmp(notice->z_opcode, CLIENT_NEW_SERVER)) {
|
|
new_server((char *)NULL);
|
|
} else {
|
|
syslog (LOG_INFO, "Bad control notice from client.");
|
|
}
|
|
return;
|
|
} else {
|
|
if (notice->z_kind != UNSAFE) {
|
|
gack = *notice;
|
|
gack.z_kind = HMACK;
|
|
gack.z_message_len = 0;
|
|
gack.z_multinotice = "";
|
|
gsin = cli_sin;
|
|
gsin.sin_port = from.sin_port;
|
|
if (gack.z_port == 0)
|
|
gack.z_port = from.sin_port;
|
|
DPR2 ("Client Port = %u\n", ntohs(gack.z_port));
|
|
notice->z_port = gack.z_port;
|
|
if ((ret = ZSetDestAddr(&gsin)) != ZERR_NONE) {
|
|
Zperr(ret);
|
|
com_err("hm", ret, "setting destination");
|
|
}
|
|
/* Bounce ACK to library */
|
|
if ((ret = send_outgoing(&gack)) != ZERR_NONE) {
|
|
Zperr(ret);
|
|
com_err("hm", ret, "sending raw notice");
|
|
}
|
|
}
|
|
}
|
|
if (!no_server) {
|
|
DPR2 ("Server Port = %u\n", ntohs(serv_sin.sin_port));
|
|
if ((ret = ZSetDestAddr(&serv_sin)) != ZERR_NONE) {
|
|
Zperr(ret);
|
|
com_err("hm", ret, "setting destination");
|
|
}
|
|
if ((ret = ZSendPacket(packet, pak_len, 0)) != ZERR_NONE) {
|
|
Zperr(ret);
|
|
com_err("hm", ret, "while sending raw notice");
|
|
}
|
|
}
|
|
if (add_notice_to_queue(notice, packet, &gsin, pak_len) != ZERR_NONE)
|
|
syslog(LOG_INFO, "Hey! Insufficient memory to add notice to queue!");
|
|
}
|
|
|
|
Code_t
|
|
send_outgoing(ZNotice_t *notice)
|
|
{
|
|
Code_t retval;
|
|
char *packet;
|
|
int length;
|
|
|
|
if (!(packet = (char *) malloc((unsigned)sizeof(ZPacket_t))))
|
|
return(ENOMEM);
|
|
|
|
if ((retval = ZFormatSmallRawNotice(notice, packet, &length))
|
|
!= ZERR_NONE) {
|
|
free(packet);
|
|
return(retval);
|
|
}
|
|
retval = ZSendPacket(packet, length, 0);
|
|
free(packet);
|
|
return(retval);
|
|
}
|
|
|