blob: 48208139d13e8958896a50f21cdce617ce4870f2 (
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
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
125
126
127
128
129
130
131
132
133
134
135
136
137
|
// **********************************************************************
//
// Copyright (c) 2003-2007 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.
//
// **********************************************************************
import Test.*;
class AttackClient extends Ice.Application
{
public int
run(String[] args)
{
System.out.print("getting router... ");
System.out.flush();
Ice.ObjectPrx routerBase = communicator().stringToProxy("Glacier2/router:default -p 12347 -t 10000");
Glacier2.RouterPrx router = Glacier2.RouterPrxHelper.checkedCast(routerBase);
test(router != null);
System.out.println("ok");
System.out.print("creating session... ");
System.out.flush();
try
{
Glacier2.SessionPrx session = router.createSession("userid", "abc123");
}
catch(Glacier2.PermissionDeniedException ex)
{
assert(false);
}
catch(Glacier2.CannotCreateSessionException ex)
{
assert(false);
}
communicator().setDefaultRouter(router);
System.out.println("ok");
System.out.print("making thousands of invocations on proxies... ");
System.out.flush();
Ice.ObjectPrx backendBase = communicator().stringToProxy("dummy:tcp -p 12010 -t 10000");
BackendPrx backend = BackendPrxHelper.uncheckedCast(backendBase);
backend.ice_ping();
java.util.HashMap backends = new java.util.HashMap();
java.util.Random rand = new java.util.Random();
String msg = "";
for(int i = 1; i <= 10000; ++i)
{
if(i % 100 == 0)
{
for(int j = 0; j < msg.length(); ++j)
{
System.out.print('\b');
}
msg = "" + i;
System.out.print(i);
System.out.flush();
}
Ice.Identity ident = new Ice.Identity();
StringBuffer name = new StringBuffer();
name.append((char)('A' + rand.nextInt(26)));
ident.name = name.toString();
StringBuffer category = new StringBuffer();
int len = rand.nextInt(2);
for(int j = 0; j < len; ++j)
{
category.append((char)('a' + rand.nextInt(26)));
}
ident.category = category.toString();
BackendPrx newBackend = BackendPrxHelper.uncheckedCast(backendBase.ice_identity(ident));
if(!backends.containsKey(newBackend))
{
backends.put(newBackend, newBackend);
backend = newBackend;
}
else
{
backend = (BackendPrx)backends.get(newBackend);
}
backend.ice_ping();
}
for(int j = 0; j < msg.length(); ++j)
{
System.out.print('\b');
}
for(int j = 0; j < msg.length(); ++j)
{
System.out.print(' ');
}
for(int j = 0; j < msg.length(); ++j)
{
System.out.print('\b');
}
System.out.println("ok");
System.out.print("testing server and router shutdown... ");
System.out.flush();
backend.shutdown();
communicator().setDefaultRouter(null);
Ice.ObjectPrx adminBase = communicator().stringToProxy("Glacier2/admin:tcp -h 127.0.0.1 -p 12348 -t 10000");
Glacier2.AdminPrx admin = Glacier2.AdminPrxHelper.checkedCast(adminBase);
test(admin != null);
admin.shutdown();
try
{
admin.ice_ping();
test(false);
}
catch(Ice.LocalException ex)
{
System.out.println("ok");
}
return 0;
}
private static void
test(boolean b)
{
if(!b)
{
throw new RuntimeException();
}
}
}
|
