version 1.2, 1999/11/02 06:11:57 |
version 1.12, 2000/01/22 06:29:17 |
|
|
/* -*- mode: C; coding: euc-japan -*- */ |
/* -*- mode: C; coding: euc-japan -*- */ |
/* $OpenXM$ */ |
/* $OpenXM: OpenXM/src/ox_math/math2ox.c,v 1.11 2000/01/20 15:32:21 ohara Exp $ */ |
/* $Id$ */ |
|
|
|
|
/* |
|
Copyright (C) Katsuyoshi OHARA, 2000. |
|
Portions copyright 1999 Wolfram Research, Inc. |
|
|
|
You must see OpenXM/Copyright/Copyright.generic. |
|
The MathLink Library is licensed from Wolfram Research Inc.. |
|
See OpenXM/Copyright/Copyright.mathlink for detail. |
|
*/ |
|
|
#include <sys/types.h> |
#include <sys/types.h> |
#include <sys/stat.h> |
#include <sys/stat.h> |
#include <fcntl.h> |
#include <fcntl.h> |
|
|
#include <mathlink.h> |
#include <mathlink.h> |
#include <unistd.h> |
#include <unistd.h> |
#include <signal.h> |
#include <signal.h> |
|
#include <mathlink.h> |
|
|
#include "ox.h" |
#include "ox.h" |
|
#include "parse.h" |
|
#include "serv2.h" |
|
|
static char *host = "localhost"; |
static char *host = "localhost"; |
static char *ctlserv = "ox"; |
static char *ctlserv = "ox"; |
static char *oxprog = "ox_sm1"; |
static char *oxprog = "ox_sm1"; |
|
|
ox_file_t sv; |
ox_file_t sv; |
|
static ox_file_t *svs = NULL; |
|
static int len_svs = 0; |
|
static int max_process = 0; |
|
|
/* Mathematica から直接呼び出される関数の定義. */ |
/* The following functions are called from Mathematica. |
/* 呼び出しの方法は math2ox.tm で定義される. */ |
See math2.tm for detail. */ |
int OX_executeStringByLocalParser(const char *str) |
void OX_get() |
{ |
{ |
ox_executeStringByLocalParser(sv, str); |
cmo *c = NULL; |
|
|
|
receive_ox_tag(sv->stream); |
|
c = receive_cmo(sv->stream); |
|
#ifdef DEBUG |
|
fprintf(stderr, "ox message is received in OxGet[].\n"); |
|
print_cmo(c); |
|
fflush(stderr); |
|
#endif |
|
send_mlo(c); |
|
ml_flush(); |
|
} |
|
|
|
int OX_execute_string(const char *str) |
|
{ |
|
ox_execute_string(sv, str); |
return 0; |
return 0; |
} |
} |
|
|
char *OX_popString() |
char *OX_popString() |
{ |
{ |
return ox_popString(sv, sv->stream); |
return ox_popString(sv); |
} |
} |
|
|
|
void OX_popCMO() |
|
{ |
|
cmo *c = ox_pop_cmo(sv); |
|
send_mlo(c); |
|
ml_flush(); |
|
} |
|
|
int OX_close() |
int OX_close() |
{ |
{ |
ox_close(sv); |
ox_close(sv); |
|
|
return 0; |
return 0; |
} |
} |
|
|
|
/* Parsing s and sending its cmo to an OX server. */ |
|
int OX_parse(char *s) |
|
{ |
|
cmo *m; |
|
symbol *symp; |
|
int len = strlen(s); |
|
init_parser(s); |
|
|
|
if(s != NULL && len > 0 && (m = parse()) != NULL) { |
|
if (m->tag == OX_DATA) { |
|
send_ox_cmo(sv->stream, ((ox_data *)m)->cmo); |
|
}else if (m->tag == OX_COMMAND) { |
|
send_ox_command(sv->stream, ((ox_command *)m)->command); |
|
}else { |
|
send_ox_cmo(sv->stream, m); |
|
} |
|
return 0; |
|
} |
|
return -1; /* if we failed. */ |
|
} |
|
|
int OX_start(char* s) |
int OX_start(char* s) |
{ |
{ |
if (s != NULL && s[0] != '\0') { |
if (s != NULL && s[0] != '\0') { |
oxprog = s; |
oxprog = s; |
} |
} |
sv = ox_start(host, ctlserv, oxprog); |
if (++max_process < len_svs) { |
fprintf(stderr, "open (%s)\n", "localhost"); |
sv = ox_start(host, ctlserv, oxprog); |
|
fprintf(stderr, "open (%s)\n", "localhost"); |
|
svs[max_process] = sv; |
|
return max_process; |
|
} |
|
return -1; |
|
} |
|
|
|
int OX_start_remote_ssh(char *s, char *host) |
|
{ |
|
if (s != NULL && s[0] != '\0') { |
|
oxprog = s; |
|
} |
|
if (host != NULL || host[0] == '\0') { |
|
host = "localhost"; |
|
} |
|
if (++max_process < len_svs) { |
|
sv = ox_start_remote_with_ssh(oxprog, host); |
|
fprintf(stderr, "open (%s)\n", host); |
|
svs[max_process] = sv; |
|
return max_process; |
|
} |
|
return -1; |
|
} |
|
|
|
int OX_start_insecure(char *host, int portCtl, int portDat) |
|
{ |
|
if (host != NULL || host[0] == '\0') { |
|
host = "localhost"; |
|
} |
|
if (portCtl == 0) { |
|
portCtl = 1200; |
|
} |
|
if (portDat == 0) { |
|
portDat = 1300; |
|
} |
|
|
|
sv = ox_start_insecure_nonreverse(host, portCtl, portDat); |
|
fprintf(stderr, "math2ox :: connect to \"%s\" with (ctl, dat) = (%d, %d)\n", host, portCtl, portDat); |
|
|
return 0; |
return 0; |
} |
} |
|
|
Line 73 int OX_setClientParam(char *h, char* c, char* p) |
|
Line 168 int OX_setClientParam(char *h, char* c, char* p) |
|
|
|
int main(int argc, char *argv[]) |
int main(int argc, char *argv[]) |
{ |
{ |
|
/* setting the OX parser */ |
|
setflag_parse(PFLAG_ADDREV); |
|
len_svs = 20; |
|
svs = (ox_file_t *)malloc(sizeof(ox_file_t)*len_svs); |
|
|
MLMain(argc, argv); |
MLMain(argc, argv); |
} |
} |