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 "ipc/mojo/ipc_channel_mojo.h" | 5 #include "ipc/mojo/ipc_channel_mojo.h" |
6 | 6 |
7 #include "base/base_paths.h" | 7 #include "base/base_paths.h" |
8 #include "base/files/file.h" | 8 #include "base/files/file.h" |
9 #include "base/message_loop/message_loop.h" | 9 #include "base/message_loop/message_loop.h" |
10 #include "base/path_service.h" | 10 #include "base/path_service.h" |
(...skipping 263 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
274 #if defined(OS_POSIX) | 274 #if defined(OS_POSIX) |
275 class ListenerThatExpectsFile : public IPC::Listener { | 275 class ListenerThatExpectsFile : public IPC::Listener { |
276 public: | 276 public: |
277 ListenerThatExpectsFile() | 277 ListenerThatExpectsFile() |
278 : sender_(NULL) {} | 278 : sender_(NULL) {} |
279 | 279 |
280 virtual ~ListenerThatExpectsFile() {} | 280 virtual ~ListenerThatExpectsFile() {} |
281 | 281 |
282 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE { | 282 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE { |
283 PickleIterator iter(message); | 283 PickleIterator iter(message); |
284 base::FileDescriptor desc; | 284 base::File file; |
285 EXPECT_TRUE(message.ReadFileDescriptor(&iter, &desc)); | 285 EXPECT_TRUE(message.ReadFile(&iter, &file)); |
286 std::string content(GetSendingFileContent().size(), ' '); | 286 std::string content(GetSendingFileContent().size(), ' '); |
287 base::File file(desc.fd); | |
288 file.Read(0, &content[0], content.size()); | 287 file.Read(0, &content[0], content.size()); |
289 EXPECT_EQ(content, GetSendingFileContent()); | 288 EXPECT_EQ(content, GetSendingFileContent()); |
290 base::MessageLoop::current()->Quit(); | 289 base::MessageLoop::current()->Quit(); |
291 ListenerThatExpectsOK::SendOK(sender_); | 290 ListenerThatExpectsOK::SendOK(sender_); |
292 return true; | 291 return true; |
293 } | 292 } |
294 | 293 |
295 virtual void OnChannelError() OVERRIDE { | 294 virtual void OnChannelError() OVERRIDE { |
296 NOTREACHED(); | 295 NOTREACHED(); |
297 } | 296 } |
298 | 297 |
299 static std::string GetSendingFileContent() { | 298 static std::string GetSendingFileContent() { |
300 return "Hello"; | 299 return "Hello"; |
301 } | 300 } |
302 | 301 |
303 static base::FilePath GetSendingFilePath() { | 302 static base::FilePath GetSendingFilePath() { |
304 base::FilePath path; | 303 base::FilePath path; |
305 bool ok = PathService::Get(base::DIR_CACHE, &path); | 304 bool ok = PathService::Get(base::DIR_CACHE, &path); |
306 EXPECT_TRUE(ok); | 305 EXPECT_TRUE(ok); |
307 return path.Append("ListenerThatExpectsFile.txt"); | 306 return path.Append("ListenerThatExpectsFile.txt"); |
308 } | 307 } |
309 | 308 |
310 static void WriteAndSendFile(IPC::Sender* sender, base::File& file) { | 309 static void WriteAndSendFile(IPC::Sender* sender, base::File& file) { |
311 std::string content = GetSendingFileContent(); | 310 std::string content = GetSendingFileContent(); |
312 file.WriteAtCurrentPos(content.data(), content.size()); | 311 file.WriteAtCurrentPos(content.data(), content.size()); |
313 file.Flush(); | 312 file.Flush(); |
314 IPC::Message* message = new IPC::Message( | 313 IPC::Message* message = new IPC::Message( |
315 0, 2, IPC::Message::PRIORITY_NORMAL); | 314 0, 2, IPC::Message::PRIORITY_NORMAL); |
316 message->WriteFileDescriptor( | 315 message->WriteFile(file.Pass()); |
317 base::FileDescriptor(file.TakePlatformFile(), false)); | |
318 ASSERT_TRUE(sender->Send(message)); | 316 ASSERT_TRUE(sender->Send(message)); |
319 } | 317 } |
320 | 318 |
321 void set_sender(IPC::Sender* sender) { sender_ = sender; } | 319 void set_sender(IPC::Sender* sender) { sender_ = sender; } |
322 | 320 |
323 private: | 321 private: |
324 IPC::Sender* sender_; | 322 IPC::Sender* sender_; |
325 }; | 323 }; |
326 | 324 |
327 | 325 |
(...skipping 24 matching lines...) Expand all Loading... |
352 client.Connect(); | 350 client.Connect(); |
353 listener.set_sender(client.channel()); | 351 listener.set_sender(client.channel()); |
354 | 352 |
355 base::MessageLoop::current()->Run(); | 353 base::MessageLoop::current()->Run(); |
356 | 354 |
357 return 0; | 355 return 0; |
358 } | 356 } |
359 #endif | 357 #endif |
360 | 358 |
361 } // namespace | 359 } // namespace |
OLD | NEW |