Google OAuth Device Flow support for FNL

mojo/data_pipe_utils/data_pipe_utils.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "mojo/data_pipe_utils/data_pipe_utils.h"
 
 #include <stdio.h>
 
 #include "base/message_loop/message_loop.h"
 #include "base/task_runner_util.h"
@@ skipping 93 matching lines @@
         // If the consumer handle was closed, then treat as EOF.
         return result == MOJO_RESULT_FAILED_PRECONDITION;
       }
     } else {
       // If the consumer handle was closed, then treat as EOF.
       return result == MOJO_RESULT_FAILED_PRECONDITION;
     }
   }
 }
 
+ScopedDataPipeConsumerHandle WriteStringToConsumerHandle(
+    const std::string& source) {
+  TRACE_EVENT0("data_pipe_utils", "WriteStringToConsumerHandle");
+  static const size_t max_buffer_size = 2 * 1024 * 1024;  // 2MB
+  DCHECK_LE(static_cast<uint32_t>(source.size()), max_buffer_size);

[viettrungluu, 2016/01/11 21:23:44]

Maybe make this a CHECK_LE instead of a DCHECK_LE (since it'll hang if it
fails)?

[ukode, 2016/02/09 00:20:17]

Done.

+  MojoCreateDataPipeOptions options = {
+      sizeof(MojoCreateDataPipeOptions),
+      MOJO_CREATE_DATA_PIPE_OPTIONS_FLAG_NONE, 1,
+      static_cast<uint32_t>(std::min(source.size(), max_buffer_size))};

[qsr, 2016/01/13 12:01:00]

once you change to a check, just use source.size()

[ukode, 2016/02/09 00:20:17]

Acknowledged.

+  DataPipe pipe(options);
+  BlockingCopyFromString(source, pipe.producer_handle.Pass());
+  return pipe.consumer_handle.Pass();
+}
+
 }  // namespace common
 }  // namespace mojo