| Index: mojo/public/platform/native/system_thunks.cc
|
| diff --git a/mojo/public/platform/native/system_thunks.cc b/mojo/public/platform/native/system_thunks.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..86447c1cdebf2fe3c9fe19d9a5c62860edf19e80
|
| --- /dev/null
|
| +++ b/mojo/public/platform/native/system_thunks.cc
|
| @@ -0,0 +1,287 @@
|
| +// Copyright 2013 The Chromium Authors. All rights reserved.
|
| +// Use of this source code is governed by a BSD-style license that can be
|
| +// found in the LICENSE file.
|
| +
|
| +#include "mojo/public/platform/native/system_thunks.h"
|
| +
|
| +#include <assert.h>
|
| +#include <stddef.h>
|
| +#include <stdint.h>
|
| +
|
| +#include "mojo/public/platform/native/thunk_export.h"
|
| +
|
| +extern "C" {
|
| +
|
| +static MojoSystemThunks g_thunks = {0};
|
| +
|
| +MojoTimeTicks MojoGetTimeTicksNow() {
|
| + assert(g_thunks.GetTimeTicksNow);
|
| + return g_thunks.GetTimeTicksNow();
|
| +}
|
| +
|
| +MojoResult MojoClose(MojoHandle handle) {
|
| + assert(g_thunks.Close);
|
| + return g_thunks.Close(handle);
|
| +}
|
| +
|
| +MojoResult MojoWait(MojoHandle handle,
|
| + MojoHandleSignals signals,
|
| + MojoDeadline deadline,
|
| + struct MojoHandleSignalsState* signals_state) {
|
| + assert(g_thunks.Wait);
|
| + return g_thunks.Wait(handle, signals, deadline, signals_state);
|
| +}
|
| +
|
| +MojoResult MojoWaitMany(const MojoHandle* handles,
|
| + const MojoHandleSignals* signals,
|
| + uint32_t num_handles,
|
| + MojoDeadline deadline,
|
| + uint32_t* result_index,
|
| + struct MojoHandleSignalsState* signals_states) {
|
| + assert(g_thunks.WaitMany);
|
| + return g_thunks.WaitMany(handles, signals, num_handles, deadline,
|
| + result_index, signals_states);
|
| +}
|
| +
|
| +MojoResult MojoCreateMessagePipe(const MojoCreateMessagePipeOptions* options,
|
| + MojoHandle* message_pipe_handle0,
|
| + MojoHandle* message_pipe_handle1) {
|
| + assert(g_thunks.CreateMessagePipe);
|
| + return g_thunks.CreateMessagePipe(options, message_pipe_handle0,
|
| + message_pipe_handle1);
|
| +}
|
| +
|
| +MojoResult MojoWriteMessage(MojoHandle message_pipe_handle,
|
| + const void* bytes,
|
| + uint32_t num_bytes,
|
| + const MojoHandle* handles,
|
| + uint32_t num_handles,
|
| + MojoWriteMessageFlags flags) {
|
| + assert(g_thunks.WriteMessage);
|
| + return g_thunks.WriteMessage(message_pipe_handle, bytes, num_bytes, handles,
|
| + num_handles, flags);
|
| +}
|
| +
|
| +MojoResult MojoReadMessage(MojoHandle message_pipe_handle,
|
| + void* bytes,
|
| + uint32_t* num_bytes,
|
| + MojoHandle* handles,
|
| + uint32_t* num_handles,
|
| + MojoReadMessageFlags flags) {
|
| + assert(g_thunks.ReadMessage);
|
| + return g_thunks.ReadMessage(message_pipe_handle, bytes, num_bytes, handles,
|
| + num_handles, flags);
|
| +}
|
| +
|
| +MojoResult MojoCreateDataPipe(const MojoCreateDataPipeOptions* options,
|
| + MojoHandle* data_pipe_producer_handle,
|
| + MojoHandle* data_pipe_consumer_handle) {
|
| + assert(g_thunks.CreateDataPipe);
|
| + return g_thunks.CreateDataPipe(options, data_pipe_producer_handle,
|
| + data_pipe_consumer_handle);
|
| +}
|
| +
|
| +MojoResult MojoWriteData(MojoHandle data_pipe_producer_handle,
|
| + const void* elements,
|
| + uint32_t* num_elements,
|
| + MojoWriteDataFlags flags) {
|
| + assert(g_thunks.WriteData);
|
| + return g_thunks.WriteData(data_pipe_producer_handle, elements, num_elements,
|
| + flags);
|
| +}
|
| +
|
| +MojoResult MojoBeginWriteData(MojoHandle data_pipe_producer_handle,
|
| + void** buffer,
|
| + uint32_t* buffer_num_elements,
|
| + MojoWriteDataFlags flags) {
|
| + assert(g_thunks.BeginWriteData);
|
| + return g_thunks.BeginWriteData(data_pipe_producer_handle, buffer,
|
| + buffer_num_elements, flags);
|
| +}
|
| +
|
| +MojoResult MojoEndWriteData(MojoHandle data_pipe_producer_handle,
|
| + uint32_t num_elements_written) {
|
| + assert(g_thunks.EndWriteData);
|
| + return g_thunks.EndWriteData(data_pipe_producer_handle, num_elements_written);
|
| +}
|
| +
|
| +MojoResult MojoReadData(MojoHandle data_pipe_consumer_handle,
|
| + void* elements,
|
| + uint32_t* num_elements,
|
| + MojoReadDataFlags flags) {
|
| + assert(g_thunks.ReadData);
|
| + return g_thunks.ReadData(data_pipe_consumer_handle, elements, num_elements,
|
| + flags);
|
| +}
|
| +
|
| +MojoResult MojoBeginReadData(MojoHandle data_pipe_consumer_handle,
|
| + const void** buffer,
|
| + uint32_t* buffer_num_elements,
|
| + MojoReadDataFlags flags) {
|
| + assert(g_thunks.BeginReadData);
|
| + return g_thunks.BeginReadData(data_pipe_consumer_handle, buffer,
|
| + buffer_num_elements, flags);
|
| +}
|
| +
|
| +MojoResult MojoEndReadData(MojoHandle data_pipe_consumer_handle,
|
| + uint32_t num_elements_read) {
|
| + assert(g_thunks.EndReadData);
|
| + return g_thunks.EndReadData(data_pipe_consumer_handle, num_elements_read);
|
| +}
|
| +
|
| +MojoResult MojoCreateSharedBuffer(
|
| + const struct MojoCreateSharedBufferOptions* options,
|
| + uint64_t num_bytes,
|
| + MojoHandle* shared_buffer_handle) {
|
| + assert(g_thunks.CreateSharedBuffer);
|
| + return g_thunks.CreateSharedBuffer(options, num_bytes, shared_buffer_handle);
|
| +}
|
| +
|
| +MojoResult MojoDuplicateBufferHandle(
|
| + MojoHandle buffer_handle,
|
| + const struct MojoDuplicateBufferHandleOptions* options,
|
| + MojoHandle* new_buffer_handle) {
|
| + assert(g_thunks.DuplicateBufferHandle);
|
| + return g_thunks.DuplicateBufferHandle(buffer_handle, options,
|
| + new_buffer_handle);
|
| +}
|
| +
|
| +MojoResult MojoMapBuffer(MojoHandle buffer_handle,
|
| + uint64_t offset,
|
| + uint64_t num_bytes,
|
| + void** buffer,
|
| + MojoMapBufferFlags flags) {
|
| + assert(g_thunks.MapBuffer);
|
| + return g_thunks.MapBuffer(buffer_handle, offset, num_bytes, buffer, flags);
|
| +}
|
| +
|
| +MojoResult MojoUnmapBuffer(void* buffer) {
|
| + assert(g_thunks.UnmapBuffer);
|
| + return g_thunks.UnmapBuffer(buffer);
|
| +}
|
| +
|
| +MojoResult MojoCreateWaitSet(MojoHandle* wait_set) {
|
| + assert(g_thunks.CreateWaitSet);
|
| + return g_thunks.CreateWaitSet(wait_set);
|
| +}
|
| +
|
| +MojoResult MojoAddHandle(MojoHandle wait_set,
|
| + MojoHandle handle,
|
| + MojoHandleSignals signals) {
|
| + assert(g_thunks.AddHandle);
|
| + return g_thunks.AddHandle(wait_set, handle, signals);
|
| +}
|
| +
|
| +MojoResult MojoRemoveHandle(MojoHandle wait_set, MojoHandle handle) {
|
| + assert(g_thunks.RemoveHandle);
|
| + return g_thunks.RemoveHandle(wait_set, handle);
|
| +}
|
| +
|
| +MojoResult MojoGetReadyHandles(MojoHandle wait_set,
|
| + uint32_t* count,
|
| + MojoHandle* handles,
|
| + MojoResult* results,
|
| + struct MojoHandleSignalsState* signals_states) {
|
| + assert(g_thunks.GetReadyHandles);
|
| + return g_thunks.GetReadyHandles(wait_set, count, handles, results,
|
| + signals_states);
|
| +}
|
| +
|
| +MojoResult MojoWatch(MojoHandle handle,
|
| + MojoHandleSignals signals,
|
| + MojoWatchCallback callback,
|
| + uintptr_t context) {
|
| + assert(g_thunks.Watch);
|
| + return g_thunks.Watch(handle, signals, callback, context);
|
| +}
|
| +
|
| +MojoResult MojoCancelWatch(MojoHandle handle, uintptr_t context) {
|
| + assert(g_thunks.CancelWatch);
|
| + return g_thunks.CancelWatch(handle, context);
|
| +}
|
| +
|
| +MojoResult MojoFuseMessagePipes(MojoHandle handle0, MojoHandle handle1) {
|
| + assert(g_thunks.FuseMessagePipes);
|
| + return g_thunks.FuseMessagePipes(handle0, handle1);
|
| +}
|
| +
|
| +MojoResult MojoWriteMessageNew(MojoHandle message_pipe_handle,
|
| + MojoMessageHandle message,
|
| + MojoWriteMessageFlags flags) {
|
| + assert(g_thunks.WriteMessageNew);
|
| + return g_thunks.WriteMessageNew(message_pipe_handle, message, flags);
|
| +}
|
| +
|
| +MojoResult MojoReadMessageNew(MojoHandle message_pipe_handle,
|
| + MojoMessageHandle* message,
|
| + uint32_t* num_bytes,
|
| + MojoHandle* handles,
|
| + uint32_t* num_handles,
|
| + MojoReadMessageFlags flags) {
|
| + assert(g_thunks.ReadMessageNew);
|
| + return g_thunks.ReadMessageNew(message_pipe_handle, message, num_bytes,
|
| + handles, num_handles, flags);
|
| +}
|
| +
|
| +MojoResult MojoAllocMessage(uint32_t num_bytes,
|
| + const MojoHandle* handles,
|
| + uint32_t num_handles,
|
| + MojoAllocMessageFlags flags,
|
| + MojoMessageHandle* message) {
|
| + assert(g_thunks.AllocMessage);
|
| + return g_thunks.AllocMessage(
|
| + num_bytes, handles, num_handles, flags, message);
|
| +}
|
| +
|
| +MojoResult MojoFreeMessage(MojoMessageHandle message) {
|
| + assert(g_thunks.FreeMessage);
|
| + return g_thunks.FreeMessage(message);
|
| +}
|
| +
|
| +MojoResult MojoGetMessageBuffer(MojoMessageHandle message, void** buffer) {
|
| + assert(g_thunks.GetMessageBuffer);
|
| + return g_thunks.GetMessageBuffer(message, buffer);
|
| +}
|
| +
|
| +MojoResult MojoWrapPlatformHandle(
|
| + const struct MojoPlatformHandle* platform_handle,
|
| + MojoHandle* mojo_handle) {
|
| + assert(g_thunks.WrapPlatformHandle);
|
| + return g_thunks.WrapPlatformHandle(platform_handle, mojo_handle);
|
| +}
|
| +
|
| +MojoResult MojoUnwrapPlatformHandle(
|
| + MojoHandle mojo_handle,
|
| + struct MojoPlatformHandle* platform_handle) {
|
| + assert(g_thunks.UnwrapPlatformHandle);
|
| + return g_thunks.UnwrapPlatformHandle(mojo_handle, platform_handle);
|
| +}
|
| +
|
| +MojoResult MojoWrapPlatformSharedBufferHandle(
|
| + const struct MojoPlatformHandle* platform_handle,
|
| + size_t num_bytes,
|
| + MojoPlatformSharedBufferHandleFlags flags,
|
| + MojoHandle* mojo_handle) {
|
| + assert(g_thunks.WrapPlatformSharedBufferHandle);
|
| + return g_thunks.WrapPlatformSharedBufferHandle(platform_handle, num_bytes,
|
| + flags, mojo_handle);
|
| +}
|
| +
|
| +MojoResult MojoUnwrapPlatformSharedBufferHandle(
|
| + MojoHandle mojo_handle,
|
| + struct MojoPlatformHandle* platform_handle,
|
| + size_t* num_bytes,
|
| + MojoPlatformSharedBufferHandleFlags* flags) {
|
| + assert(g_thunks.UnwrapPlatformSharedBufferHandle);
|
| + return g_thunks.UnwrapPlatformSharedBufferHandle(mojo_handle, platform_handle,
|
| + num_bytes, flags);
|
| +}
|
| +
|
| +extern "C" THUNK_EXPORT size_t MojoSetSystemThunks(
|
| + const MojoSystemThunks* system_thunks) {
|
| + if (system_thunks->size >= sizeof(g_thunks))
|
| + g_thunks = *system_thunks;
|
| + return sizeof(g_thunks);
|
| +}
|
| +
|
| +} // extern "C"
|
|
|