14e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// Copyright 2013 The Chromium Authors. All rights reserved. 24e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 34e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// found in the LICENSE file. 44e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 5a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch#include "mojo/system/core.h" 64e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 74e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)#include <vector> 84e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 94e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)#include "base/logging.h" 10a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)#include "base/time/time.h" 116e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles)#include "mojo/embedder/platform_shared_buffer.h" 1203b57e008b61dfcb1fbad3aea950ae0e001748b0Torne (Richard Coles)#include "mojo/embedder/platform_support.h" 1346d4c2bc3267f3f028f39e7e311b0f89aba2e4fdTorne (Richard Coles)#include "mojo/public/c/system/macros.h" 145d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)#include "mojo/system/constants.h" 155d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)#include "mojo/system/data_pipe.h" 165d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)#include "mojo/system/data_pipe_consumer_dispatcher.h" 175d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)#include "mojo/system/data_pipe_producer_dispatcher.h" 184e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)#include "mojo/system/dispatcher.h" 196e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles)#include "mojo/system/handle_signals_state.h" 205d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)#include "mojo/system/local_data_pipe.h" 214e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)#include "mojo/system/memory.h" 224e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)#include "mojo/system/message_pipe.h" 234e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)#include "mojo/system/message_pipe_dispatcher.h" 24effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch#include "mojo/system/shared_buffer_dispatcher.h" 254e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)#include "mojo/system/waiter.h" 264e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 274e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)namespace mojo { 284e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)namespace system { 294e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 304e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// Implementation notes 314e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// 32cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)// Mojo primitives are implemented by the singleton |Core| object. Most calls 33cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)// are for a "primary" handle (the first argument). |Core::GetDispatcher()| is 34cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)// used to look up a |Dispatcher| object for a given handle. That object 35cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)// implements most primitives for that object. The wait primitives are not 36cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)// attached to objects and are implemented by |Core| itself. 374e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// 384e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// Some objects have multiple handles associated to them, e.g., message pipes 394e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// (which have two). In such a case, there is still a |Dispatcher| (e.g., 404e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// |MessagePipeDispatcher|) for each handle, with each handle having a strong 414e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// reference to the common "secondary" object (e.g., |MessagePipe|). This 424e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// secondary object does NOT have any references to the |Dispatcher|s (even if 434e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// it did, it wouldn't be able to do anything with them due to lock order 444e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// requirements -- see below). 454e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// 464e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// Waiting is implemented by having the thread that wants to wait call the 474e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// |Dispatcher|s for the handles that it wants to wait on with a |Waiter| 484e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// object; this |Waiter| object may be created on the stack of that thread or be 494e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// kept in thread local storage for that thread (TODO(vtl): future improvement). 504e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// The |Dispatcher| then adds the |Waiter| to a |WaiterList| that's either owned 514e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// by that |Dispatcher| (see |SimpleDispatcher|) or by a secondary object (e.g., 524e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// |MessagePipe|). To signal/wake a |Waiter|, the object in question -- either a 534e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// |SimpleDispatcher| or a secondary object -- talks to its |WaiterList|. 544e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 554e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// Thread-safety notes 564e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// 574e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// Mojo primitives calls are thread-safe. We achieve this with relatively 584e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// fine-grained locking. There is a global handle table lock. This lock should 594e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// be held as briefly as possible (TODO(vtl): a future improvement would be to 604e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// switch it to a reader-writer lock). Each |Dispatcher| object then has a lock 614e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// (which subclasses can use to protect their data). 624e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// 634e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// The lock ordering is as follows: 64e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch// 1. global handle table lock, global mapping table lock 654e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// 2. |Dispatcher| locks 664e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// 3. secondary object locks 674e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// ... 684e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// INF. |Waiter| locks 694e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// 704e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// Notes: 714e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// - While holding a |Dispatcher| lock, you may not unconditionally attempt 724e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// to take another |Dispatcher| lock. (This has consequences on the 734e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// concurrency semantics of |MojoWriteMessage()| when passing handles.) 744e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// Doing so would lead to deadlock. 754e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// - Locks at the "INF" level may not have any locks taken while they are 764e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// held. 774e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 7803b57e008b61dfcb1fbad3aea950ae0e001748b0Torne (Richard Coles)// TODO(vtl): This should take a |scoped_ptr<PlatformSupport>| as a parameter. 7903b57e008b61dfcb1fbad3aea950ae0e001748b0Torne (Richard Coles)Core::Core(scoped_ptr<embedder::PlatformSupport> platform_support) 8003b57e008b61dfcb1fbad3aea950ae0e001748b0Torne (Richard Coles) : platform_support_(platform_support.Pass()) { 815d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 825d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 83a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochCore::~Core() { 845d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 855d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 865f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles)MojoHandle Core::AddDispatcher(const scoped_refptr<Dispatcher>& dispatcher) { 875d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) base::AutoLock locker(handle_table_lock_); 884ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch return handle_table_.AddDispatcher(dispatcher); 895d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 905d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 91cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)scoped_refptr<Dispatcher> Core::GetDispatcher(MojoHandle handle) { 92cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) if (handle == MOJO_HANDLE_INVALID) 931320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci return nullptr; 94cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) 95cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) base::AutoLock locker(handle_table_lock_); 96cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) return handle_table_.GetDispatcher(handle); 97cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles)} 98cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) 99a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochMojoTimeTicks Core::GetTimeTicksNow() { 1005d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) return base::TimeTicks::Now().ToInternalValue(); 1014e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)} 1024e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 103a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochMojoResult Core::Close(MojoHandle handle) { 1044e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) if (handle == MOJO_HANDLE_INVALID) 1054e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) return MOJO_RESULT_INVALID_ARGUMENT; 1064e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 1074e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) scoped_refptr<Dispatcher> dispatcher; 1084e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) { 1094e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) base::AutoLock locker(handle_table_lock_); 1105f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) MojoResult result = 1115f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) handle_table_.GetAndRemoveDispatcher(handle, &dispatcher); 1124ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch if (result != MOJO_RESULT_OK) 1134ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch return result; 1144e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) } 1154e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 1164e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) // The dispatcher doesn't have a say in being closed, but gets notified of it. 1174e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) // Note: This is done outside of |handle_table_lock_|. As a result, there's a 1184e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) // race condition that the dispatcher must handle; see the comment in 1194e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) // |Dispatcher| in dispatcher.h. 1204e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) return dispatcher->Close(); 1214e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)} 1224e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 123a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochMojoResult Core::Wait(MojoHandle handle, 124f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) MojoHandleSignals signals, 1256e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) MojoDeadline deadline, 1266e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) UserPointer<MojoHandleSignalsState> signals_state) { 1275f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) uint32_t unused = static_cast<uint32_t>(-1); 1286e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) HandleSignalsState hss; 1296e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) MojoResult rv = WaitManyInternal(&handle, 1306e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) &signals, 1316e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) 1, 1326e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) deadline, 1336e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) &unused, 1341320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci signals_state.IsNull() ? nullptr : &hss); 1356e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) if (rv != MOJO_RESULT_INVALID_ARGUMENT && !signals_state.IsNull()) 1366e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) signals_state.Put(hss); 1376e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) return rv; 1384e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)} 1394e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 1405f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles)MojoResult Core::WaitMany(UserPointer<const MojoHandle> handles, 1415f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<const MojoHandleSignals> signals, 142a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch uint32_t num_handles, 1436e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) MojoDeadline deadline, 1446e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) UserPointer<uint32_t> result_index, 1456e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) UserPointer<MojoHandleSignalsState> signals_states) { 1464e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) if (num_handles < 1) 1474e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) return MOJO_RESULT_INVALID_ARGUMENT; 1484e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) if (num_handles > kMaxWaitManyNumHandles) 1494e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) return MOJO_RESULT_RESOURCE_EXHAUSTED; 1505f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) 1515f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<const MojoHandle>::Reader handles_reader(handles, num_handles); 1525f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<const MojoHandleSignals>::Reader signals_reader(signals, 1535f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) num_handles); 1546e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) uint32_t index = static_cast<uint32_t>(-1); 1556e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) MojoResult rv; 1566e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) if (signals_states.IsNull()) { 1576e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) rv = WaitManyInternal(handles_reader.GetPointer(), 1586e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) signals_reader.GetPointer(), 1596e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) num_handles, 1606e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) deadline, 1616e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) &index, 1621320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci nullptr); 1636e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) } else { 1646e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) UserPointer<MojoHandleSignalsState>::Writer signals_states_writer( 1656e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) signals_states, num_handles); 1666e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) // Note: The |reinterpret_cast| is safe, since |HandleSignalsState| is a 1676e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) // subclass of |MojoHandleSignalsState| that doesn't add any data members. 1686e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) rv = WaitManyInternal(handles_reader.GetPointer(), 1696e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) signals_reader.GetPointer(), 1706e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) num_handles, 1716e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) deadline, 1726e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) &index, 1736e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) reinterpret_cast<HandleSignalsState*>( 1746e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) signals_states_writer.GetPointer())); 1756e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) if (rv != MOJO_RESULT_INVALID_ARGUMENT) 1766e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) signals_states_writer.Commit(); 1776e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) } 1786e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) if (index != static_cast<uint32_t>(-1) && !result_index.IsNull()) 1796e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) result_index.Put(index); 1806e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) return rv; 1814e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)} 1824e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 1835f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles)MojoResult Core::CreateMessagePipe( 1845f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<const MojoCreateMessagePipeOptions> options, 1855f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<MojoHandle> message_pipe_handle0, 1865f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<MojoHandle> message_pipe_handle1) { 187f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) MojoCreateMessagePipeOptions validated_options = {}; 1885f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) MojoResult result = 1895f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) MessagePipeDispatcher::ValidateCreateOptions(options, &validated_options); 190f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) if (result != MOJO_RESULT_OK) 191f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) return result; 192f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) 193f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) scoped_refptr<MessagePipeDispatcher> dispatcher0( 194f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) new MessagePipeDispatcher(validated_options)); 195f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) scoped_refptr<MessagePipeDispatcher> dispatcher1( 196f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) new MessagePipeDispatcher(validated_options)); 1974e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 1984ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch std::pair<MojoHandle, MojoHandle> handle_pair; 1994e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) { 2004e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) base::AutoLock locker(handle_table_lock_); 2014ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch handle_pair = handle_table_.AddDispatcherPair(dispatcher0, dispatcher1); 2024ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch } 2034ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch if (handle_pair.first == MOJO_HANDLE_INVALID) { 2044ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch DCHECK_EQ(handle_pair.second, MOJO_HANDLE_INVALID); 2054ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch LOG(ERROR) << "Handle table full"; 2064ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch dispatcher0->Close(); 2074ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch dispatcher1->Close(); 2084ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch return MOJO_RESULT_RESOURCE_EXHAUSTED; 2094e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) } 2104e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 2111320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci scoped_refptr<MessagePipe> message_pipe(MessagePipe::CreateLocalLocal()); 2125d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) dispatcher0->Init(message_pipe, 0); 2135d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) dispatcher1->Init(message_pipe, 1); 2144e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 2155f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) message_pipe_handle0.Put(handle_pair.first); 2165f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) message_pipe_handle1.Put(handle_pair.second); 2174e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) return MOJO_RESULT_OK; 2184e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)} 2194e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 220a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles)// Implementation note: To properly cancel waiters and avoid other races, this 221a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles)// does not transfer dispatchers from one handle to another, even when sending a 222a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles)// message in-process. Instead, it must transfer the "contents" of the 223a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles)// dispatcher to a new dispatcher, and then close the old dispatcher. If this 224a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles)// isn't done, in the in-process case, calls on the old handle may complete 225a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles)// after the the message has been received and a new handle created (and 226a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles)// possibly even after calls have been made on the new handle). 227a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochMojoResult Core::WriteMessage(MojoHandle message_pipe_handle, 2285f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<const void> bytes, 229a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch uint32_t num_bytes, 2305f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<const MojoHandle> handles, 231a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch uint32_t num_handles, 232a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch MojoWriteMessageFlags flags) { 2335d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scoped_refptr<Dispatcher> dispatcher(GetDispatcher(message_pipe_handle)); 2341320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci if (!dispatcher.get()) 2354e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) return MOJO_RESULT_INVALID_ARGUMENT; 2364e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 237f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // Easy case: not sending any handles. 238f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) if (num_handles == 0) 2391320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci return dispatcher->WriteMessage(bytes, num_bytes, nullptr, flags); 240f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) 241f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // We have to handle |handles| here, since we have to mark them busy in the 242f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // global handle table. We can't delegate this to the dispatcher, since the 243f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // handle table lock must be acquired before the dispatcher lock. 244f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // 245f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // (This leads to an oddity: |handles|/|num_handles| are always verified for 246f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // validity, even for dispatchers that don't support |WriteMessage()| and will 247f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // simply return failure unconditionally. It also breaks the usual 248f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // left-to-right verification order of arguments.) 249f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) if (num_handles > kMaxMessageNumHandles) 250f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) return MOJO_RESULT_RESOURCE_EXHAUSTED; 251f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) 2525f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<const MojoHandle>::Reader handles_reader(handles, num_handles); 2535f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) 254f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // We'll need to hold on to the dispatchers so that we can pass them on to 255f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // |WriteMessage()| and also so that we can unlock their locks afterwards 256f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // without accessing the handle table. These can be dumb pointers, since their 257f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // entries in the handle table won't get removed (since they'll be marked as 258f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // busy). 2595d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) std::vector<DispatcherTransport> transports(num_handles); 260f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) 261f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // When we pass handles, we have to try to take all their dispatchers' locks 262f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // and mark the handles as busy. If the call succeeds, we then remove the 263f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // handles from the handle table. 264f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) { 265f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) base::AutoLock locker(handle_table_lock_); 2665f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) MojoResult result = 2675f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) handle_table_.MarkBusyAndStartTransport(message_pipe_handle, 2685f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) handles_reader.GetPointer(), 2695f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) num_handles, 2705f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) &transports); 2714ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch if (result != MOJO_RESULT_OK) 2724ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch return result; 273f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) } 274f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) 2755f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) MojoResult rv = 2765f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) dispatcher->WriteMessage(bytes, num_bytes, &transports, flags); 277f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) 278f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // We need to release the dispatcher locks before we take the handle table 279f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // lock. 2805d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) for (uint32_t i = 0; i < num_handles; i++) 2815d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) transports[i].End(); 282f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) 2834ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch { 284f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) base::AutoLock locker(handle_table_lock_); 2855f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) if (rv == MOJO_RESULT_OK) { 2865f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) handle_table_.RemoveBusyHandles(handles_reader.GetPointer(), num_handles); 2875f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) } else { 2885f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) handle_table_.RestoreBusyHandles(handles_reader.GetPointer(), 2895f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) num_handles); 2905f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) } 291f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) } 292f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) 293f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) return rv; 2944e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)} 2954e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 296a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochMojoResult Core::ReadMessage(MojoHandle message_pipe_handle, 2975f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<void> bytes, 2985f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<uint32_t> num_bytes, 2995f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<MojoHandle> handles, 3005f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<uint32_t> num_handles, 301a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch MojoReadMessageFlags flags) { 3025d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scoped_refptr<Dispatcher> dispatcher(GetDispatcher(message_pipe_handle)); 3031320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci if (!dispatcher.get()) 3044e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) return MOJO_RESULT_INVALID_ARGUMENT; 3054e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 3065f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) uint32_t num_handles_value = num_handles.IsNull() ? 0 : num_handles.Get(); 3075f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) 3085f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) MojoResult rv; 3095f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) if (num_handles_value == 0) { 3105f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) // Easy case: won't receive any handles. 3115f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) rv = dispatcher->ReadMessage( 3121320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci bytes, num_bytes, nullptr, &num_handles_value, flags); 3135f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) } else { 3145f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) DispatcherVector dispatchers; 3155f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) rv = dispatcher->ReadMessage( 3165f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) bytes, num_bytes, &dispatchers, &num_handles_value, flags); 3175f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) if (!dispatchers.empty()) { 3185f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) DCHECK_EQ(rv, MOJO_RESULT_OK); 3195f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) DCHECK(!num_handles.IsNull()); 3205f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) DCHECK_LE(dispatchers.size(), static_cast<size_t>(num_handles_value)); 3215f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) 3225f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) bool success; 3235f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<MojoHandle>::Writer handles_writer(handles, 3245f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) dispatchers.size()); 3255f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) { 3265f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) base::AutoLock locker(handle_table_lock_); 3275f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) success = handle_table_.AddDispatcherVector( 3285f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) dispatchers, handles_writer.GetPointer()); 3295f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) } 3305f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) if (success) { 3315f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) handles_writer.Commit(); 3325f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) } else { 3335f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) LOG(ERROR) << "Received message with " << dispatchers.size() 3345f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) << " handles, but handle table full"; 3355f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) // Close dispatchers (outside the lock). 3365f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) for (size_t i = 0; i < dispatchers.size(); i++) { 3371320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci if (dispatchers[i].get()) 3385f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) dispatchers[i]->Close(); 3395f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) } 3405f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) if (rv == MOJO_RESULT_OK) 3415f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) rv = MOJO_RESULT_RESOURCE_EXHAUSTED; 3424ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch } 343f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) } 344f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) } 345f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) 3465f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) if (!num_handles.IsNull()) 3475f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) num_handles.Put(num_handles_value); 348f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) return rv; 3494e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)} 3504e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 3515f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles)MojoResult Core::CreateDataPipe( 3525f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<const MojoCreateDataPipeOptions> options, 3535f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<MojoHandle> data_pipe_producer_handle, 3545f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<MojoHandle> data_pipe_consumer_handle) { 355f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) MojoCreateDataPipeOptions validated_options = {}; 3565f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) MojoResult result = 3575f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) DataPipe::ValidateCreateOptions(options, &validated_options); 3585d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) if (result != MOJO_RESULT_OK) 3595d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) return result; 3605d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 3615d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scoped_refptr<DataPipeProducerDispatcher> producer_dispatcher( 3625d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) new DataPipeProducerDispatcher()); 3635d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scoped_refptr<DataPipeConsumerDispatcher> consumer_dispatcher( 3645d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) new DataPipeConsumerDispatcher()); 3655d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 3664ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch std::pair<MojoHandle, MojoHandle> handle_pair; 3675d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) { 3685d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) base::AutoLock locker(handle_table_lock_); 3694ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch handle_pair = handle_table_.AddDispatcherPair(producer_dispatcher, 3704ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch consumer_dispatcher); 3714ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch } 3724ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch if (handle_pair.first == MOJO_HANDLE_INVALID) { 3734ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch DCHECK_EQ(handle_pair.second, MOJO_HANDLE_INVALID); 3744ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch LOG(ERROR) << "Handle table full"; 3754ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch producer_dispatcher->Close(); 3764ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch consumer_dispatcher->Close(); 3774ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch return MOJO_RESULT_RESOURCE_EXHAUSTED; 3785d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) } 3794ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch DCHECK_NE(handle_pair.second, MOJO_HANDLE_INVALID); 3805d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 3815d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scoped_refptr<DataPipe> data_pipe(new LocalDataPipe(validated_options)); 3825d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) producer_dispatcher->Init(data_pipe); 3835d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) consumer_dispatcher->Init(data_pipe); 3845d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 3855f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) data_pipe_producer_handle.Put(handle_pair.first); 3865f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) data_pipe_consumer_handle.Put(handle_pair.second); 3875d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) return MOJO_RESULT_OK; 388a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)} 389a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 390a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochMojoResult Core::WriteData(MojoHandle data_pipe_producer_handle, 3915f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<const void> elements, 3925f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<uint32_t> num_bytes, 393a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch MojoWriteDataFlags flags) { 3945d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scoped_refptr<Dispatcher> dispatcher( 3955d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) GetDispatcher(data_pipe_producer_handle)); 3961320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci if (!dispatcher.get()) 3975d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) return MOJO_RESULT_INVALID_ARGUMENT; 3985d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 3995d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) return dispatcher->WriteData(elements, num_bytes, flags); 4004e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)} 4014e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 402a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochMojoResult Core::BeginWriteData(MojoHandle data_pipe_producer_handle, 4035f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<void*> buffer, 4045f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<uint32_t> buffer_num_bytes, 405a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch MojoWriteDataFlags flags) { 4065d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scoped_refptr<Dispatcher> dispatcher( 4075d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) GetDispatcher(data_pipe_producer_handle)); 4081320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci if (!dispatcher.get()) 4095d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) return MOJO_RESULT_INVALID_ARGUMENT; 4105d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 4115d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) return dispatcher->BeginWriteData(buffer, buffer_num_bytes, flags); 4125d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 4135d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 414a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochMojoResult Core::EndWriteData(MojoHandle data_pipe_producer_handle, 415a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch uint32_t num_bytes_written) { 4165d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scoped_refptr<Dispatcher> dispatcher( 4175d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) GetDispatcher(data_pipe_producer_handle)); 4181320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci if (!dispatcher.get()) 4195d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) return MOJO_RESULT_INVALID_ARGUMENT; 4205d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 4215d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) return dispatcher->EndWriteData(num_bytes_written); 4225d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 4235d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 424a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochMojoResult Core::ReadData(MojoHandle data_pipe_consumer_handle, 4255f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<void> elements, 4265f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<uint32_t> num_bytes, 427a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch MojoReadDataFlags flags) { 4285d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scoped_refptr<Dispatcher> dispatcher( 4295d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) GetDispatcher(data_pipe_consumer_handle)); 4301320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci if (!dispatcher.get()) 4315d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) return MOJO_RESULT_INVALID_ARGUMENT; 4325d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 4335d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) return dispatcher->ReadData(elements, num_bytes, flags); 4345d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 4355d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 436a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochMojoResult Core::BeginReadData(MojoHandle data_pipe_consumer_handle, 4375f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<const void*> buffer, 4385f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<uint32_t> buffer_num_bytes, 439a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch MojoReadDataFlags flags) { 4405d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scoped_refptr<Dispatcher> dispatcher( 4415d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) GetDispatcher(data_pipe_consumer_handle)); 4421320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci if (!dispatcher.get()) 4435d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) return MOJO_RESULT_INVALID_ARGUMENT; 4445d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 4455d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) return dispatcher->BeginReadData(buffer, buffer_num_bytes, flags); 4465d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 4475d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 448a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochMojoResult Core::EndReadData(MojoHandle data_pipe_consumer_handle, 449a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch uint32_t num_bytes_read) { 4505d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scoped_refptr<Dispatcher> dispatcher( 4515d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) GetDispatcher(data_pipe_consumer_handle)); 4521320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci if (!dispatcher.get()) 4535d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) return MOJO_RESULT_INVALID_ARGUMENT; 4545d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 4555d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) return dispatcher->EndReadData(num_bytes_read); 4565d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 4575d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 458a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochMojoResult Core::CreateSharedBuffer( 4595f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<const MojoCreateSharedBufferOptions> options, 46023730a6e56a168d1879203e4b3819bb36e3d8f1fTorne (Richard Coles) uint64_t num_bytes, 4615f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<MojoHandle> shared_buffer_handle) { 462f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) MojoCreateSharedBufferOptions validated_options = {}; 4635f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) MojoResult result = SharedBufferDispatcher::ValidateCreateOptions( 4645f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) options, &validated_options); 465effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch if (result != MOJO_RESULT_OK) 466effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch return result; 467effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 468effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch scoped_refptr<SharedBufferDispatcher> dispatcher; 4696e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) result = SharedBufferDispatcher::Create( 47003b57e008b61dfcb1fbad3aea950ae0e001748b0Torne (Richard Coles) platform_support(), validated_options, num_bytes, &dispatcher); 471effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch if (result != MOJO_RESULT_OK) { 4721320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci DCHECK(!dispatcher.get()); 473effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch return result; 474effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 475effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 4764ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch MojoHandle h = AddDispatcher(dispatcher); 4774ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch if (h == MOJO_HANDLE_INVALID) { 4784ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch LOG(ERROR) << "Handle table full"; 4794ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch dispatcher->Close(); 4804ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch return MOJO_RESULT_RESOURCE_EXHAUSTED; 481effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 482effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 4835f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) shared_buffer_handle.Put(h); 484effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch return MOJO_RESULT_OK; 4855d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 4865d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 487a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochMojoResult Core::DuplicateBufferHandle( 4885d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) MojoHandle buffer_handle, 4895f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<const MojoDuplicateBufferHandleOptions> options, 4905f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<MojoHandle> new_buffer_handle) { 491a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) scoped_refptr<Dispatcher> dispatcher(GetDispatcher(buffer_handle)); 4921320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci if (!dispatcher.get()) 493a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) return MOJO_RESULT_INVALID_ARGUMENT; 494a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) 495effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch // Don't verify |options| here; that's the dispatcher's job. 496a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) scoped_refptr<Dispatcher> new_dispatcher; 4975f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) MojoResult result = 4985f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) dispatcher->DuplicateBufferHandle(options, &new_dispatcher); 499a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) if (result != MOJO_RESULT_OK) 500a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) return result; 501a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) 5024ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch MojoHandle new_handle = AddDispatcher(new_dispatcher); 5034ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch if (new_handle == MOJO_HANDLE_INVALID) { 5044ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch LOG(ERROR) << "Handle table full"; 5054ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch dispatcher->Close(); 5064ad1aa43a48567659193a298fad74f55e00b3dd9Ben Murdoch return MOJO_RESULT_RESOURCE_EXHAUSTED; 507a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) } 508a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) 5095f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) new_buffer_handle.Put(new_handle); 510a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) return MOJO_RESULT_OK; 5115d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 5125d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 513a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochMojoResult Core::MapBuffer(MojoHandle buffer_handle, 514a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch uint64_t offset, 515a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch uint64_t num_bytes, 5165f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) UserPointer<void*> buffer, 517a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch MojoMapBufferFlags flags) { 518a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) scoped_refptr<Dispatcher> dispatcher(GetDispatcher(buffer_handle)); 5191320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci if (!dispatcher.get()) 520a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) return MOJO_RESULT_INVALID_ARGUMENT; 521a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) 5226e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) scoped_ptr<embedder::PlatformSharedBufferMapping> mapping; 523effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch MojoResult result = dispatcher->MapBuffer(offset, num_bytes, flags, &mapping); 524a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) if (result != MOJO_RESULT_OK) 525a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) return result; 526a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) 527effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch DCHECK(mapping); 5286e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) void* address = mapping->GetBase(); 529e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch { 530e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch base::AutoLock locker(mapping_table_lock_); 531e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch result = mapping_table_.AddMapping(mapping.Pass()); 532e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch } 533e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch if (result != MOJO_RESULT_OK) 534e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch return result; 535a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) 5365f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) buffer.Put(address); 537a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) return MOJO_RESULT_OK; 5385d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 5395d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 5405f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles)MojoResult Core::UnmapBuffer(UserPointer<void> buffer) { 541e5d81f57cb97b3b6b7fccc9c5610d21eb81db09dBen Murdoch base::AutoLock locker(mapping_table_lock_); 5425f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) return mapping_table_.RemoveMapping(buffer.GetPointerValue()); 5434e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)} 5444e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 5454e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// Note: We allow |handles| to repeat the same handle multiple times, since 5464e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// different flags may be specified. 5474e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// TODO(vtl): This incurs a performance cost in |RemoveWaiter()|. Analyze this 5484e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)// more carefully and address it if necessary. 549a02191e04bc25c4935f804f2c080ae28663d096dBen MurdochMojoResult Core::WaitManyInternal(const MojoHandle* handles, 550f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) const MojoHandleSignals* signals, 551a02191e04bc25c4935f804f2c080ae28663d096dBen Murdoch uint32_t num_handles, 5525f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) MojoDeadline deadline, 5536e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) uint32_t* result_index, 5546e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) HandleSignalsState* signals_states) { 5554e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) DCHECK_GT(num_handles, 0u); 5565f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) DCHECK_EQ(*result_index, static_cast<uint32_t>(-1)); 5574e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 558010d83a9304c5a91596085d917d248abff47903aTorne (Richard Coles) DispatcherVector dispatchers; 5594e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) dispatchers.reserve(num_handles); 5604e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) for (uint32_t i = 0; i < num_handles; i++) { 561f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) scoped_refptr<Dispatcher> dispatcher = GetDispatcher(handles[i]); 5621320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci if (!dispatcher.get()) { 5635f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) *result_index = i; 5644e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) return MOJO_RESULT_INVALID_ARGUMENT; 5655f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) } 566f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) dispatchers.push_back(dispatcher); 5674e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) } 5684e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 5694e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) // TODO(vtl): Should make the waiter live (permanently) in TLS. 5704e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) Waiter waiter; 5714e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) waiter.Init(); 5724e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 5734e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) uint32_t i; 5744e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) MojoResult rv = MOJO_RESULT_OK; 5754e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) for (i = 0; i < num_handles; i++) { 5766e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) rv = dispatchers[i]->AddWaiter( 5771320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci &waiter, signals[i], i, signals_states ? &signals_states[i] : nullptr); 5785f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) if (rv != MOJO_RESULT_OK) { 5795f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) *result_index = i; 5804e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) break; 5815f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) } 5824e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) } 5834e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) uint32_t num_added = i; 5844e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 5855f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) if (rv == MOJO_RESULT_ALREADY_EXISTS) 5865f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) rv = MOJO_RESULT_OK; // The i-th one is already "triggered". 5875f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) else if (rv == MOJO_RESULT_OK) 5885f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) rv = waiter.Wait(deadline, result_index); 5894e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 5904e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) // Make sure no other dispatchers try to wake |waiter| for the current 5914e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) // |Wait()|/|WaitMany()| call. (Only after doing this can |waiter| be 5924e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) // destroyed, but this would still be required if the waiter were in TLS.) 5936e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) for (i = 0; i < num_added; i++) { 5946e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) dispatchers[i]->RemoveWaiter(&waiter, 5951320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci signals_states ? &signals_states[i] : nullptr); 5966e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) } 5976e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) if (signals_states) { 5986e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) for (; i < num_handles; i++) 5996e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) signals_states[i] = dispatchers[i]->GetHandleSignalsState(); 6006e8cce623b6e4fe0c9e4af605d675dd9d0338c38Torne (Richard Coles) } 6014e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 6024e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) return rv; 6034e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)} 6044e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 6054e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)} // namespace system 6064e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles)} // namespace mojo 607