version 1.13, 2003/01/11 11:42:31 |
version 1.16, 2003/05/29 15:50:49 |
|
|
/* -*- mode: C; coding: euc-japan -*- */ |
/* -*- mode: C; coding: euc-japan -*- */ |
/* $OpenXM: OpenXM/src/ox_toolkit/oxf.c,v 1.12 2002/04/10 08:55:45 ohara Exp $ */ |
/* $OpenXM: OpenXM/src/ox_toolkit/oxf.c,v 1.15 2003/03/23 20:17:35 ohara Exp $ */ |
|
|
/* |
/* |
This module includes functions for sending/receiveng CMO's. |
This module includes functions for sending/receiveng CMO's. |
Line 32 static int send_int32_nbo(OXFILE *oxfp, int int32); |
|
Line 32 static int send_int32_nbo(OXFILE *oxfp, int int32); |
|
static int receive_int32_lbo(OXFILE *oxfp); |
static int receive_int32_lbo(OXFILE *oxfp); |
static int receive_int32_nbo(OXFILE *oxfp); |
static int receive_int32_nbo(OXFILE *oxfp); |
|
|
|
/* enable write buffering */ |
|
int oxf_setbuffer(OXFILE *oxfp, char *buf, int size) |
|
{ |
|
if (buf == NULL && size > 0) { |
|
buf = malloc(size); |
|
} |
|
if (oxfp->wbuf != NULL) { |
|
oxf_flush(oxfp); |
|
} |
|
oxfp->wbuf = buf; |
|
oxfp->wbuf_size = size; |
|
oxfp->wbuf_count = 0; |
|
} |
|
|
int oxf_read(void *buffer, size_t size, size_t num, OXFILE *oxfp) |
int oxf_read(void *buffer, size_t size, size_t num, OXFILE *oxfp) |
{ |
{ |
int n = read(oxfp->fd, buffer, size*num); |
int n = read(oxfp->fd, buffer, size*num); |
Line 43 int oxf_read(void *buffer, size_t size, size_t num, OX |
|
Line 57 int oxf_read(void *buffer, size_t size, size_t num, OX |
|
|
|
int oxf_write(void *buffer, size_t size, size_t num, OXFILE *oxfp) |
int oxf_write(void *buffer, size_t size, size_t num, OXFILE *oxfp) |
{ |
{ |
return write(oxfp->fd, buffer, size*num); |
size_t sz = size*num; |
|
if (oxfp->wbuf == NULL) { /* no buffering */ |
|
return write(oxfp->fd, buffer, sz); |
|
} |
|
if ((oxfp->wbuf_count + sz) >= oxfp->wbuf_size) { |
|
oxf_flush(oxfp); |
|
return write(oxfp->fd, buffer, sz); |
|
} |
|
memcpy(oxfp->wbuf + oxfp->wbuf_count, buffer, sz); |
|
oxfp->wbuf_count += sz; |
|
return sz; |
} |
} |
|
|
/* sending an object of int32 type with Network Byte Order. |
/* sending an object of int32 type with Network Byte Order. |
Line 95 OXFILE *oxf_open(int fd) |
|
Line 119 OXFILE *oxf_open(int fd) |
|
oxfp->control = NULL; |
oxfp->control = NULL; |
oxfp->error = 0; |
oxfp->error = 0; |
oxfp->mathcap = NULL; |
oxfp->mathcap = NULL; |
|
oxfp->wbuf = NULL; |
|
oxfp->wbuf_size = 0; |
|
oxfp->wbuf_count = 0; |
return oxfp; |
return oxfp; |
/* oxfp->fp = fdopen(fd, "a+"); */ |
/* oxfp->fp = fdopen(fd, "a+"); */ |
/* return (oxfp->fp != NULL)? oxfp: NULL; */ |
/* return (oxfp->fp != NULL)? oxfp: NULL; */ |
Line 142 void oxf_determine_byteorder_server(OXFILE *oxfp) |
|
Line 169 void oxf_determine_byteorder_server(OXFILE *oxfp) |
|
|
|
void oxf_flush(OXFILE *oxfp) |
void oxf_flush(OXFILE *oxfp) |
{ |
{ |
/* fflush(oxfp->fp); */ |
if (oxfp->wbuf != NULL) { |
|
write(oxfp->fd, oxfp->wbuf, oxfp->wbuf_count); |
|
oxfp->wbuf_count = 0; |
|
} |
} |
} |
|
|
void oxf_close(OXFILE *oxfp) |
void oxf_close(OXFILE *oxfp) |
{ |
{ |
|
oxf_flush(oxfp); |
close(oxfp->fd); |
close(oxfp->fd); |
/* fclose(oxfp->fp); */ |
|
} |
} |
|
|
#define OXF_SETOPT_NBO 0 |
#define OXF_SETOPT_NBO 0 |
Line 270 int oxc_start(char *remote_host, short port, char *pas |
|
Line 300 int oxc_start(char *remote_host, short port, char *pas |
|
if (gethostname(localhost, MAXHOSTNAMELEN)==0) { |
if (gethostname(localhost, MAXHOSTNAMELEN)==0) { |
if ((pid = fork()) == 0) { |
if ((pid = fork()) == 0) { |
sprintf(ports, "%d", port); |
sprintf(ports, "%d", port); |
#ifdef DEBUG |
ox_printf("oxf.c:: oxc_start() does %s(ssh) -f %s -h %s -p %s -c %s\n", remote_host, cmd, localhost, ports, passwd); |
fprintf(ox_stderr, "oxf.c:: oxc_start() does %s(ssh) -f %s -h %s -p %s -c %s\n", remote_host, cmd, localhost, ports, passwd); |
|
#endif |
|
execlp("ssh", remote_host, "-f", cmd, |
execlp("ssh", remote_host, "-f", cmd, |
"-h", localhost, "-p", ports,"-c", passwd, NULL); |
"-h", localhost, "-p", ports,"-c", passwd, NULL); |
} |
} |