MCPcopy Create free account
hub / github.com/e2wugui/zeze / LinkdApp

Method LinkdApp

ZezeJava/ZezeJava/src/main/java/Zeze/Arch/LinkdApp.java:50–90  ·  view source on GitHub ↗
(@NotNull String linkdServiceName,
					@NotNull Application zeze,
					@NotNull LinkdProvider linkdProvider,
					@NotNull LinkdProviderService linkdProviderService,
					@NotNull LinkdService linkdService,
					@NotNull LoadConfig loadConfig)

Source from the content-addressed store, hash-verified

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()) {

Callers

nothing calls this directly

Calls 13

WrapMethod · 0.95
decodeMethod · 0.95
setOnChangedMethod · 0.80
setOnSetServerLoadMethod · 0.80
getOnePassiveAddressMethod · 0.80
getServiceConfMethod · 0.80
getMethod · 0.65
getNameMethod · 0.65
getKeyMethod · 0.65
getValueMethod · 0.65
RegisterProtocolsMethod · 0.45
getServiceManagerMethod · 0.45

Tested by

no test coverage detected