summaryrefslogtreecommitdiff
path: root/src/WebSocketSession.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2013-06-22 01:10:38 +0900
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2013-06-22 01:10:38 +0900
commit07d270c87e6f9184aea4ca17eb26e466712e8db2 (patch)
tree2dfbaa2e0d2ad0f38cb73098608f7d67a64320f8 /src/WebSocketSession.cc
parent126a4bde612eb0e6c48cf2f13ebe3eac45cc71a8 (diff)
Require -std=c++11 and use std::shared_ptr instead of SharedHandle
Diffstat (limited to 'src/WebSocketSession.cc')
-rw-r--r--src/WebSocketSession.cc13
1 files changed, 7 insertions, 6 deletions
diff --git a/src/WebSocketSession.cc b/src/WebSocketSession.cc
index 638876cf..6baa70bd 100644
--- a/src/WebSocketSession.cc
+++ b/src/WebSocketSession.cc
@@ -36,6 +36,7 @@
#include <cerrno>
#include <cstring>
+#include <cassert>
#include "SocketCore.h"
#include "LogFactory.h"
@@ -58,7 +59,7 @@ ssize_t sendCallback(wslay_event_context_ptr wsctx,
void* userData)
{
WebSocketSession* session = reinterpret_cast<WebSocketSession*>(userData);
- const SharedHandle<SocketCore>& socket = session->getSocket();
+ const std::shared_ptr<SocketCore>& socket = session->getSocket();
try {
ssize_t r = socket->writeData(data, len);
if(r == 0) {
@@ -84,7 +85,7 @@ ssize_t recvCallback(wslay_event_context_ptr wsctx,
void* userData)
{
WebSocketSession* session = reinterpret_cast<WebSocketSession*>(userData);
- const SharedHandle<SocketCore>& socket = session->getSocket();
+ const std::shared_ptr<SocketCore>& socket = session->getSocket();
try {
ssize_t r;
socket->readData(buf, len);
@@ -159,7 +160,7 @@ void onMsgRecvCallback(wslay_event_context_ptr wsctx,
if(!wslay_is_ctrl_frame(arg->opcode)) {
// TODO Only process text frame
ssize_t error = 0;
- SharedHandle<ValueBase> json = wsSession->parseFinal(0, 0, error);
+ std::shared_ptr<ValueBase> json = wsSession->parseFinal(0, 0, error);
if(error < 0) {
A2_LOG_INFO("Failed to parse JSON-RPC request");
RpcResponse res
@@ -201,7 +202,7 @@ void onMsgRecvCallback(wslay_event_context_ptr wsctx,
}
} // namespace
-WebSocketSession::WebSocketSession(const SharedHandle<SocketCore>& socket,
+WebSocketSession::WebSocketSession(const std::shared_ptr<SocketCore>& socket,
DownloadEngine* e)
: socket_(socket),
e_(e),
@@ -291,10 +292,10 @@ ssize_t WebSocketSession::parseUpdate(const uint8_t* data, size_t len)
return parser_.parseUpdate(reinterpret_cast<const char*>(data), len);
}
-SharedHandle<ValueBase> WebSocketSession::parseFinal
+std::shared_ptr<ValueBase> WebSocketSession::parseFinal
(const uint8_t* data, size_t len, ssize_t& error)
{
- SharedHandle<ValueBase> res =
+ std::shared_ptr<ValueBase> res =
parser_.parseFinal(reinterpret_cast<const char*>(data), len, error);
receivedLength_ = 0;
return res;