[infinispan-issues] [JBoss JIRA] (ISPN-10661) Avoid blocking IO threads on CacheInputStream
Gustavo Fernandes (Jira)
issues at jboss.org
Wed Sep 25 10:20:00 EDT 2019
[ https://issues.jboss.org/browse/ISPN-10661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gustavo Fernandes updated ISPN-10661:
-------------------------------------
Description:
As part of ISPN-10376, the REST server is serving keys using Netty's {{ChunkedWriteHandler}} that will convert a InputStream into chunks and will write it to the client.
As the source of the InputStream is a CacheStream, that can block, it's desirable to do the retrieval of the cache data in a separate thread, using the suspend and resume capabilities of the {{ChunkedWriteHandler}} when data is available
[https://netty.io/4.0/api/io/netty/handler/stream/ChunkedWriteHandler.html#resumeTransfer--|https://netty.io/4.0/api/io/netty/handler/stream/ChunkedWriteHandler.html#resumeTransfer--]
was:
As part of ISPN-10376, the REST server is serving keys using Netty's {{ChunkedWriteHandler}} that will convert a InputStream into chunks and will write it to the client.
As the source of the InputStream is a CacheStream, that can block, it's desirable to do the retrieval of the cache data in a separate thread, using the suspend and resume capabilities of the {{ChunkedWriteHandler}} when data is available
https://netty.io/4.0/api/io/netty/handler/strea/ChunkedWriteHandler.html#resumeTransfer--
> Avoid blocking IO threads on CacheInputStream
> ---------------------------------------------
>
> Key: ISPN-10661
> URL: https://issues.jboss.org/browse/ISPN-10661
> Project: Infinispan
> Issue Type: Enhancement
> Components: REST
> Reporter: Gustavo Fernandes
> Assignee: Gustavo Fernandes
> Priority: Major
>
> As part of ISPN-10376, the REST server is serving keys using Netty's {{ChunkedWriteHandler}} that will convert a InputStream into chunks and will write it to the client.
> As the source of the InputStream is a CacheStream, that can block, it's desirable to do the retrieval of the cache data in a separate thread, using the suspend and resume capabilities of the {{ChunkedWriteHandler}} when data is available
> [https://netty.io/4.0/api/io/netty/handler/stream/ChunkedWriteHandler.html#resumeTransfer--|https://netty.io/4.0/api/io/netty/handler/stream/ChunkedWriteHandler.html#resumeTransfer--]
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
More information about the infinispan-issues
mailing list