← Back to branch summary

~ubuntu-branches/ubuntu/quantal/zeroc-ice/quantal

« back to all changes in this revision

Viewing changes to java/test/Ice/hold/Server.java

  • Committer: Bazaar Package Importer
  • Author(s): Cleto Martin Angelina
  • Date: 2011-04-25 18:44:24 UTC
  • mfrom: (6.1.14 sid)
  • Revision ID: james.westby@ubuntu.com-20110425184424-sep9i9euu434vq4c
Tags: 3.4.1-7
http://bugs.debian.org/623555
* Bug fix: "libdb5.1-java.jar was renamed to db.jar", thanks to Ondřej
  Surý (Closes: #623555).
* Bug fix: "causes noise in php5", thanks to Jayen Ashar (Closes:
  #623533).

Show diffs side-by-side

added added

removed removed

Lines of Context:
java/test/Ice/hold/Server.java
1
1
// **********************************************************************
2
2
//
3
 
// Copyright (c) 2003-2009 ZeroC, Inc. All rights reserved.
 
3
// Copyright (c) 2003-2010 ZeroC, Inc. All rights reserved.
4
4
//
5
5
// This copy of Ice is licensed to you under the terms described in the
6
6
// ICE_LICENSE file included in this distribution.
7
7
//
8
8
// **********************************************************************
9
9
 
10
 
public class Server
 
10
package test.Ice.hold;
 
11
 
 
12
public class Server extends test.Util.Application
11
13
{
12
 
    private static int
13
 
    run(String[] args, Ice.Communicator communicator)
 
14
    public int run(String[] args)
14
15
    {
 
16
        Ice.Communicator communicator = communicator();
15
17
        java.util.Timer timer = new java.util.Timer();
16
18
 
17
 
        communicator.getProperties().setProperty("TestAdapter1.Endpoints", "default -p 12010 -t 10000:udp");
18
 
        communicator.getProperties().setProperty("TestAdapter1.ThreadPool.Size", "5");
19
 
        communicator.getProperties().setProperty("TestAdapter1.ThreadPool.SizeMax", "5");
20
 
        communicator.getProperties().setProperty("TestAdapter1.ThreadPool.SizeWarn", "0");
21
 
        communicator.getProperties().setProperty("TestAdapter1.ThreadPool.Serialize", "0");
22
19
        Ice.ObjectAdapter adapter1 = communicator.createObjectAdapter("TestAdapter1");
23
20
        adapter1.add(new HoldI(timer, adapter1), communicator.stringToIdentity("hold"));
24
21
 
25
 
        communicator.getProperties().setProperty("TestAdapter2.Endpoints", "default -p 12011 -t 10000:udp");
26
 
        communicator.getProperties().setProperty("TestAdapter2.ThreadPool.Size", "5");
27
 
        communicator.getProperties().setProperty("TestAdapter2.ThreadPool.SizeMax", "5");
28
 
        communicator.getProperties().setProperty("TestAdapter2.ThreadPool.SizeWarn", "0");
29
 
        communicator.getProperties().setProperty("TestAdapter2.ThreadPool.Serialize", "1");
30
22
        Ice.ObjectAdapter adapter2 = communicator.createObjectAdapter("TestAdapter2");
31
23
        adapter2.add(new HoldI(timer, adapter2), communicator.stringToIdentity("hold"));
32
24
 
33
25
        adapter1.activate();
34
26
        adapter2.activate();
35
27
 
 
28
        serverReady();
36
29
        communicator.waitForShutdown();
37
30
 
38
31
        timer.cancel();
40
33
        return 0;
41
34
    }
42
35
 
43
 
    public static void
44
 
    main(String[] args)
45
 
    {
46
 
        int status = 0;
47
 
        Ice.Communicator communicator = null;
48
 
 
49
 
        try
50
 
        {
51
 
            communicator = Ice.Util.initialize(args);
52
 
            status = run(args, communicator);
53
 
        }
54
 
        catch(Exception ex)
55
 
        {
56
 
            ex.printStackTrace();
57
 
            status = 1;
58
 
        }
59
 
 
60
 
        if(communicator != null)
61
 
        {
62
 
            try
63
 
            {
64
 
                communicator.destroy();
65
 
            }
66
 
            catch(Ice.LocalException ex)
67
 
            {
68
 
                ex.printStackTrace();
69
 
                status = 1;
70
 
            }
71
 
        }
72
 
 
 
36
    protected Ice.InitializationData getInitData(Ice.StringSeqHolder argsH)
 
37
    {
 
38
        Ice.InitializationData initData = new Ice.InitializationData();
 
39
        initData.properties = Ice.Util.createProperties(argsH);
 
40
        initData.properties.setProperty("Ice.Package.Test", "test.Ice.hold");
 
41
        initData.properties.setProperty("TestAdapter1.Endpoints", "default -p 12010:udp");
 
42
        initData.properties.setProperty("TestAdapter1.ThreadPool.Size", "5");
 
43
        initData.properties.setProperty("TestAdapter1.ThreadPool.SizeMax", "5");
 
44
        initData.properties.setProperty("TestAdapter1.ThreadPool.SizeWarn", "0");
 
45
        initData.properties.setProperty("TestAdapter1.ThreadPool.Serialize", "0");
 
46
 
 
47
        initData.properties.setProperty("TestAdapter2.Endpoints", "default -p 12011:udp");
 
48
        initData.properties.setProperty("TestAdapter2.ThreadPool.Size", "5");
 
49
        initData.properties.setProperty("TestAdapter2.ThreadPool.SizeMax", "5");
 
50
        initData.properties.setProperty("TestAdapter2.ThreadPool.SizeWarn", "0");
 
51
        initData.properties.setProperty("TestAdapter2.ThreadPool.Serialize", "1");
 
52
        return initData;
 
53
    }
 
54
 
 
55
    public static void main(String[] args)
 
56
    {
 
57
        Server app = new Server();
 
58
        int result = app.main("Server", args);
73
59
        System.gc();
74
 
        System.exit(status);
 
60
        System.exit(result);
75
61
    }
76
62
}