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

#ifndef Service_H_
#define Service_H_

#include "Message.h"
#include "MsgStream.h"
#include "error.h"
#include "cplus_bugs.h"
#include "ccu/List.h"

class UchService;

//	class for storing and retrieving events
//
class UchMsgQueue : public CcuSmartData {

protected:
#ifndef CPLUS_BUG19
	CcuListOf <UchMessage>	Queue;
#else
	CcuList	Queue;
#endif

public:
		UchMsgQueue ();
		~UchMsgQueue ();
	
inline	void		Put (UchMessage* m)	{ Queue.Append (m); }
#ifndef CPLUS_BUG19
inline	UchMessage*	Peek ()		{ return Queue.First (); }
inline	UchMessage*	Get ()		{ return Queue.RemoveFirst (); }
#else
inline	UchMessage*	Peek ()		{ return (UchMessage*) Queue.First (); }
inline	UchMessage*	Get ()		{ return (UchMessage*) Queue.RemoveFirst (); }
#endif
inline	void		PutBack (UchMessage* m)	{ Queue.Prepend (m); }
#ifndef CPLUS_BUG19
inline		operator const CcuListOf <UchMessage>& () const	{ return Queue; }
#else
inline		operator const CcuList& () const	{ return Queue; }
#endif
};

PointerClass (pUchMsgQueue, UchMsgQueue)

//	UchService is the client's view of a server
//	we use smart pointers so that the event queue can be shared
//
class UchService : public UchMsgStream {
protected:
	pUchMsgQueue	EvQueue;

public:
		UchService ();
		UchService (UchAddress*);
		UchService (const UchService&);
		~UchService ();

	UchChannel*	Copy () const;
	
	void		SetEvQueue (UchMsgQueue*);
	UchMessage*	PeekEvent (bool = TRUE);
	UchMessage*	GetEvent (bool = TRUE);
	void		PutEvent (UchMessage*);
	void		PutBackEvent (UchMessage*);
};

#endif /* Service_H_ */