nishiTV/sj3
1
0
Fork 0
Code Pull requests Activity

sj3serv: Migrate to KNF and ISO C all but setup.c

Browse source 
Signed-off-by: Masanori Ogino <mogino@acm.org>
This commit is contained in:
Masanori Ogino 2023-11-29 11:46:20 +09:00
commit 55d33df2a1
6 changed files with 1156 additions and 1147 deletions
Download patch file Download diff file Expand all files Collapse all files

218
sj3serv/comuni.c
View file

@ -28,34 +28,24 @@
* from Sony Corporation. * from Sony Corporation.
*/ */
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <unistd.h>
#include "sj_sysvdef.h" #include "sj_sysvdef.h"
#include "sj_kcnv.h"
#include <sys/socket.h>
#include <sys/un.h>
#include <sys/ioctl.h> #include <sys/ioctl.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <sys/un.h>
#include <netinet/in.h> #include <netinet/in.h>
#include <errno.h>
#include <netdb.h> #include <netdb.h>
#include <setjmp.h> #include <setjmp.h>
#include <errno.h> #include <signal.h>
#ifdef SVR4 #include <stdlib.h>
#include <sys/filio.h> #include <string.h>
#include <sys/signal.h> #include <unistd.h>
#include <poll.h>
#endif #include "sj_kcnv.h"
#ifdef TLI
#include <fcntl.h>
#include <tiuser.h>
#include <stropts.h>
#include <sys/types.h>
#include <netdir.h>
#include <netconfig.h>
#endif
#ifdef SVR4 #ifdef SVR4
#define signal sigset #define signal sigset
@ -104,7 +94,6 @@ static int putpos = 0;
static int buflen = 0; static int buflen = 0;
static int getpos = 0; static int getpos = 0;
void void
socket_init(void) socket_init(void)
{ {
@ -123,8 +112,6 @@ socket_init(void)
maxfds = 0; maxfds = 0;
} }
static void static void
set_fd(int fd) set_fd(int fd)
{ {
@ -134,12 +121,11 @@ set_fd(int fd)
maxfds++; maxfds++;
#else #else
FD_SET(fd, &fds_org); FD_SET(fd, &fds_org);
if (fd >= maxfds) maxfds = fd + 1; if (fd >= maxfds)
maxfds = fd + 1;
#endif #endif
} }
static void static void
clr_fd(int fd) clr_fd(int fd)
{ {
@ -164,7 +150,8 @@ clr_fd(int fd)
FD_CLR(fd, &fds_org); FD_CLR(fd, &fds_org);
if (maxfds == fd + 1) { if (maxfds == fd + 1) {
while (--fd >= 0) { while (--fd >= 0) {
if (FD_ISSET(fd, &fds_org)) break; if (FD_ISSET(fd, &fds_org))
break;
} }
maxfds = fd + 1; maxfds = fd + 1;
} }
@ -173,7 +160,6 @@ clr_fd(int fd)
#if (!defined(TLI) || (defined(TLI) && defined(SOCK_UNIX))) #if (!defined(TLI) || (defined(TLI) && defined(SOCK_UNIX)))
static void static void
open_af_unix(void) open_af_unix(void)
{ {
@ -191,12 +177,14 @@ open_af_unix(void)
exit(1); exit(1);
} }
if (bind(fd_unix, (struct sockaddr *)&sunix, strlen(sunix.sun_path) + 2) == ERROR) { if (bind(fd_unix, (struct sockaddr *)&sunix,
if (errno == EADDRINUSE) strlen(sunix.sun_path) + 2) == ERROR) {
if (errno == EADDRINUSE) {
fprintf(stderr, "Port '%s' is already in use\n", fprintf(stderr, "Port '%s' is already in use\n",
socket_name); socket_name);
else } else {
fprintf(stderr, "Can't bind AF_UNIX socket\n"); fprintf(stderr, "Can't bind AF_UNIX socket\n");
}
shutdown(fd_unix, 2); shutdown(fd_unix, 2);
close(fd_unix); close(fd_unix);
unlink(socket_name); unlink(socket_name);
@ -219,7 +207,6 @@ struct t_call *inet_callptr;
struct netconfig *nconf; struct netconfig *nconf;
#endif #endif
static void static void
open_af_inet(void) open_af_inet(void)
{ {
@ -240,7 +227,6 @@ open_af_inet(void)
#endif #endif
int true = 1; int true = 1;
#ifdef TLI #ifdef TLI
if ((handlep = setnetpath()) == NULL) { if ((handlep = setnetpath()) == NULL) {
fprintf(stderr, "Setnetpath fail\n"); fprintf(stderr, "Setnetpath fail\n");
@ -249,7 +235,8 @@ open_af_inet(void)
while ((nconf = getnetpath(handlep)) != NULL) { while ((nconf = getnetpath(handlep)) != NULL) {
if ((nconf->nc_semantics == NC_TPI_COTS_ORD) && if ((nconf->nc_semantics == NC_TPI_COTS_ORD) &&
(strncmp(nconf->nc_proto, proto_name, strlen(proto_name)) == 0)) (strncmp(nconf->nc_proto, proto_name, strlen(proto_name)) ==
0))
break; break;
} }
if (nconf == NULL) { if (nconf == NULL) {
@ -265,16 +252,19 @@ open_af_inet(void)
exit(1); exit(1);
} }
} }
if ((fd_inet = t_open(nconf->nc_device, O_RDWR, (struct t_info *) NULL)) < 0) { if ((fd_inet = t_open(nconf->nc_device, O_RDWR,
(struct t_info *)NULL)) < 0) {
fprintf(stderr, "Can't t_open\n"); fprintf(stderr, "Can't t_open\n");
exit(1); exit(1);
} }
if ((opt = (struct t_optmgmt *) t_alloc(fd_inet, T_OPTMGMT, T_ALL)) == NULL) { if ((opt = (struct t_optmgmt *)t_alloc(fd_inet, T_OPTMGMT, T_ALL)) ==
NULL) {
fprintf(stderr, "Can't t_alloc error for T_OPTMGT\n"); fprintf(stderr, "Can't t_alloc error for T_OPTMGT\n");
exit(1); exit(1);
} }
if ((hdr = (struct opthdr *) malloc(sizeof(*hdr) + sizeof(true))) == NULL) { if ((hdr = (struct opthdr *)malloc(sizeof(*hdr) + sizeof(true))) ==
NULL) {
fprintf(stderr, "server: not malloc\n"); fprintf(stderr, "server: not malloc\n");
exit(1); exit(1);
} }
@ -314,13 +304,15 @@ open_af_inet(void)
t_close(fd_inet); t_close(fd_inet);
exit(1); exit(1);
} }
if (memcmp(req->addr.buf, addrs->n_addrs->buf, addrs->n_addrs->len) != 0) { if (memcmp(req->addr.buf, addrs->n_addrs->buf, addrs->n_addrs->len) !=
0) {
fprintf(stderr, "Port '%s(%s)' is already in use\n", fprintf(stderr, "Port '%s(%s)' is already in use\n",
port_name, port_number); port_name, port_number);
t_close(fd_inet); t_close(fd_inet);
exit(1); exit(1);
} }
if ((inet_callptr = (struct t_call *) t_alloc(fd_inet, T_CALL, T_ALL)) == NULL) { if ((inet_callptr = (struct t_call *)t_alloc(fd_inet, T_CALL, T_ALL)) ==
NULL) {
fprintf(stderr, "t_alloc error for T_CALL\n"); fprintf(stderr, "t_alloc error for T_CALL\n");
t_close(fd_inet); t_close(fd_inet);
exit(1); exit(1);
@ -328,7 +320,6 @@ open_af_inet(void)
inet_callptr->addr = *(addrs->n_addrs); inet_callptr->addr = *(addrs->n_addrs);
inet_callptr->udata.maxlen = 0; inet_callptr->udata.maxlen = 0;
inet_callptr->udata.len = 0; inet_callptr->udata.len = 0;
inet_callptr->udata.buf = (char *)NULL; inet_callptr->udata.buf = (char *)NULL;
@ -352,17 +343,18 @@ open_af_inet(void)
if (bind(fd_inet, (struct sockaddr *)&sin, sizeof(sin)) == ERROR) { if (bind(fd_inet, (struct sockaddr *)&sin, sizeof(sin)) == ERROR) {
if (errno == EADDRINUSE) { if (errno == EADDRINUSE) {
if (sp) if (sp) {
fprintf(stderr, fprintf(stderr,
"Port '%s(%d)' is already in use\n", "Port '%s(%d)' is already in use\n",
port_name, port); port_name, port);
else } else {
fprintf(stderr, fprintf(stderr,
"Port %d is already in use\n", "Port %d is already in use\n",
port); port);
} }
else } else {
fprintf(stderr, "Can't bind AF_INET socket\n"); fprintf(stderr, "Can't bind AF_INET socket\n");
}
shutdown(fd_inet, 2); shutdown(fd_inet, 2);
close(fd_inet); close(fd_inet);
exit(1); exit(1);
@ -389,7 +381,6 @@ open_socket(void)
#if (!defined(TLI) || (defined(TLI) && defined(SOCK_UNIX))) #if (!defined(TLI) || (defined(TLI) && defined(SOCK_UNIX)))
static int static int
connect_af_unix(void) connect_af_unix(void)
{ {
@ -407,38 +398,40 @@ connect_af_unix(void)
int int
accept_func(int fd, struct t_call *callptr, char *name, int closeflg) accept_func(int fd, struct t_call *callptr, char *name, int closeflg)
{ {
int newfd; int look, newfd;
int look;
extern int t_errno; extern int t_errno;
if ((newfd = t_open(name, O_RDWR, (struct t_info *)0)) < 0) { if ((newfd = t_open(name, O_RDWR, (struct t_info *)0)) < 0) {
if (!closeflg) warning_out("Can't t_open"); if (!closeflg)
warning_out("Can't t_open");
return ERROR; return ERROR;
} }
if (t_bind(newfd, (struct t_bind *)0, (struct t_bind *)0) < 0) { if (t_bind(newfd, (struct t_bind *)0, (struct t_bind *)0) < 0) {
if (!closeflg) warning_out("t_bind error"); if (!closeflg)
warning_out("t_bind error");
return ERROR; return ERROR;
} }
t_errno = 0; t_errno = 0;
if (t_accept(fd, newfd, callptr) < 0) { if (t_accept(fd, newfd, callptr) < 0) {
t_close(newfd); t_close(newfd);
if (!closeflg) warning_out("t_accept error"); if (!closeflg)
warning_out("t_accept error");
return ERROR; return ERROR;
} }
if (ioctl(newfd, I_POP, (char *)0) < 0) { if (ioctl(newfd, I_POP, (char *)0) < 0) {
if (!closeflg) warning_out("I_POP timod failed"); if (!closeflg)
warning_out("I_POP timod failed");
return ERROR; return ERROR;
} }
if (ioctl(newfd, I_PUSH, "tirdwr") < 0) { if (ioctl(newfd, I_PUSH, "tirdwr") < 0) {
if (!closeflg) warning_out("I_PUSH tirdwr failed"); if (!closeflg)
warning_out("I_PUSH tirdwr failed");
return ERROR; return ERROR;
} }
return (newfd); return (newfd);
} }
#endif #endif
static int static int
connect_af_inet(void) connect_af_inet(void)
{ {
@ -449,12 +442,11 @@ connect_af_inet(void)
int fd; int fd;
#ifdef TLI #ifdef TLI
if (t_listen(fd_inet, inet_callptr) < 0) { if (t_listen(fd_inet, inet_callptr) < 0)
warning_out("t_listen error"); warning_out("t_listen error");
} if ((fd = accept_func(fd_inet, inet_callptr, nconf->nc_device,
FALSE)) == ERROR)
if ((fd = accept_func(fd_inet, inet_callptr, nconf->nc_device, FALSE)) == ERROR)
#else #else
if ((fd = accept(fd_inet, (struct sockaddr *)&sin, &i)) == ERROR) if ((fd = accept(fd_inet, (struct sockaddr *)&sin, &i)) == ERROR)
#endif #endif
@ -464,7 +456,6 @@ connect_af_inet(void)
#if (!defined(TLI) || (defined(TLI) && defined(SOCK_UNIX))) #if (!defined(TLI) || (defined(TLI) && defined(SOCK_UNIX)))
static void static void
close_af_unix(void) close_af_unix(void)
{ {
@ -475,7 +466,8 @@ close_af_unix(void)
ioctl(fd_unix, FIONBIO, &true); ioctl(fd_unix, FIONBIO, &true);
for (; ;) { for (; ;) {
i = sizeof(sunix); i = sizeof(sunix);
if (accept(fd_unix, (struct sockaddr *)&sunix, &i) < 0) break; if (accept(fd_unix, (struct sockaddr *)&sunix, &i) < 0)
break;
} }
shutdown(fd_unix, 2); shutdown(fd_unix, 2);
close(fd_unix); close(fd_unix);
@ -484,8 +476,6 @@ close_af_unix(void)
} }
#endif #endif
static void static void
close_af_inet(void) close_af_inet(void)
{ {
@ -498,11 +488,13 @@ close_af_inet(void)
ioctl(fd_inet, FIONBIO, &true); ioctl(fd_inet, FIONBIO, &true);
for (; ;) { for (; ;) {
#ifdef TLI #ifdef TLI
if (accept_func(fd_inet, inet_callptr, nconf->nc_device, TRUE) < 0) if (accept_func(fd_inet, inet_callptr, nconf->nc_device, TRUE) <
0)
break; break;
#else #else
i = sizeof(sin); i = sizeof(sin);
if (accept(fd_inet, (struct sockaddr *)&sin, &i) < 0) break; if (accept(fd_inet, (struct sockaddr *)&sin, &i) < 0)
break;
#endif #endif
} }
#ifdef TLI #ifdef TLI
@ -525,8 +517,6 @@ close_socket(void)
close_af_inet(); close_af_inet();
} }
static void static void
#ifdef SVR4 #ifdef SVR4
connect_client(struct pollfd *readfds) connect_client(struct pollfd *readfds)
@ -562,7 +552,8 @@ connect_client(fd_set *readfds)
} }
#endif #endif
} }
if (i == maxfds) return; if (i == maxfds)
return;
#else /* SVR4 */ #else /* SVR4 */
if (FD_ISSET(fd_inet, readfds)) if (FD_ISSET(fd_inet, readfds))
fd = connect_af_inet(); fd = connect_af_inet();
@ -580,20 +571,15 @@ connect_client(fd_set *readfds)
else else
return; return;
#endif /* SVR4 */ #endif /* SVR4 */
if (fd == ERROR) return; if (fd == ERROR)
return;
if (client_num >= MaxClientNum || client_num >= max_client) { if (client_num >= MaxClientNum || client_num >= max_client) {
warning_out("No more client"); warning_out("No more client");
} } else {
else {
debug_out(1, "client create(%d)\r\n", fd); debug_out(1, "client create(%d)\r\n", fd);
logging_out("connect to client on %d", fd); logging_out("connect to client on %d", fd);
if ((client_tmp = (Client *)malloc(sizeof(Client))) != NULL) { if ((client_tmp = (Client *)malloc(sizeof(Client))) != NULL) {
memset(client_tmp, 0, sizeof(Client)); memset(client_tmp, 0, sizeof(Client));
client_tmp->fd = fd; client_tmp->fd = fd;
@ -630,18 +616,18 @@ connect_client(fd_set *readfds)
} }
static Client * static Client *
disconnect_client(Client *cp) disconnect_client(Client *cp)
{ {
WorkArea *wp; WorkArea *wp;
StdyFile *sp; StdyFile *sp;
int fd; int fd;
Client *cl_tmp, *cl_before; Client *cl_before, *cl_tmp;
if ((sp = cp->stdy) != NULL) closestdy(sp); if ((sp = cp->stdy) != NULL)
if ((wp = cp->work) != NULL) free_workarea(wp); closestdy(sp);
if ((wp = cp->work) != NULL)
free_workarea(wp);
debug_out(1, "client dead(%d)\r\n", cp->fd); debug_out(1, "client dead(%d)\r\n", cp->fd);
logging_out("disconnect from client on %d", cp->fd); logging_out("disconnect from client on %d", cp->fd);
@ -690,10 +676,6 @@ disconnect_client(Client *cp)
return cp; return cp;
} }
#ifndef SIGPIPE
#include <signal.h>
#endif
void void
communicate(void) communicate(void)
{ {
@ -705,23 +687,23 @@ communicate(void)
int i; int i;
while (poll(poll_fds, maxfds, -1) == ERROR) { while (poll(poll_fds, maxfds, -1) == ERROR) {
if (errno != EINTR) error_out("poll"); if (errno != EINTR)
error_out("poll");
errno = 0; errno = 0;
} }
#else #else
fd_set readfds; fd_set readfds;
readfds = fds_org; readfds = fds_org;
while (select(maxfds, &readfds, NULL, NULL, NULL) == ERROR) { while (select(maxfds, &readfds, NULL, NULL, NULL) == ERROR) {
if (errno != EINTR) error_out("select"); if (errno != EINTR)
error_out("select");
errno = 0; errno = 0;
} }
#endif #endif
for (cur_client = client; cur_client;) { for (cur_client = client; cur_client;) {
if (setjmp(client_dead)) { if (setjmp(client_dead)) {
cur_client = disconnect_client(cur_client); cur_client = disconnect_client(cur_client);
continue; continue;
@ -753,33 +735,29 @@ communicate(void)
} }
} }
void void
put_flush(void) put_flush(void)
{ {
int len; int i, len;
int i;
char *p; char *p;
for (len = putpos, p = putbuf; len > 0;) { for (len = putpos, p = putbuf; len > 0;) {
if ((i = write(client_fd, p, len)) == ERROR) { if ((i = write(client_fd, p, len)) == ERROR)
longjmp(client_dead, -1); longjmp(client_dead, -1);
}
len -= i; len -= i;
p += i; p += i;
} }
putpos = 0; putpos = 0;
} }
void void
put_byte(int c) put_byte(int c)
{ {
putbuf[putpos++] = c; putbuf[putpos++] = c;
if (putpos >= sizeof(putbuf)) put_flush(); if (putpos >= sizeof(putbuf))
put_flush();
} }
void void
put_work(int c) put_work(int c)
{ {
@ -787,7 +765,6 @@ put_work(int c)
put_byte(c & 0xff); put_byte(c & 0xff);
} }
void void
put_int(int c) put_int(int c)
{ {
@ -797,7 +774,6 @@ put_int(int c)
put_byte(c); put_byte(c);
} }
u_char * u_char *
put_string(u_char *p) put_string(u_char *p)
{ {
@ -805,31 +781,33 @@ put_string(u_char* p)
do { do {
put_byte(*p); put_byte(*p);
} while (*p++); } while (*p++);
} } else {
else
put_byte(0); put_byte(0);
}
return p; return p;
} }
u_char * u_char *
put_ndata(u_char *p, int n) put_ndata(u_char *p, int n)
{ {
while (n-- > 0) put_byte(p ? *p++ : 0); while (n-- > 0)
put_byte(p ? *p++ : 0);
return p; return p;
} }
void void
get_buf(void) get_buf(void)
{ {
int i; int i;
for (;;) { for (;;) {
if ((i = read(client_fd, getbuf, sizeof(getbuf))) > 0) break; if ((i = read(client_fd, getbuf, sizeof(getbuf))) > 0)
break;
if (i == ERROR) { if (i == ERROR) {
if (errno == EINTR) continue; if (errno == EINTR)
if (errno == EWOULDBLOCK) continue; continue;
if (errno == EWOULDBLOCK)
continue;
} }
longjmp(client_dead, -1); longjmp(client_dead, -1);
} }
@ -837,39 +815,34 @@ get_buf(void)
getpos = 0; getpos = 0;
} }
int int
get_byte(void) get_byte(void)
{ {
if (getpos >= buflen) get_buf(); if (getpos >= buflen)
return (getbuf[getpos++] & 0xff); get_buf();
return getbuf[getpos++] & 0xff;
} }
int int
get_word(void) get_word(void)
{ {
int i; int i;
i = get_byte(); i = get_byte();
return ((i << 8) | get_byte()); return (i << 8) | get_byte();
} }
int int
get_int(void) get_int(void)
{ {
int i0; int i0, i1, i2;
int i1;
int i2;
i0 = get_byte(); i0 = get_byte();
i1 = get_byte(); i1 = get_byte();
i2 = get_byte(); i2 = get_byte();
return((i0 << (8*3)) | (i1 << (8*2)) | (i2 << (8*1)) | get_byte()); return (i0 << (8*3)) | (i1 << (8*2)) | (i2 << (8*1)) | get_byte();
} }
int int
get_nstring(u_char *p, int n) get_nstring(u_char *p, int n)
{ {
@ -877,16 +850,17 @@ get_nstring(u_char* p, int n)
do { do {
c = get_byte(); c = get_byte();
if (n-- > 0) *p++ = c; if (n-- > 0)
*p++ = c;
} while (c); } while (c);
return (n < 0) ? ERROR : 0; return (n < 0) ? ERROR : 0;
} }
u_char * u_char *
get_ndata(u_char *p, int n) get_ndata(u_char *p, int n)
{ {
while (n-- > 0) *p++ = get_byte(); while (n-- > 0)
*p++ = get_byte();
return p; return p;
} }

36
sj3serv/error.c
View file

@ -28,16 +28,13 @@
* from Sony Corporation. * from Sony Corporation.
*/ */
#include <stdio.h> #include <stdio.h>
#include <stdlib.h> #include <stdlib.h>
#include <string.h> #include <string.h>
#include <time.h> #include <time.h>
#include "sj_typedef.h"
#include "server.h" #include "server.h"
#include "sj_typedef.h"
extern char program_name[]; extern char program_name[];
extern int debug_level; extern int debug_level;
@ -48,7 +45,6 @@ static FILE *errfp = NULL;
static FILE *logfp = NULL; static FILE *logfp = NULL;
static FILE *dbgfp = NULL; static FILE *dbgfp = NULL;
int int
open_error(void) open_error(void)
{ {
@ -59,17 +55,16 @@ open_error(void)
if (!strcmp(error_file, tty_name)) { if (!strcmp(error_file, tty_name)) {
errfp = stderr; errfp = stderr;
flg = -1; flg = -1;
} } else if (!(errfp = fopen(error_file, "a"))) {
else if (!(errfp = fopen(error_file, "a")))
fprintf(stderr, "Can't open \"%s\"\r\n", error_file); fprintf(stderr, "Can't open \"%s\"\r\n", error_file);
} }
else } else {
errfp = NULL; errfp = NULL;
}
return flg; return flg;
} }
void void
error_out(char *s, int p1, int p2, int p3, int p4, int p5) error_out(char *s, int p1, int p2, int p3, int p4, int p5)
{ {
@ -83,7 +78,6 @@ error_out(char* s, int p1, int p2, int p3, int p4, int p5)
exit(1); exit(1);
} }
void void
warning_out(char *s, int p1, int p2, int p3, int p4, int p5) warning_out(char *s, int p1, int p2, int p3, int p4, int p5)
{ {
@ -96,7 +90,6 @@ warning_out(char* s, int p1, int p2, int p3, int p4, int p5)
} }
} }
int int
open_log(void) open_log(void)
{ {
@ -107,9 +100,9 @@ open_log(void)
if (!strcmp(log_file, tty_name)) { if (!strcmp(log_file, tty_name)) {
logfp = stderr; logfp = stderr;
flg = -1; flg = -1;
} } else {
else
logfp = fopen(log_file, "a"); logfp = fopen(log_file, "a");
}
if (logfp) { if (logfp) {
time_t t; time_t t;
@ -117,17 +110,16 @@ open_log(void)
fprintf(logfp, "%s: log started at %s\r", fprintf(logfp, "%s: log started at %s\r",
program_name, ctime(&t)); program_name, ctime(&t));
fflush(logfp); fflush(logfp);
} } else {
else
fprintf(stderr, "Can't open \"%s\"\r\n", log_file); fprintf(stderr, "Can't open \"%s\"\r\n", log_file);
} }
else } else {
logfp = NULL; logfp = NULL;
}
return flg; return flg;
} }
void void
logging_out(char *s, int p1, int p2, int p3, int p4, int p5) logging_out(char *s, int p1, int p2, int p3, int p4, int p5)
{ {
@ -140,7 +132,6 @@ logging_out(char* s, int p1, int p2, int p3, int p4, int p5)
} }
} }
int int
open_debug(void) open_debug(void)
{ {
@ -151,17 +142,16 @@ open_debug(void)
if (!strcmp(debug_file, tty_name)) { if (!strcmp(debug_file, tty_name)) {
dbgfp = stderr; dbgfp = stderr;
flg = -1; flg = -1;
} } else if (!(dbgfp = fopen(debug_file, "a"))) {
else if (!(dbgfp = fopen(debug_file, "a")))
fprintf(stderr, "Can't open \"%s\"\r\n", debug_file); fprintf(stderr, "Can't open \"%s\"\r\n", debug_file);
} }
else } else {
dbgfp = NULL; dbgfp = NULL;
}
return flg; return flg;
} }
void void
debug_out(int lvl, char *s, int p1, int p2, int p3, int p4, int p5) debug_out(int lvl, char *s, int p1, int p2, int p3, int p4, int p5)
{ {

848
sj3serv/execute.c
View file

File diff suppressed because it is too large Load diff

44
sj3serv/main.c
View file

@ -29,11 +29,7 @@
*/ */
#include "sj_sysvdef.h" #include "sj_sysvdef.h"
#include <locale.h>
#include <stdio.h>
#include <stdlib.h>
#include <signal.h>
#include <sys/types.h>
#include <sys/file.h> #include <sys/file.h>
#include <sys/ioctl.h> #include <sys/ioctl.h>
#include <sys/types.h> #include <sys/types.h>
@ -55,23 +51,19 @@
extern int fork_flag; extern int fork_flag;
extern char *lock_file; extern char *lock_file;
#ifdef LOCK_FILE #ifdef LOCK_FILE
int int
make_lockfile(void) make_lockfile(void)
{ {
int fd; int fd;
fd = open(lock_file, O_CREAT | O_EXCL, 0600); fd = open(lock_file, O_CREAT | O_EXCL, 0600);
if (fd < 0) return ERROR; if (fd < 0)
return ERROR;
close(fd); close(fd);
return 0; return 0;
} }
int int
erase_lockfile(void) erase_lockfile(void)
{ {
@ -80,18 +72,13 @@ erase_lockfile (void)
#endif #endif
static int static int
signal_handler (sig, code, scp) signal_handler(int sig, int code, struct sigcontext *scp)
int sig;
int code;
struct sigcontext *scp;
{ {
warning_out("signal %d, code %d catched.", sig, code); warning_out("signal %d, code %d catched.", sig, code);
} }
static int terminate_handler(sig, code, scp) static int
int sig; terminate_handler(int sig, int code, struct sigcontext *scp)
int code;
struct sigcontext *scp;
{ {
close_socket(); close_socket();
sj_closeall(); sj_closeall();
@ -112,8 +99,6 @@ server_terminate (void)
exit(0); exit(0);
} }
static void static void
exec_fork(void) exec_fork(void)
{ {
@ -123,8 +108,7 @@ exec_fork (void)
if (tmp < 0) { if (tmp < 0) {
fprintf(stderr, "Can't fork child process\r\n"); fprintf(stderr, "Can't fork child process\r\n");
fflush(stderr); fflush(stderr);
} } else {
else {
signal(SIGCHLD, _exit); signal(SIGCHLD, _exit);
signal(SIGHUP, SIG_IGN); signal(SIGHUP, SIG_IGN);
signal(SIGINT, SIG_IGN); signal(SIGINT, SIG_IGN);
@ -138,7 +122,6 @@ exec_fork (void)
signal(SIGHUP, (void (*)())signal_handler); signal(SIGHUP, (void (*)())signal_handler);
signal(SIGINT, (void (*)())terminate_handler); signal(SIGINT, (void (*)())terminate_handler);
signal(SIGQUIT, (void (*)())signal_handler); signal(SIGQUIT, (void (*)())signal_handler);
signal(SIGTERM, (void (*)())terminate_handler); signal(SIGTERM, (void (*)())terminate_handler);
@ -146,8 +129,6 @@ exec_fork (void)
signal(SIGTSTP, SIG_IGN); signal(SIGTSTP, SIG_IGN);
} }
static void static void
leave_tty(void) leave_tty(void)
{ {
@ -159,7 +140,8 @@ leave_tty (void)
kill(getppid(), SIGTERM); kill(getppid(), SIGTERM);
fclose(stdin); fclose(stdin);
fclose(stdout); fclose(stdout);
if (!tmp) fclose(stderr); if (!tmp)
fclose(stderr);
if (fork_flag) { if (fork_flag) {
if ((tmp = open("/dev/tty", O_RDWR)) >= 0) { if ((tmp = open("/dev/tty", O_RDWR)) >= 0) {
@ -169,14 +151,13 @@ leave_tty (void)
} }
} }
int int
main(int argc, char **argv) main(int argc, char **argv)
{ {
#ifndef __NetBSD__ #ifndef __NetBSD__
if (setuid(geteuid())) { if (setuid(geteuid())) {
fprintf(stderr, "error at setuid.\r\n"); exit(1); fprintf(stderr, "error at setuid.\r\n");
exit(1);
} }
#endif #endif
@ -186,7 +167,8 @@ main (int argc, char **argv)
#ifdef LOCK_FILE #ifdef LOCK_FILE
if (make_lockfile() == ERROR) { if (make_lockfile() == ERROR) {
fprintf(stderr, "Already running...\r\n"); exit(1); fprintf(stderr, "Already running...\r\n");
exit(1);
} }
#endif #endif

6
sj3serv/time_stamp.c
View file

@ -28,10 +28,4 @@
* from Sony Corporation. * from Sony Corporation.
*/ */
char *time_stamp = "Mon Mar 23 16:42:59 JST 1998"; char *time_stamp = "Mon Mar 23 16:42:59 JST 1998";

5
sj3serv/version.c
View file

@ -28,9 +28,4 @@
* from Sony Corporation. * from Sony Corporation.
*/ */
char *version_number = "2.08C"; char *version_number = "2.08C";