rpld.c revision 50c83d09652262aba75a6182b3203c80b48b092b
/*
* CDDL HEADER START
*
* The contents of this file are subject to the terms of the
* Common Development and Distribution License, Version 1.0 only
* (the "License"). You may not use this file except in compliance
* with the License.
*
* You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
* or http://www.opensolaris.org/os/licensing.
* See the License for the specific language governing permissions
* and limitations under the License.
*
* When distributing Covered Code, include this CDDL HEADER in each
* file and include the License file at usr/src/OPENSOLARIS.LICENSE.
* If applicable, add the following below this CDDL HEADER, with the
* fields enclosed by brackets "[]" replaced with your own identifying
* information: Portions Copyright [yyyy] [name of copyright owner]
*
* CDDL HEADER END
*/
/*
* Copyright 2005 Sun Microsystems, Inc. All rights reserved.
* Use is subject to license terms.
*/
#pragma ident "%Z%%M% %I% %E% SMI"
#include <stdio.h>
#include <sys/signal.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <sys/stropts.h>
#include <sys/stream.h>
#include <poll.h>
#include <sys/dlpi.h>
#include "rpld.h"
/* Global run-time parameters */
char configFile[MAXPATHLEN] = {DFT_CONFIGFILE};
int debugLevel = DFT_DEBUGLEVEL;
int debugDest = DFT_DEBUGDEST;
int maxClients = DFT_MAXCLIENTS;
int backGround = DFT_BACKGROUND;
char logFile[MAXPATHLEN] = {DFT_LOGFILE};
unsigned long startDelay = DFT_STARTDELAY;
unsigned long delayGran = DFT_DELAYGRAN;
int frameSize = DFT_FRAMESIZE;
char ifName[MAXPATHLEN] = "";
int ifUnit = 0;
int ppanum = 1;
int need_llc = 0;
extern void dumpctl();
extern void dumpdata();
extern void sighuphdr();
extern void sigusr1hdr();
int goaround(void);
int if_fd; /* file descriptor for network interface name */
struct pollfd llc_fd; /* file descriptor for llc device */
FILE *log_str = NULL; /* file stream for log file */
char ctlbuf[100]; /* control buffer for incoming frame */
char databuf[2000]; /* data buffer for incoming frame */
char debugmsg[MAXPATHLEN+200]; /* debug output message buffer */
struct strbuf ctl, data; /* for use with getmsg() for incoming frame */
client_t *clntp = NULL; /* pointer to the current client being served */
int totclnt = 0; /* total clients being served right now */
int outblocked = 0;
int
main(int argc, char *argv[], char *envp[])
{
time_t t;
/* program initialize */
if (initialize(argc, argv, envp) < 0)
exit(-1);
/* start processing requests */
if (debugLevel >= MSG_INFO_1) {
t = time((time_t *)NULL);
sprintf(debugmsg, "%s", ctime(&t));
senddebug(MSG_INFO_1);
sprintf(debugmsg, "Start listening to RPL requests ...\n");
senddebug(MSG_INFO_1);
}
while (1) {
if (service() < 0)
exit(-1);
}
}
int
service(void)
{
int flags;
int rc;
int n;
if (outblocked)
llc_fd.events = POLLIN | POLLOUT;
else
llc_fd.events = POLLIN;
if (totclnt > 0)
n = poll(&llc_fd, 1, 1); /* 1 ms timeout */
else
n = poll(&llc_fd, 1, -1); /* blocking poll */
if (llc_fd.revents & POLLIN) {
rc = incoming(llc_fd.fd);
if (debugLevel >= MSG_ALWAYS) {
sprintf(debugmsg, "incoming() returned\n");
senddebug(MSG_ALWAYS);
}
}
if (llc_fd.revents & POLLOUT)
outblocked = 0;
goaround();
return (rc);
}
/*
* This is the scheduler for all the outgoing traffic. Go around the
* circular linked list and only process and advance 1 in the list
* and then return no matter whether anything is being sent out in
* this step or not.
*/
int
goaround(void)
{
if (totclnt == 0 || clntp == NULL)
return (0);
switch (clntp->status) {
case ST_FIND_RCVD:
sendFOUND(llc_fd.fd, clntp);
break;
case ST_DATA_XFER:
sendFILE(llc_fd.fd, clntp);
break;
case ST_SEND_FINAL:
sendFINAL(llc_fd.fd, clntp);
break;
case ST_FINISH:
if ((--(clntp->delay)) == 0) {
if ((time((time_t)0) - clntp->timeo) > REMOVETIMEOUT)
clientremove(clntp);
else
clntp->delay = clntp->maxdelay;
}
break;
}
if (totclnt > 0 && clntp->next)
clntp = clntp->next;
return (0);
}
int
initialize(int argc, char *argv[], char *envp[])
{
char *cp;
union DL_primitives dl;
struct sigaction sa;
/*
* Parse command line, read appropriate config file and set up
* defaults
*/
if (parseargs(argc, argv, envp) < 0)
return (-1);
/*
* Here, if the -a option is specified, we are actually running in
* a child process with all the parameters stored in the set of
* global variables.
*/
/* daemonize it if running in background */
if (backGround) {
switch (fork()) {
case -1:
return (-1);
break;
case 0: /* child: close FD's and detach terminal */
close(0);
close(1);
close(2);
(void) open("/", O_RDONLY, 0);
(void) dup2(0, 1);
(void) dup2(0, 2);
/*
* Detach terminal
*/
setsid();
break;
default: /* parent */
exit(0);
break;
}
if (setpgrp() < 0)
return (-1);
sa.sa_handler = SIG_IGN;
sa.sa_flags = SA_RESTART;
(void) sigemptyset(&sa.sa_mask);
(void) sigaction(SIGHUP, &sa, NULL);
if (fork() > 0)
return (-1);
}
if (llcsetup() < 0)
return (-1);
clntp = (client_t *)NULL;
totclnt = 0;
sa.sa_handler = sighuphdr;
sa.sa_flags = SA_RESTART;
(void) sigemptyset(&sa.sa_mask);
(void) sigaction(SIGHUP, &sa, NULL);
sa.sa_handler = sigusr1hdr;
sa.sa_flags = SA_RESTART;
(void) sigemptyset(&sa.sa_mask);
(void) sigaction(SIGUSR1, &sa, NULL);
return (0);
}