summaryrefslogtreecommitdiff
path: root/cpp/test/Ice/retry/Client.cpp
blob: feafb4305c63ee5b54fbd1d8663f6bc828a1374d (plain)
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
//
// Copyright (c) ZeroC, Inc. All rights reserved.
//

#include <Ice/Ice.h>
#include <TestHelper.h>
#include <Test.h>
#include <InstrumentationI.h>

using namespace std;
using namespace Test;

class Client : public Test::TestHelper
{
public:

    void run(int, char**);
};

void
Client::run(int argc, char** argv)
{
    initCounts();

    Ice::InitializationData initData;
    initData.properties = createTestProperties(argc, argv);
    initData.observer = getObserver();
    //
    // This test kills connections, so we don't want warnings.
    //
    initData.properties->setProperty("Ice.Warn.Connections", "0");

    // Disable PrintStackTraces otherwise the test can fail on Windows/Debug
    initData.properties->setProperty("Ice.PrintStackTraces", "0");

    initData.properties->setProperty("Ice.RetryIntervals", "0 1 10 1");
    Ice::CommunicatorHolder ich1 = Ice::initialize(argc, argv, initData);

    //
    // Configure a second communicator for the invocation timeout
    // + retry test, we need to configure a large retry interval
    // to avoid time-sensitive failures.
    //
    initData.properties = initData.properties->clone();
    initData.properties->setProperty("Ice.RetryIntervals", "0 1 10000");
    initData.observer = getObserver();
    Ice::CommunicatorHolder ich2 = Ice::initialize(initData);

    RetryPrxPtr allTests(const Ice::CommunicatorPtr&, const Ice::CommunicatorPtr&, const string&);
    RetryPrxPtr retry = allTests(ich1.communicator(),
                                 ich2.communicator(),
                                 "retry:" + TestHelper::getTestEndpoint(ich1->getProperties()));
    retry->shutdown();
}

DEFINE_TEST(Client)