version 1.19, 2003/01/11 11:42:31 |
version 1.24, 2003/05/25 16:35:40 |
|
|
/* -*- mode: C; coding: euc-japan -*- */ |
/* -*- mode: C; coding: euc-japan -*- */ |
/* $OpenXM: OpenXM/src/ox_toolkit/ox.c,v 1.18 2000/12/05 08:30:25 ohara Exp $ */ |
/* $OpenXM: OpenXM/src/ox_toolkit/ox.c,v 1.23 2003/03/30 08:05:22 ohara Exp $ */ |
|
|
/* |
/* |
This module includes functions for sending/receiveng CMO's. |
This module includes functions for sending/receiveng CMO's. |
|
|
|
|
#include <stdio.h> |
#include <stdio.h> |
#include <stdlib.h> |
#include <stdlib.h> |
|
#include <stdarg.h> |
#include <string.h> |
#include <string.h> |
#include <unistd.h> |
#include <unistd.h> |
#include <fcntl.h> |
#include <fcntl.h> |
|
|
#include "ox_toolkit.h" |
#include "ox_toolkit.h" |
#include "parse.h" |
#include "parse.h" |
|
|
|
static FILE *ox_stderr = NULL; |
|
|
/* sorting by the value of CMO_xxx. (for debugging) */ |
/* sorting by the value of CMO_xxx. (for debugging) */ |
static cmo_null* receive_cmo_null(OXFILE *oxfp); |
static cmo_null* receive_cmo_null(OXFILE *oxfp); |
static cmo_int32* receive_cmo_int32(OXFILE *oxfp); |
static cmo_int32* receive_cmo_int32(OXFILE *oxfp); |
Line 26 static cmo_string* receive_cmo_string(OXFILE *ox |
|
Line 29 static cmo_string* receive_cmo_string(OXFILE *ox |
|
static cmo_mathcap* receive_cmo_mathcap(OXFILE *oxfp); |
static cmo_mathcap* receive_cmo_mathcap(OXFILE *oxfp); |
static cmo_list* receive_cmo_list(OXFILE *oxfp); |
static cmo_list* receive_cmo_list(OXFILE *oxfp); |
static cmo_monomial32* receive_cmo_monomial32(OXFILE *oxfp); |
static cmo_monomial32* receive_cmo_monomial32(OXFILE *oxfp); |
static cmo_zz* receive_cmo_zz(OXFILE *oxfp); |
|
static cmo_zero* receive_cmo_zero(OXFILE *oxfp); |
static cmo_zero* receive_cmo_zero(OXFILE *oxfp); |
static cmo_dms_generic* receive_cmo_dms_generic(OXFILE *oxfp); |
static cmo_dms_generic* receive_cmo_dms_generic(OXFILE *oxfp); |
static cmo_ring_by_name* receive_cmo_ring_by_name(OXFILE *oxfp); |
static cmo_ring_by_name* receive_cmo_ring_by_name(OXFILE *oxfp); |
static cmo_distributed_polynomial* receive_cmo_distributed_polynomial(OXFILE *oxfp); |
static cmo_distributed_polynomial* receive_cmo_distributed_polynomial(OXFILE *oxfp); |
|
|
static cmo_error2* receive_cmo_error2(OXFILE *oxfp); |
static cmo_error2* receive_cmo_error2(OXFILE *oxfp); |
static void receive_mpz(OXFILE *oxfp, mpz_ptr mpz); |
|
|
|
static int send_cmo_null(OXFILE *oxfp, cmo_null* c); |
static int send_cmo_null(OXFILE *oxfp, cmo_null* c); |
static int send_cmo_int32(OXFILE *oxfp, cmo_int32* m); |
static int send_cmo_int32(OXFILE *oxfp, cmo_int32* m); |
Line 41 static int send_cmo_string(OXFILE *oxfp, cmo_ |
|
Line 41 static int send_cmo_string(OXFILE *oxfp, cmo_ |
|
static int send_cmo_mathcap(OXFILE *oxfp, cmo_mathcap* c); |
static int send_cmo_mathcap(OXFILE *oxfp, cmo_mathcap* c); |
static int send_cmo_list(OXFILE *oxfp, cmo_list* c); |
static int send_cmo_list(OXFILE *oxfp, cmo_list* c); |
static int send_cmo_monomial32(OXFILE *oxfp, cmo_monomial32* c); |
static int send_cmo_monomial32(OXFILE *oxfp, cmo_monomial32* c); |
static int send_cmo_zz(OXFILE *oxfp, cmo_zz* c); |
|
static int send_cmo_error2(OXFILE *oxfp, cmo_error2* c); |
static int send_cmo_error2(OXFILE *oxfp, cmo_error2* c); |
static int send_mpz(OXFILE *oxfp, mpz_ptr mpz); |
|
static int send_cmo_distributed_polynomial(OXFILE *oxfp, cmo_distributed_polynomial* c); |
static int send_cmo_distributed_polynomial(OXFILE *oxfp, cmo_distributed_polynomial* c); |
|
|
|
static cmo_zz* receive_cmo_zz(OXFILE *oxfp); |
|
static void receive_mpz(OXFILE *oxfp, mpz_ptr mpz); |
|
static int send_cmo_zz(OXFILE *oxfp, cmo_zz* c); |
|
static int send_mpz(OXFILE *oxfp, mpz_ptr mpz); |
|
|
/* hook functions. (yet not implemented) */ |
/* hook functions. (yet not implemented) */ |
static hook_t hook_before_send_cmo = NULL; |
static hook_t hook_before_send_cmo = NULL; |
static hook_t hook_after_send_cmo = NULL; |
static hook_t hook_after_send_cmo = NULL; |
Line 228 static cmo_error2* receive_cmo_error2(OXFILE *oxfp) |
|
Line 231 static cmo_error2* receive_cmo_error2(OXFILE *oxfp) |
|
/* receive_cmo() is called after receive_ox_tag(). */ |
/* receive_cmo() is called after receive_ox_tag(). */ |
cmo* receive_cmo(OXFILE *oxfp) |
cmo* receive_cmo(OXFILE *oxfp) |
{ |
{ |
cmo* m; |
|
int tag = receive_int32(oxfp); |
int tag = receive_int32(oxfp); |
|
return receive_cmo_tag(oxfp, tag); |
|
} |
|
|
|
cmo *receive_cmo_tag(OXFILE *oxfp, int tag) |
|
{ |
|
cmo* m; |
switch(tag) { |
switch(tag) { |
case CMO_NULL: |
case CMO_NULL: |
m = receive_cmo_null(oxfp); |
m = receive_cmo_null(oxfp); |
Line 271 cmo* receive_cmo(OXFILE *oxfp) |
|
Line 279 cmo* receive_cmo(OXFILE *oxfp) |
|
case CMO_QQ: |
case CMO_QQ: |
default: |
default: |
m = NULL; |
m = NULL; |
fprintf(ox_stderr, "the CMO (%d) is not implemented.\n", tag); |
ox_printf("the CMO (%d) is not implemented.\n", tag); |
} |
} |
return m; |
return m; |
} |
} |
Line 298 void send_ox_command(OXFILE *oxfp, int sm_command) |
|
Line 306 void send_ox_command(OXFILE *oxfp, int sm_command) |
|
void ox_close(OXFILE *sv) |
void ox_close(OXFILE *sv) |
{ |
{ |
send_ox_command(oxf_control(sv), SM_control_kill); |
send_ox_command(oxf_control(sv), SM_control_kill); |
#ifdef DEBUG |
|
sleep(2); |
sleep(2); |
/* We wait thar an OpenXM server terminates. */ |
/* We wait thar an OpenXM server terminates. */ |
fprintf(ox_stderr, "I have closed the connection to an Open XM server.\n"); |
ox_printf("I have closed the connection to an Open XM server.\n"); |
#endif |
|
} |
} |
|
|
void ox_shutdown(OXFILE *sv) |
void ox_shutdown(OXFILE *sv) |
Line 383 void ox_reset(OXFILE *sv) |
|
Line 389 void ox_reset(OXFILE *sv) |
|
} |
} |
|
|
send_ox_tag(sv, OX_SYNC_BALL); |
send_ox_tag(sv, OX_SYNC_BALL); |
#ifdef DEBUG |
ox_printf("I have reset an Open XM server.\n"); |
fprintf(ox_stderr, "I have reset an Open XM server.\n"); |
|
#endif |
|
} |
} |
|
|
void send_ox(OXFILE *oxfp, ox *m) |
void send_ox(OXFILE *oxfp, ox *m) |
Line 566 ox_sync_ball* new_ox_sync_ball() |
|
Line 570 ox_sync_ball* new_ox_sync_ball() |
|
|
|
int ox_stderr_init(FILE *fp) |
int ox_stderr_init(FILE *fp) |
{ |
{ |
ox_stderr = (fp != NULL)? fp: (stderr); |
ox_stderr = fp; |
setbuf(ox_stderr, NULL); |
if (ox_stderr != NULL) { |
|
setbuf(ox_stderr, NULL); |
|
} |
|
} |
|
|
|
int ox_printf(char *format, ...) |
|
{ |
|
if (ox_stderr != NULL) { |
|
va_list ap; |
|
va_start(ap, format); |
|
vfprintf(ox_stderr, format, ap); |
|
} |
} |
} |