| 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 |
| 285 EXPECT_TRUE(message.ReadFileDescriptor(&iter, &desc)); | 285 base::ScopedFD fd; |
| 286 EXPECT_TRUE(message.ReadFile(&iter, &fd)); |
| 287 base::File file(fd.release()); |
| 286 std::string content(GetSendingFileContent().size(), ' '); | 288 std::string content(GetSendingFileContent().size(), ' '); |
| 287 base::File file(desc.fd); | |
| 288 file.Read(0, &content[0], content.size()); | 289 file.Read(0, &content[0], content.size()); |
| 289 EXPECT_EQ(content, GetSendingFileContent()); | 290 EXPECT_EQ(content, GetSendingFileContent()); |
| 290 base::MessageLoop::current()->Quit(); | 291 base::MessageLoop::current()->Quit(); |
| 291 ListenerThatExpectsOK::SendOK(sender_); | 292 ListenerThatExpectsOK::SendOK(sender_); |
| 292 return true; | 293 return true; |
| 293 } | 294 } |
| 294 | 295 |
| 295 virtual void OnChannelError() OVERRIDE { | 296 virtual void OnChannelError() OVERRIDE { |
| 296 NOTREACHED(); | 297 NOTREACHED(); |
| 297 } | 298 } |
| 298 | 299 |
| 299 static std::string GetSendingFileContent() { | 300 static std::string GetSendingFileContent() { |
| 300 return "Hello"; | 301 return "Hello"; |
| 301 } | 302 } |
| 302 | 303 |
| 303 static base::FilePath GetSendingFilePath() { | 304 static base::FilePath GetSendingFilePath() { |
| 304 base::FilePath path; | 305 base::FilePath path; |
| 305 bool ok = PathService::Get(base::DIR_CACHE, &path); | 306 bool ok = PathService::Get(base::DIR_CACHE, &path); |
| 306 EXPECT_TRUE(ok); | 307 EXPECT_TRUE(ok); |
| 307 return path.Append("ListenerThatExpectsFile.txt"); | 308 return path.Append("ListenerThatExpectsFile.txt"); |
| 308 } | 309 } |
| 309 | 310 |
| 310 static void WriteAndSendFile(IPC::Sender* sender, base::File& file) { | 311 static void WriteAndSendFile(IPC::Sender* sender, base::File& file) { |
| 311 std::string content = GetSendingFileContent(); | 312 std::string content = GetSendingFileContent(); |
| 312 file.WriteAtCurrentPos(content.data(), content.size()); | 313 file.WriteAtCurrentPos(content.data(), content.size()); |
| 313 file.Flush(); | 314 file.Flush(); |
| 314 IPC::Message* message = new IPC::Message( | 315 IPC::Message* message = new IPC::Message( |
| 315 0, 2, IPC::Message::PRIORITY_NORMAL); | 316 0, 2, IPC::Message::PRIORITY_NORMAL); |
| 316 message->WriteFileDescriptor( | 317 message->WriteFile(base::ScopedFD(file.TakePlatformFile())); |
| 317 base::FileDescriptor(file.TakePlatformFile(), false)); | |
| 318 ASSERT_TRUE(sender->Send(message)); | 318 ASSERT_TRUE(sender->Send(message)); |
| 319 } | 319 } |
| 320 | 320 |
| 321 void set_sender(IPC::Sender* sender) { sender_ = sender; } | 321 void set_sender(IPC::Sender* sender) { sender_ = sender; } |
| 322 | 322 |
| 323 private: | 323 private: |
| 324 IPC::Sender* sender_; | 324 IPC::Sender* sender_; |
| 325 }; | 325 }; |
| 326 | 326 |
| 327 | 327 |
| (...skipping 24 matching lines...) Expand all Loading... |
| 352 client.Connect(); | 352 client.Connect(); |
| 353 listener.set_sender(client.channel()); | 353 listener.set_sender(client.channel()); |
| 354 | 354 |
| 355 base::MessageLoop::current()->Run(); | 355 base::MessageLoop::current()->Run(); |
| 356 | 356 |
| 357 return 0; | 357 return 0; |
| 358 } | 358 } |
| 359 #endif | 359 #endif |
| 360 | 360 |
| 361 } // namespace | 361 } // namespace |
| OLD | NEW |