first simple but complete test works. Vey nice :)

Author: thsc

src/net/sharksystem/asp3/ASP3ChunkReader.java

@@ -42,7 +42,7 @@ public void run() {
             //<<<<<<<<<<<<<<<<<<debug
             b = new StringBuilder();
             b.append(this.getLogStart());
-            b.append("read chunk URL: ");
+            b.append("read chunkURI: ");
             b.append(chunkUrl);
             System.out.println(b.toString());
             //>>>>>>>>>>>>>>>>>>>debug

src/net/sharksystem/asp3/ASP3Engine.java

@@ -149,10 +149,13 @@ public void handleConnection(InputStream is, OutputStream os) {
             System.out.println(b.toString());
             //>>>>>>>>>>>>>>>>>>>debug
 
+            // era we are about to transmit
             int workingEra = this.getEraStartSync(peer);
+            
+            // newest era (which is not necessarily highest number!!)
             int currentEra = this.era;
 
-            // we start a conversation - increase era
+            // we start a conversation - increase era for newly produced messages
             this.incrementEra();
 
             //<<<<<<<<<<<<<<<<<<debug
@@ -175,9 +178,22 @@ public void handleConnection(InputStream is, OutputStream os) {
             b.append("memento saved");
             System.out.println(b.toString());
             //>>>>>>>>>>>>>>>>>>>debug
-
+            
+            /*
+            There is a little challenge: era uses a circle of numbers
+            We cannot say: higher number, later era. That rule does *not*
+            apply. We can calculate next era, though. 
+
+            That loop has to be re-entered as long as working era has not 
+            yet reached currentEra. In other words: lastRound is reached whenever
+            workingEra == currentEra. Processing currentEra is the last round
+            We at at least one round!
+            */
+
+            boolean lastRound = false; // assume more than one round
             do {
-
+                lastRound = workingEra == currentEra;
+                
                 List<ASP3Chunk> chunks = this.chunkStorage.getChunks(workingEra);
                 //<<<<<<<<<<<<<<<<<<debug
                 b = new StringBuilder();
@@ -211,6 +227,7 @@ public void handleConnection(InputStream is, OutputStream os) {
                     b = new StringBuilder();
                     b.append(this.getLogStart());
                     b.append("send chunk");
+                    System.out.println(b.toString());
                     //>>>>>>>>>>>>>>>>>>>debug
                     this.sendChunk(chunk, dos);
 
@@ -219,15 +236,18 @@ public void handleConnection(InputStream is, OutputStream os) {
                     //<<<<<<<<<<<<<<<<<<debug
                     b = new StringBuilder();
                     b.append(this.getLogStart());
-                    b.append("removed recipient");
+                    b.append("removed recipient ");
                     b.append(peer);
+                    System.out.println(b.toString());
                     //>>>>>>>>>>>>>>>>>>>debug
                     // empty?
                     if(chunk.getRecipients().isEmpty()) {
                         chunk.drop();
                         //<<<<<<<<<<<<<<<<<<debug
+                        b = new StringBuilder();
                         b.append(this.getLogStart());
                         b.append("chunk dropped");
+                        System.out.println(b.toString());
                     }
                 }
 
@@ -240,8 +260,8 @@ public void handleConnection(InputStream is, OutputStream os) {
                 // next era which isn't necessarilly workingEra++ 
                 workingEra = this.getNextEra(workingEra);
 
-                // until served era we came in in the first place
-            } while(workingEra != currentEra);
+                // as long as not already performed last round
+            } while(!lastRound);
 
             //<<<<<<<<<<<<<<<<<<debug
             b = new StringBuilder();
@@ -379,6 +399,7 @@ private void sendChunk(ASP3Chunk chunk, DataOutputStream dos)
             b.append(")");
             b.append("read message: ");
             b.append(message);
+            System.out.println(b.toString());
             //>>>>>>>>>>>>>>>>>>>debug
 
             dos.writeUTF((String) message);
@@ -390,6 +411,7 @@ private void sendChunk(ASP3Chunk chunk, DataOutputStream dos)
             b.append(")");
             b.append("wrote message: ");
             b.append(message);
+            System.out.println(b.toString());
             //>>>>>>>>>>>>>>>>>>>debug
 
         }
@@ -399,7 +421,7 @@ private void sendChunk(ASP3Chunk chunk, DataOutputStream dos)
         b.append(this.owner);
         b.append(")");
         b.append("stop iterating messages ");
-        
+        System.out.println(b.toString());
     }
 
     /**

src/net/sharksystem/asp3/ASP3StorageFS.java

@@ -85,22 +85,26 @@ public List<ASP3Chunk> getChunks(int era) throws IOException {
         List<ASP3Chunk> chunkList = new ArrayList<>();
 
         File dir = new File(this.getPath(era));
+        
+        // can be null!
         File[] contentFileList = dir.listFiles(new FilenameFilter() {
                 @Override
                 public boolean accept(File dir, String fileName) {
                     return fileName.endsWith(DATA_EXTENSION);
                 }
             });
 
-        for (int i = 0; i < contentFileList.length; i++) {
-            String name = contentFileList[i].getName();
-            
-            // cut extension
-            int index = name.lastIndexOf('.');
-            if(index != -1) {
-                String chunkName = name.substring(0, index);
-                String fName = this.getFullFileNameByChunkName(era, chunkName);
-                chunkList.add(new ASP3ChunkFS(this, fName));
+        if(contentFileList != null) {
+            for (int i = 0; i < contentFileList.length; i++) {
+                String name = contentFileList[i].getName();
+
+                // cut extension
+                int index = name.lastIndexOf('.');
+                if(index != -1) {
+                    String chunkName = name.substring(0, index);
+                    String fName = this.getFullFileNameByChunkName(era, chunkName);
+                    chunkList.add(new ASP3ChunkFS(this, fName));
+                }
             }
         }
 

test/BasicTests.java

@@ -6,8 +6,6 @@
 import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.util.List;
-import java.util.logging.Level;
-import java.util.logging.Logger;
 import net.sharksystem.asp3.ASP3Engine;
 import net.sharksystem.asp3.ASP3EngineFS;
 import net.sharksystem.asp3.ASP3Exception;
@@ -103,7 +101,7 @@ public void usage() throws IOException, ASP3Exception, InterruptedException {
 
        bobEngine.handleConnection(bobChannel.getInputStream(), bobChannel.getOutputStream());
 
-       Thread.sleep(2000);
+       Thread.sleep(10000);
 
         // check received message
         List<String> messages = aliceReader.getMessages();