This source file includes following definitions.
- ReadBegin
- ReadRetry
- buffer_
- AsPPB_Gamepad_API
- Sample
- OnPluginMsgSendMemory
#include "ppapi/proxy/gamepad_resource.h"
#include <string.h>
#include "base/bind.h"
#include "base/threading/platform_thread.h"
#include "ppapi/proxy/dispatch_reply_message.h"
#include "ppapi/proxy/ppapi_messages.h"
#include "ppapi/shared_impl/ppb_gamepad_shared.h"
namespace ppapi {
namespace proxy {
namespace {
base::subtle::Atomic32 ReadBegin(const base::subtle::Atomic32* sequence) {
base::subtle::Atomic32 version;
for (;;) {
version = base::subtle::NoBarrier_Load(sequence);
if ((version & 1) == 0)
break;
base::PlatformThread::YieldCurrentThread();
}
return version;
}
bool ReadRetry(const base::subtle::Atomic32* sequence,
base::subtle::Atomic32 version) {
return base::subtle::Release_Load(sequence) != version;
}
}
GamepadResource::GamepadResource(Connection connection, PP_Instance instance)
: PluginResource(connection, instance),
buffer_(NULL) {
memset(&last_read_, 0, sizeof(last_read_));
SendCreate(BROWSER, PpapiHostMsg_Gamepad_Create());
Call<PpapiPluginMsg_Gamepad_SendMemory>(
BROWSER,
PpapiHostMsg_Gamepad_RequestMemory(),
base::Bind(&GamepadResource::OnPluginMsgSendMemory, this));
}
GamepadResource::~GamepadResource() {
}
thunk::PPB_Gamepad_API* GamepadResource::AsPPB_Gamepad_API() {
return this;
}
void GamepadResource::Sample(PP_Instance ,
PP_GamepadsSampleData* data) {
if (!buffer_) {
memset(data, 0, sizeof(PP_GamepadsSampleData));
return;
}
const int kMaximumContentionCount = 10;
int contention_count = -1;
base::subtle::Atomic32 version;
WebKitGamepads read_into;
do {
version = ReadBegin(&buffer_->sequence);
memcpy(&read_into, &buffer_->buffer, sizeof(read_into));
++contention_count;
if (contention_count == kMaximumContentionCount)
break;
} while (ReadRetry(&buffer_->sequence, version));
if (contention_count < kMaximumContentionCount)
ConvertWebKitGamepadData(read_into, &last_read_);
memcpy(data, &last_read_, sizeof(PP_GamepadsSampleData));
}
void GamepadResource::OnPluginMsgSendMemory(
const ResourceMessageReplyParams& params) {
base::SharedMemoryHandle handle = base::SharedMemory::NULLHandle();
params.TakeSharedMemoryHandleAtIndex(0, &handle);
shared_memory_.reset(new base::SharedMemory(handle, true));
CHECK(shared_memory_->Map(sizeof(ContentGamepadHardwareBuffer)));
buffer_ = static_cast<const ContentGamepadHardwareBuffer*>(
shared_memory_->memory());
}
}
}