Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1899)

Unified Diff: ppapi/tests/test_websocket.cc

Issue 9586015: WebSocket Pepper API: unit test must use close code defined by API (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 8 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « no previous file | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: ppapi/tests/test_websocket.cc
diff --git a/ppapi/tests/test_websocket.cc b/ppapi/tests/test_websocket.cc
index ce01d67b729c8d558b438da8b13efbddaac7a2ed..2eb7af465f65d37b727626ca7afb41bb5f53ab8f 100644
--- a/ppapi/tests/test_websocket.cc
+++ b/ppapi/tests/test_websocket.cc
@@ -42,11 +42,6 @@ const char* const kInvalidURLs[] = {
NULL
};
-// Connection close code is defined in WebSocket protocol specification.
-// The magic number 1000 means gracefull closure without any error.
-// See section 7.4.1. of RFC 6455.
-const uint16_t kCloseCodeNormalClosure = 1000U;
-
// Internal packet sizes.
const uint64_t kCloseFrameSize = 6;
const uint64_t kMessageFrameOverhead = 6;
@@ -433,7 +428,7 @@ std::string TestWebSocket::TestInvalidClose() {
// Close before connect.
PP_Resource ws = websocket_interface_->Create(instance_->pp_instance());
int32_t result = websocket_interface_->Close(
- ws, kCloseCodeNormalClosure, reason,
+ ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason,
static_cast<pp::CompletionCallback>(callback).pp_completion_callback());
ASSERT_EQ(PP_ERROR_FAILED, result);
core_interface_->ReleaseResource(ws);
@@ -464,7 +459,8 @@ std::string TestWebSocket::TestValidClose() {
PP_Resource ws = Connect(kEchoServerURL, &result, NULL);
ASSERT_TRUE(ws);
ASSERT_EQ(PP_OK, result);
- result = websocket_interface_->Close(ws, kCloseCodeNormalClosure, reason,
+ result = websocket_interface_->Close(ws,
+ PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason,
static_cast<pp::CompletionCallback>(callback).pp_completion_callback());
ASSERT_EQ(PP_OK_COMPLETIONPENDING, result);
result = callback.WaitForResult();
@@ -478,7 +474,8 @@ std::string TestWebSocket::TestValidClose() {
result = websocket_interface_->Connect(ws, url, protocols, 0U,
static_cast<pp::CompletionCallback>(callback).pp_completion_callback());
ASSERT_EQ(PP_OK_COMPLETIONPENDING, result);
- result = websocket_interface_->Close(ws, kCloseCodeNormalClosure, reason,
+ result = websocket_interface_->Close(ws,
+ PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason,
static_cast<pp::CompletionCallback>(
another_callback).pp_completion_callback());
ASSERT_EQ(PP_OK_COMPLETIONPENDING, result);
@@ -494,10 +491,12 @@ std::string TestWebSocket::TestValidClose() {
ws = Connect(kEchoServerURL, &result, NULL);
ASSERT_TRUE(ws);
ASSERT_EQ(PP_OK, result);
- result = websocket_interface_->Close(ws, kCloseCodeNormalClosure, reason,
+ result = websocket_interface_->Close(ws,
+ PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason,
static_cast<pp::CompletionCallback>(callback).pp_completion_callback());
ASSERT_EQ(PP_OK_COMPLETIONPENDING, result);
- result = websocket_interface_->Close(ws, kCloseCodeNormalClosure, reason,
+ result = websocket_interface_->Close(ws,
+ PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason,
static_cast<pp::CompletionCallback>(
another_callback).pp_completion_callback());
ASSERT_EQ(PP_ERROR_INPROGRESS, result);
@@ -513,7 +512,8 @@ std::string TestWebSocket::TestValidClose() {
result = websocket_interface_->ReceiveMessage(ws, &receive_message_var,
static_cast<pp::CompletionCallback>(callback).pp_completion_callback());
ASSERT_EQ(PP_OK_COMPLETIONPENDING, result);
- result = websocket_interface_->Close(ws, kCloseCodeNormalClosure, reason,
+ result = websocket_interface_->Close(ws,
+ PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason,
static_cast<pp::CompletionCallback>(
another_callback).pp_completion_callback());
ASSERT_EQ(PP_OK_COMPLETIONPENDING, result);
@@ -645,7 +645,8 @@ std::string TestWebSocket::TestBufferedAmount() {
std::string reason_str = "close while busy";
PP_Var reason = CreateVarString(reason_str.c_str());
TestCompletionCallback callback(instance_->pp_instance());
- result = websocket_interface_->Close(ws, kCloseCodeNormalClosure, reason,
+ result = websocket_interface_->Close(ws,
+ PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason,
static_cast<pp::CompletionCallback>(callback).pp_completion_callback());
ASSERT_EQ(PP_OK_COMPLETIONPENDING, result);
ASSERT_EQ(PP_WEBSOCKETREADYSTATE_CLOSING,
@@ -736,14 +737,15 @@ std::string TestWebSocket::TestCcInterfaces() {
TestCompletionCallback close_callback(instance_->pp_instance());
std::string reason("bye");
- result = ws.Close(kCloseCodeNormalClosure, pp::Var(reason), close_callback);
+ result = ws.Close(
+ PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, pp::Var(reason), close_callback);
ASSERT_EQ(PP_OK_COMPLETIONPENDING, result);
result = close_callback.WaitForResult();
ASSERT_EQ(PP_OK, result);
// Check initialized properties access.
ASSERT_EQ(0, ws.GetBufferedAmount());
- ASSERT_EQ(kCloseCodeNormalClosure, ws.GetCloseCode());
+ ASSERT_EQ(PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, ws.GetCloseCode());
ASSERT_TRUE(AreEqualWithString(ws.GetCloseReason().pp_var(), reason.c_str()));
ASSERT_EQ(true, ws.GetCloseWasClean());
ASSERT_TRUE(AreEqualWithString(ws.GetExtensions().pp_var(), ""));
@@ -845,7 +847,8 @@ std::string TestWebSocket::TestUtilityInvalidClose() {
// Close before connect.
{
TestWebSocketAPI websocket(instance_);
- int32_t result = websocket.Close(kCloseCodeNormalClosure, reason);
+ int32_t result = websocket.Close(
+ PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason);
ASSERT_EQ(PP_ERROR_FAILED, result);
ASSERT_EQ(0U, websocket.GetSeenEvents().size());
}
@@ -877,7 +880,8 @@ std::string TestWebSocket::TestUtilityValidClose() {
int32_t result = websocket.Connect(url, NULL, 0U);
ASSERT_EQ(PP_OK_COMPLETIONPENDING, result);
websocket.WaitForConnected();
- result = websocket.Close(kCloseCodeNormalClosure, pp::Var(reason));
+ result = websocket.Close(
+ PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, pp::Var(reason));
ASSERT_EQ(PP_OK_COMPLETIONPENDING, result);
websocket.WaitForClosed();
const std::vector<WebSocketEvent>& events = websocket.GetSeenEvents();
@@ -885,7 +889,7 @@ std::string TestWebSocket::TestUtilityValidClose() {
ASSERT_EQ(WebSocketEvent::EVENT_OPEN, events[0].event_type);
ASSERT_EQ(WebSocketEvent::EVENT_CLOSE, events[1].event_type);
ASSERT_TRUE(events[1].was_clean);
- ASSERT_EQ(kCloseCodeNormalClosure, events[1].close_code);
+ ASSERT_EQ(PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, events[1].close_code);
ASSERT_TRUE(AreEqualWithString(events[1].var.pp_var(), reason.c_str()));
}
@@ -896,7 +900,8 @@ std::string TestWebSocket::TestUtilityValidClose() {
TestWebSocketAPI websocket(instance_);
int32_t result = websocket.Connect(url, NULL, 0U);
ASSERT_EQ(PP_OK_COMPLETIONPENDING, result);
- result = websocket.Close(kCloseCodeNormalClosure, pp::Var(reason));
+ result = websocket.Close(
+ PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, pp::Var(reason));
ASSERT_EQ(PP_OK_COMPLETIONPENDING, result);
websocket.WaitForClosed();
const std::vector<WebSocketEvent>& events = websocket.GetSeenEvents();
@@ -915,9 +920,11 @@ std::string TestWebSocket::TestUtilityValidClose() {
{
TestWebSocketAPI websocket(instance_);
int32_t result = websocket.Connect(url, NULL, 0U);
- result = websocket.Close(kCloseCodeNormalClosure, pp::Var(reason));
+ result = websocket.Close(
+ PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, pp::Var(reason));
ASSERT_EQ(PP_OK_COMPLETIONPENDING, result);
- result = websocket.Close(kCloseCodeNormalClosure, pp::Var(reason));
+ result = websocket.Close(
+ PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, pp::Var(reason));
ASSERT_EQ(PP_ERROR_INPROGRESS, result);
websocket.WaitForClosed();
const std::vector<WebSocketEvent>& events = websocket.GetSeenEvents();
@@ -1049,7 +1056,8 @@ std::string TestWebSocket::TestUtilityBufferedAmount() {
// Close connection.
std::string reason_str = "close while busy";
- result = websocket.Close(kCloseCodeNormalClosure, pp::Var(reason_str));
+ result = websocket.Close(
+ PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, pp::Var(reason_str));
ASSERT_EQ(PP_WEBSOCKETREADYSTATE_CLOSING, websocket.GetReadyState());
websocket.WaitForClosed();
ASSERT_EQ(PP_WEBSOCKETREADYSTATE_CLOSED, websocket.GetReadyState());
« no previous file with comments | « no previous file | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698