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
173
174
175
|
/* This file is part of the Spring engine (GPL v2 or later), see LICENSE.html */
#include "System/Object.h"
#include "System/creg/STL_Set.h"
#include "System/Log/ILog.h"
#include "System/Platform/CrashHandler.h"
CR_BIND(CObject, )
CR_REG_METADATA(CObject, (
CR_MEMBER(sync_id),
CR_MEMBER(detached),
CR_IGNORED(listening), //handled in Serialize
CR_IGNORED(listeners), //handled in Serialize
CR_SERIALIZER(Serialize),
CR_POSTLOAD(PostLoad)
))
Threading::AtomicCounterInt64 CObject::cur_sync_id(0);
//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////
CObject::CObject() : detached(false), listeners(), listening()
{
// 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
}
CObject::~CObject()
{
assert(!detached);
detached = true;
for (int depType = 0; depType < DEPENDENCE_COUNT; ++depType) {
if (!listeners[depType])
continue;
for (CObject* obj: *listeners[depType]) {
obj->DependentDied(this);
assert(obj->listening[depType]);
obj->listening[depType]->erase(this);
}
delete listeners[depType];
}
for (int depType = 0; depType < DEPENDENCE_COUNT; ++depType) {
if (!listening[depType])
continue;
for (CObject* obj: *listening[depType]) {
assert(obj->listeners[depType]);
obj->listeners[depType]->erase(this);
}
delete listening[depType];
}
}
#ifdef USING_CREG
void CObject::Serialize(creg::ISerializer* ser)
{
if (ser->IsWriting()) {
int num = 0;
for (int dt = 0; dt < DEPENDENCE_COUNT; ++dt) {
if (listening[dt]) {
++num;
}
}
ser->Serialize(&num, sizeof(int));
for (int dt = 0; dt < DEPENDENCE_COUNT; ++dt) {
if (listening[dt]) {
ser->Serialize(&dt, sizeof(int));
TSyncSafeSet& dl = *listening[dt];
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));
if (!listening[dt])
listening[dt] = new TSyncSafeSet();
TSyncSafeSet& dl = *listening[dt];
for (int o = 0; o < size; o++) {
CObject* obj = NULL;
ser->SerializeObjectPtr((void**)&obj, NULL);
dl.insert(obj);
}
}
// cur_sync_id needs fixing since it's not serialized
// it might not be exactly where we left it, but that's not important
// since only order matters
cur_sync_id = Threading::AtomicCounterInt64(std::max(sync_id, (boost::int64_t) cur_sync_id));
}
}
void CObject::PostLoad()
{
for (int depType = 0; depType < DEPENDENCE_COUNT; ++depType) {
if (!listening[depType])
continue;
for (CObject* obj: *listening[depType]) {
if (!obj->listeners[depType])
obj->listeners[depType] = new TSyncSafeSet();
obj->listeners[depType]->insert(this);
}
}
}
#endif //USING_CREG
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 && !obj->detached);
if (!listening[dep])
listening[dep] = new TSyncSafeSet();
listening[dep]->insert(obj);
if (!obj->listeners[dep])
obj->listeners[dep] = new TSyncSafeSet();
obj->listeners[dep]->insert(this);
}
void CObject::DeleteDeathDependence(CObject* obj, DependenceType dep)
{
assert(!detached);
if (obj->detached)
return;
obj->listeners[dep]->erase(this);
listening[dep]->erase(obj);
}
|
