version 1.7, 1999/11/19 20:51:36 |
version 1.9, 1999/12/14 09:31:55 |
|
|
/* -*- mode: C; coding: euc-japan -*- */ |
/* -*- mode: C; coding: euc-japan -*- */ |
/* $OpenXM: OpenXM/src/ox_math/math2ox.c,v 1.6 1999/11/07 12:12:55 ohara Exp $ */ |
/* $OpenXM: OpenXM/src/ox_math/math2ox.c,v 1.8 1999/11/29 12:09:57 ohara Exp $ */ |
|
|
#include <sys/types.h> |
#include <sys/types.h> |
#include <sys/stat.h> |
#include <sys/stat.h> |
Line 21 static char *ctlserv = "ox"; |
|
Line 21 static char *ctlserv = "ox"; |
|
static char *oxprog = "ox_sm1"; |
static char *oxprog = "ox_sm1"; |
|
|
ox_file_t sv; |
ox_file_t sv; |
MLINK lp; |
static ox_file_t *svs = NULL; |
|
static int len_svs = 0; |
|
static int max_process = 0; |
|
|
/* Mathematica から直接呼び出される関数の定義. */ |
/* Mathematica から直接呼び出される関数の定義. */ |
/* 呼び出しの方法は math2ox.tm で定義される. */ |
/* 呼び出しの方法は math2ox.tm で定義される. */ |
void OX_receive() |
void OX_get() |
{ |
{ |
cmo *c = NULL; |
cmo *c = NULL; |
|
|
receive_ox_tag(sv->stream); |
receive_ox_tag(sv->stream); |
c = receive_cmo(sv->stream); |
c = receive_cmo(sv->stream); |
#ifdef DEBUG |
#ifdef DEBUG |
fprintf(stderr, "received ox in OxReceive[].\n"); |
fprintf(stderr, "ox message is received in OxGet[].\n"); |
print_cmo(c); |
print_cmo(c); |
fflush(stderr); |
fflush(stderr); |
#endif |
#endif |
MATH_sendObject(c); |
send_mlo(c); |
|
ml_flush(); |
} |
} |
|
|
int OX_executeStringByLocalParser(const char *str) |
int OX_execute_string(const char *str) |
{ |
{ |
ox_executeStringByLocalParser(sv, 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() |
void OX_popCMO() |
{ |
{ |
cmo *c = ox_pop_cmo(sv, sv->stream); |
cmo *c = ox_pop_cmo(sv); |
MATH_sendObject(c); |
send_mlo(c); |
|
ml_flush(); |
} |
} |
|
|
int OX_close() |
int OX_close() |
Line 94 int OX_start(char* s) |
|
Line 98 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); |
lp = stdlink; |
fprintf(stderr, "open (%s)\n", "localhost"); |
return 0; |
svs[max_process] = sv; |
|
return max_process; |
|
} |
|
return -1; |
} |
} |
|
|
int OX_start_insecure(char *host, int portCtl, int portDat) |
int OX_start_insecure(char *host, int portCtl, int portDat) |
Line 115 int OX_start_insecure(char *host, int portCtl, int por |
|
Line 122 int OX_start_insecure(char *host, int portCtl, int por |
|
sv = ox_start_insecure_nonreverse(host, portCtl, portDat); |
sv = ox_start_insecure_nonreverse(host, portCtl, portDat); |
fprintf(stderr, "math2ox :: connect to \"%s\" with (ctl, dat) = (%d, %d)\n", host, portCtl, portDat); |
fprintf(stderr, "math2ox :: connect to \"%s\" with (ctl, dat) = (%d, %d)\n", host, portCtl, portDat); |
|
|
lp = stdlink; |
|
|
|
return 0; |
return 0; |
} |
} |
|
|
Line 140 int main(int argc, char *argv[]) |
|
Line 145 int main(int argc, char *argv[]) |
|
/* 構文解析器の設定 */ |
/* 構文解析器の設定 */ |
setflag_parse(PFLAG_ADDREV); |
setflag_parse(PFLAG_ADDREV); |
setgetc(mygetc); |
setgetc(mygetc); |
|
|
|
len_svs = 20; |
|
svs = (ox_file_t *)malloc(sizeof(ox_file_t)*len_svs); |
|
|
MLMain(argc, argv); |
MLMain(argc, argv); |
} |
} |