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

Side by Side Diff: mojo/system/remote_message_pipe_unittest.cc

Issue 324783002: Mojo: Add a MojoCreateMessagePipeOptions struct parameter to MojoCreateMessagePipe. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: rebased Created 6 years, 6 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
« no previous file with comments | « mojo/system/multiprocess_message_pipe_unittest.cc ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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 <stdint.h> 5 #include <stdint.h>
6 #include <stdio.h> 6 #include <stdio.h>
7 #include <string.h> 7 #include <string.h>
8 8
9 #include <vector> 9 #include <vector>
10 10
(...skipping 435 matching lines...) Expand 10 before | Expand all | Expand 10 after
446 446
447 scoped_refptr<MessagePipe> mp0(new MessagePipe( 447 scoped_refptr<MessagePipe> mp0(new MessagePipe(
448 scoped_ptr<MessagePipeEndpoint>(new LocalMessagePipeEndpoint()), 448 scoped_ptr<MessagePipeEndpoint>(new LocalMessagePipeEndpoint()),
449 scoped_ptr<MessagePipeEndpoint>(new ProxyMessagePipeEndpoint()))); 449 scoped_ptr<MessagePipeEndpoint>(new ProxyMessagePipeEndpoint())));
450 scoped_refptr<MessagePipe> mp1(new MessagePipe( 450 scoped_refptr<MessagePipe> mp1(new MessagePipe(
451 scoped_ptr<MessagePipeEndpoint>(new ProxyMessagePipeEndpoint()), 451 scoped_ptr<MessagePipeEndpoint>(new ProxyMessagePipeEndpoint()),
452 scoped_ptr<MessagePipeEndpoint>(new LocalMessagePipeEndpoint()))); 452 scoped_ptr<MessagePipeEndpoint>(new LocalMessagePipeEndpoint())));
453 ConnectMessagePipes(mp0, mp1); 453 ConnectMessagePipes(mp0, mp1);
454 454
455 // We'll try to pass this dispatcher. 455 // We'll try to pass this dispatcher.
456 scoped_refptr<MessagePipeDispatcher> dispatcher(new MessagePipeDispatcher()); 456 scoped_refptr<MessagePipeDispatcher> dispatcher(new MessagePipeDispatcher(
457 MessagePipeDispatcher::kDefaultCreateOptions));
457 scoped_refptr<MessagePipe> local_mp(new MessagePipe()); 458 scoped_refptr<MessagePipe> local_mp(new MessagePipe());
458 dispatcher->Init(local_mp, 0); 459 dispatcher->Init(local_mp, 0);
459 460
460 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do 461 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do
461 // it later, it might already be readable.) 462 // it later, it might already be readable.)
462 waiter.Init(); 463 waiter.Init();
463 EXPECT_EQ(MOJO_RESULT_OK, 464 EXPECT_EQ(MOJO_RESULT_OK,
464 mp1->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_READABLE, 123)); 465 mp1->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_READABLE, 123));
465 466
466 // Write to MP 0, port 0. 467 // Write to MP 0, port 0.
(...skipping 109 matching lines...) Expand 10 before | Expand all | Expand 10 after
576 scoped_refptr<MessagePipe> mp0(new MessagePipe( 577 scoped_refptr<MessagePipe> mp0(new MessagePipe(
577 scoped_ptr<MessagePipeEndpoint>(new LocalMessagePipeEndpoint()), 578 scoped_ptr<MessagePipeEndpoint>(new LocalMessagePipeEndpoint()),
578 scoped_ptr<MessagePipeEndpoint>(new ProxyMessagePipeEndpoint()))); 579 scoped_ptr<MessagePipeEndpoint>(new ProxyMessagePipeEndpoint())));
579 scoped_refptr<MessagePipe> mp1(new MessagePipe( 580 scoped_refptr<MessagePipe> mp1(new MessagePipe(
580 scoped_ptr<MessagePipeEndpoint>(new ProxyMessagePipeEndpoint()), 581 scoped_ptr<MessagePipeEndpoint>(new ProxyMessagePipeEndpoint()),
581 scoped_ptr<MessagePipeEndpoint>(new LocalMessagePipeEndpoint()))); 582 scoped_ptr<MessagePipeEndpoint>(new LocalMessagePipeEndpoint())));
582 ConnectMessagePipes(mp0, mp1); 583 ConnectMessagePipes(mp0, mp1);
583 584
584 // We'll try to pass this dispatcher. 585 // We'll try to pass this dispatcher.
585 scoped_refptr<SharedBufferDispatcher> dispatcher; 586 scoped_refptr<SharedBufferDispatcher> dispatcher;
586 MojoCreateSharedBufferOptions validated_options = {};
587 EXPECT_EQ(MOJO_RESULT_OK, 587 EXPECT_EQ(MOJO_RESULT_OK,
588 SharedBufferDispatcher::ValidateCreateOptions(NULL, 588 SharedBufferDispatcher::Create(
589 &validated_options)); 589 SharedBufferDispatcher::kDefaultCreateOptions, 100,
590 EXPECT_EQ(MOJO_RESULT_OK, 590 &dispatcher));
591 SharedBufferDispatcher::Create(validated_options, 100,
592 &dispatcher));
593 ASSERT_TRUE(dispatcher); 591 ASSERT_TRUE(dispatcher);
594 592
595 // Make a mapping. 593 // Make a mapping.
596 scoped_ptr<RawSharedBufferMapping> mapping0; 594 scoped_ptr<RawSharedBufferMapping> mapping0;
597 EXPECT_EQ(MOJO_RESULT_OK, 595 EXPECT_EQ(MOJO_RESULT_OK,
598 dispatcher->MapBuffer(0, 100, MOJO_MAP_BUFFER_FLAG_NONE, 596 dispatcher->MapBuffer(0, 100, MOJO_MAP_BUFFER_FLAG_NONE,
599 &mapping0)); 597 &mapping0));
600 ASSERT_TRUE(mapping0); 598 ASSERT_TRUE(mapping0);
601 ASSERT_TRUE(mapping0->base()); 599 ASSERT_TRUE(mapping0->base());
602 ASSERT_EQ(100u, mapping0->length()); 600 ASSERT_EQ(100u, mapping0->length());
(...skipping 215 matching lines...) Expand 10 before | Expand all | Expand 10 after
818 816
819 mp1->Close(1); 817 mp1->Close(1);
820 818
821 RestoreInitialState(); 819 RestoreInitialState();
822 } 820 }
823 } 821 }
824 822
825 } // namespace 823 } // namespace
826 } // namespace system 824 } // namespace system
827 } // namespace mojo 825 } // namespace mojo
OLDNEW
« no previous file with comments | « mojo/system/multiprocess_message_pipe_unittest.cc ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698