Add Aeron check because of Fatal error

Aeron send ping to publishers, and try to connect every second
RoboTradeCode · May 25, 2022 · 2c879e9 · 2c879e9
1 parent fd5715c
commit 2c879e9
Show file tree

Hide file tree

Showing 4 changed files with 42 additions and 10 deletions.
diff --git a/kernel/balancer_by_market_order.php b/kernel/balancer_by_market_order.php
@@ -1,6 +1,7 @@
 <?php
 
 use robotrade\Api;
+use Src\Aeron;
 use Src\Configurator;
 use Src\Core;
 use Src\Gate;
@@ -23,9 +24,9 @@
 // API для формирования сообщения для отправки по aeron
 $robotrade_api = new Api($common_config['exchange'], $common_config['algorithm'], $common_config['node'], $common_config['instance']);
 
-// нужен publisher, отправлять команды по aeron в гейт
-$publisher = new Publisher($config['aeron']['publishers']['gate']['channel'], $config['aeron']['publishers']['gate']['stream_id']);
-sleep(1);
+Aeron::checkConnection(
+    $publisher = new Publisher($config['aeron']['publishers']['gate']['channel'], $config['aeron']['publishers']['gate']['stream_id'])
+);
 
 // класс для работы с гейтом
 $gate = new Gate($publisher, $robotrade_api, $common_config['gate_sleep'] ?? 0);

diff --git a/kernel/cross_3t.php b/kernel/cross_3t.php
@@ -1,6 +1,7 @@
 <?php
 
 use robotrade\Api;
+use Src\Aeron;
 use Src\Configurator;
 use Src\Core;
 use Src\Gate;
@@ -26,8 +27,9 @@
 $robotrade_api = new Api($common_config['exchange'], $common_config['algorithm'], $common_config['node'], $common_config['instance']);
 
 // нужен publisher, отправлять команды по aeron в гейт
-$publisher = new Publisher($config['aeron']['publishers']['gate']['channel'], $config['aeron']['publishers']['gate']['stream_id']);
-sleep(1);
+Aeron::checkConnection(
+    $publisher = new Publisher($config['aeron']['publishers']['gate']['channel'], $config['aeron']['publishers']['gate']['stream_id'])
+);
 
 // создаем класс cross 3t
 $cross_3t = new Cross3T($config, $common_config);

diff --git a/kernel/receive_data.php b/kernel/receive_data.php
@@ -28,11 +28,12 @@
 
     $log = new Log($common_config['exchange'], $common_config['algorithm'], $common_config['node'], $common_config['instance']);
 
-}
+    // нужен publisher, отправлять логи на сервер логов
+    Aeron::checkConnection(
+        $publisher = new Publisher($config['aeron']['publishers']['log']['channel'], $config['aeron']['publishers']['log']['stream_id'])
+    );
 
-// нужен publisher, отправлять логи на сервер логов
-$publisher = new Publisher($config['aeron']['publishers']['log']['channel'], $config['aeron']['publishers']['log']['stream_id']);
-sleep(1);
+}
 
 function handler_orderbooks(string $message): void
 {
@@ -123,7 +124,7 @@ function handler_balances(string $message): void
 
     $subscriber_balances->poll();
 
-    if ($common_config['send_ping_to_log_server'] && isset($discrete_time) && isset($log) && $discrete_time->proof()) {
+    if ($common_config['send_ping_to_log_server'] && isset($publisher) && isset($discrete_time) && isset($log) && $discrete_time->proof()) {
 
         if (isset($i)) {
             $i++;

diff --git a/src/Aeron.php b/src/Aeron.php
@@ -2,6 +2,9 @@
 
 namespace Src;
 
+use Aeron\Publisher;
+use Exception;
+
 class Aeron
 {
 
@@ -19,4 +22,29 @@ public static function messageDecode(string $message)
 
     }
 
+    public static function checkConnection(Publisher $publisher): void
+    {
+
+        do {
+
+            try {
+
+                $publisher->offer('ping');
+
+                $do = false;
+
+            } catch (Exception) {
+
+                $do = true;
+
+                echo '[' . date('Y-m-d H:i:s') . '] Try to connect Aeron' . PHP_EOL;
+
+                sleep(1);
+
+            }
+
+        } while ($do);
+
+    }
+
 }