tarantool / tarantool-java
69%
master: 78%

LAST BUILD BRANCH: Totktonada/remove-gitter-badge
DEFAULT BRANCH: master
Repo Added
Files 71
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst

LAST BUILD ON BRANCH nicktorwald/gh-142-race-condition
branch: nicktorwald/gh-142-race-condition
CHANGE BRANCH
x

350

Pull #145

travis-ci

web-flow 
Race condition in TarantoolClientImpl

A state of a client is a set of the following flags: {READING, WRITING,
RECONNECT, CLOSED}. Let's name a state when no flags are set
UNINITIALIZED.

A reader thread sets READING, performs reading until an error or an
interruption, drops READING and tries to trigger reconnection (if a
state allows, see below). A writer do quite same things, but with the
WRITING flag. The key point here is that a reconnection is triggered
from a reader/writer thread and only when certain conditions are met.

The prerequisite to set RECONNECT and signal (unpark) a connector thread
is that a client has UNINITIALIZED state.

There are several problems here:

- Say, a reader stalls a bit after dropping READING, then a writer drops
WRITING and trigger reconnection. Then reader wokes up and set RECONNECT
again.

- Calling unpark() N times for a connector thread when it is alive
doesn't lead to skipping next N park() calls, so the problem above is
not just about extra reconnection, but lead the connector thread to be
stuck.

- Say, a reader stalls just before setting READING. A writer is hit by
an IO error and triggers reconnection (set RECONNECT, unpark connector).
Then the reader wakes up and set READING+RECONNECT state that disallows
a connector thread to proceed further (it expects pure RECONNECT). Even
when the reader drops READING it will not wake up (unpark) the connector
thread, because RECONNECT was already set (state is not UNINITIALIZED).

This commit introduces several changes that eliminate the problems
above:

- Use ReentrantLock + Condition instead of park() / unpark() to never
miss signals to reconnect, does not matter whether a connector is
parked.

- Ensure a reader and a writer threads from one generation (that are
created on the same reconnection iteration) triggers reconnection once.

- Hold RECONNECT state most of time a connector works (while acquiring
a new socket, connecting and reading Tarantool greeting) and pre... (continued)
Pull Request #145: Race condition in TarantoolClientImpl

62 of 62 new or added lines in 1 file covered. (100.0%)

1669 of 2402 relevant lines covered (69.48%)

0.69 hits per line

Relevant lines Covered
2402 RELEVANT LINES 1669 COVERED LINES
0.69 HITS PER LINE
Source Files on nicktorwald/gh-142-race-condition
Coverage ∆ File Lines Relevant Covered Missed Hits/Line

Recent builds

Builds Branch Commit Type Ran Committer Via Coverage
350 nicktorwald/gh-142-race-condition Race condition in TarantoolClientImpl A state of a client is a set of the following flags: {READING, WRITING, RECONNECT, CLOSED}. Let's name a state when no flags are set UNINITIALIZED. A reader thread sets READING, performs reading until an err... Pull #145 web-flow travis-ci pending completion  
316 nicktorwald/gh-142-race-condition Race condition in TarantoolClientImpl A state of a client is a set of the following flags: {READING, WRITING, RECONNECT, CLOSED}. Let's name a state when no flags are set UNINITIALIZED. A reader thread sets READING, performs reading until an err... Pull #145 web-flow travis-ci pending completion  
315 nicktorwald/gh-142-race-condition Race condition in TarantoolClientImpl A state of a client is a set of the following flags: {READING, WRITING, RECONNECT, CLOSED}. Let's name a state when no flags are set UNINITIALIZED. A reader thread sets READING, performs reading until an err... push nicktorwald travis-ci pending completion  
313 nicktorwald/gh-142-race-condition debug commit Pull #145 web-flow travis-ci pending completion  
312 nicktorwald/gh-142-race-condition debug commit push nicktorwald travis-ci pending completion  
311 nicktorwald/gh-142-race-condition debug commit Pull #161 web-flow travis-ci pending completion  
310 nicktorwald/gh-142-race-condition Race condition in TarantoolClientImpl A state of a client is a set of the following flags: {READING, WRITING, RECONNECT, CLOSED}. Let's name a state when no flags are set UNINITIALIZED. A reader thread sets READING, performs reading until an err... Pull #145 web-flow travis-ci pending completion  
273 nicktorwald/gh-142-race-condition Race condition in TarantoolClientImpl - Avoid a possible race between reading, writing and reconnecting threads when a reconnection process is started. It might have happened that the lagged thread (reading or writing) could reset the state to RE... Pull #145 web-flow travis-ci pending completion  
272 nicktorwald/gh-142-race-condition Race condition in TarantoolClientImpl - Avoid a possible race between reading, writing and reconnecting threads when a reconnection process is started. It might have happened that the lagged thread (reading or writing) could reset the state to RE... push nicktorwald travis-ci pending completion  
271 nicktorwald/gh-142-race-condition Race condition in TarantoolClientImpl - Avoid a possible race between reading, writing and reconnecting threads when a reconnection process is started. It might have happened that the lagged thread (reading or writing) could reset the state to RE... Pull #145 web-flow travis-ci pending completion  
See All Builds (426)