Main Page

Source Files

Class Hierarchy

Alphabetical List

Compound List

Compound Members

File Members

Related Pages

Search for

---

server/bed.cxx File Reference

multi-user backend main More...

#include <errno.h>
#include <setjmp.h>
#include <stdlib.h>
#include <signal.h>
#include <sys/time.h>
#include <time.h>
#include "udanax.h"
#include "players.h"
#include "requests.h"

Include dependency graph for bed.cxx:

Go to the source code of this file.

Functions
bool	getrequest (Session *sess, typerequest *requestptr)
	???
void	sendresultoutput (Session *session)
	???
void	xuputstring (char *string, FILE *fd)
	???
void	processrcfile ()
	???
void	crash (int)
	???
void	leave (PLAYER player[], int *xn_players)
	???
int	open_sock ()
	???
void	new_players (PLAYER player[], int *n_playersp, int block, Session *sess)
	???
void	logaccount (Tumbler *tp)
	???
void	xanadu (Session *sess)
	???
void	flagquitting (int)
	???
int	main (int argc, char *argv[])
	???
bool	establishprotocol (FILE *inp, FILE *outp)
	???
void	frontenddied ()
	???
void	setmaximumsetupsize (Session *sess)
	???
void	sourceunixcommand (Session *sess)
	???
bool	decrementusers ()
	???
Variables
int	backenddaemon
jmp_buf	frontendeof
int	user = 0
int	errno
FILE *	logfile
FILE *	nulllog
FILE *	reallog
char	outputbuffer [BUFSIZ]
char	inputbuffer [BUFSIZ]
bool	logstuff
FILE *	interfaceinput
FILE *	febelog
timeval	timeout
int	main_socket
Tumbler	currentaccount
bool	quitafteruser = false
bool	mightbeblocked = false

---

Detailed Description

multi-user backend main

(to be defined)

Definition in file bed.cxx.

---

Function Documentation

void crash (  int   )

??? (to be defined) Definition at line 294 of file socketbe.cxx. References L, and user. Referenced by main(). { int i; L("CRASH while dealing with user %d\n", user); for (i = 0; i < 32; i++) close(i); /* BOO HISS: too many closes */ exit(9); }

bool decrementusers (   )

??? (to be defined) Definition at line 417 of file bed.cxx. References n_players, player, and user. { if (n_players > 1) { player[user].wantsout = 1; } return (n_players > 1); }

bool establishprotocol (  FILE *  inp, FILE *  outp )

??? (to be defined) Definition at line 335 of file bed.cxx. References Session::errp, febelog, firstputforrequest, Session::inp, L, metachar, nulllog, Session::outp, pullc(), sendresultoutput(), and xuputstring(). Referenced by main(), and new_players(). { L("Entering establishprotocol()\n"); metachar ch; /* This is the metaprotocol for the time being */ while ((ch = getc(inp)) != '\n') putc((ch > ' ' ? ch : '.'), stderr); while ((ch = getc(inp)) == '\n') putc(ch, stderr); L("establishprotocol: synced up\n"); if (ch == 'P' && getc(inp) == '0' && getc(inp) == '~') { if (!feof(inp)) { /* Don't send to a dead pipe */ xuputstring("\nP0~", outp); fflush(outp); L("Leaving establishprotocol(), SUCCESS\n"); return true; } } else { if (!feof(inp)) { /* Don't send to a dead pipe */ xuputstring("\nP?~", outp); fflush(outp); } } L("Leaving establishprotocol(), FAIL\n"); return false; }

void flagquitting (  int   )

??? (to be defined) Definition at line 180 of file bed.cxx. References closediskfile(), interfaceinput, mightbeblocked, QUIT, quitafteruser, and writeenfilades(). Referenced by main(). { signal(SIGINT, SIG_IGN); /* Don't die too early */ if (mightbeblocked) { if (interfaceinput) { fprintf(interfaceinput, "%d~\n", QUIT); fclose(interfaceinput); } writeenfilades(); closediskfile(); exit(0); } else quitafteruser = true; /* Flag to stop backend after current request */ }

void frontenddied (   )

??? (to be defined) Definition at line 377 of file bed.cxx. References assert, diskexit(), frontendeof, and L. { longjmp(frontendeof, 1); }

bool getrequest (  Session *  sess, typerequest *  requestptr )

??? (to be defined) Parameters: sess  Input: User's session context Definition at line 326 of file get2.cxx. : User's session context typerequest *requestptr) { prompt(sess, "\nrequest? "); int c = getc(sess->inp); if ((int) c == EOF) { L("endfile\n"); sess->inp = stdin; } /* else if (c == ':') { while ((c = * getc (sess->inp)) != '\n'); * return * (false); } */ ungetc(c, sess->inp); return getnumber(sess, requestptr) && validrequest(sess, *requestptr); }

