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

#ifndef Server_H_
#define Server_H_

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

class	UchServer;

class UchClient : public UchMsgStream {
friend	class	UchServer;

protected:
	UchServer*	MyServer;

public:
		UchClient (const UchClient& cl);
		UchClient (UchServer&, int);
		~UchClient ();
	
	UchChannel*	Copy () const;
	void		Delete ();
	
inline	UchServer*		GetServer ()	{ return MyServer; }
};

class UchServer : public UchStream {
friend	class	UchClient;

protected:
#ifndef CPLUS_BUG19
	CcuListOf <UchClient>	Clients;
#else
	CcuList	Clients;
#endif

public:
		UchServer (const UchServer&);
		UchServer (UchBaseMultiplexer&, UchAddress*);
		~UchServer ();
	
	UchChannel*	Copy () const;
	void		HandleRead ();
	
	void		RemoveClient (UchClient*);
	void		Unlisten ();
	void		Broadcast (UchMessage&, bool = false);
	void		Broadcast (UchMessage&, UchClient*, bool = false);
	void		Broadcast (UchMsgBuffer&, bool = false);
	void		Broadcast (UchMsgBuffer&, UchClient*, bool = false);
// called by HandleRead when a new client connects: must build up a client from a channel
virtual	UchClient*		CreateClient (int);
virtual	void		HandleRemove (UchClient*);
virtual	bool		SysError (errtype, const char*, int = 0, int = 0);
virtual	void		Error (errtype, const char*, const char*);
};


#endif /* Server_H_ */