Reduce boilerplate when creating simple mojom::URLLoaders.

content/browser/webui/web_ui_url_loader_factory.cc

 // Copyright 2017 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 "content/browser/webui/web_ui_url_loader_factory.h"
 
 #include <map>
 
 #include "base/bind.h"
 #include "base/lazy_instance.h"
@@ skipping 72 matching lines @@
       source = input;
     }
     temp_str = ui::ReplaceTemplateExpressions(source, *replacements);
     bytes = base::RefCountedString::TakeString(&temp_str);
     input.set(reinterpret_cast<const char*>(bytes->front()), bytes->size());
   }
 
   uint32_t output_size =
       gzipped ? compression::GetUncompressedSize(input) : bytes->size();
 
-  MojoCreateDataPipeOptions options;
-  options.struct_size = sizeof(MojoCreateDataPipeOptions);
-  options.flags = MOJO_CREATE_DATA_PIPE_OPTIONS_FLAG_NONE;
-  options.element_num_bytes = 1;
-  options.capacity_num_bytes = output_size;
-  mojo::DataPipe data_pipe(options);
-
-  DCHECK(data_pipe.producer_handle.is_valid());
-  DCHECK(data_pipe.consumer_handle.is_valid());
+  mojo::DataPipe data_pipe(output_size);
 
   void* buffer = nullptr;
   uint32_t num_bytes = output_size;
   MojoResult result =
       BeginWriteDataRaw(data_pipe.producer_handle.get(), &buffer, &num_bytes,
                         MOJO_WRITE_DATA_FLAG_NONE);
   CHECK_EQ(result, MOJO_RESULT_OK);
   CHECK_EQ(num_bytes, output_size);
 
   if (gzipped) {
     base::StringPiece output(static_cast<char*>(buffer), num_bytes);
     CHECK(compression::GzipUncompress(input, output));
   } else {
     memcpy(buffer, bytes->front(), output_size);
   }
   result = EndWriteDataRaw(data_pipe.producer_handle.get(), num_bytes);
   CHECK_EQ(result, MOJO_RESULT_OK);
 
   client->OnStartLoadingResponseBody(std::move(data_pipe.consumer_handle));
-
-  ResourceRequestCompletionStatus request_complete_data;
-  request_complete_data.error_code = net::OK;
-  request_complete_data.exists_in_cache = false;
-  request_complete_data.completion_time = base::TimeTicks::Now();
-  request_complete_data.encoded_data_length = output_size;
-  request_complete_data.encoded_body_length = output_size;
-  client->OnComplete(request_complete_data);
+  client->OnComplete(ResourceRequestCompletionStatus(output_size));
 }
 
 void DataAvailable(scoped_refptr<ResourceResponse> headers,
                    const ui::TemplateReplacements* replacements,
                    bool gzipped,
                    scoped_refptr<URLDataSourceImpl> source,
                    mojom::URLLoaderClientPtrInfo client_info,
                    scoped_refptr<base::RefCountedMemory> bytes) {
   // Since the bytes are from the memory mapped resource file, copying the
   // data can lead to disk access.
@@ skipping 165 matching lines @@
 }  // namespace
 
 mojom::URLLoaderFactoryPtr GetWebUIURLLoader(FrameTreeNode* node) {
   int ftn_id = node->frame_tree_node_id();
   if (g_factories.Get()[ftn_id].get() == nullptr)
     g_factories.Get()[ftn_id] = base::MakeUnique<WebUIURLLoaderFactory>(node);
   return g_factories.Get()[ftn_id]->CreateBinding();
 }
 
 }  // namespace content