提交 6448d361 编写于 作者: R Rajan 提交者: Matteo Merli

signSafeMod while getNextBroker index (#141)

上级 710755ff
...@@ -15,6 +15,8 @@ ...@@ -15,6 +15,8 @@
*/ */
package com.yahoo.pulsar.discovery.service.web; package com.yahoo.pulsar.discovery.service.web;
import static org.apache.bookkeeper.util.MathUtils.signSafeMod;
import java.io.IOException; import java.io.IOException;
import java.net.URI; import java.net.URI;
import java.net.URISyntaxException; import java.net.URISyntaxException;
...@@ -151,7 +153,7 @@ public class DiscoveryServiceServlet extends HttpServlet { ...@@ -151,7 +153,7 @@ public class DiscoveryServiceServlet extends HttpServlet {
throw new RestException(Status.SERVICE_UNAVAILABLE, "No active broker is available"); throw new RestException(Status.SERVICE_UNAVAILABLE, "No active broker is available");
} else { } else {
int brokersCount = availableBrokers.size(); int brokersCount = availableBrokers.size();
int nextIdx = Math.abs(counter.getAndIncrement()) % brokersCount; int nextIdx = signSafeMod(counter.getAndIncrement(), brokersCount);
return availableBrokers.get(nextIdx); return availableBrokers.get(nextIdx);
} }
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册