summaryrefslogtreecommitdiff
path: root/comm/OLD/Agent.h
blob: e7db419ba2180a9705b2c3eda24c6a3fdc5b5aa4 (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
/*
 *	The Unix Channel
 *
 *	by Michel Beaudouin-Lafon
 *
 *	Copyright 1990-1993
 *	Laboratoire de Recherche en Informatique (LRI)
 *
 *	Agents, by Stephane Chatty
 *
 *	$Id$
 *	$CurLog$
 */

#ifndef Agent_H_
#define Agent_H_

#include "ccu/List.h"
#include "MsgStream.h"
#include "Multiplexer.h"
#include "error.h"

class UchRemoteAgent;

class UchAgent : public UchStream {
friend	class	UchRemoteAgent;

protected:
	CcuListOf <UchRemoteAgent>	RemoteAgents;
	pUchMultiplexer	ChanSet;

	void		HandleRead ();

public:
		UchAgent ();
		UchAgent (const UchAgent&);
		UchAgent (UchAddress*);
		~UchAgent ();
	
	UchChannel*	Copy () const;
	
	bool		Setup (UchMultiplexer* cs = 0);
inline	UchMultiplexer*	GetMultiplexer ()			{ return ChanSet; }

	UchRemoteAgent*	Contact (UchAddress*);
	void		RemoveRemoteAgent (UchRemoteAgent*);
	void		Run ();
	void		Unlisten ();

	void		Broadcast (UchMessage&, bool = FALSE);
	void		Broadcast (UchMessage&, UchRemoteAgent*, bool = FALSE);
	void		Broadcast (UchMsgBuffer&, bool = FALSE);
	void		Broadcast (UchMsgBuffer&, UchRemoteAgent*, bool = FALSE);

virtual	void		HandleNew (UchRemoteAgent*);
virtual	void		HandleRemove (UchRemoteAgent*);
virtual	bool		SysError (errtype, const char*, int = 0, int = 0);
virtual	void		Error (errtype, const char*, const char*);
};


class UchRemoteAgent : public UchMsgStream {
friend	class	UchAgent;

protected:
	UchAgent	*MyLocalAgent;

public:
		UchRemoteAgent (UchAgent*);
		UchRemoteAgent (const UchRemoteAgent& cl);
		UchRemoteAgent (UchAgent*, UchAddress*);
		UchRemoteAgent (UchAgent*, UchChannel* ch);
		~UchRemoteAgent ();
	
	UchChannel*	Copy () const;
	void		Delete ();
	
inline	UchAgent*		GetLocalContact ()	{ return MyLocalAgent; }
};


#endif /* Agent_H_ */