-/******************************************************************************\r
-*\r
-* Copyright (c) 2019 Intel.\r
-*\r
-* Licensed under the Apache License, Version 2.0 (the "License");\r
-* you may not use this file except in compliance with the License.\r
-* You may obtain a copy of the License at\r
-*\r
-* http://www.apache.org/licenses/LICENSE-2.0\r
-*\r
-* Unless required by applicable law or agreed to in writing, software\r
-* distributed under the License is distributed on an "AS IS" BASIS,\r
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
-* See the License for the specific language governing permissions and\r
-* limitations under the License.\r
-*\r
-*******************************************************************************/\r
-/**\r
- * @brief This file provides implementation of synchronization related APIs (PTP/1588)\r
- * for XRAN.\r
- *\r
- * @file xran_sync_api.c\r
- * @ingroup group_lte_source_xran\r
- * @author Intel Corporation\r
- *\r
- **/\r
-\r
-#include <assert.h>\r
-#include <dirent.h>\r
-#include <stdio.h>\r
-#include <stdlib.h>\r
-#include <string.h>\r
-\r
-#include "xran_sync_api.h"\r
-#include "xran_printf.h"\r
-\r
-#define BUF_LEN 256\r
-#define PROC_DIR "/proc"\r
-#define COMM_FILE "comm"\r
-#define PMC_CMD "pmc -u -b 0 'GET PORT_DATA_SET'"\r
-#define PTP4L_PROC_NAME "ptp4l"\r
-#define PHC2SYS_PROC_NAME "phc2sys"\r
-\r
-static int find_substr(const char *str, const unsigned int str_len,\r
- const char *substr, const unsigned int substr_len)\r
-{\r
- assert(str);\r
- assert(substr);\r
- unsigned int ind = 0;\r
-\r
- while (ind + substr_len <= str_len) {\r
- if (0 == strncmp(&str[ind], substr, substr_len))\r
- return 0;\r
- ++ind;\r
- }\r
- return 1;\r
-}\r
-\r
-static int is_process_running(char *pname)\r
-{\r
- char full_path[BUF_LEN] = {0};\r
- char read_proc_name[BUF_LEN] = {0};\r
- int res = 1;\r
- DIR *dir = opendir(PROC_DIR);\r
- if (NULL == dir) {\r
- return 1;\r
- }\r
-\r
- struct dirent *entry = NULL;\r
- while (entry = readdir(dir)) {\r
- long pid = atol(entry->d_name);\r
- if (0 == pid)\r
- continue;\r
- snprintf(full_path, sizeof(full_path), "%s/%ld/%s", PROC_DIR, pid, COMM_FILE);\r
- FILE *proc_name_file = fopen(full_path, "r");\r
- if (NULL == proc_name_file)\r
- continue;\r
- fgets( read_proc_name, BUF_LEN, proc_name_file);\r
- if (0 == strncmp(read_proc_name, pname, strlen(pname))) {\r
- res = 0;\r
- fclose(proc_name_file);\r
- break;\r
- }\r
- fclose(proc_name_file);\r
- }\r
- closedir(dir);\r
- return res;\r
-}\r
-\r
-static int check_ptp_status()\r
-{\r
- char pmc_out_line[BUF_LEN];\r
- const char *keywords[2] = {"portState", "SLAVE"};\r
- int res = 1;\r
- FILE *pmc_pipe = popen(PMC_CMD, "r");\r
- if (NULL == pmc_pipe)\r
- return 1;\r
-\r
- while(fgets(pmc_out_line, BUF_LEN, pmc_pipe)) {\r
- if (0 == find_substr(pmc_out_line, strlen(pmc_out_line), keywords[0],\r
- strlen(keywords[0]))) {\r
- if (0 == find_substr(pmc_out_line, strlen(pmc_out_line),\r
- keywords[1], strlen(keywords[1]))) {\r
- res = 0;\r
- break;\r
- }\r
- }\r
- }\r
- fclose(pmc_pipe);\r
- return res;\r
-}\r
-\r
-int xran_is_synchronized()\r
-{\r
- int res = 0;\r
- res |= is_process_running(PTP4L_PROC_NAME);\r
- print_dbg("PTP4L_PROC_NAME %d\n", res);\r
- res |= is_process_running(PHC2SYS_PROC_NAME);\r
- print_dbg("PHC2SYS_PROC_NAME %d\n", res);\r
- res |= check_ptp_status();\r
- print_dbg("check_ptp_status %d\n", res);\r
- return res;\r
-}\r
+/******************************************************************************
+*
+* Copyright (c) 2019 Intel.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*******************************************************************************/
+/**
+ * @brief This file provides implementation of synchronization related APIs (PTP/1588)
+ * for XRAN.
+ *
+ * @file xran_sync_api.c
+ * @ingroup group_lte_source_xran
+ * @author Intel Corporation
+ *
+ **/
+
+#include <assert.h>
+#include <dirent.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+
+#include "xran_sync_api.h"
+#include "xran_printf.h"
+
+#define BUF_LEN 256
+#define PROC_DIR "/proc"
+#define COMM_FILE "comm"
+#define PMC_CMD "pmc -u -b 0 'GET PORT_DATA_SET'"
+#define PTP4L_PROC_NAME "ptp4l"
+#define PHC2SYS_PROC_NAME "phc2sys"
+
+static int find_substr(const char *str, const unsigned int str_len,
+ const char *substr, const unsigned int substr_len)
+{
+ assert(str);
+ assert(substr);
+ unsigned int ind = 0;
+
+ while (ind + substr_len <= str_len) {
+ if (0 == strncmp(&str[ind], substr, substr_len))
+ return 0;
+ ++ind;
+ }
+ return 1;
+}
+
+static int is_process_running(char *pname)
+{
+ char full_path[BUF_LEN] = {0};
+ char read_proc_name[BUF_LEN] = {0};
+ int res = 1;
+ DIR *dir = opendir(PROC_DIR);
+ if (NULL == dir) {
+ return 1;
+ }
+
+ struct dirent *entry = NULL;
+ while (entry = readdir(dir)) {
+ long pid = atol(entry->d_name);
+ if (0 == pid)
+ continue;
+ snprintf(full_path, sizeof(full_path), "%s/%ld/%s", PROC_DIR, pid, COMM_FILE);
+ FILE *proc_name_file = fopen(full_path, "r");
+ if (NULL == proc_name_file)
+ continue;
+ fgets( read_proc_name, BUF_LEN, proc_name_file);
+ if (0 == strncmp(read_proc_name, pname, strlen(pname))) {
+ res = 0;
+ fclose(proc_name_file);
+ break;
+ }
+ fclose(proc_name_file);
+ }
+ closedir(dir);
+ return res;
+}
+
+static int check_ptp_status()
+{
+ char pmc_out_line[BUF_LEN];
+ const char *keywords[2] = {"portState", "SLAVE"};
+ int res = 1;
+ FILE *pmc_pipe = popen(PMC_CMD, "r");
+ if (NULL == pmc_pipe)
+ return 1;
+
+ while(fgets(pmc_out_line, BUF_LEN, pmc_pipe)) {
+ if (0 == find_substr(pmc_out_line, strlen(pmc_out_line), keywords[0],
+ strlen(keywords[0]))) {
+ if (0 == find_substr(pmc_out_line, strlen(pmc_out_line),
+ keywords[1], strlen(keywords[1]))) {
+ res = 0;
+ break;
+ }
+ }
+ }
+ fclose(pmc_pipe);
+ return res;
+}
+
+int xran_is_synchronized()
+{
+ int res = 0;
+ res |= is_process_running(PTP4L_PROC_NAME);
+ print_dbg("PTP4L_PROC_NAME %d\n", res);
+ res |= is_process_running(PHC2SYS_PROC_NAME);
+ print_dbg("PHC2SYS_PROC_NAME %d\n", res);
+ res |= check_ptp_status();
+ print_dbg("check_ptp_status %d\n", res);
+ return res;
+}
Code Review / o-du / phy.git / blobdiff