OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 <algorithm> | 5 #include <algorithm> |
6 | 6 |
7 #include "base/strings/string_tokenizer.h" | 7 #include "base/strings/string_tokenizer.h" |
8 #include "mojo/examples/media_viewer/media_viewer.mojom.h" | 8 #include "mojo/examples/media_viewer/media_viewer.mojom.h" |
9 #include "mojo/public/cpp/application/application_connection.h" | 9 #include "mojo/public/cpp/application/application_connection.h" |
10 #include "mojo/public/cpp/application/application_delegate.h" | 10 #include "mojo/public/cpp/application/application_delegate.h" |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
56 uint32_t node_id, | 56 uint32_t node_id, |
57 navigation::NavigationDetailsPtr navigation_details, | 57 navigation::NavigationDetailsPtr navigation_details, |
58 navigation::ResponseDetailsPtr response_details) OVERRIDE { | 58 navigation::ResponseDetailsPtr response_details) OVERRIDE { |
59 int content_length = GetContentLength(response_details->response->headers); | 59 int content_length = GetContentLength(response_details->response->headers); |
60 unsigned char* data = new unsigned char[content_length]; | 60 unsigned char* data = new unsigned char[content_length]; |
61 unsigned char* buf = data; | 61 unsigned char* buf = data; |
62 uint32_t bytes_remaining = content_length; | 62 uint32_t bytes_remaining = content_length; |
63 uint32_t num_bytes = bytes_remaining; | 63 uint32_t num_bytes = bytes_remaining; |
64 while (bytes_remaining > 0) { | 64 while (bytes_remaining > 0) { |
65 MojoResult result = ReadDataRaw( | 65 MojoResult result = ReadDataRaw( |
66 response_details->response_body_stream.get(), | 66 response_details->response->body.get(), |
67 buf, | 67 buf, |
68 &num_bytes, | 68 &num_bytes, |
69 MOJO_READ_DATA_FLAG_NONE); | 69 MOJO_READ_DATA_FLAG_NONE); |
70 if (result == MOJO_RESULT_SHOULD_WAIT) { | 70 if (result == MOJO_RESULT_SHOULD_WAIT) { |
71 Wait(response_details->response_body_stream.get(), | 71 Wait(response_details->response->body.get(), |
72 MOJO_HANDLE_SIGNAL_READABLE, | 72 MOJO_HANDLE_SIGNAL_READABLE, |
73 MOJO_DEADLINE_INDEFINITE); | 73 MOJO_DEADLINE_INDEFINITE); |
74 } else if (result == MOJO_RESULT_OK) { | 74 } else if (result == MOJO_RESULT_OK) { |
75 buf += num_bytes; | 75 buf += num_bytes; |
76 num_bytes = bytes_remaining -= num_bytes; | 76 num_bytes = bytes_remaining -= num_bytes; |
77 } else { | 77 } else { |
78 break; | 78 break; |
79 } | 79 } |
80 } | 80 } |
81 | 81 |
(...skipping 127 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
209 } | 209 } |
210 | 210 |
211 } // namespace examples | 211 } // namespace examples |
212 | 212 |
213 // static | 213 // static |
214 ApplicationDelegate* ApplicationDelegate::Create() { | 214 ApplicationDelegate* ApplicationDelegate::Create() { |
215 return new examples::PNGViewer; | 215 return new examples::PNGViewer; |
216 } | 216 } |
217 | 217 |
218 } // namespace mojo | 218 } // namespace mojo |
OLD | NEW |