equal
deleted
inserted
replaced
94 // |
94 // |
95 CAlfStreamerBridge::~CAlfStreamerBridge() |
95 CAlfStreamerBridge::~CAlfStreamerBridge() |
96 { |
96 { |
97 iDataBuf.Close(); |
97 iDataBuf.Close(); |
98 iQueueSema.Close(); |
98 iQueueSema.Close(); |
|
99 iMessages.Close(); |
99 #ifdef ALF_DEBUG_TRACK_DRAWING |
100 #ifdef ALF_DEBUG_TRACK_DRAWING |
100 delete iCommandDebugger; |
101 delete iCommandDebugger; |
101 #endif |
102 #endif |
102 } |
103 } |
103 |
104 |
201 { |
202 { |
202 err = Trigger(iMessages.Count()-1); |
203 err = Trigger(iMessages.Count()-1); |
203 } |
204 } |
204 else if (iVarDataAddedButNotPosted) |
205 else if (iVarDataAddedButNotPosted) |
205 { |
206 { |
206 iVarDataAddedButNotPosted = EFalse; // data lost |
207 __ALFLOGSTRING1("CAlfStreamerBridge::AddData - Data lost, error: %d", err); |
|
208 iVarDataAddedButNotPosted = EFalse; // data lost |
207 iQueueSema.Signal(); |
209 iQueueSema.Signal(); |
208 } |
210 } |
209 |
211 |
210 return err; |
212 return err; |
211 } |
213 } |
411 __ALFLOGSTRING1("CAlfStreamerBridge::AppendVarDataL, size not multiple of 8: %d", aSize ); |
413 __ALFLOGSTRING1("CAlfStreamerBridge::AppendVarDataL, size not multiple of 8: %d", aSize ); |
412 aSize = aSize + ( 8 - aSize % 8 ); |
414 aSize = aSize + ( 8 - aSize % 8 ); |
413 } |
415 } |
414 if ( iDataBuf.Length() + aSize >= iDataBuf.MaxLength() ) |
416 if ( iDataBuf.Length() + aSize >= iDataBuf.MaxLength() ) |
415 { |
417 { |
416 TRAPD(err, iDataBuf.ReAllocL( iDataBuf.MaxLength() + KInitialVariableBufferSize )); |
418 TRAPD(err, iDataBuf.ReAllocL( iDataBuf.MaxLength() + aSize + KIncreaseVariableBufferSize )); |
417 if ( err ) |
419 if ( err ) |
418 { |
420 { |
419 __ALFLOGSTRING("CAlfStreamerBridge::AppendVarDataL, realloc failed"); |
421 __ALFLOGSTRING("CAlfStreamerBridge::AppendVarDataL, realloc failed"); |
420 iQueueSema.Signal(); |
422 iQueueSema.Signal(); |
421 return NULL; |
423 return NULL; |