diff options
| author | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-08 11:07:26 +0200 |
|---|---|---|
| committer | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-08 11:07:26 +0200 |
| commit | d810483912758fdc93ae67415f8857548455c430 (patch) | |
| tree | 27c5683831d383584dfad96083a2a52631b20d5e | |
| parent | 7bc7fe45b23f048a6bd609b7fbd01270b498a20b (diff) | |
Correctly drop failed clients.
| -rw-r--r-- | same/src/main/java/com/orbekk/same/Master.java | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/same/src/main/java/com/orbekk/same/Master.java b/same/src/main/java/com/orbekk/same/Master.java index 90601df..678baf2 100644 --- a/same/src/main/java/com/orbekk/same/Master.java +++ b/same/src/main/java/com/orbekk/same/Master.java @@ -51,10 +51,8 @@ public class Master { @Override public void run(T unused) { - if (rpc.isOk()) { - if (rpc.failed()) { - removeParticipant(participantLocation); - } + if (rpc.failed()) { + removeParticipant(participantLocation); } } } |