Adds FSIO R/W sync script for stormond implementation

files/build_templates/docker_image_ctl.j2

@@ -108,6 +108,11 @@ function preStartAction()
     fi
 {%- elif docker_container_name == "snmp" %}
     $SONIC_DB_CLI STATE_DB HSET 'DEVICE_METADATA|localhost' chassis_serial_number $(decode-syseeprom -s)
+{%- elif docker_container_name == "pmon" %}
+    BIN_DIR=/usr/local/bin
+    if [ -f $BIN_DIR/fsio-rw-sync ]; then
+        # Copy this script to pmon:/usr/local/bin/
+        docker cp $BIN_DIR/fsio-rw-sync pmon$DEV:$BIN_DIR/
 {%- else %}
     : # nothing
 {%- endif %}

files/build_templates/sonic_debian_extension.j2

@@ -702,6 +702,9 @@ sudo cp $IMAGE_CONFIGS/pcie-check/pcie-check.service $FILESYSTEM_ROOT_USR_LIB_SY
 echo "pcie-check.service" | sudo tee -a $GENERATED_SERVICE_FILE
 sudo cp $IMAGE_CONFIGS/pcie-check/pcie-check.sh $FILESYSTEM_ROOT/usr/bin/
 
+# Copy fsio-sync file
+sudo cp $IMAGE_CONFIGS/fsio-sync/fsio-rw-sync $FILESYSTEM_ROOT/usr/local/bin/
+
 ## Install package without starting service
 ## ref: https://wiki.debian.org/chroot
 sudo tee -a $FILESYSTEM_ROOT/usr/sbin/policy-rc.d > /dev/null <<EOF

files/image_config/fsio-sync/fsio-rw-sync

@@ -0,0 +1,59 @@
+#!/usr/bin/env python3
+
+import os
+import sys
+import json
+import syslog
+from sonic_py_common import daemon_base
+from time import time
+
+BASE_PATH = "/sys/block"
+FSSTATS_FILE = "/host/pmon/stormond/fsio-rw-stats.json"
+STATE_DB_FIELDS = ["total_fsio_reads", "total_fsio_writes", "latest_fsio_reads", "latest_fsio_writes"]
+SYSLOG_ID="fsio-rw-sync"
+FSSTATS_FILE_SYNC_ERROR = 127
+
+devices = []
+json_file_dict = {}
+
+def log_info(msg):
+    syslog.openlog(SYSLOG_ID)
+    syslog.syslog(syslog.LOG_INFO, msg)
+    syslog.closelog()
+
+def log_error(msg):
+    syslog.openlog(SYSLOG_ID)
+    syslog.syslog(syslog.LOG_ERR, msg)
+    syslog.closelog()
+
+def get_storage_disks():
+    fdlist = os.listdir(BASE_PATH)
+    for fd in fdlist:
+        if 'boot' in fd or 'loop' in fd:
+            continue
+        else:
+            devices.append(fd)
+            json_file_dict[fd] = {}
+
+def main():
+
+    log_info("Syncing total and latest procfs reads and writes from STATE_DB to JSON file")
+    try:
+        state_db = daemon_base.db_connect("STATE_DB")
+        get_storage_disks()
+
+        # Sync accumulated and latest procfs reads and writes from STATE_DB
+        for device in devices:
+            for field in STATE_DB_FIELDS:
+                json_file_dict[device][field] = state_db.hget('STORAGE_INFO|{}'.format(device), field)
+
+        json_file_dict["successful_sync_time"] = state_db.hget('STORAGE_INFO|FSSTATS_SYNC', "successful_sync_time")
+
+        with open(FSSTATS_FILE, 'w+') as f:
+            f.write(json.dumps(json_file_dict))
+    except Exception as ex:
+        log_error("Unable to sync state_db to disk: {}".format(ex))
+
+
+if __name__ == "__main__":
+    main()