-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/38440/
-----------------------------------------------------------
(Updated Sept. 17, 2015, 4:47 p.m.)
Review request for geode, Bruce Schuchardt and Kirk Lund.
Changes
-------
Kirk had pointed out that the async close code did not really make sense in the
SocketCreator class.
So I split it out into the new SocketCloser. This should make it easier to unit
test.
Also now both CacheClientNotifier and ConnectionTable have their own
SocketCloser instead of trying to share a static one.
This cleans up the close logic and allows the CacheClientNotifier to have
smaller thread pools.
Bugs: GEODE-332
https://issues.apache.org/jira/browse/GEODE-332
Repository: geode
Description
-------
The changes in SocketCreator.java are for pooling of async close
(ConnectionTable also calls closeAsyncThreadExecutor).
The changes in Connection.java and ConnectionTable.java are for pooling of p2p
reader threads.
The async close thread pool will use at most 32 threads to do socket closes.
Once all 32 threads are busy the unlimited LinkedBlockingQueue starts queuing
close requests. The number of threads can be changed from 32 by using the
"p2p.ASYNC_CLOSE_POOL_MAX_THREADS" system property.
If a thread in this pool is not used for 120 seconds it will timeout (this
timeout can be changed using the "p2p.ASYNC_CLOSE_POOL_KEEP_ALIVE_TIME" system
property).
The threads requesting a socket close will not wait for the close to complete.
The previous code (that created a thread for every request) waited 50ms for the
request to complete. This can be enabled using the
"p2p.ASYNC_CLOSE_WAIT_MILLISECONDS" system property.
The p2p reader thread pool has an unlimited number of threads. The pool is used
anytime a peer connects to us to create a p2p reader for his sender. It is also
used on the sender side to do the initial handshake when connecting.
If a thread in this pool is not used for 120 seconds it will timeout (this
timeout can be changed using the "p2p.READER_POOL_KEEP_ALIVE_TIME" system
property).
Diffs (updated)
-----
gemfire-core/src/main/java/com/gemstone/gemfire/internal/SocketCloser.java
PRE-CREATION
gemfire-core/src/main/java/com/gemstone/gemfire/internal/SocketCreator.java
ff4a22c08f909b731a3a70fa39a893cb5fc0015a
gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientNotifier.java
2cede256f4fd26e46478c459ea5c7ada00161f2f
gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxy.java
15f83bb344e453caaad6269ffd63a28f166a02b6
gemfire-core/src/main/java/com/gemstone/gemfire/internal/tcp/Connection.java
cd1b7dc998df343a1e035fb9cb68f071073d362c
gemfire-core/src/main/java/com/gemstone/gemfire/internal/tcp/ConnectionTable.java
9beb947dfc130634f60022d7385c24e985acab4b
Diff: https://reviews.apache.org/r/38440/diff/
Testing
-------
precheckin
Thanks,
Darrel Schneider
