public_git
/
democratic-csi
mirror of https://github.com/democratic-csi/democratic-csi.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix registry usage 

Signed-off-by: Travis Glenn Hansen <travisghansen@yahoo.com>
This commit is contained in:
Travis Glenn Hansen 2025-04-05 17:53:59 -06:00
parent 957d7fc6bc
commit a032ed3e18
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/driver/controller-synology/http/index.js
View File

@ -4,6 +4,7 @@ const https = require("https");
const { axios_request, stringify } = require("../../../utils/general"); const { axios_request, stringify } = require("../../../utils/general");
const Mutex = require("async-mutex").Mutex; const Mutex = require("async-mutex").Mutex;
const { GrpcError, grpc } = require("../../../utils/grpc"); const { GrpcError, grpc } = require("../../../utils/grpc");
const { Registry } = require("../../../utils/registry");
const USER_AGENT = "democratic-csi"; const USER_AGENT = "democratic-csi";
const __REGISTRY_NS__ = "SynologyHttpClient"; const __REGISTRY_NS__ = "SynologyHttpClient";
@ -84,6 +85,7 @@ class SynologyHttpClient {
this.logger = console; this.logger = console;
this.doLoginMutex = new Mutex(); this.doLoginMutex = new Mutex();
this.apiSerializeMutex = new Mutex(); this.apiSerializeMutex = new Mutex();
this.registry = new Registry();
if (false) { if (false) {
setInterval(() => { setInterval(() => {
@ -94,7 +96,7 @@ class SynologyHttpClient {
} }
getHttpAgent() { getHttpAgent() {
return this.ctx.registry.get(`${__REGISTRY_NS__}:http_agent`, () => { return this.registry.get(`${__REGISTRY_NS__}:http_agent`, () => {
return new http.Agent({ return new http.Agent({
keepAlive: true, keepAlive: true,
maxSockets: Infinity, maxSockets: Infinity,
@ -104,7 +106,7 @@ class SynologyHttpClient {
} }
getHttpsAgent() { getHttpsAgent() {
return this.ctx.registry.get(`${__REGISTRY_NS__}:https_agent`, () => { return this.registry.get(`${__REGISTRY_NS__}:https_agent`, () => {
return new https.Agent({ return new https.Agent({
keepAlive: true, keepAlive: true,
maxSockets: Infinity, maxSockets: Infinity,