[JBoss JIRA] (ISPN-6371) Limit unboxing of Integer values in Distributed Streams
by William Burns (JIRA)
[ https://issues.jboss.org/browse/ISPN-6371?page=com.atlassian.jira.plugin.... ]
William Burns updated ISPN-6371:
--------------------------------
Status: Open (was: New)
> Limit unboxing of Integer values in Distributed Streams
> -------------------------------------------------------
>
> Key: ISPN-6371
> URL: https://issues.jboss.org/browse/ISPN-6371
> Project: Infinispan
> Issue Type: Enhancement
> Affects Versions: 8.2.0.Final
> Reporter: William Burns
> Assignee: William Burns
> Fix For: 9.0.0.Alpha1
>
>
> Currently when a distributed stream filters entries it has to check the segment. Unfortunately each check of the segment requires unboxing an Integer value. If we instead unbox all of the Integers into something like a BitSet we won't incur this cost per entry and instead it will be limited by how many segments we have.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years
[JBoss JIRA] (ISPN-6371) Limit unboxing of Integer values in Distributed Streams
by William Burns (JIRA)
[ https://issues.jboss.org/browse/ISPN-6371?page=com.atlassian.jira.plugin.... ]
William Burns updated ISPN-6371:
--------------------------------
Summary: Limit unboxing of Integer values in Distributed Streams (was: Limit boxing of Integer values in Distributed Streams)
> Limit unboxing of Integer values in Distributed Streams
> -------------------------------------------------------
>
> Key: ISPN-6371
> URL: https://issues.jboss.org/browse/ISPN-6371
> Project: Infinispan
> Issue Type: Enhancement
> Affects Versions: 8.2.0.Final
> Reporter: William Burns
> Assignee: William Burns
> Fix For: 9.0.0.Alpha1
>
>
> Currently when a distributed stream filters entries it has to check the segment. Unfortunately each check of the segment requires unboxing an Integer value. If we instead unbox all of the Integers into something like a BitSet we won't incur this cost per entry and instead it will be limited by how many segments we have.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years
[JBoss JIRA] (ISPN-6371) Limit boxing of Integer values in Distributed Streams
by William Burns (JIRA)
[ https://issues.jboss.org/browse/ISPN-6371?page=com.atlassian.jira.plugin.... ]
William Burns updated ISPN-6371:
--------------------------------
Summary: Limit boxing of Integer values in Distributed Streams (was: Use BitSet for segment filter to limit unboxing for every element)
> Limit boxing of Integer values in Distributed Streams
> -----------------------------------------------------
>
> Key: ISPN-6371
> URL: https://issues.jboss.org/browse/ISPN-6371
> Project: Infinispan
> Issue Type: Enhancement
> Affects Versions: 8.2.0.Final
> Reporter: William Burns
> Assignee: William Burns
> Fix For: 9.0.0.Alpha1
>
>
> Currently when a distributed stream filters entries it has to check the segment. Unfortunately each check of the segment requires unboxing an Integer value. If we instead unbox all of the Integers into something like a BitSet we won't incur this cost per entry and instead it will be limited by how many segments we have.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years
[JBoss JIRA] (ISPN-6371) Use BitSet for segment filter to limit unboxing for every element
by William Burns (JIRA)
William Burns created ISPN-6371:
-----------------------------------
Summary: Use BitSet for segment filter to limit unboxing for every element
Key: ISPN-6371
URL: https://issues.jboss.org/browse/ISPN-6371
Project: Infinispan
Issue Type: Enhancement
Affects Versions: 8.2.0.Final
Reporter: William Burns
Assignee: William Burns
Fix For: 9.0.0.Alpha1
Currently when a distributed stream filters entries it has to check the segment. Unfortunately each check of the segment requires unboxing an Integer value. If we instead unbox all of the Integers into something like a BitSet we won't incur this cost per entry and instead it will be limited by how many segments we have.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years
[JBoss JIRA] (ISPN-6272) Extend CacheStream interface to allow for Serializable lambdas
by Dan Berindei (JIRA)
[ https://issues.jboss.org/browse/ISPN-6272?page=com.atlassian.jira.plugin.... ]
Dan Berindei updated ISPN-6272:
-------------------------------
Status: Resolved (was: Pull Request Sent)
Resolution: Done
> Extend CacheStream interface to allow for Serializable lambdas
> --------------------------------------------------------------
>
> Key: ISPN-6272
> URL: https://issues.jboss.org/browse/ISPN-6272
> Project: Infinispan
> Issue Type: Enhancement
> Components: Distributed Execution and Map/Reduce
> Reporter: William Burns
> Assignee: William Burns
> Fix For: 9.0.0.Alpha1
>
>
> Recently it was found that we could add multiple overrides of a method where it was using a FunctionalInterface but also make that interface extend Serializable. This would allow for provided lambdas to be instantly serializable since the JVM will pick the most specific argument.
> Example:
> {code}
> CacheStream filter(Predicate<? super R> predicate);
> {code}
> vs
> {code}
> CacheStream filter(SerializablePredicate<? super R> predicate);
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years
[JBoss JIRA] (ISPN-6357) Deadlock during server start
by William Burns (JIRA)
[ https://issues.jboss.org/browse/ISPN-6357?page=com.atlassian.jira.plugin.... ]
William Burns updated ISPN-6357:
--------------------------------
Status: Resolved (was: Pull Request Sent)
Fix Version/s: 9.0.0.Alpha1
8.2.1.Final
Resolution: Done
> Deadlock during server start
> ----------------------------
>
> Key: ISPN-6357
> URL: https://issues.jboss.org/browse/ISPN-6357
> Project: Infinispan
> Issue Type: Bug
> Components: Core, Server
> Affects Versions: 8.2.0.Final
> Reporter: Gustavo Fernandes
> Assignee: Dan Berindei
> Priority: Critical
> Fix For: 9.0.0.Alpha1, 8.2.1.Final
>
> Attachments: s0.txt, s1.txt, server1.txt, server2.txt
>
>
> This happens frequently when starting servers in parallel, the more servers, the easier to reproduce.
> Attached the stack trace of server1 and server2 after hanging.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years
[JBoss JIRA] (ISPN-6368) Race condition in InternalCacheRegistryImpl.registerInternalCache
by Adrian Nistor (JIRA)
[ https://issues.jboss.org/browse/ISPN-6368?page=com.atlassian.jira.plugin.... ]
Adrian Nistor updated ISPN-6368:
--------------------------------
Affects Version/s: 8.2.0.Final
8.1.0.Final
> Race condition in InternalCacheRegistryImpl.registerInternalCache
> -----------------------------------------------------------------
>
> Key: ISPN-6368
> URL: https://issues.jboss.org/browse/ISPN-6368
> Project: Infinispan
> Issue Type: Bug
> Components: Core
> Affects Versions: 8.1.0.Final, 8.2.0.Final
> Reporter: Adrian Nistor
> Assignee: Adrian Nistor
> Fix For: 9.0.0.Final, 9.0.0.Alpha1, 8.1.3.Final, 8.2.1.Final
>
>
> Access to internalCaches set can cause race conditions and errors related to duplicate cache definitions can be mistakenly reported.
> {code}
> 17:51:40,668 ERROR [org.jboss.msc.service.fail] (MSC service thread 1-3) MSC000001: Failed to start service jboss.datagrid-infinispan.clustered.disttestcache: org.jboss.msc.service.StartException in service jboss.datagrid-infinispan.clustered.disttestcache: Failed to start service
> at org.jboss.msc.service.ServiceControllerImpl$StartTask.run(ServiceControllerImpl.java:1904)
> 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.commons.CacheConfigurationException: ISPN000358: A cache configuration named ___query_known_classes already exists. This cannot be configured externally by the user.
> at org.infinispan.registry.impl.InternalCacheRegistryImpl.registerInternalCache(InternalCacheRegistryImpl.java:56)
> at org.infinispan.registry.impl.InternalCacheRegistryImpl.registerInternalCache(InternalCacheRegistryImpl.java:49)
> at org.infinispan.query.backend.QueryKnownClasses.startInternalCache(QueryKnownClasses.java:219)
> at org.infinispan.query.backend.QueryKnownClasses.start(QueryKnownClasses.java:119)
> at org.infinispan.query.backend.QueryInterceptor.start(QueryInterceptor.java:129)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at org.infinispan.commons.util.ReflectionUtil.invokeAccessibly(ReflectionUtil.java:168)
> at org.infinispan.factories.AbstractComponentRegistry$PrioritizedMethod.invoke(AbstractComponentRegistry.java:859)
> at org.infinispan.factories.AbstractComponentRegistry.invokeStartMethods(AbstractComponentRegistry.java:628)
> at org.infinispan.factories.AbstractComponentRegistry.internalStart(AbstractComponentRegistry.java:617)
> at org.infinispan.factories.AbstractComponentRegistry.start(AbstractComponentRegistry.java:542)
> at org.infinispan.factories.ComponentRegistry.start(ComponentRegistry.java:238)
> at org.infinispan.cache.impl.CacheImpl.start(CacheImpl.java:849)
> at org.infinispan.manager.DefaultCacheManager.wireAndStartCache(DefaultCacheManager.java:635)
> at org.infinispan.manager.DefaultCacheManager.createCache(DefaultCacheManager.java:585)
> at org.infinispan.manager.DefaultCacheManager.getCache(DefaultCacheManager.java:451)
> at org.infinispan.manager.impl.AbstractDelegatingEmbeddedCacheManager.getCache(AbstractDelegatingEmbeddedCacheManager.java:133)
> at org.infinispan.server.infinispan.SecurityActions$5.run(SecurityActions.java:130)
> at org.infinispan.server.infinispan.SecurityActions$5.run(SecurityActions.java:127)
> at org.infinispan.security.Security.doPrivileged(Security.java:76)
> at org.infinispan.server.infinispan.SecurityActions.doPrivileged(SecurityActions.java:63)
> at org.infinispan.server.infinispan.SecurityActions.startCache(SecurityActions.java:135)
> at org.jboss.as.clustering.infinispan.subsystem.CacheService.start(CacheService.java:86)
> at org.jboss.msc.service.ServiceControllerImpl$StartTask.startService(ServiceControllerImpl.java:1948)
> at org.jboss.msc.service.ServiceControllerImpl$StartTask.run(ServiceControllerImpl.java:1881)
> ... 3 more
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years
[JBoss JIRA] (ISPN-6368) Race condition in InternalCacheRegistryImpl.registerInternalCache
by Adrian Nistor (JIRA)
[ https://issues.jboss.org/browse/ISPN-6368?page=com.atlassian.jira.plugin.... ]
Adrian Nistor reassigned ISPN-6368:
-----------------------------------
Assignee: Adrian Nistor
> Race condition in InternalCacheRegistryImpl.registerInternalCache
> -----------------------------------------------------------------
>
> Key: ISPN-6368
> URL: https://issues.jboss.org/browse/ISPN-6368
> Project: Infinispan
> Issue Type: Bug
> Components: Core
> Reporter: Adrian Nistor
> Assignee: Adrian Nistor
> Fix For: 9.0.0.Final, 9.0.0.Alpha1, 8.1.3.Final, 8.2.1.Final
>
>
> Access to internalCaches set can cause race conditions and errors related to duplicate cache definitions can be mistakenly reported.
> {code}
> 17:51:40,668 ERROR [org.jboss.msc.service.fail] (MSC service thread 1-3) MSC000001: Failed to start service jboss.datagrid-infinispan.clustered.disttestcache: org.jboss.msc.service.StartException in service jboss.datagrid-infinispan.clustered.disttestcache: Failed to start service
> at org.jboss.msc.service.ServiceControllerImpl$StartTask.run(ServiceControllerImpl.java:1904)
> 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.commons.CacheConfigurationException: ISPN000358: A cache configuration named ___query_known_classes already exists. This cannot be configured externally by the user.
> at org.infinispan.registry.impl.InternalCacheRegistryImpl.registerInternalCache(InternalCacheRegistryImpl.java:56)
> at org.infinispan.registry.impl.InternalCacheRegistryImpl.registerInternalCache(InternalCacheRegistryImpl.java:49)
> at org.infinispan.query.backend.QueryKnownClasses.startInternalCache(QueryKnownClasses.java:219)
> at org.infinispan.query.backend.QueryKnownClasses.start(QueryKnownClasses.java:119)
> at org.infinispan.query.backend.QueryInterceptor.start(QueryInterceptor.java:129)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at org.infinispan.commons.util.ReflectionUtil.invokeAccessibly(ReflectionUtil.java:168)
> at org.infinispan.factories.AbstractComponentRegistry$PrioritizedMethod.invoke(AbstractComponentRegistry.java:859)
> at org.infinispan.factories.AbstractComponentRegistry.invokeStartMethods(AbstractComponentRegistry.java:628)
> at org.infinispan.factories.AbstractComponentRegistry.internalStart(AbstractComponentRegistry.java:617)
> at org.infinispan.factories.AbstractComponentRegistry.start(AbstractComponentRegistry.java:542)
> at org.infinispan.factories.ComponentRegistry.start(ComponentRegistry.java:238)
> at org.infinispan.cache.impl.CacheImpl.start(CacheImpl.java:849)
> at org.infinispan.manager.DefaultCacheManager.wireAndStartCache(DefaultCacheManager.java:635)
> at org.infinispan.manager.DefaultCacheManager.createCache(DefaultCacheManager.java:585)
> at org.infinispan.manager.DefaultCacheManager.getCache(DefaultCacheManager.java:451)
> at org.infinispan.manager.impl.AbstractDelegatingEmbeddedCacheManager.getCache(AbstractDelegatingEmbeddedCacheManager.java:133)
> at org.infinispan.server.infinispan.SecurityActions$5.run(SecurityActions.java:130)
> at org.infinispan.server.infinispan.SecurityActions$5.run(SecurityActions.java:127)
> at org.infinispan.security.Security.doPrivileged(Security.java:76)
> at org.infinispan.server.infinispan.SecurityActions.doPrivileged(SecurityActions.java:63)
> at org.infinispan.server.infinispan.SecurityActions.startCache(SecurityActions.java:135)
> at org.jboss.as.clustering.infinispan.subsystem.CacheService.start(CacheService.java:86)
> at org.jboss.msc.service.ServiceControllerImpl$StartTask.startService(ServiceControllerImpl.java:1948)
> at org.jboss.msc.service.ServiceControllerImpl$StartTask.run(ServiceControllerImpl.java:1881)
> ... 3 more
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years
[JBoss JIRA] (ISPN-6368) Race condition in InternalCacheRegistryImpl.registerInternalCache
by Adrian Nistor (JIRA)
[ https://issues.jboss.org/browse/ISPN-6368?page=com.atlassian.jira.plugin.... ]
Adrian Nistor updated ISPN-6368:
--------------------------------
Status: Open (was: New)
> Race condition in InternalCacheRegistryImpl.registerInternalCache
> -----------------------------------------------------------------
>
> Key: ISPN-6368
> URL: https://issues.jboss.org/browse/ISPN-6368
> Project: Infinispan
> Issue Type: Bug
> Components: Core
> Reporter: Adrian Nistor
> Assignee: Adrian Nistor
> Fix For: 9.0.0.Final, 9.0.0.Alpha1, 8.1.3.Final, 8.2.1.Final
>
>
> Access to internalCaches set can cause race conditions and errors related to duplicate cache definitions can be mistakenly reported.
> {code}
> 17:51:40,668 ERROR [org.jboss.msc.service.fail] (MSC service thread 1-3) MSC000001: Failed to start service jboss.datagrid-infinispan.clustered.disttestcache: org.jboss.msc.service.StartException in service jboss.datagrid-infinispan.clustered.disttestcache: Failed to start service
> at org.jboss.msc.service.ServiceControllerImpl$StartTask.run(ServiceControllerImpl.java:1904)
> 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.commons.CacheConfigurationException: ISPN000358: A cache configuration named ___query_known_classes already exists. This cannot be configured externally by the user.
> at org.infinispan.registry.impl.InternalCacheRegistryImpl.registerInternalCache(InternalCacheRegistryImpl.java:56)
> at org.infinispan.registry.impl.InternalCacheRegistryImpl.registerInternalCache(InternalCacheRegistryImpl.java:49)
> at org.infinispan.query.backend.QueryKnownClasses.startInternalCache(QueryKnownClasses.java:219)
> at org.infinispan.query.backend.QueryKnownClasses.start(QueryKnownClasses.java:119)
> at org.infinispan.query.backend.QueryInterceptor.start(QueryInterceptor.java:129)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at org.infinispan.commons.util.ReflectionUtil.invokeAccessibly(ReflectionUtil.java:168)
> at org.infinispan.factories.AbstractComponentRegistry$PrioritizedMethod.invoke(AbstractComponentRegistry.java:859)
> at org.infinispan.factories.AbstractComponentRegistry.invokeStartMethods(AbstractComponentRegistry.java:628)
> at org.infinispan.factories.AbstractComponentRegistry.internalStart(AbstractComponentRegistry.java:617)
> at org.infinispan.factories.AbstractComponentRegistry.start(AbstractComponentRegistry.java:542)
> at org.infinispan.factories.ComponentRegistry.start(ComponentRegistry.java:238)
> at org.infinispan.cache.impl.CacheImpl.start(CacheImpl.java:849)
> at org.infinispan.manager.DefaultCacheManager.wireAndStartCache(DefaultCacheManager.java:635)
> at org.infinispan.manager.DefaultCacheManager.createCache(DefaultCacheManager.java:585)
> at org.infinispan.manager.DefaultCacheManager.getCache(DefaultCacheManager.java:451)
> at org.infinispan.manager.impl.AbstractDelegatingEmbeddedCacheManager.getCache(AbstractDelegatingEmbeddedCacheManager.java:133)
> at org.infinispan.server.infinispan.SecurityActions$5.run(SecurityActions.java:130)
> at org.infinispan.server.infinispan.SecurityActions$5.run(SecurityActions.java:127)
> at org.infinispan.security.Security.doPrivileged(Security.java:76)
> at org.infinispan.server.infinispan.SecurityActions.doPrivileged(SecurityActions.java:63)
> at org.infinispan.server.infinispan.SecurityActions.startCache(SecurityActions.java:135)
> at org.jboss.as.clustering.infinispan.subsystem.CacheService.start(CacheService.java:86)
> at org.jboss.msc.service.ServiceControllerImpl$StartTask.startService(ServiceControllerImpl.java:1948)
> at org.jboss.msc.service.ServiceControllerImpl$StartTask.run(ServiceControllerImpl.java:1881)
> ... 3 more
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years