summaryrefslogtreecommitdiff
path: root/comm/BusAccess.h
blob: b77ee26f6d2dba8db335d29d9a72ac6faa68f5ed (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
/*
 *	Ivy League
 *
 *	Ivy bus access
 *
 *	Copyright 1997-2000
 *	Centre d'Etudes de la Navigation Aerienne (CENA)
 *
 *	by Stephane Chatty
 *
 *	$Id$
 *
 */

#ifndef BusAccess_H_
#define BusAccess_H_

#include "Datagram.h"
#include "Stream.h"
#include "BufStream.h"
#include "SignalHandler.h"
#include "ivl/List.h"
#include "ivl/IdTable.h"
#include "ivl/String.h"
#include "ivl/HashTable.h"
#include "ivl/Event.h"
#include "ivl/Trigger.h"

class IvlInetAddress;
class IvlBusSubscription;
class IvlBusTrigger;
class IvlBaseReaction;

class IvlBusAccess : public IvlDatagram, public IvlBaseScheduledHandler {
friend	class	IvlBusAgent;

protected:
static	int	Version;
static	const char* const	DefaultBus;
static	const char* const	DefaultBusNet;
static	sword const	DefaultBusPort;
	IvlString	Name;
	sword	ListenPort;
	sword	BroadcastPort;
	IvlStream*	Server;
	IvlListOf<IvlBusAgent>	Agents;
	IvlListOf<IvlBusTrigger>	LocalSubscriptions;
	IvlIdTableOf<IvlBusTrigger>	IdToSubscription;

	void	HandleRead ();
	void	Clear ();
	void	DeferredHandle (int);
	void	HandleEvent (int, const char*);
	bool	CheckUnicity (IvlBusAgent*, sword);

public:
	IvlTrigger	NewAgents;

		IvlBusAccess (const char*, const char* = 0);
		~IvlBusAccess ();
	void	Subscribe (IvlBaseReaction&, const char*, ...);
	void	Emit (const char*, ...);
};

class IvlBusAgent : public IvlBufStream {
friend	class	IvlBusAccess;
friend	class	IvlBusServer;

protected:
	IvlListOf<IvlBusSubscription>	RemoteSubscriptions;
	sword	RemoteId;
	IvlBusAccess*	MyBus;
	IvlString	Name;

	void	WriteString (const char*);
	void	ProcessLine (const char*);

		IvlBusAgent (int, IvlBusAccess*);
		IvlBusAgent (lword, sword, IvlBusAccess*);
		~IvlBusAgent ();

	void	HandleRead ();
	void	SendLocalSubscription (const IvlBusTrigger*);
	void	SayHello ();
	void	SayBye ();
	void	EmitEvent (const char*);

public:
	IvlTrigger	Bye;
	IvlHashedArrayOf<IvlTrigger>	DirectMsg;

	void	Emit (int, const char*, ...);
inline	const char*	GetName () const	{ return Name; }
};

class IvlBusAgentEvent : public IvlEvent {
public:
static	IvlEventType*	BusNewAgent, *BusAgentBye;

protected:
	IvlBusAgent*	Agent;

public:
		IvlBusAgentEvent (IvlBusAgent*, IvlEventType*);
		~IvlBusAgentEvent ();

inline	IvlBusAgent*	GetAgent () const	{ return Agent;}
};

class IvlDirectEvent : public IvlEvent {
public:
	IvlBusAgent*	Agent;
	IvlString	Msg;

public:
		IvlDirectEvent (IvlBusAgent*, const char*);
		~IvlDirectEvent ();
};

class IvlBusEvent : public IvlEvent {
public:
	IvlString	Regexp;
	int	NbMatches;
	IvlListOf<IvlString>	MatchList;
	IvlString	Matches;

		IvlBusEvent (const char*, const char*);
		~IvlBusEvent ();
};

#endif	/* BusAccess_H_ */