← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/pbms/src/cslib/CSObject.cc

  • Committer: Brian Aker
  • Date: 2010-12-08 22:35:56 UTC
  • mfrom: (1819.9.158 update-innobase)
  • Revision ID: brian@tangent.org-20101208223556-37mi4omqg7lkjzf3
Merge in Stewart's changes, 1.3 changes.

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/pbms/src/cslib/CSObject.cc
 
1
/* Copyright (c) 2008 PrimeBase Technologies GmbH, Germany
 
2
 *
 
3
 * PrimeBase Media Stream for MySQL
 
4
 *
 
5
 * This program is free software; you can redistribute it and/or modify
 
6
 * it under the terms of the GNU General Public License as published by
 
7
 * the Free Software Foundation; either version 2 of the License, or
 
8
 * (at your option) any later version.
 
9
 *
 
10
 * This program is distributed in the hope that it will be useful,
 
11
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 
12
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
13
 * GNU General Public License for more details.
 
14
 *
 
15
 * You should have received a copy of the GNU General Public License
 
16
 * along with this program; if not, write to the Free Software
 
17
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
 
18
 *
 
19
 * Original author: Paul McCullagh (H&G2JCtL)
 
20
 * Continued development: Barry Leslie
 
21
 *
 
22
 * 2007-05-20
 
23
 *
 
24
 * A basic syncronized object.
 
25
 *
 
26
 */
 
27
 
 
28
#include "CSConfig.h"
 
29
 
 
30
#include <assert.h>
 
31
 
 
32
#include "CSGlobal.h"
 
33
#include "CSDefs.h"
 
34
#include "CSObject.h"
 
35
#include "CSMemory.h"
 
36
 
 
37
#ifdef DEBUG
 
38
#undef retain
 
39
#undef release
 
40
#endif
 
41
 
 
42
/*
 
43
 * ---------------------------------------------------------------
 
44
 * BASIC OBJECTS
 
45
 */
 
46
 
 
47
#ifdef DEBUG
 
48
void CSObject::retain(const char *func, const char *file, uint32_t line)
 
49
{
 
50
        CSException::throwAssertion(func, file, line, "Non-referenced object cannot be referenced");
 
51
}
 
52
#else
 
53
void CSObject::retain()
 
54
{
 
55
        CSException::throwAssertion(CS_CONTEXT, "Non-referenced object cannot be referenced");
 
56
}
 
57
#endif
 
58
 
 
59
#ifdef DEBUG
 
60
void CSObject::release(const char *, const char *, uint32_t )
 
61
#else
 
62
void CSObject::release()
 
63
#endif
 
64
{
 
65
        delete this;
 
66
}
 
67
 
 
68
CSObject *CSObject::getKey() { CSException::throwCoreError(CS_CONTEXT, CS_ERR_IMPL_MISSING, __FUNC__); return NULL; }
 
69
 
 
70
int CSObject::compareKey(CSObject *)  { CSException::throwCoreError(CS_CONTEXT, CS_ERR_IMPL_MISSING, __FUNC__); return 0; }
 
71
 
 
72
uint32_t CSObject::hashKey()  { CSException::throwCoreError(CS_CONTEXT, CS_ERR_IMPL_MISSING, __FUNC__); return 0; }
 
73
 
 
74
CSObject *CSObject::getHashLink() { CSException::throwCoreError(CS_CONTEXT, CS_ERR_IMPL_MISSING, __FUNC__); return NULL; }
 
75
 
 
76
void CSObject::setHashLink(CSObject *) { CSException::throwCoreError(CS_CONTEXT, CS_ERR_IMPL_MISSING, __FUNC__); }
 
77
 
 
78
CSObject *CSObject::getNextLink() { CSException::throwCoreError(CS_CONTEXT, CS_ERR_IMPL_MISSING, __FUNC__); return NULL; }
 
79
 
 
80
CSObject *CSObject::getPrevLink() { CSException::throwCoreError(CS_CONTEXT, CS_ERR_IMPL_MISSING, __FUNC__); return NULL; }
 
81
 
 
82
void CSObject::setNextLink(CSObject *) { CSException::throwCoreError(CS_CONTEXT, CS_ERR_IMPL_MISSING, __FUNC__); }
 
83
 
 
84
void CSObject::setPrevLink(CSObject *) { CSException::throwCoreError(CS_CONTEXT, CS_ERR_IMPL_MISSING, __FUNC__); }
 
85
 
 
86
/*
 
87
 * ---------------------------------------------------------------
 
88
 * STATIC OBJECTS
 
89
 */
 
90
 
 
91
#ifdef DEBUG
 
92
void CSStaticObject::retain(const char *, const char *, uint32_t )
 
93
#else
 
94
void CSStaticObject::retain()
 
95
#endif
 
96
{
 
97
}
 
98
 
 
99
#ifdef DEBUG
 
100
void CSStaticObject::release(const char *, const char *, uint32_t )
 
101
#else
 
102
void CSStaticObject::release()
 
103
#endif
 
104
{
 
105
        finalize();
 
106
}
 
107
 
 
108
/*
 
109
 * ---------------------------------------------------------------
 
110
 * REFERENCE OBJECTS
 
111
 */
 
