=================================================================== RCS file: /home/cvs/OpenXM/src/ox_toolkit/ox.c,v retrieving revision 1.2 retrieving revision 1.8 diff -u -p -r1.2 -r1.8 --- OpenXM/src/ox_toolkit/ox.c 1999/12/13 02:27:15 1.2 +++ OpenXM/src/ox_toolkit/ox.c 2000/01/19 19:46:42 1.8 @@ -1,38 +1,21 @@ /* -*- mode: C; coding: euc-japan -*- */ -/* $OpenXM: OpenXM/src/ox_toolkit/ox.c,v 1.1 1999/12/09 22:44:56 ohara Exp $ */ +/* $OpenXM: OpenXM/src/ox_toolkit/ox.c,v 1.7 2000/01/17 19:55:55 ohara Exp $ */ -/* -関数の名前付け規約(その2): -(1) receive_cmo 関数はCMOタグとデータ本体を受信する. この関数は CMOタグの -値が事前に分からないときに使用する. 返り値として、cmo へのポインタを返す. -(2) receive_cmo_XXX 関数は, CMOタグを親の関数で受信してから呼び出される関 -数で、データ本体のみを受信し、cmo_XXX へのポインタを返す. しかも、 -関数内部で new_cmo_XXX 関数を呼び出す. -(3) send_cmo 関数はCMOタグとデータ本体を送信する. -(4) send_cmo_XXX 関数はCMOタグを親の関数で送信してから呼び出される関数で、 -データ本体のみを送信する. - ----- -(5) receive_ox_XXX 関数は存在しない(作らない). receive_cmo を利用する. -(6) send_ox_XXX 関数は OX タグを含めて送信する. -(7) ox_XXX 関数は一連の送受信を含むより抽象的な操作を表現する. -ox_XXX 関数は、第一引数として、ox_file_t型の変数 sv をとる. - -(8) YYY_cmo 関数と YYY_cmo_XXX 関数の関係は次の通り: -まず YYY_cmo 関数で cmo のタグを処理し、タグを除いた残りの部分を -YYY_cmo_XXX 関数が処理する. cmo の内部に cmo_ZZZ へのポインタが -あるときには、その種類によらずに YYY_cmo 関数を呼び出す. +/* + This module includes functions for sending/receiveng CMO's. + Some commnets is written in Japanese by the EUC-JP coded + character set. */ + #include #include #include #include #include #include -#include -#include #include +#include #include "mysocket.h" #include "ox.h" @@ -60,7 +43,7 @@ static int dump_mpz(mpz_ptr mpz); static int login_with_otp(int fd, char* passwd); static char *create_otp(); -/* CMO_xxx の値順にならべること(デバッグのため) */ +/* CMO_xxx の値の順にならべること(デバッグのため) */ static cmo_null* receive_cmo_null(int fd); static cmo_int32* receive_cmo_int32(int fd); static cmo_string* receive_cmo_string(int fd); @@ -89,13 +72,23 @@ static int send_cmo_distributed_polynomial(in static void resize_mpz(mpz_ptr mpz, int size); +static int print_cmo_int32(cmo_int32* c); +static int print_cmo_list(cmo_list* li); +static int print_cmo_mathcap(cmo_mathcap* c); +static int print_cmo_string(cmo_string* c); + +static char* new_string_set_cmo_null(); +static char* new_string_set_cmo_int32(int integer); +static char* new_string_set_cmo_list(cmo_list *c); +static char* new_string_set_cmo_zz(cmo_zz *c); + int current_fd = 0; int set_current_fd(int fd) { current_fd = fd; } -/* hook 関数 */ +/* hook functions. (yet not implemented) */ static hook_t hook_before_send_cmo = NULL; static hook_t hook_after_send_cmo = NULL; @@ -125,10 +118,10 @@ static cmo *call_hook_after_send_cmo(int fd, cmo *c) return c; } -/* エラーハンドリングのため */ +/* Handling an error. */ static int current_received_serial = 0; -/* エラーを起こしたときにサーバは次を呼び出す. */ +/* If an error object be needed, then a server call the following function. */ cmo_error2* make_error_object(int err_code, cmo *ob) { cmo_list* li = new_cmo_list(); @@ -139,25 +132,24 @@ cmo_error2* make_error_object(int err_code, cmo *ob) return new_cmo_error2((cmo *)li); } -/* add at Mon Sep 7 15:51:28 JST 1998 */ #define DEFAULT_SERIAL_NUMBER 0x0000ffff #define receive_serial_number(x) (receive_int32(x)) -/* 新しいシリアル番号を得る */ +/* getting a next serial number. */ int next_serial() { static int serial_number = DEFAULT_SERIAL_NUMBER; return serial_number++; } -/* int32 型のオブジェクトを送信する. */ +/* sending an object of int32 type. (not equal to cmo_int32 type) */ int send_int32(int fd, int int32) { int32 = htonl(int32); return write(fd, &int32, sizeof(int)); } -/* int32 型のオブジェクトを受信する. */ +/* receiving an object of int32 type. (not equal to cmo_int32 type) */ int receive_int32(int fd) { int tag; @@ -165,7 +157,7 @@ int receive_int32(int fd) return ntohl(tag); } -/* (OX_tag, serial number) を受信する. */ +/* receiving an (OX_tag, serial number) */ int receive_ox_tag(int fd) { int serial; @@ -174,14 +166,14 @@ int receive_ox_tag(int fd) return tag; } -/* (OX_tag, serial number) を送信する. */ +/* sending an (OX_tag, serial number) */ int send_ox_tag(int fd, int tag) { send_int32(fd, tag); return send_int32(fd, next_serial()); } -/* CMO_LIST 関係の関数群 */ +/* functions for a cmo_list */ cell* new_cell() { cell* h = malloc(sizeof(cell)); @@ -212,12 +204,24 @@ int append_cmo_list(cmo_list* this, cmo* newcmo) return 0; } +cmo *nth_cmo_list(cmo_list* this, int n) +{ + cell *cp = this->head; + if(this->length <= n) { + return NULL; + } + while(n-- > 0) { + cp = cp->next; + } + return cp->cmo; +} + int length_cmo_list(cmo_list* this) { return this->length; } -/** receive_cmo_XXX 関数群 **/ +/* functions named receive_cmo_*. */ static cmo_null* receive_cmo_null(int fd) { return new_cmo_null(); @@ -293,7 +297,7 @@ static cmo_dms_generic* receive_cmo_dms_generic(int fd static cmo_ring_by_name* receive_cmo_ring_by_name(int fd) { cmo* ob = receive_cmo(fd); - /* 意味的チェックが必要 */ + /* We need to check semantics but yet ... */ return new_cmo_ring_by_name(ob); } @@ -391,7 +395,7 @@ static void resize_mpz(mpz_ptr mpz, int size) mpz->_mp_size = size; } -/** new_cmo_XXX 関数群 **/ +/* functions named new_cmo_*. */ cmo_null* new_cmo_null() { cmo_null* m = malloc(sizeof(cmo_null)); @@ -477,6 +481,13 @@ cmo_zz* new_cmo_zz_set_si(int i) return c; } +cmo_zz* new_cmo_zz_set_mpz(mpz_ptr z) +{ + cmo_zz* c = new_cmo_zz(); + mpz_set(c->mpz, z); + return c; +} + cmo_zz *new_cmo_zz_set_string(char *s) { cmo_zz* c = new_cmo_zz_noinit(); @@ -582,12 +593,12 @@ int print_cmo(cmo* c) } } -int print_cmo_int32(cmo_int32* c) +static int print_cmo_int32(cmo_int32* c) { fprintf(stderr, ", %d)", c->i); } -int print_cmo_list(cmo_list* li) +static int print_cmo_list(cmo_list* li) { cell* cp = li->head; while(cp->next != NULL) { @@ -598,14 +609,14 @@ int print_cmo_list(cmo_list* li) fprintf(stderr, ")"); } -int print_cmo_mathcap(cmo_mathcap* c) +static int print_cmo_mathcap(cmo_mathcap* c) { fprintf(stderr, ", "); print_cmo(c->ob); fprintf(stderr, ")"); } -int print_cmo_string(cmo_string* c) +static int print_cmo_string(cmo_string* c) { fprintf(stderr, ", \"%s\")", c->s); } @@ -614,22 +625,40 @@ void ox_close(ox_file_t sv) { send_ox_command(sv->control, SM_control_kill); #ifdef DEBUG - sleep(2); /* OpenXM server の終了を待つ. あまり意味はない. */ + sleep(2); + /* We wait thar an OpenXM server terminates. */ fprintf(stderr, "I have closed the connection to an Open XM server.\n"); #endif } -void ox_executeStringByLocalParser(ox_file_t sv, char* s) +void ox_shutdown(ox_file_t sv) { - if (s != NULL) { - /* 文字列ををスタックにプッシュ. */ - send_ox_cmo(sv->stream, (cmo *)new_cmo_string(s)); - /* サーバに実行させる. */ - send_ox_command(sv->stream, SM_executeStringByLocalParser); - } + /* We need to use SM_shutdown but yet ... */ + ox_close(sv); } -/* ox_mathcap() をコールする. */ +int ox_cmo_rpc(ox_file_t sv, char *function, int argc, cmo *argv[]) +{ + int i = argc; + while(i-- > 0) { + send_ox_cmo(sv->stream, argv[i]); + } + send_ox_cmo(sv->stream, (cmo *)new_cmo_int32(argc)); + send_ox_cmo(sv->stream, (cmo *)new_cmo_string(function)); + send_ox_command(sv->stream, SM_executeFunction); +} + +void ox_execute_string(ox_file_t sv, char* s) +{ + send_ox_cmo(sv->stream, (cmo *)new_cmo_string(s)); + send_ox_command(sv->stream, SM_executeStringByLocalParser); +} + +void ox_push_cmd(ox_file_t sv, int sm_code) +{ + send_ox_command(sv->stream, sm_code); +} + cmo_mathcap* ox_mathcap(ox_file_t sv) { send_ox_command(sv->stream, SM_mathcap); @@ -638,31 +667,48 @@ cmo_mathcap* ox_mathcap(ox_file_t sv) return (cmo_mathcap *)receive_cmo(sv->stream); } -char* ox_popString(ox_file_t sv, int fd) +char* ox_popString(ox_file_t sv) { cmo_string* m = NULL; - send_ox_command(fd, SM_popString); - receive_ox_tag(fd); /* OX_DATA */ - m = (cmo_string *)receive_cmo(fd); + send_ox_command(sv->stream, SM_popString); + receive_ox_tag(sv->stream); /* OX_DATA */ + m = (cmo_string *)receive_cmo(sv->stream); return m->s; } -cmo* ox_pop_cmo(ox_file_t sv, int fd) +int ox_pops(ox_file_t sv, int num) { - send_ox_command(fd, SM_popCMO); - receive_ox_tag(fd); /* OX_DATA */ - return receive_cmo(fd); + send_ox_cmo(sv->stream, (cmo *)new_cmo_int32(num)); + send_ox_command(sv->stream, SM_pops); } -/* 手抜き. (後で改善しよう...) */ +cmo* ox_pop_cmo(ox_file_t sv) +{ + send_ox_command(sv->stream, SM_popCMO); + receive_ox_tag(sv->stream); /* OX_DATA */ + return receive_cmo(sv->stream); +} + +void ox_push_cmo(ox_file_t sv, cmo *c) +{ + send_ox_cmo(sv->stream, c); +} + +/* a dummy function for flushing a connection. */ +int ox_flush(ox_file_t sv) +{ + return 1; +} + +/* a dummy password function. */ static char *create_otp() { static char otp[] = "otpasswd"; return otp; } -/* OneTimePassword の処理 */ +/* proceeding an one time password. */ static int login_with_otp(int fd, char* passwd) { int len = strlen(passwd)+1; @@ -684,34 +730,42 @@ static int login_with_otp(int fd, char* passwd) return ret; } -static int exists_ox(char *dir, char *prog) +/* The environment variable OpenXM_HOME must be defined. */ +static char *concat_openxm_home_bin(char *s) { - char *path = alloca(strlen(dir)+strlen(prog)+6); - sprintf(path, "%s/%s", dir, prog); - return access(path, X_OK|R_OK); + char *path; + char *base; + + /* if s includes '/' then it is not concaticated. */ + if (strchr(s, '/') != NULL) { + return s; + } + + base = getenv("OpenXM_HOME"); + path = malloc(strlen(base)+5+strlen(s)); + sprintf(path, "%s/bin/%s", base, s); + return path; } -static char *search_ox(char *prog) +/* example: which("xterm", getenv("PATH")); */ +static char *which(char *prog, char *path_env) { - char *env = getenv("OpenXM_HOME"); - char *dir; - if (env != NULL) { - dir = malloc(strlen(env)+5); - sprintf(dir, "%s/bin", env); - if (exists_ox(dir, prog) == 0) { - return dir; - } - free(dir); - } - dir = "/usr/local/OpenXM/bin"; - if (exists_ox(dir, prog) == 0) { - return dir; - } - dir = "."; - if (exists_ox(dir, prog) == 0) { - return dir; - } - return NULL; + char *tok; + char *path; + char delim[] = ":"; + char *e = alloca(strlen(path_env)+1); + strcpy(e, path_env); + tok = strtok(e, delim); + while (tok != NULL) { + char *path = malloc(strlen(tok)+strlen(prog)+2); + sprintf(path, "%s/%s", tok, prog); + if (access(path, X_OK&R_OK) == 0) { + return path; + } + free(path); + tok = strtok(NULL, delim); + } + return NULL; } static int mysocketAccept2(int fd, char *pass) @@ -725,10 +779,13 @@ static int mysocketAccept2(int fd, char *pass) return -1; } +/* if it is not 0, then we use oxlog to execute ox. */ +static int flag_ox_start_with_oxlog = 1; + /* (-reverse 版の ox_start) ox_start は クライアントが呼び出すための関数である. - サーバでは使われない. ctl_prog は コントロールサーバであり, + サーバでは使われない. ctl_prog はコントロールサーバであり, -ox, -reverse, -data, -control, -pass, -host というオプションを理解することを仮定する. dat_prog は計算サーバである. 接続時には, sv->control を先にオープンする. @@ -736,17 +793,20 @@ static int mysocketAccept2(int fd, char *pass) ox_file_t ox_start(char* host, char* ctl_prog, char* dat_prog) { + ox_file_t sv = NULL; char *pass; - char ctl[16], dat[16]; - short portControl = 0; /* short であることに注意 */ + char ctl[128], dat[128]; + short portControl = 0; /* short! */ short portStream = 0; - ox_file_t sv = NULL; - char *dir; + char *oxlog; - if ((dir = search_ox(ctl_prog)) == NULL) { - fprintf(stderr, "client:: %s not found.\n", ctl_prog); - return NULL; - } + /* not overwrite */ + setenv("OpenXM_HOME", "/usr/local/OpenXM", 0); + + oxlog = concat_openxm_home_bin("oxlog"); + ctl_prog = concat_openxm_home_bin(ctl_prog); + dat_prog = concat_openxm_home_bin(dat_prog); + sv = malloc(sizeof(__ox_file_struct)); sv->control = mysocketListen(host, &portControl); sv->stream = mysocketListen(host, &portStream); @@ -756,19 +816,26 @@ ox_file_t ox_start(char* host, char* ctl_prog, char* d pass = create_otp(); if (fork() == 0) { - dup2(2, 1); - dup2(open(DEFAULT_LOGFILE, O_RDWR|O_CREAT|O_TRUNC, 0644), 2); - chdir(dir); - execl(ctl_prog, ctl_prog, "-reverse", "-ox", dat_prog, - "-data", dat, "-control", ctl, "-pass", pass, - "-host", host, NULL); + if (flag_ox_start_with_oxlog) { + execl(oxlog, oxlog, "xterm", "-icon", "-e", ctl_prog, + "-reverse", "-ox", dat_prog, + "-data", dat, "-control", ctl, "-pass", pass, + "-host", host, NULL); + }else { + dup2(2, 1); + dup2(open(tempnam("/tmp", "ox."), O_RDWR|O_CREAT|O_TRUNC, 0644), 2); + execl(ctl_prog, ctl_prog, "-reverse", "-ox", dat_prog, + "-data", dat, "-control", ctl, "-pass", pass, + "-host", host, NULL); + } + exit(1); } if ((sv->control = mysocketAccept2(sv->control, pass)) == -1) { close(sv->stream); return NULL; } - /* 10マイクロ秒, 時間稼ぎする. */ + /* waiting 10 micro second. */ usleep(10); if((sv->stream = mysocketAccept2(sv->stream, pass)) == -1) { return NULL; @@ -776,6 +843,25 @@ ox_file_t ox_start(char* host, char* ctl_prog, char* d return sv; } +/* ssh -f host oxlog xterm -e ox -ox ox_asir ... */ +int ssh_ox_server(char *host, char *ctl_prog, char *dat_prog, short portControl, short portStream) +{ + char *oxlog; + char *ssh; + oxlog = concat_openxm_home_bin("oxlog"); + ctl_prog = concat_openxm_home_bin(ctl_prog); + dat_prog = concat_openxm_home_bin(dat_prog); + + ssh = which("ssh", getenv(PATH)); + + if (fork() == 0) { + execl(ssh, ssh, "-f", host, oxlog, "xterm", "-icon", + "-e", ctl_prog, "-insecure", "-ox", dat_prog, + "-data", portStream, "-control", portControl, "-host", host, NULL); + exit(1); + } +} + /* (-insecure 版の ox_start) まだ、中身はありません。 ox_start_insecure_nonreverse は クライアントが呼び出すための関数である. @@ -794,13 +880,22 @@ ox_file_t ox_start_insecure_nonreverse(char* host, sho /* ox は insecure のとき byte order の決定が正しくできないようだ... */ decideByteOrderClient(sv->control, 0); #endif - /* 10マイクロ秒, 時間稼ぎする. */ + /* wainting 10 micro second. */ usleep(10); sv->stream = mysocketOpen(host, portStream); decideByteOrderClient(sv->stream, 0); return sv; } +ox_file_t ox_start_insecure_nonreverse2(char* host, char *ctl_prog, char *dat_prog) +{ + short portControl= 1200; /* 自動生成させよう... */ + short portStream = 1300; + + ssh_ox_server(host, ctl_prog, dat_prog, portControl, portStream); + return ox_start_insecure_nonreverse(host, portControl, portStream); +} + void ox_reset(ox_file_t sv) { send_ox_command(sv->control, SM_control_reset_connection); @@ -818,7 +913,7 @@ void ox_reset(ox_file_t sv) #endif } -/* 以下は bconv.c で必要とする関数群である. */ +/* the following functions are needed by bconv.c */ /* cmolen 関数は cmo の(送信時の)バイト長を返す. */ /* cmolen_XXX 関数は cmo_XXX の tag を除いたバイト長を返す. */ @@ -872,7 +967,7 @@ static int cmolen_cmo_distributed_polynomial(cmo_distr return cmolen_cmo_list((cmo_list *)c) + cmolen_cmo(c->ringdef); } -/* CMO がバイトエンコードされた場合のバイト列の長さを求める */ +/* calculating the length of the byte stream of given CMO. */ int cmolen_cmo(cmo* c) { int size = sizeof(int); @@ -983,7 +1078,7 @@ static int dump_cmo_distributed_polynomial(cmo_distrib } } -/* タグを書き出してから、各関数を呼び出す */ +/* after its tag is sent, we invoke each functions. */ int dump_cmo(cmo* m) { dump_integer(m->tag); @@ -1058,23 +1153,21 @@ int dump_ox_command(ox_command* m) dump_integer(m->command); } -int send_ox(ox_file_t s, ox *m) +int send_ox(int fd, ox *m) { - int tag = m->tag; int code; - if (tag == OX_DATA) { - send_ox_cmo(s->stream, ((ox_data *)m)->cmo); - }else if (tag == OX_COMMAND) { - code = ((ox_command *)m)->command; - if (code >= 1024) { - /* control command */ - send_ox_command(s->control, code); - }else { - send_ox_command(s->stream, code); - } - }else { + switch(m->tag) { + case OX_DATA: + send_ox_cmo(fd, ((ox_data *)m)->cmo); + break; + case OX_COMMAND: + send_ox_command(fd, ((ox_command *)m)->command); + break; + default: +#if 0 /* CMO?? */ send_ox_cmo(s->stream, (cmo *)m); +#endif } } @@ -1084,7 +1177,7 @@ int send_ox_cmo(int fd, cmo* m) send_cmo(fd, m); } -/* send_cmo_xxx 関数群 */ +/* send_cmo_* functions */ static int send_cmo_null(int fd, cmo_null* c) { return 0; @@ -1162,7 +1255,7 @@ static int send_cmo_error2(int fd, cmo_error2* c) return 0; } -/* CMOを送る. OX_tag は送信済*/ +/* sending a CMO. (Remarks: OX_tag is already sent.) */ int send_cmo(int fd, cmo* c) { int tag = c->tag; @@ -1174,7 +1267,7 @@ int send_cmo(int fd, cmo* c) case CMO_NULL: case CMO_ZERO: case CMO_DMS_GENERIC: - send_cmo_null(fd, c); /* 空の関数 */ + send_cmo_null(fd, c); /* empty function. */ break; case CMO_INT32: send_cmo_int32(fd, (cmo_int32 *)c); @@ -1246,11 +1339,9 @@ static cmo_list* make_list_of_id(int ver, char* ver_s, cmo_list *cap; char buff[512]; - setgetc(mygetc); sprintf(buff, ID_TEMP, ver, sysname, ver_s, getenv("HOSTTYPE")); - setmode_mygetc(buff, 512); + init_parser(buff); cap = (cmo_list *)parse(); - resetgetc(); return cap; } @@ -1312,18 +1403,18 @@ int decideByteOrderServer(oxfd fd, int order) } /* cmo と string (ここではC言語のstring) の変換関数群 */ -char *convert_zz_to_string(cmo_zz *c) +static char *new_string_set_cmo_zz(cmo_zz *c) { return mpz_get_str(NULL, 10, c->mpz); } -char *convert_null_to_string() +static char *new_string_set_cmo_null() { static char* null_string = ""; return null_string; } -char *convert_int_to_string(int integer) +static char *new_string_set_cmo_int32(int integer) { char buff[1024]; char *s; @@ -1335,7 +1426,7 @@ char *convert_int_to_string(int integer) return s; } -char *convert_cmo_list_to_string(cmo_list *m) +static char *new_string_set_cmo_list(cmo_list *m) { char *s; int i; @@ -1345,7 +1436,7 @@ char *convert_cmo_list_to_string(cmo_list *m) cell *cp = m->head; for(i = 0; i < len; i++) { - sp[i] = convert_cmo_to_string(cp->cmo); + sp[i] = new_string_set_cmo(cp->cmo); size += strlen(sp[i]) + 3; cp = cp->next; } @@ -1361,26 +1452,26 @@ char *convert_cmo_list_to_string(cmo_list *m) return s; } -char *convert_cmo_to_string(cmo *m) +char *new_string_set_cmo(cmo *m) { symbol *symp; switch(m->tag) { case CMO_ZZ: - return convert_zz_to_string((cmo_zz *)m); + return new_string_set_cmo_zz((cmo_zz *)m); case CMO_INT32: - return convert_int_to_string(((cmo_int32 *)m)->i); + return new_string_set_cmo_int32(((cmo_int32 *)m)->i); case CMO_STRING: return ((cmo_string *)m)->s; case CMO_NULL: - return convert_null_to_string(); + return new_string_set_cmo_null(); case CMO_LIST: - return convert_cmo_list_to_string((cmo_list *)m); + return new_string_set_cmo_list((cmo_list *)m); default: #ifdef DEBUG symp = lookup_by_tag(m->tag); fprintf(stderr, "I do not know how to convert %s to a string.\n", symp->key); #endif - /* まだ実装していません. */ + /* yet not implemented. */ return NULL; } }