#include <map>
#include <sstream>
-#include "ppapi/c/dev/ppb_testing_dev.h"
#include "ppapi/c/pp_var.h"
#include "ppapi/c/ppb_file_io.h"
-#include "ppapi/cpp/dev/var_resource_dev.h"
#include "ppapi/cpp/file_io.h"
#include "ppapi/cpp/file_ref.h"
#include "ppapi/cpp/file_system.h"
class ScopedArrayBufferSizeSetter {
public:
- ScopedArrayBufferSizeSetter(const PPB_Testing_Dev* interface,
+ ScopedArrayBufferSizeSetter(const PPB_Testing_Private* interface,
PP_Instance instance,
uint32_t threshold)
: interface_(interface),
interface_->SetMinimumArrayBufferSizeForShmem(instance_, 0);
}
private:
- const PPB_Testing_Dev* interface_;
+ const PPB_Testing_Private* interface_;
PP_Instance instance_;
};
ASSERT_TRUE(AddEchoingListener(*iter));
message_data_.clear();
instance_->PostMessage(test_data);
- ASSERT_EQ(message_data_.size(), 0);
- ASSERT_EQ(WaitForMessages(), 1);
+ ASSERT_EQ(0, message_data_.size());
+ ASSERT_EQ(1, WaitForMessages());
ASSERT_TRUE(message_data_.back().is_bool());
if (!message_data_.back().AsBool())
return std::string("Failed: ") + *iter;
}
std::string TestPostMessage::TestSendInInit() {
- ASSERT_EQ(WaitForMessages(), 1);
+ ASSERT_EQ(1, WaitForMessages());
// This test assumes Init already sent a message.
- ASSERT_EQ(message_data_.size(), 1);
+ ASSERT_EQ(1, message_data_.size());
ASSERT_TRUE(message_data_.back().is_string());
- ASSERT_EQ(message_data_.back().AsString(), kTestString);
+ ASSERT_EQ(kTestString, message_data_.back().AsString());
message_data_.clear();
PASS();
}
message_data_.clear();
instance_->PostMessage(pp::Var(kTestString));
// PostMessage is asynchronous, so we should not receive a response yet.
- ASSERT_EQ(message_data_.size(), 0);
- ASSERT_EQ(WaitForMessages(), 1);
+ ASSERT_EQ(0, message_data_.size());
+ ASSERT_EQ(1, WaitForMessages());
ASSERT_TRUE(message_data_.back().is_string());
ASSERT_EQ(message_data_.back().AsString(), kTestString);
message_data_.clear();
instance_->PostMessage(pp::Var(kTestBool));
- ASSERT_EQ(message_data_.size(), 0);
- ASSERT_EQ(WaitForMessages(), 1);
+ ASSERT_EQ(0, message_data_.size());
+ ASSERT_EQ(1, WaitForMessages());
ASSERT_TRUE(message_data_.back().is_bool());
ASSERT_EQ(message_data_.back().AsBool(), kTestBool);
message_data_.clear();
instance_->PostMessage(pp::Var(kTestInt));
- ASSERT_EQ(message_data_.size(), 0);
- ASSERT_EQ(WaitForMessages(), 1);
+ ASSERT_EQ(0, message_data_.size());
+ ASSERT_EQ(1, WaitForMessages());
ASSERT_TRUE(message_data_.back().is_number());
- ASSERT_DOUBLE_EQ(message_data_.back().AsDouble(),
- static_cast<double>(kTestInt));
+ ASSERT_DOUBLE_EQ(static_cast<double>(kTestInt),
+ message_data_.back().AsDouble());
message_data_.clear();
instance_->PostMessage(pp::Var(kTestDouble));
- ASSERT_EQ(message_data_.size(), 0);
- ASSERT_EQ(WaitForMessages(), 1);
+ ASSERT_EQ(0, message_data_.size());
+ ASSERT_EQ(1, WaitForMessages());
ASSERT_TRUE(message_data_.back().is_number());
ASSERT_DOUBLE_EQ(message_data_.back().AsDouble(), kTestDouble);
message_data_.clear();
instance_->PostMessage(pp::Var());
- ASSERT_EQ(message_data_.size(), 0);
- ASSERT_EQ(WaitForMessages(), 1);
+ ASSERT_EQ(0, message_data_.size());
+ ASSERT_EQ(1, WaitForMessages());
ASSERT_TRUE(message_data_.back().is_undefined());
message_data_.clear();
instance_->PostMessage(pp::Var(pp::Var::Null()));
- ASSERT_EQ(message_data_.size(), 0);
- ASSERT_EQ(WaitForMessages(), 1);
+ ASSERT_EQ(0, message_data_.size());
+ ASSERT_EQ(1, WaitForMessages());
ASSERT_TRUE(message_data_.back().is_null());
message_data_.clear();
message_data_.clear();
instance_->PostMessage(test_data);
// PostMessage is asynchronous, so we should not receive a response yet.
- ASSERT_EQ(message_data_.size(), 0);
- ASSERT_EQ(WaitForMessages(), 1);
+ ASSERT_EQ(0, message_data_.size());
+ ASSERT_EQ(1, WaitForMessages());
ASSERT_TRUE(message_data_.back().is_array_buffer());
pp::VarArrayBuffer received(message_data_.back());
message_data_.clear();
message_data_.clear();
instance_->PostMessage(array);
// PostMessage is asynchronous, so we should not receive a response yet.
- ASSERT_EQ(message_data_.size(), 0);
- ASSERT_EQ(WaitForMessages(), 1);
+ ASSERT_EQ(0, message_data_.size());
+ ASSERT_EQ(1, WaitForMessages());
ASSERT_TRUE(message_data_.back().is_array());
ASSERT_TRUE(VarsEqual(array, message_data_.back()));
message_data_.clear();
instance_->PostMessage(dictionary);
// PostMessage is asynchronous, so we should not receive a response yet.
- ASSERT_EQ(message_data_.size(), 0);
- ASSERT_EQ(WaitForMessages(), 1);
+ ASSERT_EQ(0, message_data_.size());
+ ASSERT_EQ(1, WaitForMessages());
ASSERT_TRUE(message_data_.back().is_dictionary());
ASSERT_TRUE(VarsEqual(dictionary, message_data_.back()));
// This opens a real (temporary) file using the HTML5 FileSystem API and
// writes to it.
ASSERT_TRUE(AddEchoingListener("message_event.data"));
- ASSERT_EQ(message_data_.size(), 0);
+ ASSERT_EQ(0, message_data_.size());
std::string js_code =
"function(callback) {"
" window.webkitRequestFileSystem(window.TEMPORARY, 1024,"
ASSERT_EQ(PostAsyncMessageFromJavaScriptAndWait(js_code), 1);
pp::Var var = message_data_.back();
ASSERT_TRUE(var.is_resource());
- pp::VarResource_Dev var_resource(var);
- pp::Resource result = var_resource.AsResource();
+ pp::Resource result = var.AsResource();
ASSERT_TRUE(pp::FileSystem::IsFileSystem(result));
{
pp::FileSystem file_system(result);
ASSERT_TRUE(AddEchoingListener("message_event.data"));
instance_->PostMessage(dictionary);
// PostMessage is asynchronous, so we should not receive a response yet.
- ASSERT_EQ(message_data_.size(), 0);
- ASSERT_EQ(WaitForMessages(), 1);
+ ASSERT_EQ(0, message_data_.size());
+ ASSERT_EQ(1, WaitForMessages());
ASSERT_TRUE(message_data_.back().is_dictionary());
pp::VarDictionary result(message_data_.back());
ASSERT_TRUE(VarsEqual(dictionary, message_data_.back()));
ASSERT_TRUE(AddEchoingListener("message_event.data"));
instance_->PostMessage(dictionary);
// PostMessage is asynchronous, so we should not receive a response yet.
- ASSERT_EQ(message_data_.size(), 0);
+ ASSERT_EQ(0, message_data_.size());
ASSERT_EQ(WaitForMessages(), 0);
// Break the cycles.
// Test sending a cycle from JavaScript to the plugin.
ASSERT_TRUE(AddEchoingListener("message_event.data"));
PostMessageFromJavaScript("function() { var x = []; x[0] = x; return x; }");
- ASSERT_EQ(message_data_.size(), 0);
+ ASSERT_EQ(0, message_data_.size());
ASSERT_EQ(WaitForMessages(), 0);
WaitForMessages();
ASSERT_TRUE(AddEchoingListener("message_event.constructor.name"));
message_data_.clear();
instance_->PostMessage(pp::Var(kTestInt));
- ASSERT_EQ(message_data_.size(), 0);
- ASSERT_EQ(WaitForMessages(), 1);
+ ASSERT_EQ(0, message_data_.size());
+ ASSERT_EQ(1, WaitForMessages());
ASSERT_TRUE(message_data_.back().is_string());
ASSERT_EQ(message_data_.back().AsString(), "MessageEvent");
ASSERT_TRUE(ClearListeners());
ASSERT_TRUE(success);
message_data_.clear();
instance_->PostMessage(pp::Var(kTestInt));
- ASSERT_EQ(message_data_.size(), 0);
- ASSERT_EQ(WaitForMessages(), 1);
+ ASSERT_EQ(0, message_data_.size());
+ ASSERT_EQ(1, WaitForMessages());
ASSERT_TRUE(message_data_.back().is_bool());
ASSERT_TRUE(message_data_.back().AsBool());
ASSERT_TRUE(ClearListeners());
message_data_.clear();
instance_->PostMessage(pp::Var(kTestInt));
// Make sure we don't get a response in a re-entrant fashion.
- ASSERT_EQ(message_data_.size(), 0);
+ ASSERT_EQ(0, message_data_.size());
// We should get 3 messages.
ASSERT_EQ(WaitForMessages(), 3);
// Copy to a vector of doubles and sort; w3c does not specify the order for
PP_JoinThread(threads[i]);
// PostMessage is asynchronous, so we should not receive a response yet.
- ASSERT_EQ(message_data_.size(), 0);
+ ASSERT_EQ(0, message_data_.size());
// Make sure we got all values that we expected. Note that because it's legal
// for the JavaScript engine to treat our integers as floating points, we
std::vector<int32_t> expected_counts(kThreadsToRun + 1,
kMessagesToSendPerThread);
std::vector<int32_t> received_counts(kThreadsToRun + 1, 0);
- ASSERT_EQ(WaitForMessages(), expected_num);
+ ASSERT_EQ(expected_num, WaitForMessages());
for (int32_t i = 0; i < expected_num; ++i) {
const pp::Var& latest_var(message_data_[i]);
ASSERT_TRUE(latest_var.is_int() || latest_var.is_double());
ASSERT_TRUE(received_value <= kThreadsToRun);
++received_counts[received_value];
}
- ASSERT_EQ(received_counts, expected_counts);
+ ASSERT_EQ(expected_counts, received_counts);
message_data_.clear();
ASSERT_TRUE(ClearListeners());