Use new proxy address formatter
This commit is contained in:
parent
dd73a8ee9a
commit
f8470fc8f6
|
|
@ -3,6 +3,7 @@ import FrontendManager from './frontendmanager';
|
||||||
import uuid from 'uuid';
|
import uuid from 'uuid';
|
||||||
import PoolEntryUpdater from 'cytube-common/lib/redis/poolentryupdater';
|
import PoolEntryUpdater from 'cytube-common/lib/redis/poolentryupdater';
|
||||||
import JSONProtocol from 'cytube-common/lib/proxy/protocol';
|
import JSONProtocol from 'cytube-common/lib/proxy/protocol';
|
||||||
|
import { formatProxyAddress } from 'cytube-common/lib/util/addressutil';
|
||||||
|
|
||||||
const BACKEND_POOL = 'backend-hosts';
|
const BACKEND_POOL = 'backend-hosts';
|
||||||
|
|
||||||
|
|
@ -28,8 +29,10 @@ export default class IOBackend {
|
||||||
}
|
}
|
||||||
|
|
||||||
initBackendPoolUpdater() {
|
initBackendPoolUpdater() {
|
||||||
|
const hostname = this.proxyListenerConfig.getHost();
|
||||||
|
const port = this.proxyListenerConfig.getPort();
|
||||||
const entry = {
|
const entry = {
|
||||||
address: this.proxyListenerConfig.getHost() + '/' + this.proxyListenerConfig.getPort()
|
address: formatProxyAddress(hostname, port)
|
||||||
}
|
}
|
||||||
this.poolEntryUpdater = new PoolEntryUpdater(
|
this.poolEntryUpdater = new PoolEntryUpdater(
|
||||||
this.poolRedisClient,
|
this.poolRedisClient,
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue