home
***
CD-ROM
|
disk
|
FTP
|
other
***
search
/
Club Amiga de Montreal - CAM
/
CAM_CD_1.iso
/
files
/
332.lha
/
IPC_nov89
/
Sources
/
Broker_skel.c
< prev
next >
Wrap
C/C++ Source or Header
|
1990-01-09
|
3KB
|
123 lines
/* Primitive test program for LoadIPCPort facility */
/* ...simply displays a request for a port in its console window */
/* Shared Library version 89:3:26 */
#include "IPCPorts.h"
#include "IPC_proto.h"
#include "IPC.h"
#include "exec/memory.h"
#include "exec/tasks.h"
#include "libraries/DOS.h"
#define SOL(s) ((LONG)sizeof(s))
#define IPPL MAKE_ID('I','P','P','L')
#define PORT MAKE_ID('P','O','R','T')
ULONG IPCBase = NULL;
struct IPCPort *brokerport;
struct IPCMessage *imsg=NULL;
void baditem(struct IPCItem *, ULONG);
void outputstr(char *);
struct Task * FindTask(char *);
void Cleanup();
ULONG bportsig = 0; /* signal masks for port */
int active = TRUE;
void _main()
{
ULONG sigset;
IPCBase = OpenLibrary("ppipc.library",0);
if (!IPCBase) {
outputstr("couldn't find IPC Library -- TTFN...\n");
_exit(20);
}
brokerport = ServeIPCPort("PortBrokerPort");
if (!brokerport) {Cleanup(); _exit(11);}
bportsig = 1<<brokerport->ipp_Port.mp_SigBit;
outputstr("Opened 'PortBrokerPort'\n");
do {
while ( procimsg() ) ; /* loop */
if (active) {
sigset = Wait(bportsig | SIGBREAKF_CTRL_C);
if (sigset & SIGBREAKF_CTRL_C) {
active = FALSE;
ShutIPCPort(brokerport);
continue; /* so we clear out any messages that sneak in */
}
}
} while (active);
outputstr("Broker terminating...\n");
Cleanup();
}
void Cleanup()
{
if (brokerport) LeaveIPCPort(brokerport);
CloseLibrary(IPCBase);
}
procimsg()
{
struct IPCItem *item;
if (!(imsg = (struct IPCMessage *) GetMsg(brokerport))) return FALSE;
outputstr("got message\n");
item = imsg->ipc_Items;
if (imsg->ipc_Id == IPPL && item->ii_Id == PORT
&& loadport(item->ii_Ptr)) /* everything OK */;
else imsg->ipc_Flags |= IPC_NOTKNOWN;
ReplyMsg(imsg);
return TRUE;
}
void baditem(item, extraflags)
struct IPCItem *item;
ULONG extraflags;
{
imsg->ipc_Flags |= IPC_CHECKITEM;
item->ii_Flags |= IPC_NOTKNOWN | extraflags;
}
void outputstr(str) char *str;
{
Write(Output(), str, strlen(str));
}
/*
* loadport(portptr)
*
* -- actually initiates the loading procedure (here just a skeleton).
* returns TRUE if successful, otherwise FALSE.
*/
loadport(port) struct IPCPort *port;
{
outputstr("Please load server for port '");
outputstr(port->ipp_Name);
outputstr("' -- Thanks\n");
return TRUE; /* -- doesn't know how to fail yet... */
}
/****************************************************************/