void leave (  PLAYER  player[], int *  xn_players )

??? (to be defined) Definition at line 225 of file socketbe.cxx. References inputfds, L, PLAYER, player, and _player::wantsout. Referenced by main(). { register int i; for (i = 0; i < *xn_players; i++) if (player[i].wantsout) { FD_CLR(player[i].socket, &inputfds); //OBSOLETE inputfds ^= (1 << (player[i].socket)); if (close(player[i].socket) != 0) { L("user %d: ", i); perror("close player.socket"); } if (*xn_players > 1) { player[i] = player[*xn_players - 1]; } (*xn_players)--; --i; /* since this entry is new, test again */ } }

void logaccount (  Tumbler *  tp  )

??? (to be defined) Definition at line 535 of file get1fe.cxx. References interfaceinput, puttumbler(), and XACCOUNT. Referenced by main(). { if (interfaceinput) { fprintf(interfaceinput, "%d~", XACCOUNT); puttumbler(interfaceinput, tp); } }

int main (  int  argc, char *  argv[] )

??? (to be defined) <Input: User's session context Definition at line 204 of file bed.cxx. References Session::account, assert, backenddaemon, closediskfile(), crash(), currentaccount, debug, diskflush(), errno, fdtoplayer, febelog, flagquitting(), init(), initsession(), Session::inp, inputbuffer, inputfds, interfaceinput, L, leave(), logaccount(), logfile, main_socket, mightbeblocked, n_players, new_players(), nfds, nsessorcommand, NULL, nulllog, open_sock(), Session::outp, outputbuffer, player, processrcfile(), QUIT, quitafteruser, reallog, timeout, tumblereq(), user, writeenfilades(), and xanadu(). { /* inside temporary */ Session sess; char buf[100]; //UNUSED FILE *fd; struct tm *local; long clock; /* extern void crash();* *//* if broken pipe, release port (I hope) */ //UNUSED int s; /* for socket */ fd_set inputfds2; int i; freopen("backenderror", "w", stderr); setbuf(stderr, NULL); backenddaemon = 1; FD_ZERO(&inputfds); processrcfile(); signal(SIGPIPE, crash); signal(SIGHUP, crash); signal(SIGXCPU, SIG_IGN); signal(SIGINT, flagquitting); febelog = interfaceinput = reallog = logfile = nulllog = fopen("/dev/null", "a"); clock = time(0); local = localtime(&clock); sprintf(buf, "ln%d.%d.%d:%d", local->tm_mon + 1, local->tm_mday, local->tm_hour, local->tm_min); interfaceinput = fopen(buf, "w"); #ifndef DISTRIBUTION sprintf(buf, "febe%d.%d.%d:%d", local->tm_mon + 1, local->tm_mday, local->tm_hour, local->tm_min); febelog = fopen(buf, "w"); setbuf(febelog, NULL); #endif setbuf(stdin, inputbuffer); setbuf(stdout, outputbuffer); debug = 0; init(1); //now uses a ctor:: inittask(&sess); errno = 0; initsession("enf.enf"); main_socket = open_sock(); if (n_players < 1) { mightbeblocked = true; new_players(player, &n_players, true, &sess); /* wait for fe to talk to */ mightbeblocked = false; } for (;;) { if (n_players < 1) { diskflush(); /* Write out everything when no one around */ mightbeblocked = true; new_players(player, &n_players, true, &sess); /* wait for fe to talk to */ mightbeblocked = false; } inputfds2 = inputfds; timeout.tv_sec = 2; /* wait 2 seconds on a select, then look for a new user */ timeout.tv_usec = 0; int nevents = select(nfds + 1, &inputfds2, 0, 0, &timeout); if (nevents < 0) { if (errno == EINTR) { continue; } perror("select"); assert(0); // select in main } else { if (nevents) L("Somone connected to our main socket\n"); for (i = 0; i <= nfds; i++) { if (FD_ISSET(i, &inputfds2)) { //OBSOLETE if ((1 << i) & inputfds2) { L("Read-Event on socket %d\n", i); user = fdtoplayer[i]; sess.inp = player[user].inp; sess.outp = player[user].outp; sess.account = player[user].account; if (!tumblereq(&currentaccount, &sess.account)) { currentaccount = sess.account; logaccount(&sess.account); } xanadu(&sess); if (quitafteruser) { if (interfaceinput) { fprintf(interfaceinput, "%d~\n", QUIT); fclose(interfaceinput); } writeenfilades(); closediskfile(); exit(0); } /* testforreservedness("main"); */ /* logfile = nulllog; */ nsessorcommand++; } } } leave(player, &n_players); mightbeblocked = true; new_players(player, &n_players, false, &sess); mightbeblocked = false; } return 0; }

void new_players (  PLAYER  player[], int *  n_playersp, int  block, Session *  sess )

??? (to be defined) Parameters: sess  Input: User's session context Definition at line 126 of file socketbe.cxx. References ERROR, establishprotocol(), fdtoplayer, _player::inp, Session::inp, inputfds, L, main_socket, max, MAX_PLAYERS, nfds, NULL, open_sock(), Session::outp, _player::outp, PLAYER, player, _player::socket, and _player::wantsout. Referenced by main(). : User's session context /* array of player info structures */ /* number of players (incl comp) */ /* if nobody wants to join, wait on socket until somebody * does. */ { int s; /* temp holder for new socket */ int rc; /* # ready selected sockets */ struct sockaddr_in from; /* connection acceptor */ socklen_t fromlen = sizeof(from); struct timeval t; /* don't let select() run forever */ //UNUSED int i; //UNUSED FILE *temp; //UNUSED char devicename[100]; //UNUSED int len; //UNUSED typerequest requestinstance; int open_sock(); /* to open main socket */ if (main_socket == ERROR) main_socket = open_sock(); /* set up 0 second timeout for use on select() calls */ /* well it USED to be 0 seconds, but that seems too fast now !<reg sep 10 1999> */ t.tv_sec = 0L; t.tv_usec = 3L; for (;;) { fd_set readfds; FD_ZERO(&readfds); FD_SET(main_socket, &readfds); //OBSOLETE readfds = 1 << main_socket; t.tv_sec = 0L; t.tv_usec = 3L; if ((rc = select(32, &readfds, 0, 0, &t)) == -1) { // Wait on Main Socket perror("new_players:select"); fflush(stdout); break; } if (rc > 0 || block) { if ((s = accept(main_socket, (sockaddr *) &from, &fromlen)) < 0) { perror("new_players:accept"); fflush(stdout); break; } if (*n_playersp >= MAX_PLAYERS) { L("TOOMANY frontends: won't log another one\n"); close(s); } else { block = false; #ifndef DISTRIBUTION L("accepted connection from %d ", s); #endif /* read ttyname and open socket for it; */ player[*n_playersp].socket = s; if ((player[*n_playersp].inp = fdopen(s, "r")) == NULL) { perror("fdopen(r)"); break; } if ((sess->outp = player[*n_playersp].outp = fdopen(s, "w")) == NULL) { perror("fdopen(w)"); break; } sess->inp = player[*n_playersp].inp; #ifndef DISTRIBUTION L("%s\n", (char *) &(player[*n_playersp].account)); #endif if (!establishprotocol(sess->inp, sess->outp)) { break; } // getrequest(sess, &requestinstance); // getxaccount(sess, &(player[*n_playersp].account)); // logaccount(&(player[*n_playersp].account)); player[*n_playersp].wantsout = false; fdtoplayer[s] = *n_playersp; FD_SET(s, &inputfds); nfds = max(s, nfds); (*n_playersp)++; break; } } else break; } }

int open_sock (   )

??? (to be defined) Definition at line 256 of file socketbe.cxx. References L, and portname. Referenced by main(), and new_players(). { /* Open the main socket. */ int s; struct sockaddr_in sockaddr; //UNUSED struct hostent *host; if ((s = socket(AF_INET, SOCK_STREAM, 0)) < 0) { perror("socket()"); exit(1); } /* * if ((host = gethostbyname(hostname)) == NULL) { perror("gethostbyname()"); * exit(1); } */ sockaddr.sin_family = AF_INET; sockaddr.sin_port = htons(portname); sockaddr.sin_addr.s_addr = /* inetaddr */ INADDR_ANY; L("calling bind s = %d \n", s); if (bind(s, (struct sockaddr *) &sockaddr, sizeof(sockaddr)) < 0) { perror("bind()"); exit(1); } if (listen(s, 0) < 0) { perror("listen()"); exit(1); } return (s); }

void processrcfile (   )

??? (to be defined) Definition at line 110 of file rcfile.cxx. { FILE *rcfd; static char buf[BUFSIZ]; static char line[256]; static char name[256]; int temp; if ((rcfd = fopen(RCFILENAME, "r")) != NULL) { while (fgets(buf, BUFSIZ, rcfd)) { if (buf[0] != '#' && sscanf(buf, "%s = %s", name, line) == 2) { //UNUSED if (!strcmp(name, BACKENDFILEMETANAME)) //UNUSED strcpy(backendfilename, line); //UNUSED else if (!strcmp(name, ACCOUNTFILEMETANAME)) //UNUSED strcpy(accountfilename, line); //UNUSED else if (!strcmp(name, PORTMETANAME)) { if (sscanf(line, "%d", &portname) < 1) { L("Could not use port = %s, using %d\n", line, PORT); portname = PORT; } } else if (!strcmp(name, HOSTMETANAME)) strcpy(hostname, line); //UNUSED else if (!strcmp(name, BACKENDDIRECTORYMETANAME)) //UNUSED strcpy(backenddirectoryname, line); //UNUSED else if (!strcmp(name, BACKENDGLUEFILEMETANAME)) //UNUSED strcpy(backendgluefilename, line); //UNUSED else if (!strcmp(name, FRONTENDGLUEFILEMETANAME)) //UNUSED strcpy(frontendgluefilename, line); //UNUSED else if (!strcmp(name, FRONTENDFILEMETANAME)) //UNUSED strcpy(frontendfilename, line); else if (!strcmp(name, ALLOCSIZENAME)) { temp = allocsize; sscanf(line, "%d", &allocsize); if (allocsize < 100000 || allocsize > 300000000) { /* minimal sanity checking */ incrementalallocsize = temp; } } else if (!strcmp(name, INCREMENTALALLOCSIZENAME)) { temp = incrementalallocsize; sscanf(line, "%d", &incrementalallocsize); if (incrementalallocsize < 10000 || incrementalallocsize > 100000000) { incrementalallocsize = temp; } } else L("Don't know about %s = %s\n", name, line); } } fclose(rcfd); } }

void sendresultoutput (  Session *  session  )

??? (to be defined) Parameters: session  Input: User's session context Definition at line 192 of file putfe.cxx. References Session::outp. Referenced by establishprotocol(), and xanadu(). : User's session context { /* FILE *fd; fd = session->outp; write (fd->_file, fd->_base, (int) (fd->_ptr - fd->_base)); fd->_ptr = fd->_base; * fd->_cnt = BUFSIZ; */ fflush(session->outp); }

void setmaximumsetupsize (  Session *  sess  )

??? (to be defined) Parameters: sess  Input: User's session context Definition at line 391 of file bed.cxx. : User's session context { }

void sourceunixcommand (  Session *  sess  )

??? (to be defined) Parameters: sess  Input: User's session context Definition at line 404 of file bed.cxx. : User's session context { }

void xanadu (  Session *  sess  )

??? (to be defined) Parameters: sess  Input: User's session context Definition at line 142 of file bed.cxx. References closeberts(), Session::free(), frontendeof, getrequest(), interfaceinput, L, logstuff, nulllog, player, QUIT, requestfns, sendresultoutput(), typerequest, and user. : User's session context { L("Entering xanadu()\n"); typerequest request; logstuff = false; if (setjmp(frontendeof)) { closeberts(sess); player[user].wantsout = true; } else if (getrequest(sess, &request)) { (*requestfns[request]) (sess); sendresultoutput(sess); if (request == QUIT) player[user].wantsout = true; } sess->free(); if (interfaceinput && interfaceinput != nulllog) fflush(interfaceinput); logstuff = false; L("Leaving xanadu()\n"); }

void xuputstring (  char *  string, FILE *  fd )

??? (to be defined) Definition at line 145 of file putfe.cxx. Referenced by error(), establishprotocol(), and prompt(). { /* while (*string) xuputc (*string++, fd); */ fwrite(string, 1, strlen(string), fd); }

---

Variable Documentation

int backenddaemon

Definition at line 91 of file bed.cxx.

Tumbler currentaccount [static]

Definition at line 120 of file bed.cxx. Referenced by main().

int errno

Definition at line 109 of file bed.cxx.

FILE* febelog

Definition at line 117 of file bed.cxx.

jmp_buf frontendeof

Definition at line 105 of file bed.cxx. Referenced by frontenddied(), and xanadu().

char inputbuffer[BUFSIZ]

Definition at line 114 of file bed.cxx.

FILE* interfaceinput

Definition at line 116 of file bed.cxx.

FILE* logfile

Definition at line 110 of file bed.cxx.

bool logstuff

Definition at line 115 of file bed.cxx.

int main_socket

Definition at line 119 of file bed.cxx. Referenced by main(), and new_players().

bool mightbeblocked = false

Definition at line 122 of file bed.cxx. Referenced by flagquitting(), and main().

FILE* nulllog

Definition at line 111 of file bed.cxx.

char outputbuffer[BUFSIZ]

Definition at line 113 of file bed.cxx.

bool quitafteruser = false

Definition at line 121 of file bed.cxx. Referenced by flagquitting(), and main().

FILE* reallog

Definition at line 112 of file bed.cxx.

struct timeval timeout

Definition at line 118 of file bed.cxx. Referenced by main().

int user = 0

Definition at line 107 of file bed.cxx.

---