OpenXM/src/ox_math/ox.c - diff

Return to ox.c CVS log

Up to [local] / OpenXM / src / ox_math

Diff for /OpenXM/src/ox_math/Attic/ox.c between version 1.9 and 1.11

version 1.9, 1999/11/04 19:33:17

version 1.11, 1999/11/06 21:39:36

Line 1

/* -*- mode: C; coding: euc-japan -*- */

/* $OpenXM: OpenXM/src/ox_math/ox.c,v 1.8 1999/11/04 18:13:47 ohara Exp $ */

/* $OpenXM: OpenXM/src/ox_math/ox.c,v 1.10 1999/11/05 12:34:25 ohara Exp $ */

関数の名前付け規約(その2):

Line 31 YYY_cmo_XXX 関数が処理する. cmo の内部に cmo_ZZZ への

#include <errno.h>

#include <fcntl.h>

#include <gmp.h>

#include <unistd.h>

#include <sys/file.h>

#include "mysocket.h"

#include "ox.h"

Line 509 void send_ox_command(int fd, int sm_command)

Line 511 void send_ox_command(int fd, int sm_command)

int print_cmo(cmo* c)

{

int tag = c->tag;

fprintf(stderr, "local::tag = (%d): ", tag);

#ifdef DEBUG

symbol* symp = lookup_by_tag(tag);

if (symp != NULL) {

fprintf(stderr, "local::tag = %s: ", symp->key);

}else {

fprintf(stderr, "local::tag = %d: ", tag);

}

#endif

switch(tag) {

case CMO_LIST:

print_cmo_list((cmo_list *)c);

Line 561 int print_cmo_string(cmo_string* c)

Line 572 int print_cmo_string(cmo_string* c)

void ox_close(ox_file_t sv)

{

send_ox_command(sv->control, SM_control_kill);

#if DEBUG

#ifdef DEBUG

sleep(2); /* OpenXM server の終了を待つ. あまり意味はない. */

fprintf(stderr, "I have closed the connection to an Open XM server.\n");

#endif

Line 569 void ox_close(ox_file_t sv)

Line 580 void ox_close(ox_file_t sv)

void ox_executeStringByLocalParser(ox_file_t sv, char* s)

{

/* 文字列ををスタックにプッシュ. */

if (s != NULL) {

send_ox_cmo(sv->stream, (cmo *)new_cmo_string(s));

/* 文字列ををスタックにプッシュ. */

send_ox_cmo(sv->stream, (cmo *)new_cmo_string(s));

/* サーバに実行させる. */

send_ox_command(sv->stream, SM_executeStringByLocalParser);

}

/* ox_mathcap() をコールする. */

Line 612 static char *create_otp()

Line 624 static char *create_otp()

/* OneTimePassword の処理 */

static int login_with_otp(int fd, char* passwd)

{

char buff[1024];

int len = strlen(passwd)+1;

int n = read(fd, buff, 1024);

char *buf = alloca(len);

int len = strlen(passwd)+1;

int n = read(fd, buf, len);

if (n != len) {

int ret = strcmp(passwd, buf);

#ifdef DEBUG

if (ret != 0) {

fprintf(stderr, "Socket#%d: Login incorrect.\n", fd);

fprintf(stderr, "password = (%s), length = (%d).\n", passwd, len);

}else {

fprintf(stderr, "received = (%d), length = (%d).\n", buff, n);

fprintf(stderr, "Socket#%d: login!.\n", fd);

fflush(stderr);

}

fprintf(stderr, "password = (%s), %d bytes.\n", passwd, len);

fprintf(stderr, "received = (%s), %d bytes.\n", buf, n);

fflush(stderr);

#endif

return ret;

}

static int exists_ox(char *dir, char *prog)

{

char *path = alloca(strlen(dir)+strlen(prog)+6);

sprintf(path, "%s/%s", dir, prog);

return access(path, X_OK|R_OK);

}

static char *search_ox(char *prog)

{

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;

}

static int mysocketAccept2(int fd, char *pass)

{

fd = mysocketAccept(fd);

if(login_with_otp(fd, pass)==0) {

decideByteOrderClient(fd, 0);

return fd;

}

close(fd);

return -1;

}

(-reverse 版の ox_start)

ox_start はクライアントが呼び出すための関数である.

サーバでは使われない. prog1 はコントロールサーバであり,

サーバでは使われない. ctl_prog はコントロールサーバであり,

-ox, -reverse, -data, -control, -pass, -host

というオプションを理解することを仮定する. prog2 は計算サーバである.

というオプションを理解することを仮定する. dat_prog は計算サーバである.

接続時には, sv->control を先にオープンする.

ox_file_t ox_start(char* host, char* prog1, char* prog2)

ox_file_t ox_start(char* host, char* ctl_prog, char* dat_prog)

{

char *pass = create_otp();

char *pass;

char ctl[16], dat[16];

short portControl = 0; /* short であることに注意 */

short portStream = 0;

ox_file_t sv = malloc(sizeof(__ox_file_struct));

ox_file_t sv = NULL;

char *dir;

if ((dir = search_ox(ctl_prog)) == NULL) {

fprintf(stderr, "client:: %s not found.\n", ctl_prog);

return NULL;

}

sv = malloc(sizeof(__ox_file_struct));

sv->control = mysocketListen(host, &portControl);

sv->stream = mysocketListen(host, &portStream);

sprintf(ctl, "%d", portControl);

sprintf(dat, "%d", portStream);

pass = create_otp();

if (fork() == 0) {

dup2(2, 1);

dup2(open(DEFAULT_LOGFILE, O_RDWR|O_CREAT|O_TRUNC, 0644), 2);

execl(prog1, prog1, "-reverse", "-ox", prog2,

chdir(dir);

execl(ctl_prog, ctl_prog, "-reverse", "-ox", dat_prog,

"-data", dat, "-control", ctl, "-pass", pass,

"-host", host, NULL);

}

sv->control = mysocketAccept(sv->control);

if ((sv->control = mysocketAccept2(sv->control, pass)) == -1) {

login_with_otp(sv->control, pass);

close(sv->stream);

decideByteOrderClient(sv->control, 0);

return NULL;

}

/* 10マイクロ秒, 時間稼ぎする. */

usleep(10);

sv->stream = mysocketAccept(sv->stream);

if((sv->stream = mysocketAccept2(sv->stream, pass)) == -1) {

login_with_otp(sv->stream, pass);

return NULL;

decideByteOrderClient(sv->stream, 0);

}

return sv;

}

(-insecure 版の ox_start) まだ、中身はありません。

ox_start_insecure_nonreverse はクライアントが呼び出すための関数である.

接続時には, sv->control を先にオープンする.

Line 702 void ox_reset(ox_file_t sv)

Line 772 void ox_reset(ox_file_t sv)

}

send_ox_tag(sv->stream, OX_SYNC_BALL);

#if DEBUG

#ifdef DEBUG

fprintf(stderr, "I have reset an Open XM server.\n");

#endif

}

Line 1130 static int known_types[] = {

Line 1200 static int known_types[] = {

CMO_ERROR2,

};

#define ID_TEMP "(CMO_MATHCAP, (CMO_LIST, (CMO_LIST, (CMO_INT32, %d), (CMO_STRING, \"%s\"), (CMO_STRING, \"%s\"), (CMO_STRING, \"%s\")), (CMO_LIST, (CMO_INT32, 1), (CMO_INT32, 2), (CMO_INT32, 4), (CMO_INT32, 5), (CMO_INT32, 17), (CMO_INT32, 20), (CMO_INT32, 2130706434))))\n"

#define ID_TEMP "(CMO_LIST, (CMO_INT32, %d), (CMO_STRING, \"%s\"), (CMO_STRING, \"%s\"), (CMO_STRING, \"%s\"))"

cmo* make_mathcap_object2(int ver, char* ver_s, char* sysname)

static cmo_list* make_list_of_id(int ver, char* ver_s, char* sysname)

{

cmo *cap;

cmo_list *cap;

char buff[8192];

char buff[512];

setgetc(mygetc);

sprintf(buff, ID_TEMP, ver, sysname, ver_s, getenv("HOSTTYPE"));

setmode_mygetc(buff, 8192);

setmode_mygetc(buff, 512);

cap = parse();

resetgetc();

return cap;

}

cmo* make_mathcap_object(int version, char* id_string)

static cmo_list *make_list_of_tag(int type)

{

cmo_list *li_ver, *li_cmo, *li;

cmo_list *li = new_cmo_list();

symbol *symp;

int i;

int i = 0;

li_ver = new_cmo_list();

while((symp = lookup(i++))->key != NULL) {

append_cmo_list(li_ver, (cmo *)new_cmo_int32(version));

if (symp->type == type) {

append_cmo_list(li_ver, (cmo *)new_cmo_string(id_string));

append_cmo_list(li, (cmo *)new_cmo_int32(symp->tag));

}

return li;

}

li_cmo = new_cmo_list();

cmo* make_mathcap_object(int version, char *id_string)

for(i=0; i<MAX_TYPES; i++) {

{

if (known_types[i] != -1) {

char sysname[] = "ox_math";

append_cmo_list(li_cmo, (cmo *)new_cmo_int32(known_types[i]));

cmo_list *li = new_cmo_list();

}

cmo_list *li_ver = make_list_of_id(version, id_string, sysname);

}

cmo_list *li_cmo = make_list_of_tag(IS_CMO);

cmo_list *li_sm = make_list_of_tag(IS_SM);

li = new_cmo_list();

append_cmo_list(li, (cmo *)li_ver);

append_cmo_list(li, (cmo *)li_cmo);

append_cmo_list(li, (cmo *)li_sm);

return (cmo *)new_cmo_mathcap((cmo *)li);

}

Line 1238 char *convert_zz_to_string(cmo_zz *c)

Line 1314 char *convert_zz_to_string(cmo_zz *c)

char *convert_cmo_to_string(cmo *m)

{

symbol *symp;

switch(m->tag) {

case CMO_ZZ:

return convert_zz_to_string((cmo_zz *)m);

Line 1248 char *convert_cmo_to_string(cmo *m)

Line 1325 char *convert_cmo_to_string(cmo *m)

case CMO_NULL:

return convert_null_to_string();

default:

fprintf(stderr, "sorry, not implemented CMO\n");

symp = lookup_by_tag(m->tag);

fprintf(stderr, "I do not know how to convert %s to a string.\n", symp->key);

/* まだ実装していません. */

return NULL;

}

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>