Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(309)

Side by Side Diff: components/nacl/loader/nacl_ipc_adapter.cc

Issue 150713003: Create IPC channel to communicate with the renderer in NaClListener::OnStart(). (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright 2013 The Chromium Authors. All rights reserved. 1 // Copyright 2013 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 "components/nacl/loader/nacl_ipc_adapter.h" 5 #include "components/nacl/loader/nacl_ipc_adapter.h"
6 6
7 #include <limits.h> 7 #include <limits.h>
8 #include <string.h> 8 #include <string.h>
9 9
10 #include "base/basictypes.h" 10 #include "base/basictypes.h"
(...skipping 487 matching lines...) Expand 10 before | Expand all | Expand 10 after
498 case ppapi::proxy::SerializedHandle::SOCKET: { 498 case ppapi::proxy::SerializedHandle::SOCKET: {
499 nacl_desc.reset(new NaClDescWrapper(NaClDescSyncSocketMake( 499 nacl_desc.reset(new NaClDescWrapper(NaClDescSyncSocketMake(
500 #if defined(OS_WIN) 500 #if defined(OS_WIN)
501 iter->descriptor() 501 iter->descriptor()
502 #else 502 #else
503 iter->descriptor().fd 503 iter->descriptor().fd
504 #endif 504 #endif
505 ))); 505 )));
506 break; 506 break;
507 } 507 }
508 case ppapi::proxy::SerializedHandle::CHANNEL_HANDLE: {
509 // Check that this came from a PpapiMsg_CreateNaClChannel message.
510 // This code here is only appropriate for that message.
511 DCHECK(msg.type() == PpapiMsg_CreateNaClChannel::ID);
512 IPC::ChannelHandle channel_handle =
513 IPC::Channel::GenerateVerifiedChannelID("nacl");
514 scoped_refptr<NaClIPCAdapter> ipc_adapter(
515 new NaClIPCAdapter(channel_handle, task_runner_.get()));
516 ipc_adapter->ConnectChannel();
517 #if defined(OS_POSIX)
518 channel_handle.socket = base::FileDescriptor(
519 ipc_adapter->TakeClientFileDescriptor(), true);
520 #endif
521 nacl_desc.reset(new NaClDescWrapper(ipc_adapter->MakeNaClDesc()));
522 // Send back a message that the channel was created.
523 scoped_ptr<IPC::Message> response(
524 new PpapiHostMsg_NaClChannelCreated(channel_handle));
525 task_runner_->PostTask(FROM_HERE,
526 base::Bind(&NaClIPCAdapter::SendMessageOnIOThread, this,
527 base::Passed(&response)));
528 break;
529 }
530 case ppapi::proxy::SerializedHandle::FILE: { 508 case ppapi::proxy::SerializedHandle::FILE: {
531 // Create the NaClDesc for the file descriptor. If quota checking is 509 // Create the NaClDesc for the file descriptor. If quota checking is
532 // required, wrap it in a NaClDescQuota. 510 // required, wrap it in a NaClDescQuota.
533 NaClDesc* desc = NaClDescIoDescFromHandleAllocCtor( 511 NaClDesc* desc = NaClDescIoDescFromHandleAllocCtor(
534 #if defined(OS_WIN) 512 #if defined(OS_WIN)
535 iter->descriptor(), 513 iter->descriptor(),
536 #else 514 #else
537 iter->descriptor().fd, 515 iter->descriptor().fd,
538 #endif 516 #endif
539 TranslatePepperFileReadWriteOpenFlags(iter->open_flags())); 517 TranslatePepperFileReadWriteOpenFlags(iter->open_flags()));
540 if (desc && iter->file_io()) { 518 if (desc && iter->file_io()) {
541 desc = MakeNaClDescQuota( 519 desc = MakeNaClDescQuota(
542 locked_data_.nacl_msg_scanner_.GetFile(iter->file_io()), 520 locked_data_.nacl_msg_scanner_.GetFile(iter->file_io()),
543 desc); 521 desc);
544 } 522 }
545 if (desc) 523 if (desc)
546 nacl_desc.reset(new NaClDescWrapper(desc)); 524 nacl_desc.reset(new NaClDescWrapper(desc));
547 break; 525 break;
548 } 526 }
549 527
528 case ppapi::proxy::SerializedHandle::CHANNEL_HANDLE:
Mark Seaborn 2014/02/04 19:28:12 Should we also remove the definition of CHANNEL_HA
hidehiko 2014/02/05 06:30:16 Done.
550 case ppapi::proxy::SerializedHandle::INVALID: { 529 case ppapi::proxy::SerializedHandle::INVALID: {
551 // Nothing to do. TODO(dmichael): Should we log this? Or is it 530 // Nothing to do. TODO(dmichael): Should we log this? Or is it
552 // sometimes okay to pass an INVALID handle? 531 // sometimes okay to pass an INVALID handle?
553 break; 532 break;
554 } 533 }
555 // No default, so the compiler will warn us if new types get added. 534 // No default, so the compiler will warn us if new types get added.
556 } 535 }
557 if (nacl_desc.get()) 536 if (nacl_desc.get())
558 rewritten_msg->AddDescriptor(nacl_desc.release()); 537 rewritten_msg->AddDescriptor(nacl_desc.release());
559 } 538 }
(...skipping 127 matching lines...) Expand 10 before | Expand all | Expand 10 after
687 header.flags = msg.flags(); 666 header.flags = msg.flags();
688 header.num_fds = static_cast<int>(rewritten_msg->desc_count()); 667 header.num_fds = static_cast<int>(rewritten_msg->desc_count());
689 668
690 rewritten_msg->SetData(header, msg.payload(), msg.payload_size()); 669 rewritten_msg->SetData(header, msg.payload(), msg.payload_size());
691 locked_data_.to_be_received_.push(rewritten_msg); 670 locked_data_.to_be_received_.push(rewritten_msg);
692 } 671 }
693 672
694 int TranslatePepperFileReadWriteOpenFlagsForTesting(int32_t pp_open_flags) { 673 int TranslatePepperFileReadWriteOpenFlagsForTesting(int32_t pp_open_flags) {
695 return TranslatePepperFileReadWriteOpenFlags(pp_open_flags); 674 return TranslatePepperFileReadWriteOpenFlags(pp_open_flags);
696 } 675 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698