version 1.15, 2002/11/07 23:52:20 |
version 1.18, 2003/11/17 05:45:47 |
|
|
/* $OpenXM: OpenXM/src/kan96xx/plugin/oxmisc2.c,v 1.14 2002/11/07 13:32:06 takayama Exp $ */ |
/* $OpenXM: OpenXM/src/kan96xx/plugin/oxmisc2.c,v 1.17 2002/11/08 14:18:02 takayama Exp $ */ |
#include <stdio.h> |
#include <stdio.h> |
#include "ox_kan.h" |
#include "ox_kan.h" |
#include "oxmisc2.h" /* This file requires sm1 object description. */ |
#include "oxmisc2.h" /* This file requires sm1 object description. */ |
Line 382 int oxClientToObject(oxclientp client,struct object ro |
|
Line 382 int oxClientToObject(oxclientp client,struct object ro |
|
} |
} |
putoa(rob,11,KpoInteger(client->engineByteOrder)); |
putoa(rob,11,KpoInteger(client->engineByteOrder)); |
putoa(rob,12,KpoInteger(client->controlByteOrder)); |
putoa(rob,12,KpoInteger(client->controlByteOrder)); |
|
putoa(rob,13,KpoInteger(client->engineID)); |
return(0); |
return(0); |
} |
} |
|
|
Line 438 int oxObjectToClient(struct object ob,oxclientp cp) |
|
Line 439 int oxObjectToClient(struct object ob,oxclientp cp) |
|
cp->engineByteOrder = KopInteger(ob1); |
cp->engineByteOrder = KopInteger(ob1); |
ob1 = getoa(ob,12); |
ob1 = getoa(ob,12); |
cp->controlByteOrder = KopInteger(ob1); |
cp->controlByteOrder = KopInteger(ob1); |
|
|
|
ob1 = getoa(ob,13); |
|
cp->engineID = KopInteger(ob1); |
|
|
|
|
return(0); |
return(0); |
Line 644 struct object KoxWatch(struct object client,struct obj |
|
Line 648 struct object KoxWatch(struct object client,struct obj |
|
return(KpoInteger(ans)); |
return(KpoInteger(ans)); |
} |
} |
|
|
|
struct object KoxLog(struct object client,struct object in,struct object out) |
|
{ |
|
int ans,k; |
|
static oxclientp cc1 = NULL; |
|
struct object rob; |
|
rob.tag = Snull; |
|
if (cc1 == NULL) { |
|
cc1 = (oxclientp) mymalloc(sizeof(oxclient)); |
|
if (cc1 == NULL) { |
|
errorOxmisc2("KoxLog(): no more memory."); |
|
return(rob); |
|
} |
|
oxInitClient(cc1); |
|
} |
|
|
|
if (oxObjectToClient(client,cc1) == -1) return(rob); |
|
if (cc1 == NULL) { |
|
errorOxmisc2("KoxLog(): the first argument must be a client object."); |
|
return(rob); |
|
} |
|
|
|
if (in.tag != Sfile) { |
|
errorOxmisc2("KoxLog(): the second argument is not a file object."); |
|
return rob; |
|
} |
|
if (out.tag != Sfile) { |
|
errorOxmisc2("KoxLog(): the third argument is not a file object."); |
|
return rob; |
|
} |
|
k = fp2log(cc1->datafp2,in.rc.file,out.rc.file); |
|
/* synchronize cc1 and client. */ |
|
oxClientToObject(cc1,client); |
|
|
|
return(KpoInteger(ans)); |
|
} |
|
|
|
struct object KoxLogStop(struct object client) { |
|
static oxclientp cc1 = NULL; |
|
struct object rob; |
|
rob.tag = Snull; |
|
if (cc1 == NULL) { |
|
cc1 = (oxclientp) mymalloc(sizeof(oxclient)); |
|
if (cc1 == NULL) { |
|
errorOxmisc2("KoxLog(): no more memory."); |
|
return(rob); |
|
} |
|
oxInitClient(cc1); |
|
} |
|
|
|
if (oxObjectToClient(client,cc1) == -1) return(rob); |
|
if (cc1 == NULL) { |
|
errorOxmisc2("KoxLog(): the first argument must be a client object."); |
|
return(rob); |
|
} |
|
return(KpoInteger(fp2stopLog(cc1->datafp2))); |
|
} |
|
|
struct object KoxCloseClient(struct object client) { |
struct object KoxCloseClient(struct object client) { |
oxclientp cc1 = NULL; |
oxclientp cc1 = NULL; |
Line 1296 oxclientp oxCreateEngine_RFC_101(int fdstream,int port |
|
Line 1356 oxclientp oxCreateEngine_RFC_101(int fdstream,int port |
|
client->dataport = portStream; |
client->dataport = portStream; |
client->controlport = -1; |
client->controlport = -1; |
client->controlfd = -1; |
client->controlfd = -1; |
client->id = engineID; |
client->id = oxGetClientID(); |
|
client->engineID = engineID; |
client->type = CLIENT_SOCKET; /* socket */ |
client->type = CLIENT_SOCKET; /* socket */ |
client->engineByteOrder = engineByteOrder; |
client->engineByteOrder = engineByteOrder; |
client->controlByteOrder = -1; |
client->controlByteOrder = -1; |
Line 1324 void oxClientListRemove(struct object ob) { |
|
Line 1385 void oxClientListRemove(struct object ob) { |
|
/* errorOxmisc2("oxClientListRemove(): the client table is full.\n");*/ |
/* errorOxmisc2("oxClientListRemove(): the client table is full.\n");*/ |
} |
} |
} |
} |
|
static void KoxCleanClientList() { |
|
extern int OxClientListn; |
|
extern struct object OxClientList[]; |
|
int i,j,n; |
|
struct object ob; |
|
n = 0; |
|
for (i=0; i<OxClientListn; i++) { |
|
if ((OxClientList[i]).tag != Snull) { |
|
if (!isItClientObject(OxClientList[i])) { |
|
(OxClientList[i]).tag = Snull; |
|
} |
|
} |
|
} |
|
} |
struct object KoxGetClientList() { |
struct object KoxGetClientList() { |
extern int OxClientListn; |
extern int OxClientListn; |
extern struct object OxClientList[]; |
extern struct object OxClientList[]; |
int i,j,n; |
int i,j,n; |
struct object rob; |
struct object rob; |
|
KoxCleanClientList(); |
n = 0; |
n = 0; |
for (i=0; i<OxClientListn; i++) { |
for (i=0; i<OxClientListn; i++) { |
if ((OxClientList[i]).tag != Snull) n++; |
if ((OxClientList[i]).tag != Snull) n++; |