Newer
Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
/* xtrn.cpp */
/* Synchronet external program support routines */
/* $Id$ */
/****************************************************************************
* @format.tab-size 4 (Plain Text/Source Code File Header) *
* @format.use-tabs true (see http://www.synchro.net/ptsc_hdr.html) *
* *
* Copyright 2000 Rob Swindell - http://www.synchro.net/copyright.html *
* *
* This program is free software; you can redistribute it and/or *
* modify it under the terms of the GNU General Public License *
* as published by the Free Software Foundation; either version 2 *
* of the License, or (at your option) any later version. *
* See the GNU General Public License for more details: gpl.txt or *
* http://www.fsf.org/copyleft/gpl.html *
* *
* Anonymous FTP access to the most recent released source is available at *
* ftp://vert.synchro.net, ftp://cvs.synchro.net and ftp://ftp.synchro.net *
* *
* Anonymous CVS access to the development source and modification history *
* is available at cvs.synchro.net:/cvsroot/sbbs, example: *
* cvs -d :pserver:anonymous@cvs.synchro.net:/cvsroot/sbbs login *
* (just hit return, no password is necessary) *
* cvs -d :pserver:anonymous@cvs.synchro.net:/cvsroot/sbbs checkout src *
* *
* For Synchronet coding style and modification guidelines, see *
* http://www.synchro.net/source.html *
* *
* You are encouraged to submit any modifications (preferably in Unix diff *
* format) via e-mail to mods@synchro.net *
* *
* Note: If this box doesn't appear square, then you need to fix your tabs. *
****************************************************************************/
#include "sbbs.h"
#include "cmdshell.h"
#include "telnet.h"
#ifdef __unix__
#include <sys/wait.h> // WEXITSTATUS
#endif

