File: [local] / OpenXM / src / ox_toolkit / oxf_old.c (download)
Revision 1.7, Mon Sep 15 09:31:42 2003 UTC (21 years ago) by ohara
Branch: MAIN
CVS Tags: new-mathcap-branch, RELEASE_1_2_3_12, RELEASE_1_2_3, RELEASE_1_2_2_KNOPPIX_b, RELEASE_1_2_2_KNOPPIX, KNOPPIX_2006, DEB_REL_1_2_3-9 Changes since 1.6: +2 -2
lines
Add some "cast".
Fixed some bugs.
|
/* -*- mode: C; coding: euc-japan -*- */
/* $OpenXM: OpenXM/src/ox_toolkit/oxf_old.c,v 1.7 2003/09/15 09:31:42 ohara Exp $ */
/* このモジュールは互換性のためのものです。*/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/file.h>
#include <sys/param.h>
#include <time.h>
#if defined(__sun__)
#include <netdb.h>
#include <sys/types.h>
#include <netinet/in.h>
#endif
#include "mysocket.h"
#include "ox_toolkit.h"
OXFILE *oxf_control_set(OXFILE *oxfp, OXFILE *ctl)
{
oxfp->control = ctl;
return oxfp;
}
static char *OpenXM_HOME = "/usr/local/OpenXM";
static char *concat_openxm_home_bin(char *s);
OXFILE * ox_start(char* host, char* prog1, char* prog2);
OXFILE * ox_start_insecure_nonreverse(char* host, short portControl, short portStream);
OXFILE * ox_start_remote_with_ssh(char *dat_prog, char* host);
#if 0
/* 将来計画: start 関数は次のような設計であるべきだろう */
OXFILE *oxf_connect_client()
{
short port = 0; /* Listen() に決めさせる. */
int listened = Listen(&port);
execute_server(port);
return oxf_connect_passive(listened); /* ここで、認証, バイトオーダの決定 */
}
OXFILE *ox_start_calc(char *cserver)
{
short port = 0; /* Listen() に決めさせる. */
int listened;
listened = Listen(&port);
oxc_open(oxfp_ctl, port, cserver); /* ここでpasswordを送る手もあるが... */
return oxf_connect_passive(listened); /* 認証しない. バイトオーダは決定する. */
}
int ox_start()
{
OXFILE *oxfp_ctl, *oxfp_calc;
oxfp_ctl = oxf_connect_client();
/* mathcap の交換 */
oxfp_calc = ox_start_calc("ox_sm1");
return oxf_control_set(oxfp_calc, oxfp_ctl);
}
#endif
static OXFILE *mysocketAccept2(int listened, char *passwd)
{
OXFILE *oxfp = oxf_connect_passive(listened);
if(oxf_confirm_client(oxfp, passwd)) {
oxf_determine_byteorder_client(oxfp);
return oxfp;
}
oxf_close(oxfp);
return NULL;
}
/* The environment variable OpenXM_HOME must be defined. */
static char *concat_openxm_home_bin(char *s)
{
char *path;
/* if s includes '/' then it is not concaticated. */
if (strchr(s, '/') != NULL) {
return s;
}
path = MALLOC(strlen(OpenXM_HOME)+6+strlen(s));
sprintf(path, "%s/bin/%s", OpenXM_HOME, s);
return path;
}
void set_OpenXM_HOME()
{
char *e;
if ((e = getenv("OpenXM_HOME")) != NULL
#if defined(__CYGWIN__)
|| (e = getenv("OPENXM_HOME")) != NULL
#endif
) {
OpenXM_HOME = e;
}
}
void ox_exec_local(char* ctl_prog, char* dat_prog, int portControl, int portStream, char *passwd)
{
char ctl[128], dat[128];
char localhost[MAXHOSTNAMELEN];
sprintf(ctl, "%d", portControl);
sprintf(dat, "%d", portStream);
set_OpenXM_HOME();
ctl_prog = concat_openxm_home_bin(ctl_prog);
dat_prog = concat_openxm_home_bin(dat_prog);
if (gethostname(localhost, MAXHOSTNAMELEN)==0) {
if (fork() == 0) {
execlp("oxlog", "oxlog", "xterm", "-icon", "-e", ctl_prog,
"-reverse", "-ox", dat_prog,
"-data", dat, "-control", ctl, "-pass", passwd,
"-host", localhost, NULL);
exit(1);
}
}
}
/*
(-reverse 版の ox_start)
ox_start は クライアントが呼び出すための関数である.
サーバでは使われない. ctl_prog はコントロールサーバであり,
-ox, -reverse, -data, -control, -pass, -host
というオプションを理解することを仮定する. dat_prog は計算サーバである.
接続時には, ct を先にオープンする.
*/
OXFILE *ox_start(char* host, char* ctl_prog, char* dat_prog)
{
OXFILE *st, *ct;
char *passwd = generate_otp();
int listen[2];
int ports[2] = {0};
/* host を無視 */
listen[0] = oxf_listen(&ports[0]);
listen[1] = oxf_listen(&ports[1]);
ox_exec_local(ctl_prog, dat_prog, ports[0], ports[1], passwd);
ct = mysocketAccept2(listen[0], passwd);
if (ct != NULL) {
usleep(10); /* zzz... */
st = mysocketAccept2(listen[1], passwd);
if (st != NULL) {
return oxf_control_set(st, ct);
}
}
return NULL;
}
/*
(-insecure 版の ox_start) まだ、中身はありません。
ox_start_insecure は クライアントが呼び出すための関数である.
接続時には, ct を先にオープンする.
既定値:
portControl = 1200
portStream = 1300
*/
OXFILE *ox_start_insecure(char* host, short portControl, short portStream)
{
OXFILE *ct, *st;
ct = oxf_connect_active(host, portControl);
/* ox は insecure のとき byte order の決定が正しくできないようだ... */
/* oxf_determine_byteorder_client(ct); */
/* wainting 10 micro second. */
usleep(10);
st = oxf_connect_active(host, portStream);
oxf_determine_byteorder_client(st);
return oxf_control_set(st, ct);
}
/* ssh -f host oxlog xterm -e ox -ox ox_asir ... */
void ssh_ox_server(char *remote_host, char *ctl_prog, char *dat_prog, short portControl, short portStream)
{
ctl_prog = concat_openxm_home_bin(ctl_prog);
dat_prog = concat_openxm_home_bin(dat_prog);
if (fork() == 0) {
execlp("ssh", "ssh", "-f", remote_host, "oxlog", "xterm", "-icon",
"-e", ctl_prog, "-insecure", "-ox", dat_prog,
"-data", portStream, "-control", portControl,
"-host", remote_host, NULL);
exit(1);
}
}
OXFILE *ox_start_remote_with_ssh(char *dat_prog, char* remote_host)
{
ssh_ox_server(remote_host, "ox", dat_prog, 1200, 1300);
return ox_start_insecure(remote_host, 1200, 1300);
}