blob: 3e5b0e3d9182043c2115a271a5489351f3190f3f (
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
|
// **********************************************************************
//
// 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 <Ice/Ice.h>
#include <ChatSessionI.h>
using namespace std;
using namespace Demo;
ChatRoomMembers::ChatRoomMembers()
{
}
void
ChatRoomMembers::add(const ChatCallbackPrx& callback)
{
IceUtil::Mutex::Lock sync(*this);
_members.push_back(callback);
}
void
ChatRoomMembers::remove(const ChatCallbackPrx& callback)
{
IceUtil::Mutex::Lock sync(*this);
list<ChatCallbackPrx>::iterator p = find(_members.begin(), _members.end(), callback);
if(p != _members.end())
{
_members.erase(p);
}
}
void
ChatRoomMembers::message(const string& data)
{
IceUtil::Mutex::Lock sync(*this);
list<ChatCallbackPrx>::iterator p = _members.begin();
while(p != _members.end())
{
try
{
(*p)->message(data);
}
catch(const Ice::LocalException&)
{
p = _members.erase(p);
continue;
}
++p;
}
}
ChatSessionI::ChatSessionI(const ChatRoomMembersPtr& members, const string& userId) :
_members(members),
_userId(userId),
_destroy(false)
{
_members->message(_userId + " has entered the chat room.");
}
void
ChatSessionI::setCallback(const ChatCallbackPrx& callback, const Ice::Current& current)
{
IceUtil::Mutex::Lock sync(*this);
if(!_callback)
{
_callback = callback;
_members->add(callback);
}
}
void
ChatSessionI::say(const string& data, const Ice::Current&)
{
_members->message(_userId + " says: " + data);
}
void
ChatSessionI::destroy(const Ice::Current& current)
{
IceUtil::Mutex::Lock sync(*this);
if(!_destroy)
{
_destroy = true;
if(_callback)
{
_members->remove(_callback);
_callback = 0;
}
current.adapter->remove(current.id);
_members->message(_userId + " has left the chat room.");
}
}
|