rswindell
committed
#define XTRN_IO_BUF_LEN 5000
/*****************************************************************************/
/* Interrupt routine to expand WWIV Ctrl-C# codes into ANSI escape sequences */
/*****************************************************************************/
BYTE* wwiv_expand(BYTE* buf, ulong buflen, BYTE* outbuf, ulong& newlen
,ulong user_misc, bool& ctrl_c)
{
char ansi_seq[32];
ulong i,j,k;
for(i=j=0;i<buflen;i++) {
if(buf[i]==CTRL_C) { /* WWIV color escape char */
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
ctrl_c=true;
continue;
}
if(!ctrl_c) {
outbuf[j++]=buf[i];
continue;
}
ctrl_c=false;
if(user_misc&ANSI) {
switch(buf[i]) {
default:
strcpy(ansi_seq,"\x1b[0m"); /* low grey */
break;
case '1':
strcpy(ansi_seq,"\x1b[0;1;36m"); /* high cyan */
break;
case '2':
strcpy(ansi_seq,"\x1b[0;1;33m"); /* high yellow */
break;
case '3':
strcpy(ansi_seq,"\x1b[0;35m"); /* low magenta */
break;
case '4':
strcpy(ansi_seq,"\x1b[0;1;44m"); /* white on blue */
break;
case '5':
strcpy(ansi_seq,"\x1b[0;32m"); /* low green */
break;
case '6':
strcpy(ansi_seq,"\x1b[0;1;5;31m"); /* high blinking red */
break;
case '7':
strcpy(ansi_seq,"\x1b[0;1;34m"); /* high blue */
break;
case '8':
strcpy(ansi_seq,"\x1b[0;34m"); /* low blue */
break;
case '9':
strcpy(ansi_seq,"\x1b[0;36m"); /* low cyan */
break;
}
for(k=0;ansi_seq[k];k++)
outbuf[j++]=ansi_seq[k];
}
}
newlen=j;
return(outbuf);
}
/*****************************************************************************/
// Escapes Telnet IAC (255) by doubling the IAC char
/*****************************************************************************/
BYTE* telnet_expand(BYTE* inbuf, ulong inlen, BYTE* outbuf, ulong& newlen)
{
BYTE* first_iac;
ulong i,outlen;
first_iac=(BYTE*)memchr(inbuf, TELNET_IAC, inlen);
if(first_iac==NULL) { /* Nothing to expand */
newlen=inlen;
return(inbuf);
}
outlen=first_iac-inbuf;
memcpy(outbuf, inbuf, outlen);
for(i=outlen;i<inlen;i++) {
if(inbuf[i]==TELNET_IAC)
outbuf[outlen++]=inbuf[i];
}
newlen=outlen;
return(outbuf);
}
#define XTRN_LOADABLE_MODULE \
if(cmdline[0]=='*') { /* Baja module or JavaScript */ \
sprintf(str,"%.*s",sizeof(str)-1,cmdline+1); \
p=strchr(str,SP); \
if(p) { \
strcpy(main_csi.str,p+1); \
*p=0; \
} else \
main_csi.str[0]=0; \
if(!strchr(str,'.')) \
strcat(str,".bin"); \
return(exec_bin(str,&main_csi)); \
}
#ifdef JAVASCRIPT
#define XTRN_LOADABLE_JS_MODULE \
if(cmdline[0]=='?') /* JavaScript */ \
return(js_execfile(cmdline+1))
#else
#define XTRN_LOADABLE_JS_MODULE
#endif
#ifdef _WIN32
#include "execvxd.h" /* Win9X FOSSIL VxD API */
extern SOCKET node_socket[];
// -------------------------------------------------------------------------
// GetAddressOfOpenVxDHandle
//
// This function returns the address of OpenVxDHandle. OpenVxDHandle is a
// KERNEL32 function that returns a ring 0 event handle that corresponds to a
// given ring 3 event handle. The ring 0 handle can be used by VxDs to
// synchronize with the Win32 app.
//
typedef HANDLE (WINAPI *OPENVXDHANDLE)(HANDLE);
OPENVXDHANDLE GetAddressOfOpenVxDHandle(void)
if ((hK32 = LoadLibrary("KERNEL32")) == NULL)
return((OPENVXDHANDLE)GetProcAddress(hK32, "OpenVxDHandle"));
/* Clean-up resources while preserving current LastError value */
#define XTRN_CLEANUP \
last_error=GetLastError(); \
if(vxd!=INVALID_HANDLE_VALUE) CloseHandle(vxd); \
if(rdslot!=INVALID_HANDLE_VALUE) CloseHandle(rdslot); \
if(wrslot!=INVALID_HANDLE_VALUE) CloseHandle(wrslot); \
if(start_event!=NULL) CloseHandle(start_event); \
if(hungup_event!=NULL) CloseHandle(hungup_event); \
ReleaseMutex(exec_mutex); \
SetLastError(last_error)
/****************************************************************************/
/* Runs an external program */
/****************************************************************************/
int sbbs_t::external(char* cmdline, long mode, char* startup_dir)
{
char str[256],*p,*p_startup_dir;
char fname[128];
char fullcmdline[256];
char realcmdline[256];
char comspec_str[128];
char title[256];
BYTE buf[XTRN_IO_BUF_LEN],*bp;
BYTE telnet_buf[XTRN_IO_BUF_LEN*2];
BYTE wwiv_buf[XTRN_IO_BUF_LEN*2];
bool wwiv_flag=false;

rswindell
committed
bool native=false; // DOS program by default
bool nt=false; // WinNT/2K?

rswindell
committed
bool rio_abortable_save;
uint i;
time_t hungup=0;
HANDLE vxd=INVALID_HANDLE_VALUE;
HANDLE rdslot=INVALID_HANDLE_VALUE;
HANDLE wrslot=INVALID_HANDLE_VALUE;
HANDLE start_event=NULL;
HANDLE hungup_event=NULL;
PROCESS_INFORMATION process_info;
DWORD hVM;
DWORD rd;
DWORD wr;
DWORD len;
DWORD avail;
DWORD dummy;
DWORD retval;
DWORD last_error;
DWORD loop_since_io=0;
struct tm * tm_p;
sbbsexec_start_t start;
OPENVXDHANDLE OpenVxDHandle;
if(online==ON_LOCAL)
eprintf("Executing external: %s",cmdline);
XTRN_LOADABLE_MODULE;
XTRN_LOADABLE_JS_MODULE;
attr(cfg.color[clr_external]); /* setup default attributes */
strcpy(str,cmdline); /* Set str to program name only */
p=strchr(str,SP);
if(p) *p=0;
strcpy(fname,str);
p=strrchr(fname,'/');
if(!p) p=strrchr(fname,'\\');
if(!p) p=strchr(fname,':');
if(!p) p=fname;
else p++;
for(i=0;i<cfg.total_natvpgms;i++)
if(!stricmp(p,cfg.natvpgm[i]->name))
break;
if(i<cfg.total_natvpgms || mode&EX_NATIVE)
native=true;
if(mode&EX_SH || strcspn(cmdline,"<>|")!=strlen(cmdline))
sprintf(comspec_str,"%s /C ", comspec);
else
comspec_str[0]=0;
if(startup_dir && cmdline[1]!=':' && cmdline[0]!='/'
&& cmdline[0]!='\\' && cmdline[0]!='.')
sprintf(fullcmdline, "%s%s%s", comspec_str, startup_dir, cmdline);
else
sprintf(fullcmdline, "%s%s", comspec_str, cmdline);
strcpy(realcmdline, fullcmdline); // for errormsg if failed to execute
now=time(NULL);
tm_p=gmtime(&now);

rswindell
committed
if((retval=WaitForSingleObject(exec_mutex,5000))!=WAIT_OBJECT_0) {
errormsg(WHERE, ERR_TIMEOUT, "exec_mutex", retval);
return(GetLastError());
}
if(native) { // Native (32-bit) external
// Current environment passed to child process
sprintf(dszlog,"DSZLOG=%sPROTOCOL.LOG",cfg.node_dir);
if(putenv(dszlog)) /* Makes the DSZ LOG active */
errormsg(WHERE,ERR_WRITE,"environment",0);
sprintf(sbbsnode,"SBBSNODE=%s",cfg.node_dir);
putenv(sbbsnode); /* create environment var to contain node path */
sprintf(sbbsnnum,"SBBSNNUM=%d",cfg.node_num);
putenv(sbbsnnum); /* create environment var to contain node num */
sprintf(sbbsctrl,"SBBSCTRL=%s",cfg.ctrl_dir);
putenv(sbbsctrl);
} else { // DOS external
sprintf(str,"%sDOSXTRN.RET", cfg.node_dir);
remove(str);
// Create temporary environment file
sprintf(str,"%sDOSXTRN.ENV", cfg.node_dir);
FILE* fp=fopen(str,"w");
if(fp==NULL) {

rswindell
committed
XTRN_CLEANUP;
errormsg(WHERE, ERR_CREATE, str, 0);
}
fprintf(fp, "%s\n", fullcmdline);
fprintf(fp, "DSZLOG=%sPROTOCOL.LOG\n", cfg.node_dir);
fprintf(fp, "SBBSCTRL=%s\n", cfg.ctrl_dir);
fprintf(fp, "SBBSNODE=%s\n", cfg.node_dir);
fprintf(fp, "SBBSNNUM=%d\n", cfg.node_num);
if(tm_p!=NULL) {

rswindell
committed
fprintf(fp, "DAY=%02u\n", tm_p->tm_mday);
fprintf(fp, "WEEKDAY=%s\n",wday[tm_p->tm_wday]);
fprintf(fp, "MONTHNAME=%s\n",mon[tm_p->tm_mon]);

rswindell
committed
fprintf(fp, "MONTH=%02u\n",tm_p->tm_mon+1);
fprintf(fp, "YEAR=%u\n",1900+tm_p->tm_year);
}
fclose(fp);
sprintf(fullcmdline, "%sDOSXTRN.EXE %s", cfg.exec_dir, str);
OpenVxDHandle=GetAddressOfOpenVxDHandle();
if(!(mode&EX_OFFLINE) && OpenVxDHandle==NULL) { // Windows NT/2000
nt=true;
i=SBBSEXEC_MODE_FOSSIL;
if(mode&EX_INR)
i|=SBBSEXEC_MODE_DOS_IN;
if(mode&EX_OUTR)
i|=SBBSEXEC_MODE_DOS_OUT;

rswindell
committed
sprintf(str," NT %u %u %u"
,cfg.node_num,i,startup->xtrn_polls_before_yield);
strcat(fullcmdline,str);
sprintf(str,"sbbsexec_hungup%d",cfg.node_num);
if((hungup_event=CreateEvent(
NULL // pointer to security attributes
,TRUE // flag for manual-reset event
,FALSE // flag for initial state
,str // pointer to event-object name
))==NULL) {
errormsg(WHERE, ERR_CREATE, "exec start event", 0);
return(GetLastError());
}
sprintf(str,"\\\\.\\mailslot\\sbbsexec\\rd%d"
,cfg.node_num);
rdslot=CreateMailslot(str
,sizeof(buf) // Maximum message size (0=unlimited)
,0 // Read time-out
,NULL); // Security
if(rdslot==INVALID_HANDLE_VALUE) {
errormsg(WHERE, ERR_CREATE, str, 0);
return(GetLastError());
}
}
else if(!(mode&EX_OFFLINE)) {
// Load vxd to intercept interrupts
sprintf(str,"\\\\.\\%s%s",cfg.exec_dir, SBBSEXEC_VXD);
if((vxd=CreateFile(str,0,0,0
,CREATE_NEW, FILE_FLAG_DELETE_ON_CLOSE,0))
==INVALID_HANDLE_VALUE) {
errormsg(WHERE, ERR_OPEN, str, 0);
return(GetLastError());
}
if((start_event=CreateEvent(
NULL // pointer to security attributes
,TRUE // flag for manual-reset event
,FALSE // flag for initial state
,NULL // pointer to event-object name
))==NULL) {
errormsg(WHERE, ERR_CREATE, "exec start event", 0);
return(GetLastError());
}
if(OpenVxDHandle!=NULL)
start.event=OpenVxDHandle(start_event);
else
start.event=start_event;
start.mode=SBBSEXEC_MODE_FOSSIL;
if(mode&EX_INR)
start.mode|=SBBSEXEC_MODE_DOS_IN;
if(mode&EX_OUTR)
start.mode|=SBBSEXEC_MODE_DOS_OUT;

rswindell
committed
sprintf(str," 95 %u %u %u"
,cfg.node_num,start.mode,startup->xtrn_polls_before_yield);

rswindell
committed
strcat(fullcmdline,str);
if(!DeviceIoControl(
vxd, // handle to device of interest
SBBSEXEC_IOCTL_START, // control code of operation to perform
&start, // pointer to buffer to supply input data
sizeof(start), // size of input buffer
NULL, // pointer to buffer to receive output data
0, // size of output buffer
&rd, // pointer to variable to receive output byte count
NULL // Overlapped I/O
)) {
errormsg(WHERE, ERR_IOCTL, SBBSEXEC_VXD, SBBSEXEC_IOCTL_START);
return(GetLastError());
}
}
}
if(startup_dir!=NULL && startup_dir[0])
p_startup_dir=startup_dir;
else
p_startup_dir=NULL;
STARTUPINFO startup_info={0};
startup_info.cb=sizeof(startup_info);
if(mode&EX_OFFLINE)
startup_info.lpTitle=NULL;
else {
sprintf(title,"%s running %s on node %d"
,useron.number ? useron.alias : "Event"
,realcmdline
,cfg.node_num);
startup_info.lpTitle=title;
}
if(startup->options&BBS_OPT_XTRN_MINIMIZED) {
startup_info.wShowWindow=SW_SHOWMINNOACTIVE;
startup_info.dwFlags|=STARTF_USESHOWWINDOW;
}
if(native && !(mode&EX_OFFLINE)) {
FILE* fp;
sprintf(fname,"%sDOOR32.SYS",cfg.node_dir);
fp=fopen(fname,"wb");
fprintf(fp,"2\r\n%d\r\n38400\r\n%s%c\r\n%d\r\n%s\r\n%s\r\n%d\r\n%d\r\n"
"%d\r\n%d\r\n"
,client_socket_dup
,VERSION_NOTICE,REVISION
,useron.number
,useron.name
,useron.alias
,useron.level
,timeleft/60
,useron.misc&ANSI ? 1 : 0
,cfg.node_num);
fclose(fp);
/* not temporary */
pthread_mutex_lock(&input_thread_mutex);
}
if(!CreateProcess(
NULL, // pointer to name of executable module
fullcmdline, // pointer to command line string
NULL, // process security attributes
NULL, // thread security attributes
native && !(mode&EX_OFFLINE), // handle inheritance flag
CREATE_NEW_CONSOLE/*|CREATE_SEPARATE_WOW_VDM*/, // creation flags
NULL, // pointer to new environment block
p_startup_dir, // pointer to current directory name
&startup_info, // pointer to STARTUPINFO
&process_info // pointer to PROCESS_INFORMATION
)) {
if(native && !(mode&EX_OFFLINE))
pthread_mutex_unlock(&input_thread_mutex);
SetLastError(last_error); /* Restore LastError */
errormsg(WHERE, ERR_EXEC, realcmdline, mode);
return(GetLastError());
}

rswindell
committed
#if 0
char dbgstr[256];
sprintf(dbgstr,"Node %d created: hProcess %X hThread %X processID %X threadID %X\n"
,cfg.node_num
,process_info.hProcess
,process_info.hThread
,process_info.dwProcessId
,process_info.dwThreadId);
OutputDebugString(dbgstr);
#endif
if(!native) {
if(!(mode&EX_OFFLINE) && !nt) {
// Wait for notification from VXD that new VM has started
if((retval=WaitForSingleObject(start_event, 5000))!=WAIT_OBJECT_0) {
TerminateProcess(process_info.hProcess, __LINE__);
errormsg(WHERE, ERR_TIMEOUT, "start_event", retval);
return(GetLastError());
}
CloseHandle(start_event);
start_event=NULL; /* Mark as closed */
if(!DeviceIoControl(
vxd, // handle to device of interest
SBBSEXEC_IOCTL_COMPLETE, // control code of operation to perform
NULL, // pointer to buffer to supply input data
0, // size of input buffer
&hVM, // pointer to buffer to receive output data
sizeof(hVM), // size of output buffer
&rd, // pointer to variable to receive output byte count
NULL // Overlapped I/O
)) {
TerminateProcess(process_info.hProcess, __LINE__);
errormsg(WHERE, ERR_IOCTL, SBBSEXEC_VXD, SBBSEXEC_IOCTL_COMPLETE);
return(GetLastError());
}
}
}

rswindell
committed
ReleaseMutex(exec_mutex);
/* Disable Ctrl-C checking */

rswindell
committed
if(!(mode&EX_OFFLINE)) {
rio_abortable_save=rio_abortable;
rio_abortable=false;
}

rswindell
committed
// Executing app in foreground?, monitor

rswindell
committed
while(!(mode&EX_BG)) {
if(!online && !(mode&EX_OFFLINE)) { // Tell VXD/VDD and external that user hung-up
if(was_online) {
sprintf(str,"%s hung-up in external program",useron.alias);
logline("X!",str);
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
hungup=time(NULL);
if(!native) {
if(nt)
SetEvent(hungup_event);
else if(!DeviceIoControl(
vxd, // handle to device of interest
SBBSEXEC_IOCTL_DISCONNECT, // operation to perform
&hVM, // pointer to buffer to supply input data
sizeof(hVM),// size of input buffer
NULL, // pointer to buffer to receive output data
0, // size of output buffer
&rd, // pointer to variable to receive output byte count
NULL // Overlapped I/O
)) {
errormsg(WHERE, ERR_IOCTL, SBBSEXEC_VXD, SBBSEXEC_IOCTL_DISCONNECT);
break;
}
}
was_online=false;
}
if(hungup && time(NULL)-hungup>5)
TerminateProcess(process_info.hProcess, 2112);
}
if(native || mode&EX_OFFLINE) {
if(GetExitCodeProcess(process_info.hProcess, &retval)==FALSE) {
errormsg(WHERE, ERR_CHK, "ExitCodeProcess"
,(DWORD)process_info.hProcess);
break;
}
if(retval!=STILL_ACTIVE)
break;
Sleep(500);
} else {
if(nt) { // Windows NT/2000
/* Write to VDD */
wr=RingBufPeek(&inbuf,buf,sizeof(buf));
if(wr) {
if(wrslot==INVALID_HANDLE_VALUE) {
sprintf(str,"\\\\.\\mailslot\\sbbsexec\\wr%d"
,cfg.node_num);
wrslot=CreateFile(str
,GENERIC_WRITE
,FILE_SHARE_READ
,NULL
,OPEN_EXISTING
,FILE_ATTRIBUTE_NORMAL
,(HANDLE) NULL);
#if 0
if(wrslot==INVALID_HANDLE_VALUE) {
errormsg(WHERE,ERR_OPEN,str,0);
break;
}
#endif
}
if(wrslot!=INVALID_HANDLE_VALUE
&& WriteFile(wrslot,buf,wr,&len,NULL)==TRUE) {
RingBufRead(&inbuf, NULL, len);
wr=len;
} else // VDD not loaded yet
wr=0;
}
/* Read from VDD */
len=sizeof(buf);
avail=RingBufFree(&outbuf);
if(avail==0)
lprintf("!Node %d output buffer full (%u bytes)"
,cfg.node_num,RingBufFull(&outbuf));
if(avail>=RingBufFull(&outbuf)
&& ReadFile(rdslot,buf,len,&rd,NULL)==TRUE && rd>0) {
if(mode&EX_WWIV) {
bp=wwiv_expand(buf, rd, wwiv_buf, rd, useron.misc, wwiv_flag);
if(rd>sizeof(wwiv_buf))
errorlog("WWIV_BUF OVERRUN");
} else {
bp=telnet_expand(buf, rd, telnet_buf, rd);
if(rd>sizeof(telnet_buf))
errorlog("TELNET_BUF OVERRUN");
}
RingBufWrite(&outbuf, bp, rd);
sem_post(&output_sem);
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
}
} else { // Windows 9x
/* Write to VXD */
wr=RingBufPeek(&inbuf, buf+sizeof(hVM),sizeof(buf)-sizeof(hVM));
if(wr) {
*(DWORD*)buf=hVM;
wr+=sizeof(hVM);
if(!DeviceIoControl(
vxd, // handle to device of interest
SBBSEXEC_IOCTL_WRITE, // control code of operation to perform
buf, // pointer to buffer to supply input data
wr, // size of input buffer
&rd, // pointer to buffer to receive output data
sizeof(rd), // size of output buffer
&dummy, // pointer to variable to receive output byte count
NULL // Overlapped I/O
)) {
errormsg(WHERE, ERR_IOCTL, SBBSEXEC_VXD, SBBSEXEC_IOCTL_READ);
break;
}
RingBufRead(&inbuf, NULL, rd);
wr=rd;
}
/* Read from VXD */
rd=0;
len=sizeof(buf);
avail=RingBufFree(&outbuf);
if(avail==0)
lprintf("!Node %d output buffer full (%u bytes)"
,cfg.node_num,RingBufFull(&outbuf));
if(avail>=RingBufFull(&outbuf)) {
if(!DeviceIoControl(
vxd, // handle to device of interest
SBBSEXEC_IOCTL_READ, // control code of operation to perform
&hVM, // pointer to buffer to supply input data
sizeof(hVM), // size of input buffer
buf, // pointer to buffer to receive output data
len, // size of output buffer
&rd, // pointer to variable to receive output byte count
NULL // Overlapped I/O
)) {
errormsg(WHERE, ERR_IOCTL, SBBSEXEC_VXD, SBBSEXEC_IOCTL_READ);
break;
}
#if 0
if(rd>1)
lprintf("read %d bytes from xtrn", rd);
#endif
if(mode&EX_WWIV)
bp=wwiv_expand(buf, rd, wwiv_buf, rd, useron.misc, wwiv_flag);
else
bp=telnet_expand(buf, rd, telnet_buf, rd);
RingBufWrite(&outbuf, bp, rd);
sem_post(&output_sem);
}
}
if(!rd && !wr) {
if(++loop_since_io>=1000) {
if(GetExitCodeProcess(process_info.hProcess, &retval)==FALSE) {
errormsg(WHERE, ERR_CHK, "ExitCodeProcess"
,(DWORD)process_info.hProcess);
break;
}
if(retval!=STILL_ACTIVE) {
#if 0
if(hungup)
Sleep(5000); // Give the application time to close files
#endif
break;
}

rswindell
committed

rswindell
committed
OutputDebugString(".");
// Let's make sure the socket is up
// Sending will trigger a socket d/c detection
sprintf(str,"%c%c",TELNET_IAC,TELNET_GA);
putcom(str,2);
// Check if the node has been interrupted
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
getnodedat(cfg.node_num,&thisnode,0);
if(thisnode.misc&NODE_INTR)
break;
}
Sleep(1);
}
} else
loop_since_io=0;
}
}
if(!native && !(mode&EX_OFFLINE) && !nt) {
if(!DeviceIoControl(
vxd, // handle to device of interest
SBBSEXEC_IOCTL_STOP, // control code of operation to perform
&hVM, // pointer to buffer to supply input data
sizeof(hVM), // size of input buffer
NULL, // pointer to buffer to receive output data
0, // size of output buffer
&rd, // pointer to variable to receive output byte count
NULL // Overlapped I/O
)) {
errormsg(WHERE, ERR_IOCTL, SBBSEXEC_VXD, SBBSEXEC_IOCTL_STOP);
}
}
if(!(mode&EX_BG)) { /* !background execution */
if(retval==STILL_ACTIVE)
TerminateProcess(process_info.hProcess, GetLastError());
sprintf(str,"%sDOSXTRN.RET", cfg.node_dir);
FILE* fp=fopen(str,"r");
if(fp!=NULL) {
fscanf(fp,"%d",&retval);
fclose(fp);
}
}
XTRN_CLEANUP;
if(!(mode&EX_OFFLINE)) { /* !off-line execution */
if(native)
pthread_mutex_unlock(&input_thread_mutex);

rswindell
committed
curatr=0; // Can't guarantee current attributes

rswindell
committed
rio_abortable=rio_abortable_save; // Restore abortable state

rswindell
committed
/* Got back to Text/NVT mode */
sprintf(str,"%c%c%c",TELNET_IAC,TELNET_DONT,TELNET_BINARY);
putcom(str,3);
telnet_mode&=~TELNET_MODE_BIN_RX;
}
// lprintf("%s returned %d",realcmdline, retval);
errorlevel = retval; // Baja-retrievable error value

