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