Comments (3)
The issue seems to be in this
rlp_03/src/main/java/com/teragrep/rlp_03/RelpServerPlainSocket.java
Lines 101 to 106 in 8537321
Write should also be handled in
rlp_03/src/main/java/com/teragrep/rlp_03/RelpServerPlainSocket.java
Lines 130 to 135 in 8537321
Current implementation leaves them in endless loops that significantly slows down processing.
It also happens in singlethreaded mode:
java.net.SocketException: Connection reset
at java.base/sun.nio.ch.SocketChannelImpl.throwConnectionReset(SocketChannelImpl.java:394)
at java.base/sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:411)
at com.teragrep.rlp_03.RelpServerPlainSocket.read(RelpServerPlainSocket.java:164)
at com.teragrep.rlp_03.MessageReader.readRequest(MessageReader.java:109)
at com.teragrep.rlp_03.RelpServerPlainSocket.processRead(RelpServerPlainSocket.java:103)
at com.teragrep.rlp_03.SocketProcessor.processReadWriteClose(SocketProcessor.java:421)
at com.teragrep.rlp_03.SocketProcessor.runSingleThreaded(SocketProcessor.java:201)
at com.teragrep.rlp_03.SocketProcessor.run(SocketProcessor.java:174)
at java.base/java.lang.Thread.run(Thread.java:833)
from rlp_03.
from rlp_03.
Seems to be working, I opened a PR for it
from rlp_03.
Related Issues (20)
- create single thread client
- client close does not completeExceptionally remaining transactions
- avoid terminating threads from the executor service
- extract eventloop out from the ServerFactory
- provide Future from ClientFactory
- remove extra throws from ClientFactory.open method
- Client: retried sends may result in double rsp for a same frame HOT 1
- EventLoop may terminate in case of a disconnect HOT 1
- FragmentAccess.toFragmentByteStream will return null
- OutOfMemoryError and IllegalArgumentException: EstablishedContextStub does not implement this when flooding connections
- debug logging is on info level at EstablishedContextImpl
- Long events caused CancelledKeyException and broke input
- ReadMe example code can't handle multiple connections HOT 1
- Server processings gets stuck if SequencingDelegate throws
- Change RelpFrame to be closeable instead of autocloseable
- Change EstablishedContext to be closeable instead of autocloseable
- change Access and Lease types to avoid creating new objects HOT 1
- move test package com.teragrep.rlp_03.channel.context.frame to com.teragrep.rlp_03.frame;
- upgrade dependency rlp_01 to 4.0.3
- ManualPerformanceTest is broken
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from rlp_03.