| Index: mojo/edk/system/local_message_pipe_endpoint.cc
|
| diff --git a/mojo/edk/system/local_message_pipe_endpoint.cc b/mojo/edk/system/local_message_pipe_endpoint.cc
|
| index 14d28c40872192b84ed4a3add14de14398a9fdfc..8e65486e3ba607095fbb1f20c466c491ab83012a 100644
|
| --- a/mojo/edk/system/local_message_pipe_endpoint.cc
|
| +++ b/mojo/edk/system/local_message_pipe_endpoint.cc
|
| @@ -151,12 +151,15 @@ HandleSignalsState LocalMessagePipeEndpoint::GetHandleSignalsState() const {
|
| MojoResult LocalMessagePipeEndpoint::AddAwakable(
|
| Awakable* awakable,
|
| MojoHandleSignals signals,
|
| + bool force,
|
| uint64_t context,
|
| HandleSignalsState* signals_state) {
|
| DCHECK(is_open_);
|
|
|
| HandleSignalsState state = GetHandleSignalsState();
|
| if (state.satisfies(signals)) {
|
| + if (force)
|
| + awakable_list_.Add(awakable, signals, context);
|
| if (signals_state)
|
| *signals_state = state;
|
| return MOJO_RESULT_ALREADY_EXISTS;
|
|
|