16 #include "ctestserverstreammanager.h" |
16 #include "ctestserverstreammanager.h" |
17 #include <minputstream.h> |
17 #include <minputstream.h> |
18 #include <moutputstream.h> |
18 #include <moutputstream.h> |
19 #include "httptestutils.h" |
19 #include "httptestutils.h" |
20 #include "chttpclienttestparams.h" |
20 #include "chttpclienttestparams.h" |
21 |
21 #include <escapeutils.h> |
22 const TUint KCarriageReturn = '\r'; |
22 |
23 const TUint KLineFeed = '\n'; |
|
24 const TUint KSpace = ' '; |
|
25 |
23 |
26 CLocalTestServerStreamManager* CLocalTestServerStreamManager::NewL(CHTTPTestUtils& aTestUtils, MInputStream* aInStream, MOutputStream* aOutStream, CHttpClientTestParamArray& aTestParamArray) |
24 CLocalTestServerStreamManager* CLocalTestServerStreamManager::NewL(CHTTPTestUtils& aTestUtils, MInputStream* aInStream, MOutputStream* aOutStream, CHttpClientTestParamArray& aTestParamArray) |
27 { |
25 { |
28 CLocalTestServerStreamManager* self = new(ELeave) CLocalTestServerStreamManager(aTestUtils, aInStream, aOutStream, aTestParamArray); |
26 CLocalTestServerStreamManager* self = new(ELeave) CLocalTestServerStreamManager(aTestUtils, aInStream, aOutStream, aTestParamArray); |
29 CleanupStack::PushL(self); |
27 CleanupStack::PushL(self); |
66 { |
64 { |
67 iRequestStream = aBuffer.AllocL(); |
65 iRequestStream = aBuffer.AllocL(); |
68 } |
66 } |
69 else |
67 else |
70 { |
68 { |
71 // Check to see if the buffer needs to grow |
69 if(aBuffer.CompareF(iCurrentTestParam->EncodedAuthenticationRequest()) != 0) |
72 TInt maxLength = iRequestStream->Des().MaxLength(); |
70 { |
73 TInt reqdLength = iRequestStream->Length() + aBuffer.Length(); |
71 // Check to see if the buffer needs to grow |
74 if (reqdLength > maxLength) |
72 TInt maxLength = iRequestStream->Des().MaxLength(); |
75 { |
73 TInt reqdLength = iRequestStream->Length() + aBuffer.Length(); |
76 HBufC8* largerBuffer = iRequestStream->ReAllocL(maxLength + aBuffer.Length()); |
74 if (reqdLength > maxLength) |
77 |
75 { |
78 // Switch buffers. The old one was removed by ReAlloc. |
76 HBufC8* largerBuffer = iRequestStream->ReAllocL(maxLength + aBuffer.Length()); |
79 iRequestStream = largerBuffer; |
77 |
80 } |
78 // Switch buffers. The old one was removed by ReAlloc. |
81 |
79 iRequestStream = largerBuffer; |
82 // Can now append confidently |
80 } |
83 iRequestStream->Des().Append(aBuffer); |
81 |
|
82 // Can now append confidently |
|
83 iRequestStream->Des().Append(aBuffer); |
|
84 } |
|
85 else |
|
86 { |
|
87 iRequestStream = aBuffer.AllocL(); |
|
88 iCurrentTestParam->SetAuthReqRes(); |
|
89 } |
84 } |
90 } |
85 iInputStream->ReceivedDataRes(); |
91 iInputStream->ReceivedDataRes(); |
86 ProcessRequestStreamL(); |
92 ProcessRequestStreamL(); |
87 } |
93 } |
88 |
94 |