From 2208907a43fbeec7a638af723ab28db84503df9b Mon Sep 17 00:00:00 2001
From: bashmak <nerosketch@gmail.com>
Date: Thu, 18 May 2017 15:29:30 +0300
Subject: [PATCH] =?UTF-8?q?=D0=94=D0=BE=D0=B1=D0=B0=D0=B2=D0=B8=D0=BB=20?=
 =?UTF-8?q?=D0=BF=D0=B8=D0=BD=D0=B3=D0=BE=D0=B2=D0=B0=D0=BB=D0=BA=D1=83=20?=
 =?UTF-8?q?=D1=87=D0=B5=D1=80=D0=B5=D0=B7=20NAS?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 agent/mod_mikrotik.py | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/agent/mod_mikrotik.py b/agent/mod_mikrotik.py
index 5a28925..1b09957 100644
--- a/agent/mod_mikrotik.py
+++ b/agent/mod_mikrotik.py
@@ -413,6 +413,21 @@ class MikrotikTransmitter(QueueManager, IpAddressListManager):
         if queue.abon != user:
             QueueManager.update(self, user)
 
+    def ping(self, host, count=10):
+        r = self._exec_cmd([
+            '/ip/arp/print',
+            '?address=%s' % host
+        ])
+        if r == [{}]:
+            return
+        interface = r[0]['=interface']
+        r = self._exec_cmd([
+            '/ping', '=address=%s' % host, '=arp-ping=yes', '=interval=100ms', '=count=%d' % count,
+            '=interface=%s' % interface
+        ])
+        received, sent = int(r[-2:][0]['=received']), int(r[-2:][0]['=sent'])
+        return received, sent
+
     # приостановливаем обслуживание абонента
     def pause_user(self, user):
         pass