Lines Matching refs:ws
304 PP_Resource ws = websocket_interface_->Create(instance_->pp_instance()); in Connect() local
305 if (!ws) in Connect()
315 ws, url_var, protocols, protocol_count, in Connect()
321 return ws; in Connect()
324 void TestWebSocket::Send(int32_t /* result */, PP_Resource ws, in Send() argument
327 websocket_interface_->SendMessage(ws, message_var); in Send()
338 PP_Resource ws = websocket_interface_->Create(instance_->pp_instance()); in TestIsWebSocket() local
339 ASSERT_TRUE(ws); in TestIsWebSocket()
341 result = websocket_interface_->IsWebSocket(ws); in TestIsWebSocket()
344 core_interface_->ReleaseResource(ws); in TestIsWebSocket()
350 PP_Resource ws = websocket_interface_->Create(instance_->pp_instance()); in TestUninitializedPropertiesAccess() local
351 ASSERT_TRUE(ws); in TestUninitializedPropertiesAccess()
353 uint64_t bufferedAmount = websocket_interface_->GetBufferedAmount(ws); in TestUninitializedPropertiesAccess()
356 uint16_t close_code = websocket_interface_->GetCloseCode(ws); in TestUninitializedPropertiesAccess()
359 PP_Var close_reason = websocket_interface_->GetCloseReason(ws); in TestUninitializedPropertiesAccess()
363 PP_Bool close_was_clean = websocket_interface_->GetCloseWasClean(ws); in TestUninitializedPropertiesAccess()
366 PP_Var extensions = websocket_interface_->GetExtensions(ws); in TestUninitializedPropertiesAccess()
370 PP_Var protocol = websocket_interface_->GetProtocol(ws); in TestUninitializedPropertiesAccess()
375 websocket_interface_->GetReadyState(ws); in TestUninitializedPropertiesAccess()
378 PP_Var url = websocket_interface_->GetURL(ws); in TestUninitializedPropertiesAccess()
382 core_interface_->ReleaseResource(ws); in TestUninitializedPropertiesAccess()
390 PP_Resource ws = websocket_interface_->Create(instance_->pp_instance()); in TestInvalidConnect() local
391 ASSERT_TRUE(ws); in TestInvalidConnect()
395 ws, PP_MakeUndefined(), protocols, 1U, in TestInvalidConnect()
400 ws, PP_MakeUndefined(), protocols, 1U, in TestInvalidConnect()
404 core_interface_->ReleaseResource(ws); in TestInvalidConnect()
408 ws = Connect(kInvalidURLs[i], &result, std::string()); in TestInvalidConnect()
409 ASSERT_TRUE(ws); in TestInvalidConnect()
412 core_interface_->ReleaseResource(ws); in TestInvalidConnect()
429 PP_Resource ws = websocket_interface_->Create(instance_->pp_instance()); in TestProtocols() local
430 ASSERT_TRUE(ws); in TestProtocols()
433 ws, url, bad_protocols, 2U, in TestProtocols()
436 core_interface_->ReleaseResource(ws); in TestProtocols()
438 ws = websocket_interface_->Create(instance_->pp_instance()); in TestProtocols()
439 ASSERT_TRUE(ws); in TestProtocols()
441 ws, url, good_protocols, 2U, PP_BlockUntilComplete()); in TestProtocols()
443 core_interface_->ReleaseResource(ws); in TestProtocols()
450 core_interface_->ReleaseResource(ws); in TestProtocols()
458 PP_Resource ws = Connect(kInvalidURLs[i], &result, std::string()); in TestGetURL() local
459 ASSERT_TRUE(ws); in TestGetURL()
460 PP_Var url = websocket_interface_->GetURL(ws); in TestGetURL()
465 core_interface_->ReleaseResource(ws); in TestGetURL()
473 PP_Resource ws = Connect(GetFullURL(kEchoServerURL), &result, std::string()); in TestValidConnect() local
474 ASSERT_TRUE(ws); in TestValidConnect()
476 PP_Var extensions = websocket_interface_->GetExtensions(ws); in TestValidConnect()
478 core_interface_->ReleaseResource(ws); in TestValidConnect()
490 PP_Resource ws = websocket_interface_->Create(instance_->pp_instance()); in TestInvalidClose() local
492 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason, in TestInvalidClose()
495 core_interface_->ReleaseResource(ws); in TestInvalidClose()
499 ws = Connect(GetFullURL(kEchoServerURL), &result, std::string()); in TestInvalidClose()
500 ASSERT_TRUE(ws); in TestInvalidClose()
503 ws, 1U, reason, callback.GetCallback().pp_completion_callback())); in TestInvalidClose()
505 core_interface_->ReleaseResource(ws); in TestInvalidClose()
508 ws = Connect(GetFullURL(kEchoServerURL), &result, std::string()); in TestInvalidClose()
509 ASSERT_TRUE(ws); in TestInvalidClose()
512 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, PP_MakeNull(), in TestInvalidClose()
515 core_interface_->ReleaseResource(ws); in TestInvalidClose()
518 ws = Connect(GetFullURL(kEchoServerURL), &result, std::string()); in TestInvalidClose()
519 ASSERT_TRUE(ws); in TestInvalidClose()
523 ws, &receive_message_var, in TestInvalidClose()
527 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, PP_MakeNull(), in TestInvalidClose()
532 result = websocket_interface_->SendMessage(ws, send_message_var); in TestInvalidClose()
539 core_interface_->ReleaseResource(ws); in TestInvalidClose()
542 ws = Connect(GetFullURL(kEchoServerURL), &result, std::string()); in TestInvalidClose()
543 ASSERT_TRUE(ws); in TestInvalidClose()
546 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason, in TestInvalidClose()
551 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason, in TestInvalidClose()
559 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason, in TestInvalidClose()
562 core_interface_->ReleaseResource(ws); in TestInvalidClose()
579 PP_Resource ws = Connect(GetFullURL(kEchoServerURL), &result, std::string()); in TestValidClose() local
580 ASSERT_TRUE(ws); in TestValidClose()
583 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason, in TestValidClose()
587 core_interface_->ReleaseResource(ws); in TestValidClose()
590 ws = Connect(GetFullURL(kEchoServerURL), &result, std::string()); in TestValidClose()
591 ASSERT_TRUE(ws); in TestValidClose()
594 ws, PP_WEBSOCKETSTATUSCODE_NOT_SPECIFIED, reason, in TestValidClose()
597 core_interface_->ReleaseResource(ws); in TestValidClose()
600 ws = Connect(GetFullURL(kEchoServerURL), &result, std::string()); in TestValidClose()
601 ASSERT_TRUE(ws); in TestValidClose()
604 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, PP_MakeUndefined(), in TestValidClose()
608 core_interface_->ReleaseResource(ws); in TestValidClose()
613 ws = websocket_interface_->Create(instance_->pp_instance()); in TestValidClose()
615 ws, url, protocols, 0U, callback.GetCallback().pp_completion_callback()); in TestValidClose()
618 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason, in TestValidClose()
625 core_interface_->ReleaseResource(ws); in TestValidClose()
630 ws = Connect(GetFullURL(kEchoServerURL), &result, std::string()); in TestValidClose()
631 ASSERT_TRUE(ws); in TestValidClose()
634 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason, in TestValidClose()
638 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason, in TestValidClose()
643 core_interface_->ReleaseResource(ws); in TestValidClose()
646 ws = Connect(GetFullURL(kEchoServerURL), &result, std::string()); in TestValidClose()
647 ASSERT_TRUE(ws); in TestValidClose()
651 ws, &receive_message_var, in TestValidClose()
655 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason, in TestValidClose()
662 core_interface_->ReleaseResource(ws); in TestValidClose()
665 ws = Connect(GetFullURL(kEchoServerURL), &result, std::string()); in TestValidClose()
666 ASSERT_TRUE(ws); in TestValidClose()
669 ws, &receive_message_var, in TestValidClose()
673 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, PP_MakeUndefined(), in TestValidClose()
680 core_interface_->ReleaseResource(ws); in TestValidClose()
683 ws = Connect( in TestValidClose()
685 ASSERT_TRUE(ws); in TestValidClose()
690 result = websocket_interface_->SendMessage(ws, close_request_var); in TestValidClose()
693 ws, &receive_message_var, in TestValidClose()
696 core_interface_->ReleaseResource(ws); in TestValidClose()
714 PP_Resource ws = Connect(url.c_str(), &result, expected_protocols[i]); in TestGetProtocol() local
715 ASSERT_TRUE(ws); in TestGetProtocol()
718 PP_Var protocol = websocket_interface_->GetProtocol(ws); in TestGetProtocol()
722 core_interface_->ReleaseResource(ws); in TestGetProtocol()
731 PP_Resource ws = in TestTextSendReceive() local
733 ASSERT_TRUE(ws); in TestTextSendReceive()
739 int32_t result = websocket_interface_->SendMessage(ws, message_var); in TestTextSendReceive()
747 ws, &received_message, callback.GetCallback().pp_completion_callback())); in TestTextSendReceive()
751 core_interface_->ReleaseResource(ws); in TestTextSendReceive()
760 PP_Resource ws = in TestTextSendReceiveTwice() local
762 ASSERT_TRUE(ws); in TestTextSendReceiveTwice()
768 ws, std::string("hello"))); in TestTextSendReceiveTwice()
771 ws, std::string("Goodbye"))); in TestTextSendReceiveTwice()
778 ws, &received_message, callback.GetCallback().pp_completion_callback()); in TestTextSendReceiveTwice()
786 websocket_interface_->GetReadyState(ws); in TestTextSendReceiveTwice()
801 core_interface_->ReleaseResource(ws); in TestTextSendReceiveTwice()
808 PP_Resource ws = in TestBinarySendReceive() local
810 ASSERT_TRUE(ws); in TestBinarySendReceive()
818 int32_t result = websocket_interface_->SendMessage(ws, message_var); in TestBinarySendReceive()
826 ws, &received_message, callback.GetCallback().pp_completion_callback())); in TestBinarySendReceive()
830 core_interface_->ReleaseResource(ws); in TestBinarySendReceive()
838 PP_Resource ws = in TestStressedSendReceive() local
840 ASSERT_TRUE(ws); in TestStressedSendReceive()
863 result = websocket_interface_->SendMessage(ws, text_var); in TestStressedSendReceive()
865 result = websocket_interface_->SendMessage(ws, binary_var); in TestStressedSendReceive()
868 result = websocket_interface_->SendMessage(ws, large_binary_var); in TestStressedSendReceive()
879 ws, &received_message, in TestStressedSendReceive()
891 core_interface_->ReleaseResource(ws); in TestStressedSendReceive()
899 PP_Resource ws = in TestBufferedAmount() local
901 ASSERT_TRUE(ws); in TestBufferedAmount()
912 result = websocket_interface_->SendMessage(ws, message_var); in TestBufferedAmount()
914 buffered_amount = websocket_interface_->GetBufferedAmount(ws); in TestBufferedAmount()
925 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason, in TestBufferedAmount()
929 websocket_interface_->GetReadyState(ws)); in TestBufferedAmount()
934 websocket_interface_->GetReadyState(ws)); in TestBufferedAmount()
936 uint64_t base_buffered_amount = websocket_interface_->GetBufferedAmount(ws); in TestBufferedAmount()
941 result = websocket_interface_->SendMessage(ws, empty_string); in TestBufferedAmount()
943 buffered_amount = websocket_interface_->GetBufferedAmount(ws); in TestBufferedAmount()
947 result = websocket_interface_->SendMessage(ws, reason); in TestBufferedAmount()
949 buffered_amount = websocket_interface_->GetBufferedAmount(ws); in TestBufferedAmount()
956 core_interface_->ReleaseResource(ws); in TestBufferedAmount()
968 PP_Resource ws = websocket_interface_->Create(instance_->pp_instance()); in TestAbortCallsWithCallback() local
969 ASSERT_TRUE(ws); in TestAbortCallsWithCallback()
975 ws, url_var, NULL, 0, in TestAbortCallsWithCallback()
978 core_interface_->ReleaseResource(ws); in TestAbortCallsWithCallback()
983 ws = Connect(url, &result, std::string()); in TestAbortCallsWithCallback()
984 ASSERT_TRUE(ws); in TestAbortCallsWithCallback()
990 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, reason_var, in TestAbortCallsWithCallback()
993 core_interface_->ReleaseResource(ws); in TestAbortCallsWithCallback()
1000 ws = Connect(url, &result, std::string()); in TestAbortCallsWithCallback()
1001 ASSERT_TRUE(ws); in TestAbortCallsWithCallback()
1007 ws, &receive_var, in TestAbortCallsWithCallback()
1010 core_interface_->ReleaseResource(ws); in TestAbortCallsWithCallback()
1016 ws = Connect(url, &result, std::string()); in TestAbortCallsWithCallback()
1017 ASSERT_TRUE(ws); in TestAbortCallsWithCallback()
1020 ws, &receive_var, in TestAbortCallsWithCallback()
1023 ReleaseResourceDelegate receive_delegate(core_interface_, ws); in TestAbortCallsWithCallback()
1026 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, PP_MakeUndefined(), in TestAbortCallsWithCallback()
1050 PP_Resource ws = Connect(url, &result, std::string()); in TestAbortSendMessageCall() local
1051 ASSERT_TRUE(ws); in TestAbortSendMessageCall()
1053 result = websocket_interface_->SendMessage(ws, large_var); in TestAbortSendMessageCall()
1055 core_interface_->ReleaseResource(ws); in TestAbortSendMessageCall()
1065 PP_Resource ws = Connect(url, &result, std::string()); in TestAbortCloseCall() local
1066 ASSERT_TRUE(ws); in TestAbortCloseCall()
1071 ws, PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, PP_MakeUndefined(), in TestAbortCloseCall()
1073 ReleaseResourceDelegate close_delegate(core_interface_, ws); in TestAbortCloseCall()
1091 PP_Resource ws; in TestAbortReceiveMessageCall() local
1098 ws = Connect(url, &result, std::string()); in TestAbortReceiveMessageCall()
1099 ASSERT_TRUE(ws); in TestAbortReceiveMessageCall()
1102 result = websocket_interface_->SendMessage(ws, text_var); in TestAbortReceiveMessageCall()
1109 ws, &var, callback.GetCallback().pp_completion_callback())); in TestAbortReceiveMessageCall()
1115 ws, &var, callback.GetCallback().pp_completion_callback()); in TestAbortReceiveMessageCall()
1116 core_interface_->ReleaseResource(ws); in TestAbortReceiveMessageCall()
1124 ws = Connect(url, &result, std::string()); in TestAbortReceiveMessageCall()
1125 ASSERT_TRUE(ws); in TestAbortReceiveMessageCall()
1129 result = websocket_interface_->SendMessage(ws, large_var); in TestAbortReceiveMessageCall()
1131 result = websocket_interface_->SendMessage(ws, text_var); in TestAbortReceiveMessageCall()
1138 ws, &var, callback.GetCallback().pp_completion_callback())); in TestAbortReceiveMessageCall()
1144 ws, &var, callback.GetCallback().pp_completion_callback()); in TestAbortReceiveMessageCall()
1145 core_interface_->ReleaseResource(ws); in TestAbortReceiveMessageCall()
1161 pp::WebSocket ws(instance_); in TestCcInterfaces() local
1164 ASSERT_EQ(0, ws.GetBufferedAmount()); in TestCcInterfaces()
1165 ASSERT_EQ(0, ws.GetCloseCode()); in TestCcInterfaces()
1166 ASSERT_TRUE(AreEqualWithString(ws.GetCloseReason().pp_var(), std::string())); in TestCcInterfaces()
1167 ASSERT_EQ(false, ws.GetCloseWasClean()); in TestCcInterfaces()
1168 ASSERT_TRUE(AreEqualWithString(ws.GetExtensions().pp_var(), std::string())); in TestCcInterfaces()
1169 ASSERT_TRUE(AreEqualWithString(ws.GetProtocol().pp_var(), std::string())); in TestCcInterfaces()
1170 ASSERT_EQ(PP_WEBSOCKETREADYSTATE_INVALID, ws.GetReadyState()); in TestCcInterfaces()
1171 ASSERT_TRUE(AreEqualWithString(ws.GetURL().pp_var(), std::string())); in TestCcInterfaces()
1176 connect_callback.WaitForResult(ws.Connect( in TestCcInterfaces()
1183 int32_t result = ws.SendMessage(pp::Var(text_message)); in TestCcInterfaces()
1189 result = ws.SendMessage( in TestCcInterfaces()
1197 ws.ReceiveMessage(&text_receive_var, in TestCcInterfaces()
1207 ws.ReceiveMessage(&binary_receive_var, in TestCcInterfaces()
1215 close_callback.WaitForResult(ws.Close( in TestCcInterfaces()
1222 ASSERT_EQ(0, ws.GetBufferedAmount()); in TestCcInterfaces()
1223 ASSERT_EQ(PP_WEBSOCKETSTATUSCODE_NORMAL_CLOSURE, ws.GetCloseCode()); in TestCcInterfaces()
1225 AreEqualWithString(ws.GetCloseReason().pp_var(), reason.c_str())); in TestCcInterfaces()
1226 ASSERT_EQ(true, ws.GetCloseWasClean()); in TestCcInterfaces()
1227 ASSERT_TRUE(AreEqualWithString(ws.GetProtocol().pp_var(), std::string())); in TestCcInterfaces()
1228 ASSERT_EQ(PP_WEBSOCKETREADYSTATE_CLOSED, ws.GetReadyState()); in TestCcInterfaces()
1230 ws.GetURL().pp_var(), GetFullURL(kCloseServerURL).c_str())); in TestCcInterfaces()
1248 TestWebSocketAPI ws(instance_); in TestUtilityInvalidConnect() local
1249 result = ws.Connect(pp::Var(std::string(kInvalidURLs[i])), protocols, 0U); in TestUtilityInvalidConnect()
1251 ws.WaitForClosed(); in TestUtilityInvalidConnect()
1252 const std::vector<WebSocketEvent>& events = ws.GetSeenEvents(); in TestUtilityInvalidConnect()
1255 ASSERT_EQ(2U, ws.GetSeenEvents().size()); in TestUtilityInvalidConnect()
1258 ASSERT_EQ(0U, ws.GetSeenEvents().size()); in TestUtilityInvalidConnect()