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/mojo_core.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 MojoCore g_core = {0}; | |
13 | |
14 MojoTimeTicks MojoGetTimeTicksNow() { | 14 MojoTimeTicks MojoGetTimeTicksNow() { |
15 assert(g_core); | 15 assert(g_core.GetTimeTicksNow); |
16 return g_core->GetTimeTicksNow(); | 16 return g_core.GetTimeTicksNow(); |
17 } | 17 } |
18 | 18 |
19 MojoResult MojoClose(MojoHandle handle) { | 19 MojoResult MojoClose(MojoHandle handle) { |
20 assert(g_core); | 20 assert(g_core.Close); |
21 return g_core->Close(handle); | 21 return g_core.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_core.Wait); |
28 return g_core->Wait(handle, flags, deadline); | 28 return g_core.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_core.WaitMany); |
36 return g_core->WaitMany(handles, flags, num_handles, deadline); | 36 return g_core.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_core.CreateMessagePipe); |
42 return g_core->CreateMessagePipe(message_pipe_handle0, message_pipe_handle1); | 42 return g_core.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_core.WriteMessage); |
52 return g_core->WriteMessage(message_pipe_handle, bytes, num_bytes, handles, | 52 return g_core.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_core.ReadMessage); |
63 return g_core->ReadMessage(message_pipe_handle, bytes, num_bytes, handles, | 63 return g_core.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_core.CreateDataPipe); |
71 return g_core->CreateDataPipe(options, data_pipe_producer_handle, | 71 return g_core.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_core.WriteData); |
80 return g_core->WriteData(data_pipe_producer_handle, elements, num_elements, | 80 return g_core.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_core.BeginWriteData); |
89 return g_core->BeginWriteData(data_pipe_producer_handle, buffer, | 89 return g_core.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_core.EndWriteData); |
96 return g_core->EndWriteData(data_pipe_producer_handle, num_elements_written); | 96 return g_core.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_core.ReadData); |
104 return g_core->ReadData(data_pipe_consumer_handle, elements, num_elements, | 104 return g_core.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_core.BeginReadData); |
113 return g_core->BeginReadData(data_pipe_consumer_handle, buffer, | 113 return g_core.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_core.EndReadData); |
120 return g_core->EndReadData(data_pipe_consumer_handle, num_elements_read); | 120 return g_core.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_core.CreateSharedBuffer); |
128 return g_core->CreateSharedBuffer(options, num_bytes, shared_buffer_handle); | 128 return g_core.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_core.DuplicateBufferHandle); |
136 return g_core->DuplicateBufferHandle(buffer_handle, options, | 136 return g_core.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_core.MapBuffer); |
146 return g_core->MapBuffer(buffer_handle, offset, num_bytes, buffer, flags); | 146 return g_core.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_core.UnmapBuffer); |
151 return g_core->UnmapBuffer(buffer); | 151 return g_core.UnmapBuffer(buffer); |
152 } | |
153 | |
154 MojoResult SetMojoCore(MojoCore* mojo_core) { | |
155 if (mojo_core->size < sizeof(g_core)) { | |
156 mojo_core->size = sizeof(g_core); | |
viettrungluu
2014/04/09 20:52:23
This seems like a bad idea. I think it should take
DaveMoore
2014/04/09 22:49:08
Done.
| |
157 return MOJO_RESULT_INVALID_ARGUMENT; | |
158 } | |
159 g_core = *mojo_core; | |
160 return MOJO_RESULT_OK; | |
152 } | 161 } |
153 | 162 |
154 } // extern "C" | 163 } // 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 |