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 |