rswindell
committed
/*****************************************************************************/
// Expands Unix LF to CRLF
/*****************************************************************************/
BYTE* lf_expand(BYTE* inbuf, ulong inlen, BYTE* outbuf, ulong& newlen)
{
ulong i,j;
for(i=j=0;i<inlen;i++) {
if(inbuf[i]=='\n' && (!i || inbuf[i-1]!='\r'))
outbuf[j++]='\r';
outbuf[j++]=inbuf[i];
}
newlen=j;
return(outbuf);
}
#define MAX_ARGS 1000
int sbbs_t::external(char* cmdline, long mode, char* startup_dir)
{
char* argv[MAX_ARGS];

rswindell
committed
BYTE* bp;
BYTE buf[XTRN_IO_BUF_LEN];
BYTE output_buf[XTRN_IO_BUF_LEN*2];
ulong avail;

rswindell
committed
ulong output_len;
bool native=false; // DOS program by default

rswindell
committed
int rd;
int wr;

rswindell
committed
int argc;

rswindell
committed
int in_pipe[2];
int out_pipe[2];
XTRN_LOADABLE_MODULE;
XTRN_LOADABLE_JS_MODULE;
attr(cfg.color[clr_external]); /* setup default attributes */
strcpy(str,cmdline); /* Set str to program name only */
p=strchr(str,SP);
if(p) *p=0;
strcpy(fname,str);
p=strrchr(fname,'/');
if(!p) p=strrchr(fname,'\\');
if(!p) p=strchr(fname,':');
if(!p) p=fname;
else p++;
for(i=0;i<cfg.total_natvpgms;i++)
if(!stricmp(p,cfg.natvpgm[i]->name))
break;
if(i<cfg.total_natvpgms || mode&EX_NATIVE)
native=true;
if(!native) {
bprintf("\r\nExternal DOS programs are not yet supported in\r\n%s\r\n",VERSION_NOTICE);
return(-1);
}
if(native) { // Native (32-bit) external
// Current environment passed to child process
sprintf(dszlog,"DSZLOG=%sPROTOCOL.LOG",cfg.node_dir);
if(putenv(dszlog)) /* Makes the DSZ LOG active */
errormsg(WHERE,ERR_WRITE,"environment",0);
sprintf(sbbsnode,"SBBSNODE=%s",cfg.node_dir);
putenv(sbbsnode); /* create environment var to contain node num */
sprintf(sbbsnnum,"SBBSNNUM=%d",cfg.node_num);
putenv(sbbsnnum); /* create environment var to contain node num */
} else {
/* setup DOSemu env here */
}

rswindell
committed
if(!(mode&EX_INR))
pthread_mutex_lock(&input_thread_mutex);
#if 1
if(mode&EX_INR)
if(pipe(in_pipe)!=0) {
errormsg(WHERE,ERR_CREATE,"in_pipe",0);
return(-1);
}
#endif
if(mode&EX_OUTR)
if(pipe(out_pipe)!=0) {
errormsg(WHERE,ERR_CREATE,"out_pipe",0);
return(-1);
}
pthread_mutex_unlock(&input_thread_mutex);
errormsg(WHERE,ERR_EXEC,cmdline,0);

rswindell
committed
if(pid==0) { /* child process */
if(startup_dir!=NULL && startup_dir[0])
chdir(startup_dir);
lprintf("Node %d executing external: %s",cfg.node_num,cmdline);
if(mode&EX_SH || strcspn(cmdline,"<>|;")!=strlen(cmdline)) {
argv[0]=comspec;
argv[1]="-c";
argv[2]=cmdline;
argv[3]=NULL;
} else {
argv[0]=cmdline; /* point to the beginning of the string */
argc=1;
for(i=0;cmdline[i] && argc<MAX_ARGS;i++) /* Break up command line */
if(cmdline[i]==SP) {
cmdline[i]=0; /* insert nulls */
argv[argc++]=cmdline+i+1; /* point to the beginning of the next arg */
}
argv[argc]=NULL;
}

rswindell
committed
if(mode&EX_INR) {
close(in_pipe[1]); /* close write-end of pipe */
dup2(in_pipe[0],0); /* redirect stdin */
close(in_pipe[0]); /* close excess file descriptor */
}

rswindell
committed
if(mode&EX_OUTR) {

rswindell
committed
close(out_pipe[0]); /* close read-end of pipe */
dup2(out_pipe[1],1); /* stdout */
dup2(out_pipe[1],2); /* stderr */
close(out_pipe[1]); /* close excess file descriptor */

rswindell
committed
}
errormsg(WHERE,ERR_EXEC,argv[0],0);
exit(-1); /* should never get here */

rswindell
committed
if(mode&EX_OUTR) {
close(out_pipe[1]); /* close write-end of pipe */
while(!terminated) {

rswindell
committed
if(waitpid(pid, &i, WNOHANG)!=0) /* child exited */
break;
if(!online && !(mode&EX_OFFLINE)) {
sprintf(str,"%s hung-up in external program",useron.alias);
logline("X!",str);
break;
}

rswindell
committed
/* Input */
if(mode&EX_INR && RingBufFull(&inbuf)) {
if((wr=RingBufRead(&inbuf,buf,sizeof(buf)))!=0)
write(in_pipe[1],buf,wr);
}
/* Output */
ioctl(out_pipe[0],FIONREAD,&rd); /* peek at input */
if(!rd) {
mswait(1);
continue;
}
avail=RingBufFree(&outbuf);
if(avail==0) {
lprintf("!Node %d output buffer full (%u bytes)"
,cfg.node_num,RingBufFull(&outbuf));
mswait(1);
continue;
}
if(rd>avail)
rd=avail;
rd=sizeof(buf);
if((rd=read(out_pipe[0],buf,rd))<1) {

rswindell
committed
mswait(1);
continue;
}
if(mode&EX_BIN) /* telnet IAC expansion */
bp=telnet_expand(buf, rd, output_buf, output_len);

rswindell
committed
else /* LF to CRLF expansion */
bp=lf_expand(buf, rd, output_buf, output_len);
/* Does expanded size fit? */
if(output_len>RingBufFree(&outbuf)) {
lprintf("!Node %d output buffer overflow (%u bytes)"
,cfg.node_num,output_len);
mswait(1);
continue;
}

rswindell
committed
RingBufWrite(&outbuf, bp, output_len);
sem_post(&output_sem);
}
if(waitpid(pid, &i, WNOHANG)==0) { // Child still running?
kill(pid, SIGHUP); // Tell child user has hung up
time_t start=time(NULL); // Wait up to 10 seconds
while(time(NULL)-start<10) { // for child to terminate
if(waitpid(pid, &i, WNOHANG)!=0)
break;
mswait(500);
}
if(waitpid(pid, &i, WNOHANG)==0) // Child still running?
kill(pid, SIGKILL); // terminate child process
}
/* close unneeded descriptors */
if(mode&EX_INR)
close(in_pipe[1]);
close(out_pipe[0]);

rswindell
committed
}

rswindell
committed
if(!(mode&EX_BG)) /* !background execution, wait for child to terminate */
waitpid(pid, &i, 0);
pthread_mutex_unlock(&input_thread_mutex);
return(WEXITSTATUS(i));