From 755d245ddaceb7d3be84fece0a53c844c64778da Mon Sep 17 00:00:00 2001
From: lework <lework@yeah.net>
Date: Mon, 22 Mar 2021 18:43:25 +0800
Subject: [PATCH] add drop_cache

---
 python/supervisor_healthCheck.py | 22 +++++++++++++++++++++-
 1 file changed, 21 insertions(+), 1 deletion(-)

diff --git a/python/supervisor_healthCheck.py b/python/supervisor_healthCheck.py
index a020e11..69c2c86 100644
--- a/python/supervisor_healthCheck.py
+++ b/python/supervisor_healthCheck.py
@@ -4,7 +4,7 @@
 # @Time    : 2020-06-05
 # @Author  : lework
 # @Desc    : 针对supervisor的应用进行健康检查
-# @Version : 1.6
+# @Version : 1.7
 
 
 import os
@@ -69,6 +69,14 @@ def shell(cmd):
     proc.wait()
     return (proc.returncode,) + proc.communicate()
 
+def drop_cache():
+    """
+    清除缓存, 1: pagecache, 2: dentries and inodes, 3: 1+2
+    """
+    cmd = "sync && echo 1 > /proc/sys/vm/drop_caches"
+    exitcode, _, _ = shell(cmd)
+
+    return exitcode
 
 def get_proc_cpu(pid):
     """
@@ -554,6 +562,12 @@ class HealthCheck(object):
             time.sleep(1)
             info = s.supervisor.getProcessInfo(program)
 
+            drop_cache_state = drop_cache()
+            if  drop_cache_state == 0:
+                self.log(program, '[Action: restart] drop pagecache success.')
+            else:
+                self.log(program, '[Action: restart] drop pagecache error.')
+
         if info['state'] != 20:
             try:
                 start_result = s.supervisor.startProcess(program)
@@ -605,6 +619,12 @@ class HealthCheck(object):
             result = 'Failed to kill %s, pid: %s exiting: %s' % (program, pid, exitcode)
             self.log(program, "[Action: kill] result %s", result)
 
+        drop_cache_state = drop_cache()
+        if  drop_cache_state == 0:
+            self.log(program, '[Action: kill] drop pagecache success.')
+        else:
+            self.log(program, '[Action: kill] drop pagecache error.')
+
         return result
 
     def action_email(self, program, action_type, msg, check_status):