112
 
 
113
CSRefObject::CSRefObject():
 
114
CSObject(),
 
115
iRefCount(1)
 
116
{
 
117
#ifdef DEBUG
 
118
        iTrackMe = 0;
 
119
        cs_mm_track_memory(NULL, NULL, 0, this, true, iRefCount, iTrackMe);
 
120
#endif
 
121
}
 
122
 
 
123
CSRefObject::~CSRefObject()
 
124
{
 
125
        ASSERT(iRefCount == 0);
 
126
}
 
127
 
 
128
#ifdef DEBUG
 
129
void CSRefObject::retain(const char *func, const char *file, uint32_t line)
 
130
#else
 
131
void CSRefObject::retain()
 
132
#endif
 
133
{
 
134
        if (!iRefCount)
 
135
                CSException::throwAssertion(CS_CONTEXT, "Freed object being retained.");
 
136
                
 
137
        iRefCount++;
 
138
#ifdef DEBUG
 
139
        cs_mm_track_memory(func, file, line, this, true, iRefCount, iTrackMe);
 
140
#endif
 
141
}
 
142
 
 
143
#ifdef DEBUG
 
144
void CSRefObject::release(const char *func, const char *file, uint32_t line)
 
145
#else
 
146
void CSRefObject::release()
 
147
#endif
 
148
{
 
149
        bool terminate;
 
150
 
 
151
#ifdef DEBUG
 
152
        cs_mm_track_memory(func, file, line, this, false, iRefCount, iTrackMe);
 
153
#endif
 
154
        iRefCount--;
 
155
        if (!iRefCount)
 
156
                terminate = true;
 
157
        else
 
158
                terminate = false;
 
159
 
 
160
        if (terminate)
 
161
                delete this;
 
162
}
 
163
 
 
164
#ifdef DEBUG
 
165
void CSRefObject::startTracking()
 
166
{
 
167
        iTrackMe = 1;
 
168
        cs_mm_track_memory(NULL, NULL, 0, this, true, iRefCount, iTrackMe);
 
169
}
 
170
#endif
 
171
 
 
172
/*
 
173
 * ---------------------------------------------------------------
 
174
 * SHARED REFERENCE OBJECTS
 
175
 */
 
176
 
 
177
CSSharedRefObject::CSSharedRefObject():
 
178
CSObject(),
 
179
CSSync(),
 
180
iRefCount(1)
 
181
{
 
182
#ifdef DEBUG
 
183
        iTrackMe = 0;
 
184
        cs_mm_track_memory(NULL, NULL, 0, this, true, iRefCount, iTrackMe);
 
185
#endif
 
186
}
 
187
 
 
188
CSSharedRefObject::~CSSharedRefObject()
 
189
{
 
190
        ASSERT(iRefCount == 0);
 
191
}
 
192
 
 
193
#ifdef DEBUG
 
194
void CSSharedRefObject::retain(const char *func, const char *file, uint32_t line)
 
195
#else
 
196
void CSSharedRefObject::retain()
 
197
#endif
 
198
{
 
199
        lock();
 
200
        iRefCount++;
 
201
#ifdef DEBUG
 
202
        cs_mm_track_memory(func, file, line, this, true, iRefCount, iTrackMe);
 
203
#endif
 
204
        unlock();
 
205
}
 
206
 
 
207
#ifdef DEBUG
 
208
void CSSharedRefObject::release(const char *func, const char *file, uint32_t line)
 
209
#else
 
210
void CSSharedRefObject::release()
 
211
#endif
 
212
{
 
213
        bool terminate;
 
214
 
 
215
        lock();
 
216
#ifdef DEBUG
 
217
        cs_mm_track_memory(func, file, line, this, false, iRefCount, iTrackMe);
 
218
#endif
 
219
        iRefCount--;
 
220
        if (!iRefCount)
 
221
                terminate = true;
 
222
        else
 
223
                terminate = false;
 
224
        unlock();
 
225
 
 
226
        if (terminate)
 
227
                delete this;
 
228
}
 
229
 
 
230
#ifdef DEBUG
 
231
void CSSharedRefObject::startTracking()
 
232
{
 
233
        iTrackMe = 1;
 
234
        cs_mm_track_memory(NULL, NULL, 0, this, true, iRefCount, iTrackMe);
 
235
}
 
236
#endif
 
237
 
 
238
#ifdef DEBUG
 
239
/*
 
240
void CSSharedRefObject::retain(const char *func, const char *file, uint32_t line)
 
241
{
 
242
        lock();
 
243
        iRefCount++;
 
244
        cs_mm_print_track(func, file, line, this, true, iRefCount);
 
245
        unlock();
 
246
}
 
247
 
 
248
void CSSharedRefObject::release(const char *func, const char *file, uint32_t line)
 
249
{
 
250
        bool terminate;
 
251
 
 
252
        lock();
 
253
        cs_mm_track_memory(func, file, line, this, false, iRefCount, iTrackMe);
 
254
        iRefCount--;
 
255
        if (!iRefCount)
 
256
                terminate = true;
 
257
        else
 
258
                terminate = false;
 
259
        unlock();
 
260
 
 
261
        if (terminate)
 
262
                delete this;
 
263
}
 
264
*/
 
265
#endif
 
266
 
 
267