version 1.4, 2000/11/30 10:27:02 |
version 1.7, 2016/04/01 18:12:39 |
|
|
/* -*- mode: C -*- */ |
/* -*- mode: C -*- */ |
/* $OpenXM: OpenXM/src/oxc/sm.c,v 1.3 2000/11/28 18:11:42 ohara Exp $ */ |
/* $OpenXM: OpenXM/src/oxc/sm.c,v 1.6 2003/05/07 04:00:30 ohara Exp $ */ |
|
|
#include <stdio.h> |
#include <stdio.h> |
#include <stdlib.h> |
#include <stdlib.h> |
|
#include <string.h> |
#include <unistd.h> |
#include <unistd.h> |
#include <sys/types.h> |
#include <sys/types.h> |
#include <sys/time.h> |
#include <sys/time.h> |
Line 17 static cmo **stack = NULL; |
|
Line 18 static cmo **stack = NULL; |
|
static int stack_ptr = 0; |
static int stack_ptr = 0; |
static int stack_size = 0; |
static int stack_size = 0; |
OXFILE *stack_oxfp = NULL; |
OXFILE *stack_oxfp = NULL; |
|
int oxf_error(OXFILE *oxfp); |
|
|
#define DIFFERENCE_OF_STACK 1024 |
#define DIFFERENCE_OF_STACK 1024 |
|
|
|
|
|
|
void push_error(int errcode, cmo* pushback) |
void push_error(int errcode, cmo* pushback) |
{ |
{ |
return push((cmo *)make_error_object(errcode, pushback)); |
return push((cmo *)make_error_object(errcode, pushback)); |
} |
} |
|
|
/* |
/* |
If error occurs, then |
If error occurs, then |
an sm_* function, called by sm_run, pushes an error obect. |
an sm_* function, called by sm_run, pushes an error obect. |
*/ |
*/ |
void sm_popCMO() |
int sm_popCMO() |
{ |
{ |
cmo* m = pop(); |
cmo* m = pop(); |
send_ox_cmo(stack_oxfp, m); |
send_ox_cmo(stack_oxfp, m); |
|
return 0; |
} |
} |
|
|
void sm_pops() |
int sm_pops() |
{ |
{ |
cmo* m = pop(); |
cmo* m = pop(); |
if (m->tag == CMO_INT32) { |
if (m->tag == CMO_INT32) { |
pops(((cmo_int32 *)m)->i); |
pops(((cmo_int32 *)m)->i); |
}else { |
}else { |
push_error(-1, m); /* m is invalid. */ |
push_error(-1, m); /* m is invalid. */ |
} |
} |
|
return 0; |
} |
} |
|
|
void sm_run(int code) |
void sm_run(int code) |
Line 88 void sm_run(int code) |
|
Line 92 void sm_run(int code) |
|
if (func != NULL) { |
if (func != NULL) { |
func(stack_oxfp); |
func(stack_oxfp); |
}else { |
}else { |
fprintf(stderr, "oxc: unknown SM code(%d).\n", code); |
ox_printf("oxc: unknown SM code(%d).\n", code); |
} |
} |
} |
} |
|
|
Line 107 int sm_receive_ox() |
|
Line 111 int sm_receive_ox() |
|
break; |
break; |
case OX_COMMAND: |
case OX_COMMAND: |
code = receive_sm_command(stack_oxfp); |
code = receive_sm_command(stack_oxfp); |
fprintf(stderr, "oxc: code = %d.\n", code); |
ox_printf("oxc: code = %d.\n", code); |
sm_run(code); |
sm_run(code); |
break; |
break; |
default: |
default: |
fprintf(stderr, "illeagal message? ox_tag = (%d)\n", tag); |
ox_printf("illeagal message? ox_tag = (%d)\n", tag); |
return 0; |
return 0; |
break; |
break; |
} |
} |
Line 129 int oxf_error(OXFILE *oxfp) |
|
Line 133 int oxf_error(OXFILE *oxfp) |
|
|
|
int sm(OXFILE *oxfp) |
int sm(OXFILE *oxfp) |
{ |
{ |
stack_oxfp = oxfp; |
stack_oxfp = oxfp; |
stack_extend(); |
stack_extend(); |
while (sm_receive_ox()) { |
while (sm_receive_ox()) { |
} |
} |
fprintf(stderr, "oxc: socket(%d) is closed.\n", stack_oxfp->fd); |
ox_printf("oxc: socket(%d) is closed.\n", stack_oxfp->fd); |
|
return 0; |
} |
} |