UTF8 logo. Support for Repeater.

iotaledger · Dec 17, 2016 · 5f88959 · 5f88959
1 parent de5b312
commit 5f88959
Show file tree

Hide file tree

Showing 5 changed files with 51 additions and 33 deletions.
diff --git a/logo.ans b/logo.ans
diff --git a/logo.utf8.ans b/logo.utf8.ans
@@ -0,0 +1,25 @@
+[0;40;30m[48C[37m▄[1m███▄
+[48C[47m ▀██[40m█
+[31C▄▄    ▄[11C[0m▀▀▀
+[24C▄[1m██▄  [0m▀[1;47m▀▀[40m▀  [0m▀[1m█▀  ▄[8C▄▄▄
+[24C[0m▀[1;47m▀▀[40m▀[16C[0m■    [47m [1m▀█[40m██   ▄▄
+[31C[0m▄[1m██▄  [0m▄[1m█▄  ▄[7C[0m▀▀▀   [47m [1m█[40m██
+[25C[0m▄[1m██▄   [0m▀▀    ▀[5C▀[12C▀▀
+[21C[1m▄▄  [0m▀[1;47m▀▀[40m▀[6C▄▄    ▄[6C[0m▄[1;47m▄[40m█▄    ▄▄
+[20C[47m ██[40m█[5C▄▄   [47m ███[40m  [0m▀[1;47m▀[40m▀ [0m■   ▀[1;47m▀▀[40m▀   [0m█[1;47m█[40m██   ▄▄
+[21C[0m▀▀[5C[47m [1m█[40m██   [0m▀▀[19C▀▀   [47m [1;40m███
+[23C▄▄▄   [0m▀▀[15C▄[1;47m█[40m█▄    ▄▄[6C[0m▀▀
+[22C[47m [1m▀█[40m██[8C[0m▄[10C▀[47m [1m▀[40m▀   [0m▀[1;47m▀▀[40m▀   [0m▄[1m██▄
+[18C▄▄▄  [0m▀▀▀[5C▄[13C[1m▄[6C▄[6C▄ [0m▀▀
+[17C█[1;47m████[40m[6C[0m▄[6C▄[1m█▄[6C[0m▀[1;47m▀[40m▀    [0m▀[1;47m▀[40m▀    [0m▀[1;47m▀[40m▀
+[17C[0m▀[47m [1m▀▀[40m▀[10C▀   [0m▀[6C▄[5C[1m▄[5C[0m▄[1m█▄
+[27C[0m▄[1;47m█[40m▄   ▄   [0m▄[1m██▄[6C[0m■[5C[1m▄  [0m▀
+[28C▀   ▀[1;47m▀[40m▀  [0m▀[1;47m▀▀[40m▀[9C[0m■
+[28C▄[1;47m█[40m▄    ▄▄    [0m▄[1;47m██[40m▄
+[29C[0m▀    ▀[1;47m▀▀[40m▀   [0m▀[1;47m▀▀[40m▀  ▄▄▄
+    I O T A[19C[0m▄[1;47m██[40m▄[5C▄▄[5C[47m ████[40m  [0m▄[1;47m███[40m▄
+    [0m-------------------[8C▀▀[5C[47m [1m██[40m█[5C[0m▀▀▀   [47m [1m████[0m
+[1m    [30mLedger of Things   [10C[0m▄[1;47m██[40m▄  [0m▀▀   [1m▄▄[8C[0m▀▀▀
+[33C▀[47m [1m▀[40m▀[6C[47m ██[40m█
+[44C[0m▀▀
+
diff --git a/src/main/java/com/iota/iri/IRI.java b/src/main/java/com/iota/iri/IRI.java
@@ -172,10 +172,10 @@ private static void shutdownHook() {
     }
 
     private static void showIotaLogo() {
-        final String charset = "CP437";
+        final String charset = "UTF8";
 
         try {
-            final Path path = Paths.get("logo.ans");
+            final Path path = Paths.get("logo.utf8.ans");
             Files.readAllLines(path, Charset.forName(charset)).forEach(log::info);
         } catch (IOException e) {
             log.error("Impossible to display logo. Charset {} not supported by terminal.", charset);

diff --git a/src/main/java/com/iota/iri/service/API.java b/src/main/java/com/iota/iri/service/API.java
@@ -514,7 +514,7 @@ private void sendResponse(final HttpServerExchange exchange, final AbstractRespo
         if (res instanceof ErrorResponse) {
             exchange.setStatusCode(400); // bad request
         } else if (res instanceof ExceptionResponse) {
-            exchange.setStatusCode(500); // internall error
+            exchange.setStatusCode(500); // internal error
         }
 
         setupResponseHeaders(exchange);

diff --git a/src/main/java/com/iota/iri/service/Node.java b/src/main/java/com/iota/iri/service/Node.java
@@ -61,7 +61,7 @@ public class Node {
     private final DatagramPacket tipRequestingPacket = new DatagramPacket(new byte[TRANSACTION_PACKET_SIZE],
             TRANSACTION_PACKET_SIZE);
 
-    private final ExecutorService executor = Executors.newFixedThreadPool(4);
+    private final ExecutorService executor = Executors.newFixedThreadPool(Configuration.booling(DefaultConfSettings.EXPERIMENTAL) ? 5 :3);
 
     public void init() throws Exception {
 
@@ -90,17 +90,35 @@ public void init() throws Exception {
         executor.submit(spawnTipRequesterThread());
 
         if (Configuration.booling(DefaultConfSettings.EXPERIMENTAL)) {
-            executor.submit(spawnNeighborDNSResolver());
+            executor.submit(spawnNeighborDNSRefresherThread());
+            executor.submit(spawnRepeaterThread());
         }
         executor.shutdown();
     }
+
+    private Runnable spawnRepeaterThread() {
+        return () -> {
+
+            log.info("Spawning Repeater Thread");
+
+            while (!shuttingDown.get()) {
+                log.info("Repeater in Action...");
+                try {
+                    Thread.sleep(1000*50);
+                } catch (final Exception e) {
+                    log.error("Repeater Thread Exception:", e);
+                }
+            }
+            log.info("Shutting down Neighbor DNS Resolver Thread");
+        };
+    }
 
     private Map<String, String> neighborIpCache = new HashMap<>();
 
-    private Runnable spawnNeighborDNSResolver() {
+    private Runnable spawnNeighborDNSRefresherThread() {
         return () -> {
 
-            log.info("Spawning Neighbor DNS Checker Thread");
+            log.info("Spawning Neighbor DNS Refresher Thread");
 
             while (!shuttingDown.get()) {
                 log.info("Checking Neighbors' Ip...");
@@ -135,7 +153,7 @@ private Runnable spawnNeighborDNSResolver() {
 
                     Thread.sleep(1000*60*30);
                 } catch (final Exception e) {
-                    log.error("Spawning Neighbor DNS Resolver Thread Exception:", e);
+                    log.error("Neighbor DNS Refresher Thread Exception:", e);
                 }
             }
             log.info("Shutting down Neighbor DNS Resolver Thread");