/*
* Copyright (c) 2007 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of the License "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
*
* Description:
*
*/
#include "ResourceHandle.h"
#include "ResourceHandleManagerSymbian.h"
#include "ResolvedConnection.h"
#include "ResourceRequest.h"
#include "BrCtl.h"
#include "WebFrame.h"
// EXTERNAL DATA STRUCTURES
// EXTERNAL FUNCTION PROTOTYPES
// CONSTANTS
// MACROS
// LOCAL CONSTANTS AND MACROS
// MODULE DATA STRUCTURES
// LOCAL FUNCTION PROTOTYPES
// FORWARD DECLARATIONS
using namespace WebCore;
TInt processResponseCb(TAny* ptr)
{
ResolvedConnection* rc = static_cast<ResolvedConnection*>(ptr);
rc->processResponse();
return KErrNone;
}
ResolvedConnection::ResolvedConnection(ResourceHandle* _handle, Frame* frame) : MUrlConnection(_handle)
{
m_frame = frame;
m_didSubmit = false;
m_scheduler = NULL;
m_contentType = NULL;
m_charset = NULL;
m_contentBuf = NULL;
m_maxSize = 0;
}
ResolvedConnection::~ResolvedConnection()
{
if (m_scheduler) {
m_scheduler->Cancel();
delete m_scheduler;
}
delete m_contentType;
delete m_charset;
delete m_contentBuf;
}
int ResolvedConnection::submit()
{
m_didSubmit = true;
if (m_contentBuf) {
m_scheduler = CPeriodic::NewL( CActive::EPriorityStandard );
m_scheduler->Start( 0, 0, TCallBack( &processResponseCb, this ) );
}
return KErrNone;
}
void ResolvedConnection::cancel()
{
control(m_frame)->brCtlLinkResolver()->CancelAll();
}
void ResolvedConnection::download(ResourceHandle* handle,
const ResourceRequest& request,
const ResourceResponse& response)
{
__ASSERT_ALWAYS(EFalse, User::Panic(_L("Resource Loader"), KErrArgument));
}
void ResolvedConnection::HandleResolveComplete(const TDesC& aContentType,
const TDesC& aCharset,
const HBufC8* aContentBuf)
{
if (aContentType.Length() == 0 || aContentBuf == NULL) {
complete(KErrArgument);
}
else {
m_contentType = aContentType.Alloc();
m_charset = aCharset.Alloc();
m_contentBuf = aContentBuf->Alloc();
if (!(m_contentType && m_charset && m_contentBuf)) {
complete(KErrNoMemory);
}
else {
m_maxSize = aContentBuf->Length();
if (m_didSubmit) {
m_scheduler = CPeriodic::NewL( CActive::EPriorityStandard );
m_scheduler->Start( 0, 0, TCallBack( &processResponseCb, this ) );
}
}
}
}
void ResolvedConnection::processResponse()
{
if (m_scheduler) {
m_scheduler->Cancel();
delete m_scheduler;
m_scheduler = NULL;
}
__ASSERT_DEBUG(m_didSubmit && m_contentBuf, User::Panic(_L(""), KErrGeneral));
ResourceResponse response(m_handle->request().url().des(), m_contentType->Des(), m_contentBuf->Length(), m_charset->Des(), String() );
response.setHTTPStatusCode(200);
CResourceHandleManager::self()->receivedResponse(m_handle, response, this);
CResourceHandleManager::self()->receivedData(m_handle, m_contentBuf->Des(), m_contentBuf->Length(), this);
CResourceHandleManager::self()->receivedFinished(m_handle, KErrNone, this);
derefHandle();
}
void ResolvedConnection::HandleResolveError(TInt aError)
{
complete(aError);
}
void ResolvedConnection::complete(int error)
{
CResourceHandleManager::self()->receivedFinished(m_handle, error, this);
derefHandle();
}
// end of file