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 { ThrowerI } from "./ThrowerI.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.add(new ThrowerI(), Ice.stringToIdentity("thrower"));
await echo.setConnection();
const connection = echo.ice_getCachedConnection();
connection.setCloseCallback(() => {
// Re-establish connection if it fails (necessary for MemoryLimitException test)
echo.setConnection().then(() => echo.ice_getCachedConnection().setAdapter(adapter));
});
connection.setAdapter(adapter);
this.serverReady();
await communicator.waitForShutdown();
}
finally {
if (echo) {
await echo.shutdown();
}
if (communicator) {
await communicator.destroy();
}
}
}
}
|