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
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
|
/* This file is part of the Spring engine (GPL v2 or later), see LICENSE.html */
#include "System/Object.h"
#include "System/mmgr.h"
#include "System/creg/STL_Set.h"
#include "System/Log/ILog.h"
#include "System/Platform/CrashHandler.h"
#ifndef USE_MMGR
# define m_setOwner(file, line, func)
# define m_resetGlobals()
#endif
CR_BIND(CObject, )
CR_REG_METADATA(CObject, (
// CR_MEMBER(listening),
// CR_MEMBER(listeners),
CR_SERIALIZER(Serialize),
CR_POSTLOAD(PostLoad)
));
Threading::AtomicCounterInt64 CObject::cur_sync_id(0);
//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////
CObject::CObject() : detached(false)
{
// Note1: this static var is shared between all different types of classes synced & unsynced (CUnit, CFeature, CProjectile, ...)
// Still it doesn't break syncness even when synced objects have different sync_ids between clients as long as the sync_id is
// creation time dependent and monotonously increasing, so the _order_ remains between clients.
// Use atomic fetch-and-add, so threads don't read half written data nor write old (= smaller) numbers
sync_id = ++cur_sync_id;
assert(sync_id + 1 > sync_id); // check for overflow
}
void CObject::Detach()
{
// SYNCED
assert(!detached);
detached = true;
for (TDependenceMap::iterator i = listeners.begin(); i != listeners.end(); ++i) {
const DependenceType& depType = i->first;
TSyncSafeSet& objs = i->second;
for (TSyncSafeSet::iterator di = objs.begin(); di != objs.end(); ++di) {
CObject* const& obj = (*di);
m_setOwner(__FILE__, __LINE__, __FUNCTION__);
obj->DependentDied(this);
m_setOwner(__FILE__, __LINE__, __FUNCTION__);
assert(obj->listening.find(depType) != obj->listening.end());
obj->listening[depType].erase(this);
}
}
for (TDependenceMap::iterator i = listening.begin(); i != listening.end(); ++i) {
const DependenceType& depType = i->first;
TSyncSafeSet& objs = i->second;
for (TSyncSafeSet::iterator di = objs.begin(); di != objs.end(); ++di) {
CObject* const& obj = (*di);
m_setOwner(__FILE__, __LINE__, __FUNCTION__);
assert(obj->listeners.find(depType) != obj->listeners.end());
obj->listeners[depType].erase(this);
}
}
m_resetGlobals();
}
CObject::~CObject()
{
// UNSYNCED (if detached)
if (!detached)
Detach();
}
void CObject::Serialize(creg::ISerializer* ser)
{
//FIXME this was written when listeners & listening were std::list's, with switching to std::set it would need a rewrite
assert(false);
/*if (ser->IsWriting()) {
int num = listening.size();
ser->Serialize(&num, sizeof(int));
for (std::map<DependenceType, TSyncSafeSet >::iterator i = listening.begin(); i != listening.end(); ++i) {
int dt = i->first;
ser->Serialize(&dt, sizeof(int));
TSyncSafeSet& dl = i->second;
int size = 0;
TSyncSafeSet::const_iterator oi;
for (oi = dl.begin(); oi != dl.end(); ++oi) {
if ((*oi)->GetClass() != CObject::StaticClass()) {
size++;
}
}
ser->Serialize(&size, sizeof(int));
for (oi = dl.begin(); oi != dl.end(); ++oi) {
if ((*oi)->GetClass() != CObject::StaticClass()) {
ser->SerializeObjectPtr((void**)&*oi, (*oi)->GetClass());
} else {
LOG("Death dependance not serialized in %s", GetClass()->name.c_str());
}
}
}
} else {
int num;
ser->Serialize(&num, sizeof(int));
for (int i = 0; i < num; i++) {
int dt;
ser->Serialize(&dt, sizeof(int));
int size;
ser->Serialize(&size, sizeof(int));
TSyncSafeSet& dl = listening[(DependenceType)dt];
for (int o = 0; o < size; o++) {
TSyncSafeSet::iterator oi = dl.insert(NULL);
ser->SerializeObjectPtr((void**)&*oi, NULL);
}
}
}*/
}
void CObject::PostLoad()
{
//FIXME this was written when listeners & listening were std::list's, with switching to std::set it would need a rewrite
assert(false);
/*for (std::map<DependenceType, TSyncSafeSet >::iterator i = listening.begin(); i != listening.end(); ++i) {
for (TSyncSafeSet::iterator oi = i->second.begin(); oi != i->second.end(); ++oi) {
m_setOwner(__FILE__, __LINE__, __FUNCTION__);
TSyncSafeSet& dl = (*oi)->listeners[i->first];
dl.insert(this);
}
}*/
m_resetGlobals();
}
void CObject::DependentDied(CObject* obj)
{
}
// NOTE that we can be listening to a single object from several different places,
// however objects are responsible for not adding the same dependence more than once,
// and preferably try to delete the dependence asap in order not to waste memory
void CObject::AddDeathDependence(CObject* obj, DependenceType dep)
{
assert(!detached);
m_setOwner(__FILE__, __LINE__, __FUNCTION__);
listening[dep].insert(obj);
m_setOwner(__FILE__, __LINE__, __FUNCTION__);
obj->listeners[dep].insert(this);
m_resetGlobals();
}
void CObject::DeleteDeathDependence(CObject* obj, DependenceType dep)
{
assert(!detached);
m_setOwner(__FILE__, __LINE__, __FUNCTION__);
obj->listeners[dep].erase(this);
m_setOwner(__FILE__, __LINE__, __FUNCTION__);
listening[dep].erase(obj);
m_resetGlobals();
}
|
