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/system/core.h" | 5 #include "mojo/system/core.h" |
6 | 6 |
7 #include <vector> | 7 #include <vector> |
8 | 8 |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "base/time/time.h" | 10 #include "base/time/time.h" |
(...skipping 394 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
405 | 405 |
406 MojoResult Core::BeginReadData(MojoHandle data_pipe_consumer_handle, | 406 MojoResult Core::BeginReadData(MojoHandle data_pipe_consumer_handle, |
407 UserPointer<const void*> buffer, | 407 UserPointer<const void*> buffer, |
408 UserPointer<uint32_t> buffer_num_bytes, | 408 UserPointer<uint32_t> buffer_num_bytes, |
409 MojoReadDataFlags flags) { | 409 MojoReadDataFlags flags) { |
410 scoped_refptr<Dispatcher> dispatcher( | 410 scoped_refptr<Dispatcher> dispatcher( |
411 GetDispatcher(data_pipe_consumer_handle)); | 411 GetDispatcher(data_pipe_consumer_handle)); |
412 if (!dispatcher) | 412 if (!dispatcher) |
413 return MOJO_RESULT_INVALID_ARGUMENT; | 413 return MOJO_RESULT_INVALID_ARGUMENT; |
414 | 414 |
415 return dispatcher->BeginReadData(buffer.GetPointerUnsafe(), | 415 return dispatcher->BeginReadData(buffer, buffer_num_bytes, flags); |
416 buffer_num_bytes.GetPointerUnsafe(), flags); | |
417 } | 416 } |
418 | 417 |
419 MojoResult Core::EndReadData(MojoHandle data_pipe_consumer_handle, | 418 MojoResult Core::EndReadData(MojoHandle data_pipe_consumer_handle, |
420 uint32_t num_bytes_read) { | 419 uint32_t num_bytes_read) { |
421 scoped_refptr<Dispatcher> dispatcher( | 420 scoped_refptr<Dispatcher> dispatcher( |
422 GetDispatcher(data_pipe_consumer_handle)); | 421 GetDispatcher(data_pipe_consumer_handle)); |
423 if (!dispatcher) | 422 if (!dispatcher) |
424 return MOJO_RESULT_INVALID_ARGUMENT; | 423 return MOJO_RESULT_INVALID_ARGUMENT; |
425 | 424 |
426 return dispatcher->EndReadData(num_bytes_read); | 425 return dispatcher->EndReadData(num_bytes_read); |
(...skipping 135 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
562 // |Wait()|/|WaitMany()| call. (Only after doing this can |waiter| be | 561 // |Wait()|/|WaitMany()| call. (Only after doing this can |waiter| be |
563 // destroyed, but this would still be required if the waiter were in TLS.) | 562 // destroyed, but this would still be required if the waiter were in TLS.) |
564 for (i = 0; i < num_added; i++) | 563 for (i = 0; i < num_added; i++) |
565 dispatchers[i]->RemoveWaiter(&waiter); | 564 dispatchers[i]->RemoveWaiter(&waiter); |
566 | 565 |
567 return rv; | 566 return rv; |
568 } | 567 } |
569 | 568 |
570 } // namespace system | 569 } // namespace system |
571 } // namespace mojo | 570 } // namespace mojo |
OLD | NEW |