(@NotNull String linkdServiceName, @NotNull Application zeze, @NotNull LinkdProvider linkdProvider, @NotNull LinkdProviderService linkdProviderService, @NotNull LinkdService linkdService, @NotNull LoadConfig loadConfig)
| 48 | public final @NotNull CommandConsoleService commandConsoleService; |
| 49 | |
| 50 | public LinkdApp(@NotNull String linkdServiceName, |
| 51 | @NotNull Application zeze, |
| 52 | @NotNull LinkdProvider linkdProvider, |
| 53 | @NotNull LinkdProviderService linkdProviderService, |
| 54 | @NotNull LinkdService linkdService, |
| 55 | @NotNull LoadConfig loadConfig) { |
| 56 | this.linkdServiceName = linkdServiceName; |
| 57 | this.zeze = zeze; |
| 58 | this.linkdProvider = linkdProvider; |
| 59 | this.linkdProvider.linkdApp = this; |
| 60 | this.linkdProviderService = linkdProviderService; |
| 61 | this.linkdProviderService.linkdApp = this; |
| 62 | this.linkdService = linkdService; |
| 63 | this.linkdService.linkdApp = this; |
| 64 | |
| 65 | this.linkdProvider.distributes = new ProviderDistributeVersion(zeze, loadConfig, linkdProviderService); |
| 66 | this.linkdProvider.RegisterProtocols(this.linkdProviderService); |
| 67 | |
| 68 | this.zeze.getServiceManager().setOnChanged(this::applyOnChanged); |
| 69 | |
| 70 | this.zeze.getServiceManager().setOnSetServerLoad(serverLoad -> { |
| 71 | var ps = this.linkdProviderService.providerSessions.get(serverLoad.getName()); |
| 72 | if (ps != null) { |
| 73 | var bb = ByteBuffer.Wrap(serverLoad.param); |
| 74 | var load = new BLoad(); |
| 75 | load.decode(bb); |
| 76 | ps.load = load; |
| 77 | } |
| 78 | }); |
| 79 | |
| 80 | var kv = this.linkdProviderService.getOnePassiveAddress(); |
| 81 | providerIp = kv.getKey(); |
| 82 | providerPort = kv.getValue(); |
| 83 | |
| 84 | commandConsoleService = new CommandConsoleService("Zeze.Arch.CommandConsole", zeze.getConfig()); |
| 85 | |
| 86 | var agentConf = zeze.getConfig().getServiceConf("LoginQueueAgent"); |
| 87 | if (null != agentConf) { |
| 88 | linkdLoad = new LinkdLoad(this); |
| 89 | } |
| 90 | } |
| 91 | |
| 92 | void applyOnChanged(@NotNull BEditService edit) { |
| 93 | for (var r : edit.getRemove()) { |
nothing calls this directly
no test coverage detected