blob: 8d5af76b538bcff674009febdb9ad27d2fc4def7 (
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
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
|
// **********************************************************************
//
// Copyright (c) 2003-2010 ZeroC, Inc. All rights reserved.
//
// This copy of Ice is licensed to you under the terms described in the
// ICE_LICENSE file included in this distribution.
//
// **********************************************************************
#include <Ice/Ice.h>
#include <IceUtil/Random.h>
#include <TestCommon.h>
#include <Test.h>
#include <Dispatcher.h>
using namespace std;
namespace
{
class Callback : public IceUtil::Shared
{
public:
void
response()
{
test(Dispatcher::isDispatcherThread());
}
void
exception(const Ice::Exception& ex)
{
test(dynamic_cast<const Ice::NoEndpointException*>(&ex));
test(Dispatcher::isDispatcherThread());
}
void
sent(bool sentSynchronously)
{
test(sentSynchronously || Dispatcher::isDispatcherThread());
}
};
typedef IceUtil::Handle<Callback> CallbackPtr;
}
void
allTests(const Ice::CommunicatorPtr& communicator)
{
string sref = "test:default -p 12010";
Ice::ObjectPrx obj = communicator->stringToProxy(sref);
test(obj);
Test::TestIntfPrx p = Test::TestIntfPrx::uncheckedCast(obj);
sref = "testController:tcp -p 12011";
obj = communicator->stringToProxy(sref);
test(obj);
Test::TestIntfControllerPrx testController = Test::TestIntfControllerPrx::uncheckedCast(obj);
cout << "testing dispatcher... " << flush;
{
p->op();
CallbackPtr cb = new Callback();
Test::Callback_TestIntf_opPtr callback = Test::newCallback_TestIntf_op(cb,
&Callback::response,
&Callback::exception);
p->begin_op(callback);
Test::TestIntfPrx i = p->ice_adapterId("dummy");
i->begin_op(callback);
testController->holdAdapter();
Test::Callback_TestIntf_opWithPayloadPtr callback2 =
Test::newCallback_TestIntf_opWithPayload(cb, &Callback::response, &Callback::exception, &Callback::sent);
Ice::ByteSeq seq;
seq.resize(1024); // Make sure the request doesn't compress too well.
for(Ice::ByteSeq::iterator q = seq.begin(); q != seq.end(); ++q)
{
*q = static_cast<Ice::Byte>(IceUtilInternal::random(255));
}
while(p->begin_opWithPayload(seq, callback2)->sentSynchronously());
testController->resumeAdapter();
}
cout << "ok" << endl;
p->shutdown();
}
|
