=================================================================== RCS file: /home/cvs/OpenXM/src/ox_math/Attic/ox.c,v retrieving revision 1.2 retrieving revision 1.4 diff -u -p -r1.2 -r1.4 --- OpenXM/src/ox_math/Attic/ox.c 1999/11/02 06:11:57 1.2 +++ OpenXM/src/ox_math/Attic/ox.c 1999/11/02 21:15:02 1.4 @@ -1,6 +1,6 @@ /* -*- mode: C; coding: euc-japan -*- */ -/* $OpenXM$ */ -/* $Id: ox.c,v 1.2 1999/11/02 06:11:57 ohara Exp $ */ +/* $OpenXM: OpenXM/src/ox_math/ox.c,v 1.3 1999/11/02 18:58:25 ohara Exp $ */ +/* $Id: ox.c,v 1.4 1999/11/02 21:15:02 ohara Exp $ */ /* 関数の名前付け規約(その2): @@ -45,15 +45,16 @@ static int cmolen_cmo_string(cmo_string* c); static int cmolen_cmo_zz(cmo_zz* c); static int cmolen_cmo_monomial32(cmo_monomial32* c); -static char* dump_cmo_int32(char* array, cmo_int32* m); -static char* dump_cmo_list(char* array, cmo_list* m); -static char* dump_cmo_mathcap(char* array, cmo_mathcap* m); -static char* dump_cmo_null(char* array, cmo_null* m); -static char* dump_cmo_string(char* array, cmo_string* m); -static char* dump_cmo_monomial32(char* array, cmo_monomial32* c); -static char* dump_cmo_zz(char* array, cmo_zz* c); -static char* dump_integer(char* array, int x); -static char* dump_mpz(char* array, mpz_ptr mpz); +static int dump_cmo_int32(cmo_int32* m); +static int dump_cmo_list(cmo_list* m); +static int dump_cmo_mathcap(cmo_mathcap* m); +static int dump_cmo_null(cmo_null* m); +static int dump_cmo_string(cmo_string* m); +static int dump_cmo_monomial32(cmo_monomial32* c); +static int dump_cmo_zz(cmo_zz* c); +static int dump_string(char *s, int len); +static int dump_integer(int x); +static int dump_mpz(mpz_ptr mpz); static int funcs(int cmo_type); @@ -384,6 +385,16 @@ cmo_indeterminate* new_cmo_indeterminate(cmo* ob) return c; } +cmo_distributed_polynomial* new_cmo_distributed_polynomial() +{ + cmo_distributed_polynomial* c = malloc(sizeof(cmo_distributed_polynomial)); + c->tag = CMO_DISTRIBUTED_POLYNOMIAL; + c->length = 0; + c->head = NULL; + c->ringdef = NULL; + return c; +} + cmo_error2* new_cmo_error2(cmo* ob) { cmo_error2* c = malloc(sizeof(cmo_error2)); @@ -493,6 +504,7 @@ int print_cmo_string(cmo_string* c) } /* ox_start() から呼び出す */ +/* OneTimePassword の処理 */ static int read_password(int fd, char* passwd) { char buff[1024]; @@ -579,12 +591,10 @@ ox_file_t ox_start(char* host, char* prog1, char* prog } sv->control = mysocketAccept(sv->control); - read_password(sv->control, pass); - decideByteOrder(sv->control, sv->control, 0); + decideByteOrderWithReadPasswd(sv->control, sv->control, 0, pass); usleep(10); sv->stream = mysocketAccept(sv->stream); - read_password(sv->stream, pass); - decideByteOrder(sv->stream, sv->stream, 0); + decideByteOrderWithReadPasswd(sv->control, sv->control, 0, pass); return sv; } @@ -655,6 +665,11 @@ static int cmolen_cmo_zz(cmo_zz* c) return sizeof(len) + len*sizeof(int); } +static int cmolen_cmo_distributed_polynomial(cmo_distributed_polynomial* c) +{ + return cmolen_cmo_list((cmo_list *)c) + cmolen_cmo(c->ringdef); +} + /* CMO がバイトエンコードされた場合のバイト列の長さを求める */ int cmolen_cmo(cmo* c) { @@ -686,111 +701,159 @@ int cmolen_cmo(cmo* c) case CMO_ZZ: size += cmolen_cmo_zz((cmo_zz *)c); break; + case CMO_DISTRIBUTED_POLYNOMIAL: + size += cmolen_cmo_distributed_polynomial((cmo_distributed_polynomial *)c); + break; default: } return size; } -static char* dump_cmo_null(char* array, cmo_null* m) +static int d_ptr; +static char *d_buf; + +int init_dump_buffer(char *s) { - return array; + d_buf = s; + d_ptr = 0; } -static char* dump_cmo_int32(char* array, cmo_int32* m) +static int dump_cmo_null(cmo_null* m) { - return dump_integer(array, m->i); + return 0; } -static char* dump_cmo_string(char* array, cmo_string* m) +static int dump_cmo_int32(cmo_int32* m) { + dump_integer(m->i); +} + +static int dump_cmo_string(cmo_string* m) +{ int len = strlen(m->s); - array = dump_integer(array, len); - memcpy(array, m->s, len); - return array + len; + dump_integer(len); + dump_string(m->s, len); } -static char* dump_cmo_mathcap(char* array, cmo_mathcap* c) +static int dump_cmo_mathcap(cmo_mathcap* c) { - return dump_cmo(array, c->ob); + dump_cmo(c->ob); } -static char* dump_cmo_list(char* array, cmo_list* m) +static int dump_cmo_list(cmo_list* m) { cell* cp = m->head; int len = length_cmo_list(m); - array = dump_integer(array, len); + dump_integer(len); while(cp != NULL) { - array = dump_cmo(array, cp->cmo); + dump_cmo(cp->cmo); cp = cp->next; } - return array; } -static char* dump_cmo_monomial32(char* array, cmo_monomial32* c) +static int dump_cmo_monomial32(cmo_monomial32* c) { int i; int length = c->length; - array = dump_integer(array, c->length); + dump_integer(c->length); for(i=0; iexps[i]); + dump_integer(c->exps[i]); } - array = dump_cmo(array, c->coef); - return array; + dump_cmo(c->coef); } -static char* dump_cmo_zz(char* array, cmo_zz* c) +static int dump_cmo_zz(cmo_zz* c) { - return dump_mpz(array, c->mpz); + dump_mpz(c->mpz); } +static int dump_cmo_distributed_polynomial(cmo_distributed_polynomial* m) +{ + cell* cp = m->head; + int len = length_cmo_list((cmo_list *)m); + dump_integer(len); + dump_cmo(m->ringdef); + while(cp != NULL) { + dump_cmo(cp->cmo); + cp = cp->next; + } +} + /* タグを書き出してから、各関数を呼び出す */ -char* dump_cmo(char* array, cmo* m) +int dump_cmo(cmo* m) { - array = dump_integer(array, m->tag); + dump_integer(m->tag); switch(m->tag) { case CMO_NULL: case CMO_ZERO: case CMO_DMS_GENERIC: - return dump_cmo_null(array, m); + dump_cmo_null(m); + break; case CMO_INT32: - return dump_cmo_int32(array, (cmo_int32 *)m); + dump_cmo_int32((cmo_int32 *)m); + break; case CMO_STRING: - return dump_cmo_string(array, (cmo_string *)m); + dump_cmo_string((cmo_string *)m); + break; case CMO_MATHCAP: case CMO_RING_BY_NAME: case CMO_ERROR2: - return dump_cmo_mathcap(array, (cmo_mathcap *)m); + dump_cmo_mathcap((cmo_mathcap *)m); + break; case CMO_LIST: - return dump_cmo_list(array, (cmo_list *)m); + dump_cmo_list((cmo_list *)m); + break; case CMO_MONOMIAL32: - return dump_cmo_monomial32(array, (cmo_monomial32 *)m); + dump_cmo_monomial32((cmo_monomial32 *)m); + break; case CMO_ZZ: - return dump_cmo_zz(array, (cmo_zz *)m); + dump_cmo_zz((cmo_zz *)m); + break; + case CMO_DISTRIBUTED_POLYNOMIAL: + dump_cmo_distributed_polynomial((cmo_distributed_polynomial *)m); + break; default: - return NULL; } } -static char* dump_integer(char* array, int x) +static int dump_mpz(mpz_ptr mpz) { - int nx = htonl(x); - memcpy(array, &nx, sizeof(int)); - return array + sizeof(int); -} - -static char* dump_mpz(char* array, mpz_ptr mpz) -{ int i; int len = abs(mpz->_mp_size); - array = dump_integer(array, mpz->_mp_size); + dump_integer(mpz->_mp_size); for(i=0; i_mp_d[i]); + dump_integer(mpz->_mp_d[i]); } - return array; + return; } +static int dump_string(char *s, int len) +{ + memcpy(&d_buf[d_ptr], s, len); + d_ptr += len; +} +static int dump_integer(int x) +{ + int nx = htonl(x); + dump_string((char *)&nx, sizeof(int)); +} + +int dump_ox_data(ox_data* m) +{ + dump_integer(OX_DATA); + dump_integer(-1); + dump_cmo(m->cmo); +} + +int dump_ox_command(ox_command* m) +{ + dump_integer(OX_COMMAND); + dump_integer(-1); + dump_integer(m->command); +} + int send_ox(ox_file_t s, ox *m) { int tag = m->tag; @@ -927,20 +990,6 @@ ox_command* new_ox_command(int sm_code) return m; } -char* dump_ox_data(char* array, ox_data* m) -{ - array = dump_integer(array, OX_DATA); - array = dump_integer(array, -1); - return dump_cmo(array, m->cmo); -} - -char* dump_ox_command(char* array, ox_command* m) -{ - array = dump_integer(array, OX_COMMAND); - array = dump_integer(array, -1); - return dump_integer(array, m->command); -} - #define MAX_TYPES 8 static int known_types[] = { -1, /* gate keeper */ @@ -1028,25 +1077,38 @@ cmo* receive_cmo2(int fd) return foo(fd); } } -#endif +#endif + /* ファイルディスクリプタ fd の通信路での integer の byte order を決定する */ /* 実際には order (0,1,or 0xFF)をみてはいない */ +int decideByteOrderWithReadPasswd(int fd_read, int fd_write, int order, char* passwd) +{ + char zero = OX_BYTE_NETWORK_BYTE_ORDER; + char dest; + read_password(fd_read, passwd); + write(fd_write, &zero, sizeof(char)); + read(fd_read, &dest, sizeof(char)); + return 0; +} + +/* ファイルディスクリプタ fd の通信路での integer の byte order を決定する */ +/* 実際には order (0,1,or 0xFF)をみてはいない */ int decideByteOrder(int fd_read, int fd_write, int order) { - char zero = '\0'; + char zero = OX_BYTE_NETWORK_BYTE_ORDER; char dest; - write(fd_write, &zero, 1); - read(fd_read, &dest, 1); + write(fd_write, &zero, sizeof(char)); + read(fd_read, &dest, sizeof(char)); return 0; } /* Server 側ではこちらを用いる */ int decideByteOrder2(int fd_read, int fd_write, int order) { - char zero = '\0'; + char zero = OX_BYTE_NETWORK_BYTE_ORDER; char dest; - read(fd_read, &dest, 1); - write(fd_write, &zero, 1); + read(fd_read, &dest, sizeof(char)); + write(fd_write, &zero, sizeof(char)); return 0; }