mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-16 13:51:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

failing on linux

Browse Source
This commit is contained in:
Ciro Spaciari
2025-05-30 07:09:31 -07:00
parent 53c59ee348
commit e1a2fcf93b
1 changed files with 67 additions and 59 deletions
Download Patch File Download Diff File Expand all files Collapse all files

126
test/js/third_party/grpc-js/test-resolver.test.ts vendored
View File

@@ -367,67 +367,75 @@ describe("Name Resolver", () => {
const resolver2 = resolverManager.createResolver(target2, listener, {});
resolver2.updateResolution();
});
it("should not keep repeating successful resolutions", function (done) {
if (GRPC_NODE_USE_ALTERNATIVE_RESOLVER) {
this.skip();
}
const target = resolverManager.mapUriDefaultScheme(parseUri("localhost")!)!;
let resultCount = 0;
const resolver = resolverManager.createResolver(
target,
{
onSuccessfulResolution: (
endpointList: Endpoint[],
serviceConfig: ServiceConfig | null,
serviceConfigError: StatusObject | null,
) => {
assert(hasMatchingAddress(endpointList, { host: "127.0.0.1", port: 443 }));
assert(hasMatchingAddress(endpointList, { host: "::1", port: 443 }));
resultCount += 1;
if (resultCount === 1) {
process.nextTick(() => resolver.updateResolution());
}
it.todo(
"should not keep repeating successful resolutions",
function (done) {
if (GRPC_NODE_USE_ALTERNATIVE_RESOLVER) {
this.skip();
}
const target = resolverManager.mapUriDefaultScheme(parseUri("localhost")!)!;
let resultCount = 0;
const resolver = resolverManager.createResolver(
target,
{
onSuccessfulResolution: (
endpointList: Endpoint[],
serviceConfig: ServiceConfig | null,
serviceConfigError: StatusObject | null,
) => {
assert(hasMatchingAddress(endpointList, { host: "127.0.0.1", port: 443 }));
assert(hasMatchingAddress(endpointList, { host: "::1", port: 443 }));
resultCount += 1;
if (resultCount === 1) {
process.nextTick(() => resolver.updateResolution());
}
},
onError: (error: StatusObject) => {
assert.ifError(error);
},
},
onError: (error: StatusObject) => {
assert.ifError(error);
{ "grpc.dns_min_time_between_resolutions_ms": 2000 },
);
resolver.updateResolution();
setTimeout(() => {
assert.strictEqual(resultCount, 2, `resultCount ${resultCount} !== 2`);
done();
}, 10_000);
},
15_000,
);
it.todo(
"should not keep repeating failed resolutions",
done => {
const target = resolverManager.mapUriDefaultScheme(parseUri("host.invalid")!)!;
let resultCount = 0;
const resolver = resolverManager.createResolver(
target,
{
onSuccessfulResolution: (
endpointList: Endpoint[],
serviceConfig: ServiceConfig | null,
serviceConfigError: StatusObject | null,
) => {
assert.fail("Resolution succeeded unexpectedly");
},
onError: (error: StatusObject) => {
resultCount += 1;
if (resultCount === 1) {
process.nextTick(() => resolver.updateResolution());
}
},
},
},
{ "grpc.dns_min_time_between_resolutions_ms": 2000 },
);
resolver.updateResolution();
setTimeout(() => {
assert.strictEqual(resultCount, 2, `resultCount ${resultCount} !== 2`);
done();
}, 10_000);
}, 15_000);
it("should not keep repeating failed resolutions", done => {
const target = resolverManager.mapUriDefaultScheme(parseUri("host.invalid")!)!;
let resultCount = 0;
const resolver = resolverManager.createResolver(
target,
{
onSuccessfulResolution: (
endpointList: Endpoint[],
serviceConfig: ServiceConfig | null,
serviceConfigError: StatusObject | null,
) => {
assert.fail("Resolution succeeded unexpectedly");
},
onError: (error: StatusObject) => {
resultCount += 1;
if (resultCount === 1) {
process.nextTick(() => resolver.updateResolution());
}
},
},
{},
);
resolver.updateResolution();
setTimeout(() => {
assert.strictEqual(resultCount, 2, `resultCount ${resultCount} !== 2`);
done();
}, 10_000);
}, 15_000);
{},
);
resolver.updateResolution();
setTimeout(() => {
assert.strictEqual(resultCount, 2, `resultCount ${resultCount} !== 2`);
done();
}, 10_000);
},
15_000,
);
});
describe("UDS Names", () => {
it("Should handle a relative Unix Domain Socket name", done => {