[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