Return to tcpf_win_mini.c CVS log

Up to [local] / OpenXM_contrib2 / asir2000 / io

Adding functions to show error details.

/* $OpenXM: OpenXM_contrib2/asir2000/io/tcpf_win_mini.c,v 1.3 2006/09/29 09:02:49 noro Exp $ */

#include "ca.h"
#include "parse.h"
#include "com.h"
#include <signal.h>
#include <string.h>
#include "ox.h"
#include <stdlib.h>
#include <winsock2.h>
#include <process.h>
static int control_port,server_port;
int win_ox_launch();
void win_spawn_server(char *control_port_str,char *server_port_str);
void win_get_rootdir();
int win_pop_string(Obj *);
void free_obj(Obj obj);
extern int terminate;
static char rootdir[BUFSIZ];

int win_ox_launch()
{
	int cs,ss,cn,sn;
	char control_port_str[BUFSIZ];
	char server_port_str[BUFSIZ];
	static int launched=0;

	if ( launched ) return 0;

	control_port_str[0] = 0;
	server_port_str[0] = 0;
	do { 
		generate_port(0,control_port_str);
		generate_port(0,server_port_str);
		cs = try_bind_listen(0,control_port_str);
		if ( cs < 0 ) continue;
		ss = try_bind_listen(0,server_port_str);
		if ( ss < 0 ) continue;
		win_spawn_server(control_port_str,server_port_str);
		cs = try_accept(0,cs);
		if ( cs < 0 ) continue;
		ss = try_accept(0,ss);
		if ( ss < 0 ) continue;
	} while ( cs < 0 || ss < 0 );

	/* client mode */
	cn = get_iofp(cs,control_port_str,0);
	sn = get_iofp(ss,server_port_str,0);
	/* get_iofp returns -1 if the laucher could not spawn the server */
	if ( sn < 0 ) {
		/* we should terminate the launcher */
		ox_send_cmd(cn,SM_shutdown); ox_flush_stream_force(cn);
		return -1;
	}

	/* register server to the server list */
	control_port = cn;
	server_port = sn;
	launched = 1;
	return 0;
}

void win_get_rootdir();

void win_spawn_server(char *control_port_str,char *server_port_str)
{
	char AsirExe[BUFSIZ];
	char AsirExePath[BUFSIZ];
	char *av[BUFSIZ];

//	strcpy(rootdir,"c:\\program files\\asir");
//	sprintf(AsirExe,"%s\\bin\\engine.exe",rootdir);
	sprintf(AsirExe,"c:\\Program Files\\asir\\bin\\engine.exe",rootdir);
	sprintf(AsirExePath,"\"%s\"",AsirExe);
	av[0] = "ox_launch";
	av[1] = "127.0.0.1";
	av[2] = "0";
	av[3] = control_port_str;
	av[4] = server_port_str;
	av[5] = "ox_asir_wfep";
	av[6] = "1";
	av[7] = AsirExePath;
	av[8] = 0;

	_spawnv(_P_NOWAIT,AsirExe,av);
}

void win_get_rootdir()
{
	char *slash;

	GetCurrentDirectory(BUFSIZ,rootdir);
	slash = strrchr(rootdir,'\\');
	if ( slash ) *slash = 0;
}

// ret=1 : data, ret=0 : void, ret=-1 : terminate

int win_pop_string(Obj *obj)
{
	int id,serial;

	serial = ox_recv(server_port,&id,obj);
	if ( serial < 0 ) return -1;

	if ( id == OX_DATA )
		return 1;
	else {
		if ( id == OX_SYNC_BALL ) {
			ox_send_sync(server_port);
			ox_flush_stream_force(server_port);
		}
		*obj = 0;
		return 0;
	}
}

/* ret=1 => data, ret=0 => void, ret=-1 => terminated */

int win_pop_one(Obj *obj)
{
	int id,serial;

	serial = ox_recv(server_port,&id,obj);
	if ( serial < 0 ) return -1;

	if ( id == OX_DATA ) {
		return 1;
	} else if ( id == OX_SYNC_BALL ) {
		ox_send_sync(server_port);
		ox_flush_stream_force(server_port);
		return 0;
	} else return 0;
}

void win_execute_string(char *cmd)
{
	struct oSTRING str;

	OID(&str) = O_STR;
	BDY(&str) = cmd;
	ox_send_data(server_port,&str);
	ox_send_cmd(server_port,SM_executeStringByLocalParser);
	ox_send_cmd(server_port,SM_popString);
	ox_flush_stream_force(server_port);
}

void ox_reset()
{
	USINT t;
	int id;
	Obj obj;

	ox_send_cmd(control_port,SM_control_reset_connection);
	ox_flush_stream_force(control_port);
	ox_recv(control_port,&id,&obj); t = (USINT)obj;
	Sleep(100);
	ox_send_cmd(server_port,SM_nop);
	ox_flush_stream_force(server_port);
}

void ox_shutdown()
{
	terminate = 1;
	ox_send_cmd(server_port,SM_shutdown);
	Sleep(100);
	ox_send_cmd(control_port,SM_shutdown);
}

void free_obj(Obj obj)
{
	NODE n,n1;

	if ( !obj ) return;
	switch ( OID(obj) ) {
		case O_USINT:
			break;
		case O_STR:
			free(BDY((STRING)obj));
			break;
		case O_LIST:
			n = BDY((LIST)obj);
			while ( n ) {
				free_obj(BDY(n));
				n1 = NEXT(n);
				free(n);
				n = n1;
			}
			break;
		case O_ERR:
			free_obj(BDY((LIST)obj));
			break;
		default:
			break;
	}
	free(obj);
}