OpenXM/src/ox_toolkit/testclient.c - diff

Return to testclient.c CVS log

Up to [local] / OpenXM / src / ox_toolkit

Diff for /OpenXM/src/ox_toolkit/testclient.c between version 1.1 and 1.5

version 1.1, 1999/12/15 05:21:25

version 1.5, 2000/10/10 05:23:21

Line 1

/* -*- mode: C -*- */

/* $OpenXM$ */

/* $OpenXM: OpenXM/src/ox_toolkit/testclient.c,v 1.4 2000/03/10 12:24:40 ohara Exp $ */

/* A sample implementation of an OpenXM client with OpenXM C library */

Line 9

#include <string.h>

#include <errno.h>

#include <fcntl.h>

#include "ox.h"

ox_file_t sv;

#include "ox_toolkit.h"

int dumpx(int fd, int n)

extern OXFILE *ox_start(char* host, char* prog1, char* prog2);

OXFILE *sv;

int dumpx(OXFILE *oxfp, int n)

{

unsigned char buff[2048];

int i;

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

int len = oxf_read(buff, 1, n, oxfp);

fprintf(stderr, "I have read %d byte from socket.\n", len);

fprintf(stderr, "I have read %d byte from socket(%d).\n", len, oxfp->fd);

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

fprintf(stderr, "%02x ", buff[i]);

if (i%20 == 19) {

Line 30 int dumpx(int fd, int n)

Line 32 int dumpx(int fd, int n)

return len;

}

#define VERSION 0x11121500

#define SIZE_CMDLINE 8192

#define ID_STRING "testclient version 0.11121500"

int prompt()

static int size = SIZE_CMDLINE;

static char cmdline[SIZE_CMDLINE];

static int prompt()

{

printf("> ");

fprintf(stdout, "> ");

fgets(cmdline, size, stdin);

init_parser(cmdline);

}

#define VERSION 0x11121500

#define ID_STRING "v0.11121500"

int test_0()

{

cmo* c = NULL;

Line 46 int test_0()

Line 55 int test_0()

c = ox_mathcap(sv);

fprintf(stderr, "testclient:: cmo received.(%p)\n", c);

#else

c = ox_mathcap(sv);

c = (cmo *)ox_mathcap(sv);

#endif

print_cmo(c);

fflush(stderr);

send_ox_cmo(sv->stream, make_mathcap_object(VERSION, ID_STRING));

mathcap_sysinfo_set(VERSION, ID_STRING, "testclient");

send_ox_cmo(sv, mathcap_get());

ox_reset(sv);

send_ox_cmo(sv->stream, new_cmo_string("N[ArcTan[1]]"));

send_ox_cmo(sv, (cmo *)new_cmo_string("N[ArcTan[1]]"));

send_ox_command(sv->stream, SM_executeStringByLocalParser);

send_ox_command(sv, SM_executeStringByLocalParser);

send_ox_command(sv->stream, SM_popCMO);

send_ox_command(sv, SM_popCMO);

receive_ox_tag(sv->stream);

receive_ox_tag(sv);

c = receive_cmo(sv->stream);

c = receive_cmo(sv);

fprintf(stderr, "testclient:: cmo received.\n");

print_cmo(c);

}

int test_1()

{

cmo *c = NULL;

cmo *c, *m;

cmo *m = make_mathcap_object(1000, "test!");

mathcap_sysinfo_set(1000, "test!", "testclient");

m = mathcap_get();

fprintf(stderr, "testclient:: test cmo_mathcap.\n");

send_ox_cmo(sv->stream, m);

send_ox_cmo(sv, m);

send_ox_command(sv->stream, SM_popCMO);

send_ox_command(sv, SM_popCMO);

receive_ox_tag(sv->stream);

receive_ox_tag(sv);

c = receive_cmo(sv->stream);

c = receive_cmo(sv);

fprintf(stderr, "testclient:: cmo received.(%p)\n", c);

print_cmo(c);

fputc('\n', stderr);

}

/* Example:

testclient

>(OX_DATA,(CMO_INT32,123))

>(OX_COMMAND,(SM_popCMO))

int main(int argc, char* argv[])

{

ox* m = NULL;

Line 89 int main(int argc, char* argv[])

Line 108 int main(int argc, char* argv[])

server = argv[1];

}

fprintf(stderr, "testclient:: I use %s as an OX server.\n", server);

sv = ox_start("localhost", "ox", server);

/* sv = ox_start("localhost", "ox", server); */

if (sv == NULL) {

fprintf(stderr, "testclient:: I cannot connect to servers.\n");

exit(1);

Line 99 int main(int argc, char* argv[])

Line 118 int main(int argc, char* argv[])

test_1();

}

setflag_parse(PFLAG_ADDREV);

while(prompt(), (m = parse()) != NULL) {

send_ox(sv->stream, m);

send_ox(sv, m);

if (m->tag == OX_COMMAND) {

code = ((ox_command *)m)->command;

if (code >= 1024) {

break;

}else if (code == SM_popCMO || code == SM_popString) {

receive_ox_tag(sv->stream);

receive_ox_tag(sv);

c = receive_cmo(sv->stream);

c = receive_cmo(sv);

fprintf(stderr, "testclient:: cmo received.\n");

print_cmo(c);

}

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