SocketStreamHandleBlackBerry.cpp [plain text]
#include "config.h"
#include "SocketStreamHandle.h"
#include "Chrome.h"
#include "FrameLoaderClientBlackBerry.h"
#include "KURL.h"
#include "Logging.h"
#include "Page.h"
#include "PageClientBlackBerry.h"
#include "PageGroup.h"
#include "SocketStreamError.h"
#include "SocketStreamHandleClient.h"
#include <network/NetworkStreamFactory.h>
#include <wtf/text/CString.h>
namespace WebCore {
SocketStreamHandle::SocketStreamHandle(const String& groupName, const KURL& url, SocketStreamHandleClient* client)
: SocketStreamHandleBase(url, client)
{
LOG(Network, "SocketStreamHandle %p new client %p", this, m_client);
PageGroup* pageGroup = PageGroup::pageGroup(groupName);
ASSERT(pageGroup && !pageGroup->pages().isEmpty());
Page* page = *(pageGroup->pages().begin());
ASSERT(page && page->mainFrame());
int playerId = static_cast<FrameLoaderClientBlackBerry*>(page->mainFrame()->loader()->client())->playerId();
BlackBerry::Platform::NetworkStreamFactory* factory = page->chrome()->platformPageClient()->networkStreamFactory();
ASSERT(factory);
m_socketStream = adoptPtr(factory->createSocketStream(playerId));
ASSERT(m_socketStream);
m_socketStream->setListener(this);
BlackBerry::Platform::NetworkRequest request;
request.setRequestUrl(url.string().latin1().data(), "CONNECT");
m_socketStream->setRequest(request);
m_socketStream->streamOpen();
}
SocketStreamHandle::~SocketStreamHandle()
{
LOG(Network, "SocketStreamHandle %p delete", this);
setClient(0);
}
int SocketStreamHandle::platformSend(const char* buf, int length)
{
LOG(Network, "SocketStreamHandle %p platformSend", this);
ASSERT(m_socketStream);
return m_socketStream->streamSendData(buf, length);
}
void SocketStreamHandle::platformClose()
{
LOG(Network, "SocketStreamHandle %p platformClose", this);
ASSERT(m_socketStream);
m_socketStream->streamClose();
}
void SocketStreamHandle::notifyStatusReceived(int status, const char* message)
{
ASSERT(m_client);
RefPtr<SocketStreamHandle> protect(this);
if (FilterStream::StatusSuccess != status)
m_client->didFailSocketStream(this, SocketStreamError(status));
else {
m_state = Open;
m_client->didOpenSocketStream(this);
}
}
void SocketStreamHandle::notifyDataReceived(BlackBerry::Platform::NetworkBuffer* buffer)
{
ASSERT(m_client);
RefPtr<SocketStreamHandle> protect(this);
m_client->didReceiveSocketStreamData(this, BlackBerry::Platform::networkBufferData(buffer), BlackBerry::Platform::networkBufferDataLength(buffer));
}
void SocketStreamHandle::notifyReadyToSendData()
{
sendPendingData();
}
void SocketStreamHandle::notifyClose(int status)
{
ASSERT(m_client);
RefPtr<SocketStreamHandle> protect(this);
if (FilterStream::StatusSuccess != status)
m_client->didFailSocketStream(this, SocketStreamError(status));
m_client->didCloseSocketStream(this);
}
}