00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033
00034
00035
00036
00037
00038
00039
00040 #include "WOscBundle.h"
00041 #include "WOscException.h"
00042 #include "WOscUtil.h"
00043 #include <string.h>
00044
00045
00046
00047
00048
00049
00050
00051
00052 WOscBundle::WOscBundle(WOscTimeTag timeTag) : WOscTimeTag(timeTag)
00053 {
00054 InitEmpty();
00055 }
00056
00057
00058
00059
00060
00061 WOscBundle::WOscBundle() : WOscTimeTag(WOscTimeTag::GetImmediateTime())
00062 {
00063 InitEmpty();
00064 }
00065
00066
00067
00068
00069
00070
00071
00072
00073
00074 WOscBundle::~WOscBundle(){
00075
00076
00077 if ( m_buffer )
00078 delete [] m_buffer;
00079
00080
00081 if ( m_messages ){
00082 for( int i = 0; i < m_numMessages; i++ )
00083 delete m_messages[i];
00084 delete [] m_messages;
00085 }
00086 if ( m_bundles ){
00087 for( int i = 0; i < m_numBundles; i++ )
00088 delete m_bundles[i];
00089 delete [] m_bundles;
00090 }
00091 }
00092
00093 void
00094 WOscBundle::Reset()
00095 {
00096 if ( m_buffer )
00097 delete [] m_buffer;
00098
00099
00100 if ( m_messages ){
00101 for( int i = 0; i < m_numMessages; i++ )
00102 delete m_messages[i];
00103 delete [] m_messages;
00104 }
00105 if ( m_bundles ){
00106 for( int i = 0; i < m_numBundles; i++ )
00107 delete m_bundles[i];
00108 delete [] m_bundles;
00109 }
00110 InitEmpty();
00111 }
00112
00113
00114
00115
00116
00117
00118 void WOscBundle::InitEmpty(){
00119
00120
00121 m_messages = NULL;
00122 m_numMessages = 0;
00123
00124
00125 m_bundles = NULL;
00126 m_numBundles = 0;
00127
00128
00129 m_buffer = NULL;
00130 m_bufferSize = 0;
00131
00132 }
00133
00134
00135
00136
00137
00138
00139
00140 void WOscBundle::GenerateBufferFromElements(){
00141
00142 m_bufferSize = GetBufferLen();
00143 m_buffer = new char[m_bufferSize];
00144 char* wrPtr = m_buffer;
00145
00146
00147 memcpy(wrPtr, WOSC_BUNDLE_TAG, 8);
00148 wrPtr += 8;
00149
00150
00151 WriteToCharArray(wrPtr);
00152 wrPtr += WOscTimeTag::TIME_TAG_SIZE;
00153
00154
00155 for ( int i = 0; i < m_numMessages; i++ ){
00156
00157 int msgSize = m_messages[i]->GetBufferLen();
00158 WOscUtil::FillBufferWith(wrPtr, msgSize);
00159 wrPtr += SIZE_SIZE;
00160
00161 const char* temp = m_messages[i]->GetBuffer();
00162 memcpy(wrPtr, temp, msgSize);
00163 wrPtr += msgSize;
00164 }
00165
00166
00167 for ( int i = 0; i < m_numBundles; i++ ){
00168
00169 int bndlSize = m_bundles[i]->GetBufferLen();
00170 WOscUtil::FillBufferWith(wrPtr, bndlSize);
00171 wrPtr += SIZE_SIZE;
00172
00173 const char* temp = m_bundles[i]->GetBuffer();
00174 memcpy(wrPtr, temp, bndlSize);
00175 wrPtr += bndlSize;
00176 }
00177 }
00178
00179
00180
00181
00182
00183
00184
00185
00186
00187 void WOscBundle::Add(WOscBundle* bundle){
00188 if ( !m_bundles ){
00189 m_bundles = new WOscBundle*[1];
00190 m_bundles[0] = bundle;
00191 m_numBundles++;
00192 }else{
00193 m_numBundles++;
00194 WOscBundle** newBndlArray = new WOscBundle*[m_numBundles];
00195 for( int i = 0; i < m_numBundles-1; i++ )
00196 newBndlArray[i] = m_bundles[i];
00197 newBndlArray[m_numBundles-1] = bundle;
00198
00199 delete [] m_bundles;
00200 m_bundles = newBndlArray;
00201 }
00202 }
00203
00204
00205
00206
00207
00208
00209
00210
00211
00212 void WOscBundle::Add(WOscMessage* message){
00213 if ( !m_messages ){
00214 m_messages = new WOscMessage*[1];
00215 m_messages[0] = message;
00216 m_numMessages++;
00217 }else{
00218 m_numMessages++;
00219 WOscMessage** newMsgArray = new WOscMessage*[m_numMessages];
00220 for( int i = 0; i < m_numMessages-1; i++ )
00221 newMsgArray[i] = m_messages[i];
00222 newMsgArray[m_numMessages-1] = message;
00223 delete [] m_messages;
00224 m_messages = newMsgArray;
00225 }
00226 }
00227
00228
00229
00230
00231
00232
00233
00234
00235
00236
00237
00238 int WOscBundle::GetNumMessages(){
00239 return m_numMessages;
00240 }
00241
00242
00243
00244
00245
00246
00247
00248
00249
00250
00251
00252 int WOscBundle::GetNumBundles(){
00253 return m_numBundles;
00254 }
00255
00256
00257
00258
00259
00260
00261
00262
00263
00264
00265
00266
00267
00268
00269
00270
00271
00272
00273
00274
00275
00276 WOscMessage* WOscBundle::GetMessage(int idx){
00277 if ( idx < 0 || idx >= m_numMessages )
00278 throw WOscException(ERR_INVALID_INDEX, __FILE__, __LINE__);
00279 else{
00280 WOscMessage* retMsg = m_messages[idx];
00281 RemoveMessage(idx);
00282 return retMsg;
00283 }
00284 }
00285
00286
00287
00288
00289
00290
00291
00292
00293
00294
00295
00296
00297
00298
00299
00300
00301
00302
00303
00304
00305
00306
00307 WOscBundle* WOscBundle::GetBundle(int idx){
00308 if ( idx < 0 || idx >= m_numBundles )
00309 throw WOscException(ERR_INVALID_INDEX, __FILE__, __LINE__);
00310 else{
00311 WOscBundle* retBundle = m_bundles[idx];
00312 RemoveBundle(idx);
00313
00314
00315 return retBundle;
00316 }
00317 }
00318
00319
00320
00321
00322
00323
00324
00325
00326
00327
00328
00329
00330
00331
00332
00333
00334
00335
00336
00337
00338
00339 void WOscBundle::GetBuffer(char* buffer, int bufferLen){
00340 if (m_buffer){
00341 delete [] m_buffer;
00342 m_buffer = NULL;
00343 }
00344
00345
00346 GenerateBufferFromElements();
00347
00348
00349 if ( m_bufferSize > bufferLen ){
00350
00351 delete m_buffer;
00352 m_buffer = NULL;
00353 m_bufferSize = 0;
00354 throw WOscException(ERR_BUFFER_TO_SMALL, __FILE__, __LINE__);
00355 }
00356 memcpy(buffer, m_buffer, m_bufferSize);
00357
00358 }
00359
00360
00361
00362
00363
00364
00365
00366
00367
00368
00369
00370
00371
00372
00373
00374
00375
00376
00377
00378 const char* WOscBundle::GetBuffer(){
00379
00380 if (m_buffer){
00381 delete [] m_buffer;
00382 m_buffer = NULL;
00383 }
00384
00385
00386 GenerateBufferFromElements();
00387
00388
00389 return m_buffer;
00390 }
00391
00392
00393
00394
00395
00396
00397
00398
00399 int WOscBundle::GetBufferLen(){
00400 int bufSize, i;
00401
00402 bufSize = BUNDLE_HEADER_SIZE + WOscTimeTag::TIME_TAG_SIZE;
00403
00404 for ( i = 0; i < m_numMessages; i++ )
00405 bufSize += SIZE_SIZE + m_messages[i]->GetBufferLen();
00406
00407 for ( i = 0; i < m_numBundles; i++ )
00408 bufSize += SIZE_SIZE + m_bundles[i]->GetBufferLen();
00409
00410 return bufSize;
00411 }
00412
00413
00414
00415
00416
00417
00418
00419
00420
00421
00422
00423 void WOscBundle::RemoveBundle(int idx){
00424
00425 if ( idx >= m_numBundles || m_numBundles == 0 || idx < 0 )
00426 throw WOscException(ERR_INVALID_INDEX, __FILE__, __LINE__);
00427
00428 int i;
00429
00430 m_numBundles--;
00431
00432 WOscBundle **newBundles = new WOscBundle*[m_numBundles];
00433
00434 for ( i = 0; i < idx; i++)
00435 newBundles[i] = m_bundles[i];
00436
00437 for ( i = idx; i < m_numBundles; i++)
00438 newBundles[i] = m_bundles[i+1];
00439
00440 delete [] m_bundles;
00441 m_bundles = newBundles;
00442 }
00443
00444
00445
00446
00447
00448
00449
00450
00451
00452
00453
00454 void WOscBundle::RemoveMessage(int idx){
00455
00456 if ( idx >= m_numMessages || m_numMessages == 0 || idx < 0)
00457 throw WOscException(ERR_INVALID_INDEX, __FILE__, __LINE__);
00458
00459 int i;
00460
00461 m_numMessages--;
00462
00463 WOscMessage **newMessages = new WOscMessage*[m_numMessages];
00464
00465 for ( i = 0; i < idx; i++)
00466 newMessages[i] = m_messages[i];
00467
00468 for ( i = idx; i < m_numMessages; i++)
00469 newMessages[i] = m_messages[i+1];
00470
00471 delete [] m_messages;
00472 m_messages = newMessages;
00473 }
00474
00475