| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 // Unit test for SyncChannel. | 5 // Unit test for SyncChannel. |
| 6 | 6 |
| 7 #include "ipc/ipc_sync_channel.h" | 7 #include "ipc/ipc_sync_channel.h" |
| 8 | 8 |
| 9 #include <string> | 9 #include <string> |
| 10 #include <vector> | 10 #include <vector> |
| (...skipping 1412 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1423 class RestrictedDispatchDeadlockServer : public Worker { | 1423 class RestrictedDispatchDeadlockServer : public Worker { |
| 1424 public: | 1424 public: |
| 1425 RestrictedDispatchDeadlockServer(int server_num, | 1425 RestrictedDispatchDeadlockServer(int server_num, |
| 1426 WaitableEvent* server_ready_event, | 1426 WaitableEvent* server_ready_event, |
| 1427 WaitableEvent** events, | 1427 WaitableEvent** events, |
| 1428 RestrictedDispatchDeadlockServer* peer) | 1428 RestrictedDispatchDeadlockServer* peer) |
| 1429 : Worker(server_num == 1 ? "channel1" : "channel2", Channel::MODE_SERVER), | 1429 : Worker(server_num == 1 ? "channel1" : "channel2", Channel::MODE_SERVER), |
| 1430 server_num_(server_num), | 1430 server_num_(server_num), |
| 1431 server_ready_event_(server_ready_event), | 1431 server_ready_event_(server_ready_event), |
| 1432 events_(events), | 1432 events_(events), |
| 1433 peer_(peer), | 1433 peer_(peer) { } |
| 1434 client_kicked_(false) { } | |
| 1435 | 1434 |
| 1436 void OnDoServerTask() { | 1435 void OnDoServerTask() { |
| 1437 events_[3]->Signal(); | 1436 events_[3]->Signal(); |
| 1438 events_[2]->Wait(); | 1437 events_[2]->Wait(); |
| 1439 events_[0]->Signal(); | 1438 events_[0]->Signal(); |
| 1440 SendMessageToClient(); | 1439 SendMessageToClient(); |
| 1441 } | 1440 } |
| 1442 | 1441 |
| 1443 void Run() { | 1442 void Run() { |
| 1444 channel()->SetRestrictDispatchChannelGroup(1); | 1443 channel()->SetRestrictDispatchChannelGroup(1); |
| (...skipping 22 matching lines...) Expand all Loading... |
| 1467 Message* msg = new SyncChannelTestMsg_NoArgs; | 1466 Message* msg = new SyncChannelTestMsg_NoArgs; |
| 1468 msg->set_unblock(false); | 1467 msg->set_unblock(false); |
| 1469 DCHECK(!msg->should_unblock()); | 1468 DCHECK(!msg->should_unblock()); |
| 1470 Send(msg); | 1469 Send(msg); |
| 1471 } | 1470 } |
| 1472 | 1471 |
| 1473 int server_num_; | 1472 int server_num_; |
| 1474 WaitableEvent* server_ready_event_; | 1473 WaitableEvent* server_ready_event_; |
| 1475 WaitableEvent** events_; | 1474 WaitableEvent** events_; |
| 1476 RestrictedDispatchDeadlockServer* peer_; | 1475 RestrictedDispatchDeadlockServer* peer_; |
| 1477 bool client_kicked_; | |
| 1478 }; | 1476 }; |
| 1479 | 1477 |
| 1480 class RestrictedDispatchDeadlockClient2 : public Worker { | 1478 class RestrictedDispatchDeadlockClient2 : public Worker { |
| 1481 public: | 1479 public: |
| 1482 RestrictedDispatchDeadlockClient2(RestrictedDispatchDeadlockServer* server, | 1480 RestrictedDispatchDeadlockClient2(RestrictedDispatchDeadlockServer* server, |
| 1483 WaitableEvent* server_ready_event, | 1481 WaitableEvent* server_ready_event, |
| 1484 WaitableEvent** events) | 1482 WaitableEvent** events) |
| 1485 : Worker("channel2", Channel::MODE_CLIENT), | 1483 : Worker("channel2", Channel::MODE_CLIENT), |
| 1486 server_ready_event_(server_ready_event), | 1484 server_ready_event_(server_ready_event), |
| 1487 events_(events), | 1485 events_(events), |
| (...skipping 466 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1954 | 1952 |
| 1955 } // namespace | 1953 } // namespace |
| 1956 | 1954 |
| 1957 // Windows needs to send an out-of-band secret to verify the client end of the | 1955 // Windows needs to send an out-of-band secret to verify the client end of the |
| 1958 // channel. Test that we still connect correctly in that case. | 1956 // channel. Test that we still connect correctly in that case. |
| 1959 TEST_F(IPCSyncChannelTest, Verified) { | 1957 TEST_F(IPCSyncChannelTest, Verified) { |
| 1960 Verified(); | 1958 Verified(); |
| 1961 } | 1959 } |
| 1962 | 1960 |
| 1963 } // namespace IPC | 1961 } // namespace IPC |
| OLD | NEW |