Vladsz83 commented on code in PR #11003:
URL: https://github.com/apache/ignite/pull/11003#discussion_r1374760279
##########
modules/core/src/main/java/org/apache/ignite/internal/client/thin/ClientServicesImpl.java:
##########
@@ -281,6 +344,96 @@ else if
(ch.clientChannel().protocolCtx().isFeatureSupported(ProtocolBitmaskFeat
}
}
+ /**
+ * Asynchronously requests the service topology if the partition awareness
is enabled and if the update is requred.
+ *
+ * @param srvcTop If not {@code null}, uses this service topology record
and ignores {@code name}.
+ * @param name If {@code srvTop} is {@code null}, gets service topology
record by this name.
+ * @see #needUpdateSrvcTop(ServiceTopology, AffinityTopologyVersion)
+ */
+ private void tryRequestServiceTopology(@Nullable ServiceTopology srvcTop,
String name) {
+ if (srvcTop == null) {
+ srvcTop = servicesTopologies.compute(name, (nm, t) -> {
+ if (t == null)
+ t = new ServiceTopology();
+
+ return t;
+ });
+ }
+
+ ServiceTopology srvcTop0 = srvcTop;
+
+ AffinityTopologyVersion curAffTop =
ch.affinityContext().lastTopology().version();
+
+ if (!needUpdateSrvcTop(srvcTop0, curAffTop))
+ return;
+
+ ForkJoinPool.commonPool().execute(() -> {
+ Throwable t = null;
+
+ try {
+ if (log.isDebugEnabled())
+ log.debug("Requesting service topology update for the
service '" + name + "' ...");
+
+ List<UUID> nodes = ch.service(
+ ClientOperation.SERVICE_GET_TOPOLOGY,
+ req -> {
+ if
(!req.clientChannel().protocolCtx().isFeatureSupported(ProtocolBitmaskFeature.SERVICE_TOPOLOGY))
+ throw new
ClientFeatureNotSupportedByServerException(ProtocolBitmaskFeature.SERVICE_TOPOLOGY);
Review Comment:
How could I check it before using? I see `isFeatureSupported` applies when
trying to send something.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@ignite.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
