1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
<?php
//
// Copyright (c) ZeroC, Inc. All rights reserved.
//
error_reporting(E_ALL | E_STRICT);
require_once("Test.php");
function testSetACM($helper, $com)
{
global $NS;
$CloseOnIdleForceful = constant($NS ? "Ice\\ACMClose::CloseOnIdleForceful" :
"Ice_ACMClose::CloseOnIdleForceful");
$CloseOnInvocationAndIdle = constant($NS ? "Ice\\ACMClose::CloseOnInvocationAndIdle" :
"Ice_ACMClose::CloseOnInvocationAndIdle");
$HeartbeatOnIdle = constant($NS ? "Ice\\ACMHeartbeat::HeartbeatOnIdle" :
"Ice_ACMHeartbeat::HeartbeatOnIdle");
$HeartbeatAlways = constant($NS ? "Ice\\ACMHeartbeat::HeartbeatAlways" :
"Ice_ACMHeartbeat::HeartbeatAlways");
$None = constant($NS ? "Ice\\None" : "Ice_Unset");
echo "testing setACM/getACM... ";
flush();
$adapter = $com->createObjectAdapter(-1, -1, -1);
$communicator = $helper->communicator();
$properties = $communicator->getProperties()->clone();
$properties->setProperty("Ice.ACM.Timeout", "1");
$properties->setProperty("Ice.ACM.Client.Timeout", "15");
$properties->setProperty("Ice.ACM.Client.Close", "4");
$properties->setProperty("Ice.ACM.Client.Heartbeat", "2");
$communicator = $helper->initialize($properties);
$proxy = $communicator->stringToProxy(
$adapter->getTestIntf()->ice_toString())->ice_uncheckedCast("::Test::TestIntf");
$proxy->ice_getConnection();
$acm = $proxy->ice_getCachedConnection()->getACM();
test($acm->timeout == 15);
test($acm->close == $CloseOnIdleForceful);
test($acm->heartbeat == $HeartbeatOnIdle);
$proxy->ice_getCachedConnection()->setACM($None, $None, $None);
$acm = $proxy->ice_getCachedConnection()->getACM();
test($acm->timeout == 15);
test($acm->close == $CloseOnIdleForceful);
test($acm->heartbeat == $HeartbeatOnIdle);
$proxy->ice_getCachedConnection()->setACM(1, $CloseOnInvocationAndIdle, $HeartbeatAlways);
$acm = $proxy->ice_getCachedConnection()->getACM();
test($acm->timeout == 1);
test($acm->close == $CloseOnInvocationAndIdle);
test($acm->heartbeat == $HeartbeatAlways);
$proxy->startHeartbeatCount();
$proxy->waitForHeartbeatCount(2);
$adapter->deactivate();
$communicator->destroy();
echo "ok\n";
}
function testHeartbeatManual($helper, $com)
{
echo "testing manual heartbeats... ";
flush();
$adapter = $com->createObjectAdapter(10, -1, 0);
$communicator = $helper->communicator();
$properties = $communicator->getProperties()->clone();
$properties->setProperty("Ice.ACM.Timeout", "10");
$properties->setProperty("Ice.ACM.Client.Timeout", "10");
$properties->setProperty("Ice.ACM.Client.Close", "0");
$properties->setProperty("Ice.ACM.Client.Heartbeat", "0");
$communicator = $helper->initialize($properties);
$proxy = $communicator->stringToProxy(
$adapter->getTestIntf()->ice_toString())->ice_uncheckedCast("::Test::TestIntf");
$con = $proxy->ice_getConnection();
$proxy->startHeartbeatCount();
$con->heartbeat();
$con->heartbeat();
$con->heartbeat();
$con->heartbeat();
$con->heartbeat();
$proxy->waitForHeartbeatCount(5);
$adapter->deactivate();
$communicator->destroy();
echo "ok\n";
}
class Client extends TestHelper
{
function run($args)
{
try
{
$communicator = $this->initialize($args);
$ref = sprintf("communicator:%s", $this->getTestEndpoint());
$com = $communicator->stringToProxy($ref)->ice_uncheckedCast("::Test::RemoteCommunicator");
testSetACM($this, $com);
testHeartbeatManual($this, $com);
$com->shutdown();
$communicator->destroy();
}
catch(Exception $ex)
{
$communicator->destroy();
throw $ex;
}
}
}
?>
|
