blob: bc6b9ca366b73bfed9a1a4dc96df594a73804c98 (
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
|
// **********************************************************************
//
// Copyright (c) 2003-2005 ZeroC, Inc. All rights reserved.
//
// This copy of Ice is licensed to you under the terms described in the
// ICE_LICENSE file included in this distribution.
//
// **********************************************************************
#include <ChatSessionI.h>
#include <Ice/Ice.h>
#include <list>
using namespace std;
using namespace Demo;
class ChatRoom;
typedef IceUtil::Handle<ChatRoom> ChatRoomPtr;
class ChatRoom : public IceUtil::Mutex, public IceUtil::Shared
{
public:
static ChatRoomPtr& instance();
void enter(const Demo::ChatCallbackPrx&);
void leave(const Demo::ChatCallbackPrx&);
void message(const string&) const;
private:
list<Demo::ChatCallbackPrx> _members;
static ChatRoomPtr _instance;
static IceUtil::StaticMutex _instanceMutex;
};
ChatRoomPtr ChatRoom::_instance;
IceUtil::StaticMutex ChatRoom::_instanceMutex = ICE_STATIC_MUTEX_INITIALIZER;
ChatRoomPtr&
ChatRoom::instance()
{
IceUtil::StaticMutex::Lock sync(_instanceMutex);
if(!_instance)
{
_instance = new ChatRoom;
}
return _instance;
}
void
ChatRoom::enter(const ChatCallbackPrx& callback)
{
Lock sync(*this);
_members.push_back(ChatCallbackPrx::uncheckedCast(callback->ice_oneway()));
}
void
ChatRoom::leave(const ChatCallbackPrx& callback)
{
Lock sync(*this);
list<ChatCallbackPrx>::iterator p;
for(p = _members.begin(); p != _members.end(); ++p)
{
if(Ice::proxyIdentityEqual(callback, *p))
{
break;
}
}
assert(p != _members.end());
_members.erase(p);
}
void
ChatRoom::message(const string& data) const
{
Lock sync(*this);
for(list<ChatCallbackPrx>::const_iterator p = _members.begin(); p != _members.end(); ++p)
{
try
{
(*p)->message(data);
}
catch(const Ice::LocalException&)
{
}
}
}
ChatSessionI::ChatSessionI(const string& userId) :
_userId(userId)
{
}
void
ChatSessionI::setCallback(const ChatCallbackPrx& callback, const Ice::Current& current)
{
Lock sync(*this);
if(!_callback)
{
_callback = callback;
ChatRoomPtr chatRoom = ChatRoom::instance();
chatRoom->message(_userId + " has entered the chat room.");
chatRoom->enter(callback);
}
}
void
ChatSessionI::say(const string& data, const Ice::Current&)
{
ChatRoom::instance()->message(_userId + " says: " + data);
}
void
ChatSessionI::destroy(const Ice::Current& current)
{
Lock sync(*this);
if(_callback)
{
ChatRoomPtr chatRoom = ChatRoom::instance();
chatRoom->leave(_callback);
_callback = 0;
chatRoom->message(_userId + " has left the chat room.");
}
current.adapter->remove(current.id);
}
|
