Update to newer network service implementation and mojoms from monet

examples/pdf_viewer/pdf_viewer.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 "base/strings/string_tokenizer.h"
+#include <string>
+
 #include "examples/bitmap_uploader/bitmap_uploader.h"
 #include "mojo/application/application_runner_chromium.h"
 #include "mojo/application/content_handler_factory.h"
+#include "mojo/common/data_pipe_utils.h"
 #include "mojo/public/c/system/main.h"
 #include "mojo/public/cpp/application/application_connection.h"
 #include "mojo/public/cpp/application/application_delegate.h"
 #include "mojo/public/cpp/application/application_impl.h"
 #include "mojo/public/cpp/application/interface_factory_impl.h"
 #include "mojo/public/cpp/application/service_provider_impl.h"
 #include "mojo/services/content_handler/public/interfaces/content_handler.mojom.h"
 #include "mojo/services/input_events/public/interfaces/input_events.mojom.h"
 #include "mojo/services/input_events/public/interfaces/input_key_codes.mojom.h"
 #include "mojo/services/view_manager/public/cpp/types.h"
@@ skipping 134 matching lines @@
     FPDF_RenderPageBitmap(f_bitmap, page, 0, 0, width, height, 0, 0);
     FPDFBitmap_Destroy(f_bitmap);
 
     FPDF_ClosePage(page);
 
     embedder_data->bitmap_uploader().SetBitmap(width, height, bitmap.Pass(),
                                                BitmapUploader::BGRA);
   }
 
   void FetchPDF(URLResponsePtr response) {
-    int content_length = GetContentLength(response->headers);
-    scoped_ptr<unsigned char[]> data;
-    data_.reset(new unsigned char[content_length]);
-    unsigned char* buf = data_.get();
-    uint32_t bytes_remaining = content_length;
-    uint32_t num_bytes = bytes_remaining;
-    while (bytes_remaining > 0) {
-      MojoResult result = ReadDataRaw(response->body.get(), buf, &num_bytes,
-                                      MOJO_READ_DATA_FLAG_NONE);
-      if (result == MOJO_RESULT_SHOULD_WAIT) {
-        Wait(response->body.get(), MOJO_HANDLE_SIGNAL_READABLE,
-             MOJO_DEADLINE_INDEFINITE, nullptr);
-      } else if (result == MOJO_RESULT_OK) {
-        buf += num_bytes;
-        num_bytes = bytes_remaining -= num_bytes;
-      } else {
-        break;
-      }
-    }
-
-    doc_ = FPDF_LoadMemDocument(data_.get(), content_length, NULL);
+    data_.clear();
+    mojo::common::BlockingCopyToString(response->body.Pass(), &data_);
+    if (data_.length() >= static_cast<size_t>(std::numeric_limits<int>::max()))
+      return;
+    doc_ = FPDF_LoadMemDocument(data_.data(), static_cast<int>(data_.length()),
+                                nullptr);
     page_count_ = FPDF_GetPageCount(doc_);
   }
 
-  int GetContentLength(const Array<String>& headers) {
-    for (size_t i = 0; i < headers.size(); ++i) {
-      base::StringTokenizer t(headers[i], ": ;=");
-      while (t.GetNext()) {
-        if (!t.token_is_delim() && t.token() == "Content-Length") {
-          while (t.GetNext()) {
-            if (!t.token_is_delim())
-              return atoi(t.token().c_str());
-          }
-        }
-      }
-    }
-    return 0;
-  }
-
-  scoped_ptr<unsigned char[]> data_;
+  std::string data_;
   int current_page_;
   int page_count_;
   FPDF_DOCUMENT doc_;
   ApplicationImpl* app_;
   std::map<View*, EmbedderData*> embedder_for_roots_;
   scoped_ptr<ViewManagerClientFactory> view_manager_client_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(PDFView);
 };
 
@@ skipping 27 matching lines @@
   DISALLOW_COPY_AND_ASSIGN(PDFViewer);
 };
 
 }  // namespace examples
 }  // namespace mojo
 
 MojoResult MojoMain(MojoHandle application_request) {
   mojo::ApplicationRunnerChromium runner(new mojo::examples::PDFViewer());
   return runner.Run(application_request);
 }