[JBoss JIRA] (ISPN-387) Enable accessing Hot Rod servers via WebSockets
by Tristan Tarrant (JIRA)
[ https://issues.jboss.org/browse/ISPN-387?page=com.atlassian.jira.plugin.s... ]
Tristan Tarrant updated ISPN-387:
---------------------------------
Component/s: Memcached
> Enable accessing Hot Rod servers via WebSockets
> -----------------------------------------------
>
> Key: ISPN-387
> URL: https://issues.jboss.org/browse/ISPN-387
> Project: Infinispan
> Issue Type: Feature Request
> Components: Memcached, Remote Protocols
> Reporter: Galder Zamarreño
> Assignee: Galder Zamarreño
>
> Add a flag to Hot Rod server configuration so that appropiate Base64 encoder/decoder can be used when interfacing with WebSocket clients. This might also require for Netty WebSocket channel handlers to be set up so that WebSocket upgrade handshaking can be dealt with independent of Hot Rod.
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
6 years, 4 months
[JBoss JIRA] (ISPN-8187) Random failures in Memcached testsuite due to port conflicts
by Tristan Tarrant (JIRA)
[ https://issues.jboss.org/browse/ISPN-8187?page=com.atlassian.jira.plugin.... ]
Tristan Tarrant updated ISPN-8187:
----------------------------------
Component/s: Memcached
> Random failures in Memcached testsuite due to port conflicts
> ------------------------------------------------------------
>
> Key: ISPN-8187
> URL: https://issues.jboss.org/browse/ISPN-8187
> Project: Infinispan
> Issue Type: Bug
> Components: Memcached
> Affects Versions: 9.1.0.Final
> Reporter: Gustavo Fernandes
> Assignee: Gustavo Fernandes
> Labels: testsuite_stability
>
> {noformat}
> [ERROR] testStoreAsBinaryOverride(org.infinispan.server.memcached.MemcachedFunctionalTest) Time elapsed: 0.028 s <<< FAILURE!
> io.netty.channel.unix.Errors$NativeIoException: bind(..) failed: Address already in use
> at io.netty.channel.unix.Errors.newIOException(Errors.java:117)
> at io.netty.channel.unix.Socket.bind(Socket.java:234)
> at io.netty.channel.epoll.EpollServerSocketChannel.doBind(EpollServerSocketChannel.java:91)
> at io.netty.channel.AbstractChannel$AbstractUnsafe.bind(AbstractChannel.java:554)
> at io.netty.channel.DefaultChannelPipeline$HeadContext.bind(DefaultChannelPipeline.java:1258)
> at io.netty.channel.AbstractChannelHandlerContext.invokeBind(AbstractChannelHandlerContext.java:501)
> at io.netty.channel.AbstractChannelHandlerContext.bind(AbstractChannelHandlerContext.java:486)
> at io.netty.channel.DefaultChannelPipeline.bind(DefaultChannelPipeline.java:980)
> at io.netty.channel.AbstractChannel.bind(AbstractChannel.java:250)
> at io.netty.bootstrap.AbstractBootstrap$2.run(AbstractBootstrap.java:365)
> at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
> at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:403)
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:304)
> at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
> at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
> at java.lang.Thread.run(Thread.java:748)
> {noformat}
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
6 years, 4 months
[JBoss JIRA] (ISPN-8576) Add authorization to Distributed Locks
by Tristan Tarrant (JIRA)
Tristan Tarrant created ISPN-8576:
-------------------------------------
Summary: Add authorization to Distributed Locks
Key: ISPN-8576
URL: https://issues.jboss.org/browse/ISPN-8576
Project: Infinispan
Issue Type: Enhancement
Components: Distributed Locks, Security
Reporter: Tristan Tarrant
Assignee: Katia Aresti
Fix For: 9.3.0.Final
DistributedLocks should support authorization.
Namely only ADMIN permissions should be allowed to defineLocks and WRITE permissions should be allowed to manipulate them.
When authorization is enabled, the DistributedLockManager should return SecureClusteredLocks which verify that the user has the required privileges.
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
6 years, 4 months
[JBoss JIRA] (ISPN-8568) ClassNotFoundException with Compat mode and deployed Pojos
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPN-8568?page=com.atlassian.jira.plugin.... ]
Gustavo Fernandes updated ISPN-8568:
------------------------------------
Summary: ClassNotFoundException with Compat mode and deployed Pojos (was: ClassNotFoundException with Compat mode and custom Pojos)
> ClassNotFoundException with Compat mode and deployed Pojos
> ----------------------------------------------------------
>
> Key: ISPN-8568
> URL: https://issues.jboss.org/browse/ISPN-8568
> Project: Infinispan
> Issue Type: Bug
> Affects Versions: 9.2.0.Alpha1
> Reporter: Gustavo Fernandes
> Assignee: Gustavo Fernandes
> Fix For: 9.2.0.Beta2, 9.2.0.Final
>
>
> The cache is configured with:
> {code:xml}
> <cache-container name="local">
> <modules>
> <module name="deployment.myTask.jar"/>
> </modules>
> <local-cache name="compat">
> <compatibility enabled="true"/>
> </local-cache>
> </cache-container>
> {code}
> The {{myTask.jar}} contains Entity.class that is the Pojo to be stored in the cache.
> When doing a
> {code:java}
> remoteCache.put(1, new Entity());
> {code}
> The error is
> {noformat}
> 18:13:42,142 ERROR (main) [TestSuiteProgress] Test failed: LocalServerTestCompatModeIT.shouldRunPriceTask
> org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=9 returned
> server error (status=0x85): java.lang.ClassNotFoundException: org.infinispan.server.test.Entity from [Module "org.infinispan.commons:main" from
> local module loader @4ae82894 (finder: local module finder @543788f3 (roots: /home/gfernandes/github/infinispan/server/integration/testsuite/target/server/node1/modules,/home/gfernandes/github/infinispan/server/integration/testsuite/target/server/node1/modules/system/layers/base))]
> {noformat}
> I noticed that in this case, the Marshaller used is {{GenericJBossMarshaller}} who lives in infinispan-commons, and when asked to de-serialize the pojo in byte[] form, the classloader used is ModuleClassLoader for Module "org.infinispan.commons:main" that does not have visibility of the deployed jar's classes.
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
6 years, 4 months
[JBoss JIRA] (ISPN-8568) ClassNotFoundException with Compat mode and custom Pojos
by Adrian Nistor (JIRA)
[ https://issues.jboss.org/browse/ISPN-8568?page=com.atlassian.jira.plugin.... ]
Adrian Nistor updated ISPN-8568:
--------------------------------
Fix Version/s: 9.2.0.Final
> ClassNotFoundException with Compat mode and custom Pojos
> --------------------------------------------------------
>
> Key: ISPN-8568
> URL: https://issues.jboss.org/browse/ISPN-8568
> Project: Infinispan
> Issue Type: Bug
> Affects Versions: 9.2.0.Alpha1
> Reporter: Gustavo Fernandes
> Assignee: Gustavo Fernandes
> Fix For: 9.2.0.Beta2, 9.2.0.Final
>
>
> The cache is configured with:
> {code:xml}
> <cache-container name="local">
> <modules>
> <module name="deployment.myTask.jar"/>
> </modules>
> <local-cache name="compat">
> <compatibility enabled="true"/>
> </local-cache>
> </cache-container>
> {code}
> The {{myTask.jar}} contains Entity.class that is the Pojo to be stored in the cache.
> When doing a
> {code:java}
> remoteCache.put(1, new Entity());
> {code}
> The error is
> {noformat}
> 18:13:42,142 ERROR (main) [TestSuiteProgress] Test failed: LocalServerTestCompatModeIT.shouldRunPriceTask
> org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=9 returned
> server error (status=0x85): java.lang.ClassNotFoundException: org.infinispan.server.test.Entity from [Module "org.infinispan.commons:main" from
> local module loader @4ae82894 (finder: local module finder @543788f3 (roots: /home/gfernandes/github/infinispan/server/integration/testsuite/target/server/node1/modules,/home/gfernandes/github/infinispan/server/integration/testsuite/target/server/node1/modules/system/layers/base))]
> {noformat}
> I noticed that in this case, the Marshaller used is {{GenericJBossMarshaller}} who lives in infinispan-commons, and when asked to de-serialize the pojo in byte[] form, the classloader used is ModuleClassLoader for Module "org.infinispan.commons:main" that does not have visibility of the deployed jar's classes.
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
6 years, 4 months
[JBoss JIRA] (ISPN-8568) ClassNotFoundException with Compat mode and custom Pojos
by Adrian Nistor (JIRA)
[ https://issues.jboss.org/browse/ISPN-8568?page=com.atlassian.jira.plugin.... ]
Adrian Nistor updated ISPN-8568:
--------------------------------
Status: Resolved (was: Pull Request Sent)
Resolution: Done
Integrated in master. Thanks [~gustavonalle]!
> ClassNotFoundException with Compat mode and custom Pojos
> --------------------------------------------------------
>
> Key: ISPN-8568
> URL: https://issues.jboss.org/browse/ISPN-8568
> Project: Infinispan
> Issue Type: Bug
> Affects Versions: 9.2.0.Alpha1
> Reporter: Gustavo Fernandes
> Assignee: Gustavo Fernandes
> Fix For: 9.2.0.Beta2
>
>
> The cache is configured with:
> {code:xml}
> <cache-container name="local">
> <modules>
> <module name="deployment.myTask.jar"/>
> </modules>
> <local-cache name="compat">
> <compatibility enabled="true"/>
> </local-cache>
> </cache-container>
> {code}
> The {{myTask.jar}} contains Entity.class that is the Pojo to be stored in the cache.
> When doing a
> {code:java}
> remoteCache.put(1, new Entity());
> {code}
> The error is
> {noformat}
> 18:13:42,142 ERROR (main) [TestSuiteProgress] Test failed: LocalServerTestCompatModeIT.shouldRunPriceTask
> org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=9 returned
> server error (status=0x85): java.lang.ClassNotFoundException: org.infinispan.server.test.Entity from [Module "org.infinispan.commons:main" from
> local module loader @4ae82894 (finder: local module finder @543788f3 (roots: /home/gfernandes/github/infinispan/server/integration/testsuite/target/server/node1/modules,/home/gfernandes/github/infinispan/server/integration/testsuite/target/server/node1/modules/system/layers/base))]
> {noformat}
> I noticed that in this case, the Marshaller used is {{GenericJBossMarshaller}} who lives in infinispan-commons, and when asked to de-serialize the pojo in byte[] form, the classloader used is ModuleClassLoader for Module "org.infinispan.commons:main" that does not have visibility of the deployed jar's classes.
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
6 years, 4 months
[JBoss JIRA] (ISPN-8553) Compatibility mode not working with server tasks using Java Streams
by Adrian Nistor (JIRA)
[ https://issues.jboss.org/browse/ISPN-8553?page=com.atlassian.jira.plugin.... ]
Adrian Nistor updated ISPN-8553:
--------------------------------
Status: Resolved (was: Pull Request Sent)
Resolution: Done
Integrated in master. Thanks [~gustavonalle]!
> Compatibility mode not working with server tasks using Java Streams
> -------------------------------------------------------------------
>
> Key: ISPN-8553
> URL: https://issues.jboss.org/browse/ISPN-8553
> Project: Infinispan
> Issue Type: Bug
> Components: Server
> Affects Versions: 9.2.0.Beta1
> Reporter: Galder Zamarreño
> Assignee: Gustavo Fernandes
> Fix For: 9.2.0.Beta2, 9.2.0.Final
>
>
> I have a cache defined as:
> {code}
> <distributed-cache name="analytics">
> <compatibility enabled="true" marshaller="org.infinispan.query.remote.CompatibilityProtoStreamMarshaller"/>
> </distributed-cache>
> {code}
> Then, I have a task like this:
> {code}
> package delays.java.stream.task;
> import java.util.Arrays;
> import java.util.Calendar;
> import java.util.Collections;
> import java.util.Date;
> import java.util.Locale;
> import java.util.Map;
> import java.util.TimeZone;
> import java.util.TreeMap;
> import java.util.stream.Collector;
> import java.util.stream.Collectors;
> import org.infinispan.Cache;
> import org.infinispan.stream.CacheCollectors;
> import org.infinispan.tasks.ServerTask;
> import org.infinispan.tasks.TaskContext;
> import org.infinispan.tasks.TaskExecutionMode;
> import org.infinispan.util.function.SerializableSupplier;
> import delays.java.stream.pojos.Stop;
> public class DelayRatioTask implements ServerTask {
> private TaskContext ctx;
> @Override
> public void setTaskContext(TaskContext ctx) {
> this.ctx = ctx;
> }
> @Override
> public String getName() {
> return "delay-ratio";
> }
> @Override
> public Object call() throws Exception {
> System.out.println("Execute delay-ratio task");
> Cache<String, Stop> cache = getCache();
> Map<Integer, Long> totalPerHour = cache.values().stream()
> .collect(
> serialize(() -> Collectors.groupingBy(
> e -> getHourOfDay(e.departureTs),
> Collectors.counting()
> )));
> Map<Integer, Long> delayedPerHour = cache.values().stream()
> .filter(e -> e.delayMin > 0)
> .collect(
> serialize(() -> Collectors.groupingBy(
> e -> getHourOfDay(e.departureTs),
> Collectors.counting()
> )));
> return Arrays.asList(delayedPerHour, totalPerHour);
> // return Arrays.asList(Collections.emptyMap(), Collections.emptyMap());
> }
> @Override
> public TaskExecutionMode getExecutionMode() {
> return TaskExecutionMode.ONE_NODE;
> }
> @SuppressWarnings("unchecked")
> private <K, V> Cache<K, V> getCache() {
> return (Cache<K, V>) ctx.getCache().get();
> }
> private static <T, R> Collector<T, ?, R> serialize(SerializableSupplier<Collector<T, ?, R>> s) {
> return CacheCollectors.serializableCollector(s);
> }
> private static int getHourOfDay(Date date) {
> Calendar c = Calendar.getInstance(TimeZone.getTimeZone("GMT+1"), Locale.ENGLISH);
> c.setTime(date);
> return c.get(Calendar.HOUR_OF_DAY);
> }
> }
> {code}
> When the groupBy executes, it fails with:
> {code}
> java.lang.AssertionError: org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=333 returned server error (status=0x85): java.util.concurrent.ExecutionException: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
> java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
> at delays.java.stream.AnalyticsUtil.timed(AnalyticsUtil.java:16)
> at delays.java.stream.AnalyticsVerticle.getDelaysRatio(AnalyticsVerticle.java:72)
> at io.vertx.ext.web.impl.BlockingHandlerDecorator.lambda$handle$0(BlockingHandlerDecorator.java:48)
> at io.vertx.core.impl.ContextImpl.lambda$executeBlocking$1(ContextImpl.java:271)
> at io.vertx.core.impl.TaskQueue.lambda$new$0(TaskQueue.java:60)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=333 returned server error (status=0x85): java.util.concurrent.ExecutionException: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
> java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
> at org.infinispan.client.hotrod.impl.protocol.Codec20.checkForErrorsInResponseStatus(Codec20.java:363)
> at org.infinispan.client.hotrod.impl.protocol.Codec20.readPartialHeader(Codec20.java:152)
> at org.infinispan.client.hotrod.impl.protocol.Codec20.readHeader(Codec20.java:138)
> at org.infinispan.client.hotrod.impl.operations.HotRodOperation.readHeaderAndValidate(HotRodOperation.java:60)
> at org.infinispan.client.hotrod.impl.operations.ExecuteOperation.executeOperation(ExecuteOperation.java:50)
> at org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation.execute(RetryOnFailureOperation.java:56)
> at org.infinispan.client.hotrod.impl.RemoteCacheImpl.execute(RemoteCacheImpl.java:542)
> at delays.java.stream.AnalyticsVerticle.lambda$getDelaysRatio$1(AnalyticsVerticle.java:73)
> at delays.java.stream.AnalyticsUtil.timed(AnalyticsUtil.java:14)
> ... 7 more
> {code}
> This is coming from:
> {code}
> 10:36:18,765 WARN [org.infinispan.remoting.inboundhandler.NonTotalOrderPerCacheInboundInvocationHandler] (remote-thread--p2-t22) ISPN000071: Caught exception when handling command StreamRequestCommand{type=TERMINAL_REHASH, includeLoader=true, terminalOperation=org.infinispan.stream.impl.termop.SegmentRetryingOperation@1b024f9, topologyId=9, id=datagrid-1-bmspw0, segments=[128, 130, 6, 135, 137, 138, 11, 12, 140, 13, 143, 16, 144, 17, 146, 22, 152, 155, 28, 29, 31, 36, 37, 41, 42, 44, 172, 173, 177, 178, 179, 181, 183, 57, 185, 60, 61, 189, 64, 192, 65, 193, 66, 197, 201, 75, 204, 207, 80, 208, 82, 83, 84, 212, 85, 86, 89, 92, 96, 225, 98, 226, 99, 100, 101, 102, 231, 105, 233, 234, 107, 108, 237, 112, 242, 115, 246, 247, 120, 251, 124, 125, 253, 255], keys=[], excludedKeys=[]}: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
> at java.util.stream.Collectors.lambda$groupingBy$45(Collectors.java:907)
> at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169)
> at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
> at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
> at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
> at java.util.Spliterators$IteratorSpliterator.tryAdvance(Spliterators.java:1812)
> at org.infinispan.commons.util.Closeables$SpliteratorAsCloseableSpliterator.tryAdvance(Closeables.java:144)
> at java.util.Spliterator.forEachRemaining(Spliterator.java:326)
> at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481)
> at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471)
> at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
> at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
> at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499)
> at org.infinispan.stream.impl.local.LocalCacheStream.collect(LocalCacheStream.java:259)
> at org.infinispan.stream.impl.TerminalFunctions$CollectorFunction.apply(TerminalFunctions.java:1093)
> at org.infinispan.stream.impl.TerminalFunctions$CollectorFunction.apply(TerminalFunctions.java:1083)
> at org.infinispan.stream.impl.termop.SegmentRetryingOperation.innerPerformOperation(SegmentRetryingOperation.java:68)
> at org.infinispan.stream.impl.termop.SegmentRetryingOperation.performOperation(SegmentRetryingOperation.java:79)
> at org.infinispan.stream.impl.LocalStreamManagerImpl.streamOperationRehashAware(LocalStreamManagerImpl.java:302)
> at org.infinispan.stream.impl.StreamRequestCommand.invokeAsync(StreamRequestCommand.java:96)
> at org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler.invokeCommand(BasePerCacheInboundInvocationHandler.java:102)
> at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.invoke(BaseBlockingRunnable.java:99)
> at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.runAsync(BaseBlockingRunnable.java:71)
> at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.run(BaseBlockingRunnable.java:40)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> {code}
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
6 years, 4 months
[JBoss JIRA] (ISPN-7705) Administration console - greyed out cluster action can still be selected
by Roman Macor (JIRA)
[ https://issues.jboss.org/browse/ISPN-7705?page=com.atlassian.jira.plugin.... ]
Roman Macor reopened ISPN-7705:
-------------------------------
The node operations work correctly, but the cluster operations are greyed out when they should not be.
Steps to reproduce:
click on clusters tab -> cluster -> Actions
Result:
Reload and Restart are greyed out and cannot be clicked
Expected result:
Reload and Restart should be available, only Start should be greyed out
> Administration console - greyed out cluster action can still be selected
> ------------------------------------------------------------------------
>
> Key: ISPN-7705
> URL: https://issues.jboss.org/browse/ISPN-7705
> Project: Infinispan
> Issue Type: Bug
> Components: JMX, reporting and management
> Affects Versions: 9.0.0.Final
> Reporter: Roman Macor
> Assignee: Vladimir Blagojevic
> Priority: Minor
> Fix For: 9.0.1.Final, 9.1.0.Final
>
>
> When the cluster is in the running state, start, reload and restart actions are greyed out, but they can still be clicked and the selected action is performed.
> This is not the case for the node operations.
> Also, shouldn't restart action be available when server/node are in running state?
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
6 years, 4 months