From 47e43eefebae63afee1a1743602c15e3b1ede8ff Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= <kjetil.orbekk@gmail.com>
Date: Wed, 11 Jan 2012 14:58:48 +0100
Subject: Add SameState test.

Test network participation.
---
 jsonrpc/src/main/java/com/orbekk/same/SameState.java | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

(limited to 'jsonrpc/src/main/java/com')

diff --git a/jsonrpc/src/main/java/com/orbekk/same/SameState.java b/jsonrpc/src/main/java/com/orbekk/same/SameState.java
index c3d03f9..9638252 100644
--- a/jsonrpc/src/main/java/com/orbekk/same/SameState.java
+++ b/jsonrpc/src/main/java/com/orbekk/same/SameState.java
@@ -143,9 +143,19 @@ public class SameState extends Thread implements UrlReceiver {
         pendingParticipants.clear();
     }
 
+    /**
+     * This method runs the pending commands to SameState.
+     *
+     * It should be called by the worker thread, but can be called directly
+     * for testing purposes to avoid threading in unit tests.
+     */
+    synchronized void internalRun() {
+        handleNewParticipants();
+    }
+
     public synchronized void run() {
         while (!stopped) {
-            handleNewParticipants();
+            internalRun();
             try {
                 wait(1000);
             } catch (InterruptedException e) {
-- 
cgit v1.2.3