74 // ----------------------------------------------------------------------------- |
74 // ----------------------------------------------------------------------------- |
75 // |
75 // |
76 void CSuplSocketReader::ConstructL() |
76 void CSuplSocketReader::ConstructL() |
77 { |
77 { |
78 iTrace = CSuplConnTrace::NewL(); |
78 iTrace = CSuplConnTrace::NewL(); |
79 iReadBuffer.Create(KSocketDefaultBufferSize); |
79 User::LeaveIfError(iReadBuffer.Create(KSocketDefaultBufferSize)); |
80 iAdditionalReadBuffer.Create(0); |
80 User::LeaveIfError(iAdditionalReadBuffer.Create(0)); |
81 } |
81 } |
82 |
82 |
83 // ----------------------------------------------------------------------------- |
83 // ----------------------------------------------------------------------------- |
84 // CSuplConnection::NewL |
84 // CSuplConnection::NewL |
85 // This is the method to handle request completion for |
85 // This is the method to handle request completion for |
172 if(msgSize > 0) |
172 if(msgSize > 0) |
173 { |
173 { |
174 if(iReRead) |
174 if(iReRead) |
175 { |
175 { |
176 RBuf OriginalBuf1; |
176 RBuf OriginalBuf1; |
177 OriginalBuf1.Create(KSocketDefaultBufferSize); |
177 User::LeaveIfError(OriginalBuf1.Create(KSocketDefaultBufferSize)); |
178 OriginalBuf1.Copy(iReadBuffer); |
178 OriginalBuf1.Copy(iReadBuffer); |
179 TBuf<64> msg2; |
179 TBuf<64> msg2; |
180 msg2.Copy(_L("Length of OriginalBuf1 is: ")); |
180 msg2.Copy(_L("Length of OriginalBuf1 is: ")); |
181 msg2.AppendNum(OriginalBuf1.Length()); |
181 msg2.AppendNum(OriginalBuf1.Length()); |
182 iTrace->Trace(msg2, KTraceFileName, __LINE__); |
182 iTrace->Trace(msg2, KTraceFileName, __LINE__); |
183 iReadBuffer.ReAlloc(KSocketDefaultBufferSize + iAdditionalReadBuffer.Length()); |
183 User::LeaveIfError(iReadBuffer.ReAlloc(KSocketDefaultBufferSize + iAdditionalReadBuffer.Length())); |
184 iReadBuffer.Zero(); |
184 iReadBuffer.Zero(); |
185 iReadBuffer.Append(OriginalBuf1); |
185 iReadBuffer.Append(OriginalBuf1); |
186 iReadBuffer.Append(iAdditionalReadBuffer); |
186 iReadBuffer.Append(iAdditionalReadBuffer); |
187 |
187 |
188 iReRead = EFalse; |
188 iReRead = EFalse; |
189 OriginalBuf1.Close(); |
189 OriginalBuf1.Close(); |
190 } |
190 } |
191 iAdditionalReadBuffer.Zero(); |
191 iAdditionalReadBuffer.Zero(); |
192 iAdditionalReadBuffer.ReAlloc(msgSize); |
192 User::LeaveIfError(iAdditionalReadBuffer.ReAlloc(msgSize)); |
193 iReRead = ETrue; |
193 iReRead = ETrue; |
194 } |
194 } |
195 else |
195 else |
196 { |
196 { |
197 if(iReRead) |
197 if(iReRead) |
198 { |
198 { |
199 RBuf OriginalBuf; |
199 RBuf OriginalBuf; |
200 OriginalBuf.Create(KSocketDefaultBufferSize); |
200 User::LeaveIfError(OriginalBuf.Create(KSocketDefaultBufferSize)); |
201 OriginalBuf.Copy(iReadBuffer); |
201 OriginalBuf.Copy(iReadBuffer); |
202 |
202 |
203 iReadBuffer.ReAlloc(KSocketDefaultBufferSize + iAdditionalReadBuffer.Length()); |
203 User::LeaveIfError(iReadBuffer.ReAlloc(KSocketDefaultBufferSize + iAdditionalReadBuffer.Length())); |
204 iReadBuffer.Zero(); |
204 iReadBuffer.Zero(); |
205 iReadBuffer.Append(OriginalBuf); |
205 iReadBuffer.Append(OriginalBuf); |
206 iReadBuffer.Append(iAdditionalReadBuffer); |
206 iReadBuffer.Append(iAdditionalReadBuffer); |
207 |
207 |
208 iReRead = EFalse; |
208 iReRead = EFalse; |