| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "mojo/public/system/core_private.h" | 5 #include "mojo/public/platform/native/system_thunks.h" |
| 6 | 6 |
| 7 #include <assert.h> | 7 #include <assert.h> |
| 8 #include <stddef.h> | 8 #include <stddef.h> |
| 9 | 9 |
| 10 static mojo::Core* g_core = NULL; | |
| 11 | |
| 12 extern "C" { | 10 extern "C" { |
| 13 | 11 |
| 12 static MojoSystemThunks g_thunks = {0}; |
| 13 |
| 14 MojoTimeTicks MojoGetTimeTicksNow() { | 14 MojoTimeTicks MojoGetTimeTicksNow() { |
| 15 assert(g_core); | 15 assert(g_thunks.GetTimeTicksNow); |
| 16 return g_core->GetTimeTicksNow(); | 16 return g_thunks.GetTimeTicksNow(); |
| 17 } | 17 } |
| 18 | 18 |
| 19 MojoResult MojoClose(MojoHandle handle) { | 19 MojoResult MojoClose(MojoHandle handle) { |
| 20 assert(g_core); | 20 assert(g_thunks.Close); |
| 21 return g_core->Close(handle); | 21 return g_thunks.Close(handle); |
| 22 } | 22 } |
| 23 | 23 |
| 24 MojoResult MojoWait(MojoHandle handle, | 24 MojoResult MojoWait(MojoHandle handle, |
| 25 MojoWaitFlags flags, | 25 MojoWaitFlags flags, |
| 26 MojoDeadline deadline) { | 26 MojoDeadline deadline) { |
| 27 assert(g_core); | 27 assert(g_thunks.Wait); |
| 28 return g_core->Wait(handle, flags, deadline); | 28 return g_thunks.Wait(handle, flags, deadline); |
| 29 } | 29 } |
| 30 | 30 |
| 31 MojoResult MojoWaitMany(const MojoHandle* handles, | 31 MojoResult MojoWaitMany(const MojoHandle* handles, |
| 32 const MojoWaitFlags* flags, | 32 const MojoWaitFlags* flags, |
| 33 uint32_t num_handles, | 33 uint32_t num_handles, |
| 34 MojoDeadline deadline) { | 34 MojoDeadline deadline) { |
| 35 assert(g_core); | 35 assert(g_thunks.WaitMany); |
| 36 return g_core->WaitMany(handles, flags, num_handles, deadline); | 36 return g_thunks.WaitMany(handles, flags, num_handles, deadline); |
| 37 } | 37 } |
| 38 | 38 |
| 39 MojoResult MojoCreateMessagePipe(MojoHandle* message_pipe_handle0, | 39 MojoResult MojoCreateMessagePipe(MojoHandle* message_pipe_handle0, |
| 40 MojoHandle* message_pipe_handle1) { | 40 MojoHandle* message_pipe_handle1) { |
| 41 assert(g_core); | 41 assert(g_thunks.CreateMessagePipe); |
| 42 return g_core->CreateMessagePipe(message_pipe_handle0, message_pipe_handle1); | 42 return g_thunks.CreateMessagePipe(message_pipe_handle0, message_pipe_handle1); |
| 43 } | 43 } |
| 44 | 44 |
| 45 MojoResult MojoWriteMessage(MojoHandle message_pipe_handle, | 45 MojoResult MojoWriteMessage(MojoHandle message_pipe_handle, |
| 46 const void* bytes, | 46 const void* bytes, |
| 47 uint32_t num_bytes, | 47 uint32_t num_bytes, |
| 48 const MojoHandle* handles, | 48 const MojoHandle* handles, |
| 49 uint32_t num_handles, | 49 uint32_t num_handles, |
| 50 MojoWriteMessageFlags flags) { | 50 MojoWriteMessageFlags flags) { |
| 51 assert(g_core); | 51 assert(g_thunks.WriteMessage); |
| 52 return g_core->WriteMessage(message_pipe_handle, bytes, num_bytes, handles, | 52 return g_thunks.WriteMessage(message_pipe_handle, bytes, num_bytes, handles, |
| 53 num_handles, flags); | 53 num_handles, flags); |
| 54 } | 54 } |
| 55 | 55 |
| 56 MojoResult MojoReadMessage(MojoHandle message_pipe_handle, | 56 MojoResult MojoReadMessage(MojoHandle message_pipe_handle, |
| 57 void* bytes, | 57 void* bytes, |
| 58 uint32_t* num_bytes, | 58 uint32_t* num_bytes, |
| 59 MojoHandle* handles, | 59 MojoHandle* handles, |
| 60 uint32_t* num_handles, | 60 uint32_t* num_handles, |
| 61 MojoReadMessageFlags flags) { | 61 MojoReadMessageFlags flags) { |
| 62 assert(g_core); | 62 assert(g_thunks.ReadMessage); |
| 63 return g_core->ReadMessage(message_pipe_handle, bytes, num_bytes, handles, | 63 return g_thunks.ReadMessage(message_pipe_handle, bytes, num_bytes, handles, |
| 64 num_handles, flags); | 64 num_handles, flags); |
| 65 } | 65 } |
| 66 | 66 |
| 67 MojoResult MojoCreateDataPipe(const MojoCreateDataPipeOptions* options, | 67 MojoResult MojoCreateDataPipe(const MojoCreateDataPipeOptions* options, |
| 68 MojoHandle* data_pipe_producer_handle, | 68 MojoHandle* data_pipe_producer_handle, |
| 69 MojoHandle* data_pipe_consumer_handle) { | 69 MojoHandle* data_pipe_consumer_handle) { |
| 70 assert(g_core); | 70 assert(g_thunks.CreateDataPipe); |
| 71 return g_core->CreateDataPipe(options, data_pipe_producer_handle, | 71 return g_thunks.CreateDataPipe(options, data_pipe_producer_handle, |
| 72 data_pipe_consumer_handle); | 72 data_pipe_consumer_handle); |
| 73 } | 73 } |
| 74 | 74 |
| 75 MojoResult MojoWriteData(MojoHandle data_pipe_producer_handle, | 75 MojoResult MojoWriteData(MojoHandle data_pipe_producer_handle, |
| 76 const void* elements, | 76 const void* elements, |
| 77 uint32_t* num_elements, | 77 uint32_t* num_elements, |
| 78 MojoWriteDataFlags flags) { | 78 MojoWriteDataFlags flags) { |
| 79 assert(g_core); | 79 assert(g_thunks.WriteData); |
| 80 return g_core->WriteData(data_pipe_producer_handle, elements, num_elements, | 80 return g_thunks.WriteData(data_pipe_producer_handle, elements, num_elements, |
| 81 flags); | 81 flags); |
| 82 } | 82 } |
| 83 | 83 |
| 84 MojoResult MojoBeginWriteData(MojoHandle data_pipe_producer_handle, | 84 MojoResult MojoBeginWriteData(MojoHandle data_pipe_producer_handle, |
| 85 void** buffer, | 85 void** buffer, |
| 86 uint32_t* buffer_num_elements, | 86 uint32_t* buffer_num_elements, |
| 87 MojoWriteDataFlags flags) { | 87 MojoWriteDataFlags flags) { |
| 88 assert(g_core); | 88 assert(g_thunks.BeginWriteData); |
| 89 return g_core->BeginWriteData(data_pipe_producer_handle, buffer, | 89 return g_thunks.BeginWriteData(data_pipe_producer_handle, buffer, |
| 90 buffer_num_elements, flags); | 90 buffer_num_elements, flags); |
| 91 } | 91 } |
| 92 | 92 |
| 93 MojoResult MojoEndWriteData(MojoHandle data_pipe_producer_handle, | 93 MojoResult MojoEndWriteData(MojoHandle data_pipe_producer_handle, |
| 94 uint32_t num_elements_written) { | 94 uint32_t num_elements_written) { |
| 95 assert(g_core); | 95 assert(g_thunks.EndWriteData); |
| 96 return g_core->EndWriteData(data_pipe_producer_handle, num_elements_written); | 96 return g_thunks.EndWriteData(data_pipe_producer_handle, num_elements_written); |
| 97 } | 97 } |
| 98 | 98 |
| 99 MojoResult MojoReadData(MojoHandle data_pipe_consumer_handle, | 99 MojoResult MojoReadData(MojoHandle data_pipe_consumer_handle, |
| 100 void* elements, | 100 void* elements, |
| 101 uint32_t* num_elements, | 101 uint32_t* num_elements, |
| 102 MojoReadDataFlags flags) { | 102 MojoReadDataFlags flags) { |
| 103 assert(g_core); | 103 assert(g_thunks.ReadData); |
| 104 return g_core->ReadData(data_pipe_consumer_handle, elements, num_elements, | 104 return g_thunks.ReadData(data_pipe_consumer_handle, elements, num_elements, |
| 105 flags); | 105 flags); |
| 106 } | 106 } |
| 107 | 107 |
| 108 MojoResult MojoBeginReadData(MojoHandle data_pipe_consumer_handle, | 108 MojoResult MojoBeginReadData(MojoHandle data_pipe_consumer_handle, |
| 109 const void** buffer, | 109 const void** buffer, |
| 110 uint32_t* buffer_num_elements, | 110 uint32_t* buffer_num_elements, |
| 111 MojoReadDataFlags flags) { | 111 MojoReadDataFlags flags) { |
| 112 assert(g_core); | 112 assert(g_thunks.BeginReadData); |
| 113 return g_core->BeginReadData(data_pipe_consumer_handle, buffer, | 113 return g_thunks.BeginReadData(data_pipe_consumer_handle, buffer, |
| 114 buffer_num_elements, flags); | 114 buffer_num_elements, flags); |
| 115 } | 115 } |
| 116 | 116 |
| 117 MojoResult MojoEndReadData(MojoHandle data_pipe_consumer_handle, | 117 MojoResult MojoEndReadData(MojoHandle data_pipe_consumer_handle, |
| 118 uint32_t num_elements_read) { | 118 uint32_t num_elements_read) { |
| 119 assert(g_core); | 119 assert(g_thunks.EndReadData); |
| 120 return g_core->EndReadData(data_pipe_consumer_handle, num_elements_read); | 120 return g_thunks.EndReadData(data_pipe_consumer_handle, num_elements_read); |
| 121 } | 121 } |
| 122 | 122 |
| 123 MojoResult MojoCreateSharedBuffer( | 123 MojoResult MojoCreateSharedBuffer( |
| 124 const struct MojoCreateSharedBufferOptions* options, | 124 const struct MojoCreateSharedBufferOptions* options, |
| 125 uint64_t num_bytes, | 125 uint64_t num_bytes, |
| 126 MojoHandle* shared_buffer_handle) { | 126 MojoHandle* shared_buffer_handle) { |
| 127 assert(g_core); | 127 assert(g_thunks.CreateSharedBuffer); |
| 128 return g_core->CreateSharedBuffer(options, num_bytes, shared_buffer_handle); | 128 return g_thunks.CreateSharedBuffer(options, num_bytes, shared_buffer_handle); |
| 129 } | 129 } |
| 130 | 130 |
| 131 MojoResult MojoDuplicateBufferHandle( | 131 MojoResult MojoDuplicateBufferHandle( |
| 132 MojoHandle buffer_handle, | 132 MojoHandle buffer_handle, |
| 133 const struct MojoDuplicateBufferHandleOptions* options, | 133 const struct MojoDuplicateBufferHandleOptions* options, |
| 134 MojoHandle* new_buffer_handle) { | 134 MojoHandle* new_buffer_handle) { |
| 135 assert(g_core); | 135 assert(g_thunks.DuplicateBufferHandle); |
| 136 return g_core->DuplicateBufferHandle(buffer_handle, options, | 136 return g_thunks.DuplicateBufferHandle(buffer_handle, options, |
| 137 new_buffer_handle); | 137 new_buffer_handle); |
| 138 } | 138 } |
| 139 | 139 |
| 140 MojoResult MojoMapBuffer(MojoHandle buffer_handle, | 140 MojoResult MojoMapBuffer(MojoHandle buffer_handle, |
| 141 uint64_t offset, | 141 uint64_t offset, |
| 142 uint64_t num_bytes, | 142 uint64_t num_bytes, |
| 143 void** buffer, | 143 void** buffer, |
| 144 MojoMapBufferFlags flags) { | 144 MojoMapBufferFlags flags) { |
| 145 assert(g_core); | 145 assert(g_thunks.MapBuffer); |
| 146 return g_core->MapBuffer(buffer_handle, offset, num_bytes, buffer, flags); | 146 return g_thunks.MapBuffer(buffer_handle, offset, num_bytes, buffer, flags); |
| 147 } | 147 } |
| 148 | 148 |
| 149 MojoResult MojoUnmapBuffer(void* buffer) { | 149 MojoResult MojoUnmapBuffer(void* buffer) { |
| 150 assert(g_core); | 150 assert(g_thunks.UnmapBuffer); |
| 151 return g_core->UnmapBuffer(buffer); | 151 return g_thunks.UnmapBuffer(buffer); |
| 152 } |
| 153 |
| 154 size_t MojoSetSystemThunks(const MojoSystemThunks* system_thunks) { |
| 155 if (system_thunks->size >= sizeof(g_thunks)) |
| 156 g_thunks = *system_thunks; |
| 157 return sizeof(g_thunks); |
| 152 } | 158 } |
| 153 | 159 |
| 154 } // extern "C" | 160 } // extern "C" |
| 155 | |
| 156 namespace mojo { | |
| 157 | |
| 158 Core::~Core() { | |
| 159 } | |
| 160 | |
| 161 // static | |
| 162 void Core::Init(Core* core) { | |
| 163 assert(!g_core); | |
| 164 g_core = core; | |
| 165 } | |
| 166 | |
| 167 // static | |
| 168 Core* Core::Get() { | |
| 169 return g_core; | |
| 170 } | |
| 171 | |
| 172 // static | |
| 173 void Core::Reset() { | |
| 174 g_core = NULL; | |
| 175 } | |
| 176 | |
| 177 } // namespace mojo | |
| OLD | NEW |