Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 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 | 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x | // Copyright (c) ZeroC, Inc.
import { Ice } from "@zeroc/ice";
import { Test } from "./Test.js";
import { TestHelper } from "../../Common/TestHelper.js";
import { TestI } from "./TestI.js";
import { TestActivationI } from "./TestActivationI.js";
import { ServantLocatorI } from "./ServantLocatorI.js";
export class Server extends TestHelper {
async run(args) {
let communicator = null;
let echo = null;
try {
const [properties] = this.createTestProperties(args);
properties.setProperty("Ice.MessageSizeMax", "10");
properties.setProperty("Ice.Warn.Dispatch", "0");
properties.setProperty("Ice.Warn.Connections", "0");
[communicator] = this.initialize(properties);
echo = new Test.EchoPrx(communicator, `__echo:${this.getTestEndpoint()}`);
const adapter = await communicator.createObjectAdapter("");
adapter.addServantLocator(new ServantLocatorI("category"), "category");
adapter.addServantLocator(new ServantLocatorI(""), "");
adapter.add(new TestI(), Ice.stringToIdentity("asm"));
adapter.add(new TestActivationI(), Ice.stringToIdentity("test/activation"));
await echo.setConnection();
echo.ice_getCachedConnection().setAdapter(adapter);
this.serverReady();
await communicator.waitForShutdown();
}
finally {
if (echo) {
await echo.shutdown();
}
if (communicator) {
await communicator.destroy();
}
}
}
}
|