equal
deleted
inserted
replaced
31 const TInt DEFAULT_BUFFER_SIZE = 2048; |
31 const TInt DEFAULT_BUFFER_SIZE = 2048; |
32 |
32 |
33 CReceiver::CReceiver(IpcClient& aParent, IpcListener& aListener, RComms& aSession) |
33 CReceiver::CReceiver(IpcClient& aParent, IpcListener& aListener, RComms& aSession) |
34 : CActive(EPriorityStandard), mParent(aParent), mListener(aListener), mSession(aSession) |
34 : CActive(EPriorityStandard), mParent(aParent), mListener(aListener), mSession(aSession) |
35 { |
35 { |
36 } |
|
37 |
|
38 CReceiver* CReceiver::NewLC(IpcClient& aParent, IpcListener& aListener, RComms& aSession) |
|
39 { |
|
40 CReceiver* self = new(ELeave) CReceiver(aParent, aListener, aSession); |
|
41 CleanupStack::PushL(self); |
|
42 self->ConstructL(); |
|
43 return self; |
|
44 } |
|
45 |
|
46 void CReceiver::ConstructL() |
|
47 { |
|
48 CActiveScheduler::Add(this); |
36 CActiveScheduler::Add(this); |
49 mBuffer.CreateL(DEFAULT_BUFFER_SIZE); |
37 mBuffer.Create(DEFAULT_BUFFER_SIZE); |
50 } |
38 } |
51 |
39 |
52 CReceiver::~CReceiver() |
40 CReceiver::~CReceiver() |
53 { |
41 { |
54 mBuffer.Close(); |
42 mBuffer.Close(); |
76 case KErrOverflow: |
64 case KErrOverflow: |
77 { |
65 { |
78 // buffer was not big enough for the message so reallocate buffer with correct size |
66 // buffer was not big enough for the message so reallocate buffer with correct size |
79 mBuffer.Close(); |
67 mBuffer.Close(); |
80 mBuffer.ReAllocL(mRequiredLength()); |
68 mBuffer.ReAllocL(mRequiredLength()); |
81 LOG2(EJavaComms, EInfo, "%s: increasing buffer size to %d", __PRETTY_FUNCTION__, mRequiredLength()); |
69 WLOG2(EJavaComms, "%s: increasing buffer size to %d", __PRETTY_FUNCTION__, mRequiredLength()); |
82 Receive(); |
70 Receive(); |
83 } |
71 } |
84 break; |
72 break; |
85 |
73 |
86 default: |
74 default: |