| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 // This file contains tests that are shared between different implementations of | 5 // This file contains tests that are shared between different implementations of |
| 6 // |DataPipeImpl|. | 6 // |DataPipeImpl|. |
| 7 | 7 |
| 8 #include "mojo/edk/system/data_pipe_impl.h" | 8 #include "mojo/edk/system/data_pipe_impl.h" |
| 9 | 9 |
| 10 #include <stdint.h> | 10 #include <stdint.h> |
| (...skipping 358 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 369 scoped_refptr<DataPipeProducerDispatcher> to_send = | 369 scoped_refptr<DataPipeProducerDispatcher> to_send = |
| 370 new DataPipeProducerDispatcher(); | 370 new DataPipeProducerDispatcher(); |
| 371 to_send->Init(dp()); | 371 to_send->Init(dp()); |
| 372 scoped_refptr<Dispatcher> to_receive; | 372 scoped_refptr<Dispatcher> to_receive; |
| 373 SendDispatcher(0, to_send, &to_receive); | 373 SendDispatcher(0, to_send, &to_receive); |
| 374 // |to_send| should have been closed. This is |DCHECK()|ed when it is | 374 // |to_send| should have been closed. This is |DCHECK()|ed when it is |
| 375 // destroyed. | 375 // destroyed. |
| 376 EXPECT_TRUE(to_send->HasOneRef()); | 376 EXPECT_TRUE(to_send->HasOneRef()); |
| 377 to_send = nullptr; | 377 to_send = nullptr; |
| 378 | 378 |
| 379 ASSERT_EQ(Dispatcher::kTypeDataPipeProducer, to_receive->GetType()); | 379 ASSERT_EQ(Dispatcher::Type::DATA_PIPE_PRODUCER, to_receive->GetType()); |
| 380 producer_dispatcher_ = | 380 producer_dispatcher_ = |
| 381 static_cast<DataPipeProducerDispatcher*>(to_receive.get()); | 381 static_cast<DataPipeProducerDispatcher*>(to_receive.get()); |
| 382 } | 382 } |
| 383 | 383 |
| 384 DataPipe* DataPipeForProducer() override { | 384 DataPipe* DataPipeForProducer() override { |
| 385 if (producer_dispatcher_) | 385 if (producer_dispatcher_) |
| 386 return producer_dispatcher_->GetDataPipeForTest(); | 386 return producer_dispatcher_->GetDataPipeForTest(); |
| 387 return dp().get(); | 387 return dp().get(); |
| 388 } | 388 } |
| 389 DataPipe* DataPipeForConsumer() override { return dp().get(); } | 389 DataPipe* DataPipeForConsumer() override { return dp().get(); } |
| (...skipping 29 matching lines...) Expand all Loading... |
| 419 scoped_refptr<DataPipeConsumerDispatcher> to_send = | 419 scoped_refptr<DataPipeConsumerDispatcher> to_send = |
| 420 new DataPipeConsumerDispatcher(); | 420 new DataPipeConsumerDispatcher(); |
| 421 to_send->Init(dp()); | 421 to_send->Init(dp()); |
| 422 scoped_refptr<Dispatcher> to_receive; | 422 scoped_refptr<Dispatcher> to_receive; |
| 423 SendDispatcher(0, to_send, &to_receive); | 423 SendDispatcher(0, to_send, &to_receive); |
| 424 // |to_send| should have been closed. This is |DCHECK()|ed when it is | 424 // |to_send| should have been closed. This is |DCHECK()|ed when it is |
| 425 // destroyed. | 425 // destroyed. |
| 426 EXPECT_TRUE(to_send->HasOneRef()); | 426 EXPECT_TRUE(to_send->HasOneRef()); |
| 427 to_send = nullptr; | 427 to_send = nullptr; |
| 428 | 428 |
| 429 ASSERT_EQ(Dispatcher::kTypeDataPipeConsumer, to_receive->GetType()); | 429 ASSERT_EQ(Dispatcher::Type::DATA_PIPE_CONSUMER, to_receive->GetType()); |
| 430 consumer_dispatcher_ = | 430 consumer_dispatcher_ = |
| 431 static_cast<DataPipeConsumerDispatcher*>(to_receive.get()); | 431 static_cast<DataPipeConsumerDispatcher*>(to_receive.get()); |
| 432 } | 432 } |
| 433 | 433 |
| 434 DataPipe* DataPipeForProducer() override { return dp().get(); } | 434 DataPipe* DataPipeForProducer() override { return dp().get(); } |
| 435 DataPipe* DataPipeForConsumer() override { | 435 DataPipe* DataPipeForConsumer() override { |
| 436 if (consumer_dispatcher_) | 436 if (consumer_dispatcher_) |
| 437 return consumer_dispatcher_->GetDataPipeForTest(); | 437 return consumer_dispatcher_->GetDataPipeForTest(); |
| 438 return dp().get(); | 438 return dp().get(); |
| 439 } | 439 } |
| (...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 473 // This is the producer dispatcher we'll send. | 473 // This is the producer dispatcher we'll send. |
| 474 scoped_refptr<DataPipeProducerDispatcher> to_send = | 474 scoped_refptr<DataPipeProducerDispatcher> to_send = |
| 475 new DataPipeProducerDispatcher(); | 475 new DataPipeProducerDispatcher(); |
| 476 to_send->Init(dp()); | 476 to_send->Init(dp()); |
| 477 scoped_refptr<Dispatcher> to_receive; | 477 scoped_refptr<Dispatcher> to_receive; |
| 478 SendDispatcher(0, to_send, &to_receive); | 478 SendDispatcher(0, to_send, &to_receive); |
| 479 // |to_send| should have been closed. This is |DCHECK()|ed when it is | 479 // |to_send| should have been closed. This is |DCHECK()|ed when it is |
| 480 // destroyed. | 480 // destroyed. |
| 481 EXPECT_TRUE(to_send->HasOneRef()); | 481 EXPECT_TRUE(to_send->HasOneRef()); |
| 482 to_send = nullptr; | 482 to_send = nullptr; |
| 483 ASSERT_EQ(Dispatcher::kTypeDataPipeProducer, to_receive->GetType()); | 483 ASSERT_EQ(Dispatcher::Type::DATA_PIPE_PRODUCER, to_receive->GetType()); |
| 484 to_send = static_cast<DataPipeProducerDispatcher*>(to_receive.get()); | 484 to_send = static_cast<DataPipeProducerDispatcher*>(to_receive.get()); |
| 485 to_receive = nullptr; | 485 to_receive = nullptr; |
| 486 | 486 |
| 487 // Now send it back the other way. | 487 // Now send it back the other way. |
| 488 SendDispatcher(1, to_send, &to_receive); | 488 SendDispatcher(1, to_send, &to_receive); |
| 489 // |producer_dispatcher_| should have been closed. This is |DCHECK()|ed when | 489 // |producer_dispatcher_| should have been closed. This is |DCHECK()|ed when |
| 490 // it is destroyed. | 490 // it is destroyed. |
| 491 EXPECT_TRUE(to_send->HasOneRef()); | 491 EXPECT_TRUE(to_send->HasOneRef()); |
| 492 to_send = nullptr; | 492 to_send = nullptr; |
| 493 | 493 |
| 494 ASSERT_EQ(Dispatcher::kTypeDataPipeProducer, to_receive->GetType()); | 494 ASSERT_EQ(Dispatcher::Type::DATA_PIPE_PRODUCER, to_receive->GetType()); |
| 495 producer_dispatcher_ = | 495 producer_dispatcher_ = |
| 496 static_cast<DataPipeProducerDispatcher*>(to_receive.get()); | 496 static_cast<DataPipeProducerDispatcher*>(to_receive.get()); |
| 497 } | 497 } |
| 498 | 498 |
| 499 private: | 499 private: |
| 500 DISALLOW_COPY_AND_ASSIGN(RemoteProducerDataPipeImplTestHelper2); | 500 DISALLOW_COPY_AND_ASSIGN(RemoteProducerDataPipeImplTestHelper2); |
| 501 }; | 501 }; |
| 502 | 502 |
| 503 // RemoteConsumerDataPipeImplTestHelper2 --------------------------------------- | 503 // RemoteConsumerDataPipeImplTestHelper2 --------------------------------------- |
| 504 | 504 |
| (...skipping 15 matching lines...) Expand all Loading... |
| 520 // This is the consumer dispatcher we'll send. | 520 // This is the consumer dispatcher we'll send. |
| 521 scoped_refptr<DataPipeConsumerDispatcher> to_send = | 521 scoped_refptr<DataPipeConsumerDispatcher> to_send = |
| 522 new DataPipeConsumerDispatcher(); | 522 new DataPipeConsumerDispatcher(); |
| 523 to_send->Init(dp()); | 523 to_send->Init(dp()); |
| 524 scoped_refptr<Dispatcher> to_receive; | 524 scoped_refptr<Dispatcher> to_receive; |
| 525 SendDispatcher(0, to_send, &to_receive); | 525 SendDispatcher(0, to_send, &to_receive); |
| 526 // |to_send| should have been closed. This is |DCHECK()|ed when it is | 526 // |to_send| should have been closed. This is |DCHECK()|ed when it is |
| 527 // destroyed. | 527 // destroyed. |
| 528 EXPECT_TRUE(to_send->HasOneRef()); | 528 EXPECT_TRUE(to_send->HasOneRef()); |
| 529 to_send = nullptr; | 529 to_send = nullptr; |
| 530 ASSERT_EQ(Dispatcher::kTypeDataPipeConsumer, to_receive->GetType()); | 530 ASSERT_EQ(Dispatcher::Type::DATA_PIPE_CONSUMER, to_receive->GetType()); |
| 531 to_send = static_cast<DataPipeConsumerDispatcher*>(to_receive.get()); | 531 to_send = static_cast<DataPipeConsumerDispatcher*>(to_receive.get()); |
| 532 to_receive = nullptr; | 532 to_receive = nullptr; |
| 533 | 533 |
| 534 // Now send it back the other way. | 534 // Now send it back the other way. |
| 535 SendDispatcher(1, to_send, &to_receive); | 535 SendDispatcher(1, to_send, &to_receive); |
| 536 // |consumer_dispatcher_| should have been closed. This is |DCHECK()|ed when | 536 // |consumer_dispatcher_| should have been closed. This is |DCHECK()|ed when |
| 537 // it is destroyed. | 537 // it is destroyed. |
| 538 EXPECT_TRUE(to_send->HasOneRef()); | 538 EXPECT_TRUE(to_send->HasOneRef()); |
| 539 to_send = nullptr; | 539 to_send = nullptr; |
| 540 | 540 |
| 541 ASSERT_EQ(Dispatcher::kTypeDataPipeConsumer, to_receive->GetType()); | 541 ASSERT_EQ(Dispatcher::Type::DATA_PIPE_CONSUMER, to_receive->GetType()); |
| 542 consumer_dispatcher_ = | 542 consumer_dispatcher_ = |
| 543 static_cast<DataPipeConsumerDispatcher*>(to_receive.get()); | 543 static_cast<DataPipeConsumerDispatcher*>(to_receive.get()); |
| 544 } | 544 } |
| 545 | 545 |
| 546 private: | 546 private: |
| 547 DISALLOW_COPY_AND_ASSIGN(RemoteConsumerDataPipeImplTestHelper2); | 547 DISALLOW_COPY_AND_ASSIGN(RemoteConsumerDataPipeImplTestHelper2); |
| 548 }; | 548 }; |
| 549 | 549 |
| 550 // Test case instantiation ----------------------------------------------------- | 550 // Test case instantiation ----------------------------------------------------- |
| 551 | 551 |
| (...skipping 1838 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2390 this->ConsumerQueryData(MakeUserPointer(&num_bytes))); | 2390 this->ConsumerQueryData(MakeUserPointer(&num_bytes))); |
| 2391 EXPECT_EQ(1u * sizeof(int32_t), num_bytes); | 2391 EXPECT_EQ(1u * sizeof(int32_t), num_bytes); |
| 2392 | 2392 |
| 2393 this->ProducerClose(); | 2393 this->ProducerClose(); |
| 2394 this->ConsumerClose(); | 2394 this->ConsumerClose(); |
| 2395 } | 2395 } |
| 2396 | 2396 |
| 2397 } // namespace | 2397 } // namespace |
| 2398 } // namespace system | 2398 } // namespace system |
| 2399 } // namespace mojo | 2399 } // namespace mojo |
| OLD | NEW |