Skip to content

Instantly share code, notes, and snippets.

View DanielFroehlich's full-sized avatar

Daniel Froehlich DanielFroehlich

View GitHub Profile
---------------- Quarkus Client failing:
2019-10-19 15:51:46,359 INFO [io.qua.dep.QuarkusAugmentor] (main) Quarkus augmentation completed in 608ms
2019-10-19 15:52:46,655 INFO [org.inf.cli.hot.RemoteCacheManager] (main) ISPN004021: Infinispan version: 10.0.0.CR1
org.infinispan.client.hotrod.exceptions.TransportException:: java.net.SocketTimeoutException: FaultTolerantPingOperation{___protobuf_metadata, flags=0} timed out after 60000 ms
at org.infinispan.client.hotrod.impl.Util.rewrap(Util.java:79)
at org.infinispan.client.hotrod.impl.Util.await(Util.java:52)
at org.infinispan.client.hotrod.impl.RemoteCacheImpl.ping(RemoteCacheImpl.java:542)
at org.infinispan.client.hotrod.impl.RemoteCacheImpl.resolveStorage(RemoteCacheImpl.java:850)
at org.infinispan.client.hotrod.RemoteCacheManager.createRemoteCache(RemoteCacheManager.java:435)
@DanielFroehlich
DanielFroehlich / dedupe.java
Created June 4, 2020 17:07
rhdg de-dedupe segments
private int lastTopologyId = -1;
private Collection<Set<Integer>> lastListOfSegmentsPerServer = null;
/** Get a duplicate free list of segments per server.
* getSegmentPerServer contains primary and secondary segments. For a cache with numOwners>1, this means
* a single segment is located at multiple severs. If you want to access distinct segments (e.g. for dumping the
* whole cache), these duplicates need to be removed. That is done by this method.
* @param cacheTopologyInfo topology of cache as returned by RemoteCache.getCacheTopologyInfo()
* @return Collection of sets - for each server, a set of duplicate free segment numbers.
*/