linx/autobuild-tools
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1.9版本最新，采用sh build.sh编译方法，后续以此为基准，test.c用于测试get_nic_info接口是否存在很大的延时

Browse Source
This commit is contained in:
丘榕标
2015-11-17 16:59:12 +08:00
parent 3b2f94c550
commit 8d0df2b83c
25 changed files with 3318 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/.footprint_x86_64_base Normal file
View File

@@ -0,0 +1,13 @@
drwxr-xr-x root/root usr/
drwxr-xr-x root/root usr/bin/
-rwxr-xr-x root/root usr/bin/sys_nicmonitor
drwxr-xr-x root/root usr/include/
-rw-r--r-- root/root usr/include/nicinfo_shm.h
drwxr-xr-x root/root usr/lib64/
-rwxr-xr-x root/root usr/lib64/libnic_shm.so
drwxr-xr-x root/root var/
drwxr-xr-x root/root var/lib/
drwxr-xr-x root/root var/lib/pkg/
-rwxr-xr-x root/root var/lib/pkg/sys_nicmonitor.post_add
drwxr-xr-x root/root var/lib/pkginfo/
-rw-r--r-- root/root var/lib/pkginfo/sys_nicmonitor.md5sum

1
src/.md5sum Normal file
View File

@@ -0,0 +1 @@
072a487c0e1da0e2c9dd7b9d06359620 sys_nicmonitor-1.9.tar.gz

24
src/Pkgfile Normal file
View File

@@ -0,0 +1,24 @@
# Description: A system to store and display time-series data.
# URL: http://oss.oetiker.ch/rrdtool/index.en.html
# Maintainer: Danny Rawlins, monster dot romster at gmail dot com
# Packager: Younes Hafri, ycrux at club-internet dot fr
# Depends on: libart_lgpl libcgi libgd pango python tcl intltool
name=sys_nicmonitor
version=`grep version ./sys_nicmonitor/version.h | cut -d "=" -f 2`
release=x86_64-Linx-Rocky4.2
workdir=`pwd`
#source=/home/d5000/d5000/linx/1.8/$name-$version.tar.gz
#source=/mnt/rbqiu/nanri/sys_nicmonitor/0605/1.8/src/$name-$version.tar.gz
echo $workdir
source=$workdir/$name-$version.tar.gz
build() {
cd $name-$version
make
make DESTDIR=$PKG install
# mkdir -p $PKG/var/log/netcard
# chmod 777 $PKG/var/log/netcard
}

107
src/README Normal file
View File

@@ -0,0 +1,107 @@
=-======update 2015-11-17
编译前，进入dep目录运行sh run.sh，安装编译依赖文件.
然后sh build.sh编译1.9版本的sys_nicmonitor#1.9-x86_64-Linx-Rocky4.2.pkg.tar.gz
调试模式下：
cd sys_nicmonitor-1.9
make clean
make
make test
make runtest
版本号变更方法，更新sys_nicmonitor/version.h文件，需要同时修改//后面的和define中的，前者用于pkg包，后者用于sys_nicmonitor程序.
制作pkg包方法： sh build.sh
=========
编译前准备:
编译前先安装dotconf软件包。
libman.so拷贝到/usr/lib64/下
pkgadd dotconf#1.0.13-1.pkg.tar.gz
编译说明：
在Rocky 4.2上编译
执行： sh build.sh
将在当前的目录下生成安装包：
sys_nicmonitor#1.9-x86_64-Linx-Rocky4.2.pkg.tar.gz
========
安装说明：
1)安装，以root的用户执行安装命令：
pkgadd sys_nicmonitor#1.9-x86_64-Linx-Rocky4.2.pkg.tar.gz
如果之前已经安装，则可先卸载旧的然后再安装，或者通过更新方式安装
卸载命令: pkgrm sys_nicmonitor
更新方式安装命令：
pkgadd －u sys_nicmonitor#1.9-x86_64-Linx-Rocky4.2.pkg.tar.gz
2）查看安装是否成功
pkginfo -i|grep sys_nicmonitor
或者
查看d5000用户的目录下lib/libnic_shm.so和bin/sys_nicmonitor的日期是否匹配
=======＝
版本说明：
--V1.9 --
2013-08-12
1）修复问题：占用内存快速累加，导致内存占用很大
问题描述：日志线程资源退出时未回收，导致占用内存快速累加
解决办法：修改为一个日志线程，并且线程退出时设置为自动回收。
将日志写文件的地方放到common.c中，以便动态库和daemon程序使用一个。
2）修复问题：日志文件名在家目录或者var目录下，未在规定位置
问题描述：日志文件命名在一个单独的线程进行，导致日志线程和该线程对log_path存在同时访问的情况。
导致在换天或者换月时，日志文件名变更一半时，日志写线程此时写日志，用未更新完成的
log_path创建日志，导致日志文件不再规定的位置。
解决办法：增加线程互斥锁pthread_mutex对log_path进行保护，修复该问题。
--V1.8.1--
2013-06-05
1)修改BUG：ping_gw函数当PING失败时没有尝试对余下的GW进行PING操作
2)增加环境变量SYS_NIC_DEBUG用于调试流量抖动问题。
--V1.8 --
2013－05－27
对系统高磁盘IO情况下，应用如果进行IO将可能会被阻塞。本版本为此作出调整。
cs-fes1上编译测试OK。
1） 去掉shm和sem的实体文件
#define SHM_PATH "$D5000_HOME/share/sys_netcard_shm_path"
#define SEM_PATH "$D5000_HOME/share/sys_netcard_sem_path"
用key=0x1d5200 代替 sem
用key=0x1d5010 代替 shm
2）去掉动态库中get_nic_info接口中，判断路径的opendir调用，采用实际路径
上层应用每秒可能调用3次这个接口，每判断一个网卡都调用一次，判断都个网卡的状态时就调用多次。
可改进：一次调用get_nic_info接口，可输入多个网卡，一次返回所有网卡状态信息。
3) record_log函数为日志函数，每次写一次，都重新打开一次文件。
修改为线程模式，当记录日志时，不会被磁盘IO阻塞。
4) 安装目录为d5000用户的HOME目录下的lib和bin目录
----
V1.6与V1.7差异
共享内存路径修改:
由/home/d5000/someone/tmp/sys_netcard_shm_path 改为 /home/d5000/someone/share/sys_netcard_shm_path
信号量路径修改:
由/home/d5000/someone/tmp/sys_netcard_sem_path 改为 /home/d5000/someone/share/sys_netcard_sem_path
注意：在编译过程中，需要动态看libman.so，它存放在目录 tags/下面 ，在进行编译的时候需要将其拷贝到
/lib64/目录下，编译的基础环境是 Rocky 4.2 系统。
pkgmk命令的使用：
将源代码打包成name-version.tar.gz样式，编写Pkgfile文件。
使用命令：
pkgmk -um #更新软件包的md5值
pkgmk -kw #制作pkg安装包

15
src/build.sh Normal file
View File

@@ -0,0 +1,15 @@
verstr=`grep version ./sys_nicmonitor/version.h | cut -d "=" -f 2`
echo $verstr
worksrc=sys_nicmonitor-$verstr
cp -r sys_nicmonitor $worksrc
tar -czf $worksrc.tar.gz $worksrc
pkgmk -um
#For debug
#pkgmk -kw -pa post_add.sh
#For release
pkgmk -pa post_add.sh
rm $worksrc.tar.gz
rm -rf $worksrc

BIN
src/dep/dotconf#1.0.13-1.pkg.tar.gz Normal file
View File

Binary file not shown.

BIN
src/dep/libman.so Normal file
View File

Binary file not shown.

2
src/dep/run.sh Normal file
View File

@@ -0,0 +1,2 @@
pkgadd dotconf#1.0.13-1.pkg.tar.gz
cp ./libman.so /usr/lib64/

16
src/post_add.sh Normal file
View File

@@ -0,0 +1,16 @@
#!/bin/bash
#echo $HOME
DFDIR=`cat /etc/passwd | grep d5000 | cut -d ":" -f 6 `
#LOGDIR=$DFDIR/var/log/netcard
#mkdir -p $LOGDIR
echo $DFDIR
#echo $LOGDIR
echo "$DFDIR/lib/libnic_shm.so"
echo "$DFDIR/bin/sys_nicmonitor"
mv /usr/lib64/libnic_shm.so $DFDIR/lib
mv /usr/bin/sys_nicmonitor $DFDIR/bin
chown d5000.d5000 $DFDIR/lib/libnic_shm.so
chown d5000.d5000 $DFDIR/bin/sys_nicmonitor

10
src/post_mk.sh Normal file
View File

@@ -0,0 +1,10 @@
#!/bin/bash
PWD=`pwd`
#pkg=`basename $PWD`
pkg=sys_nicmonitor
# install the script which is run just after pkgadd or
# when booting from disk first time
mkdir -p $PKG/$PI_DIR
install -m 755 post_add.sh $PKG/$PI_DIR/${pkg}.post_add

32
src/sys_nicmonitor/Makefile Normal file
View File

@@ -0,0 +1,32 @@
#! /usr/bin/make -f
DEFAULTS = Makefile.config
include $(DEFAULTS)
all:sys_nicmonitor libnic_shm.so
CFLAGS += -Wall -Wformat=2 -Wno-format-extra-args -Wformat-security -Wformat-nonliteral #-g
sys_nicmonitor:mnic.o read_netcard.o send_alarm.o
$(CC) -lman -ldotconf -lpthread -o $@ $^
libnic_shm.so:nicinfo_shm.c
$(CC) -fpic -shared -o $@ $^
test:
gcc -o test test.c -lnic_shm -L=./ -lpthread
runtest:
LD_LIBRARY_PATH=./ ./test bond0 5000 &
clean:
$(RM) *.o
$(RM) libnic_shm.so sys_nicmonitor test
install:
$(MKDIR) -p $(LIBDIR)
$(MKDIR) -p $(BINDIR)
$(MKDIR) -p $(INCDIR)
$(CP) libnic_shm.so $(LIBDIR)
$(CP) sys_nicmonitor $(BINDIR)
$(CP) nicinfo_shm.h $(INCDIR)
uninstall:
$(RM) -f $(LIBDIR)/libnic_shm.so
$(RM) -f $(BINDIR)/sys_nicmonitor
$(RM) -f $(INCDIR)/nicinfo_shm.h

16
src/sys_nicmonitor/Makefile.config Normal file
View File

@@ -0,0 +1,16 @@
PREFIX = $(DESTDIR)
BINDIR = $(PREFIX)/usr/bin
LIBDIR = $(PREFIX)/usr/lib64
INCDIR = $(PREFIX)/usr/include
INSTALL_SH = ./install.sh
CP = cp
RM = rm
#CC = gcc
CC = g++
MKDIR = mkdir

90
src/sys_nicmonitor/README Normal file
View File

@@ -0,0 +1,90 @@
=========
编译前准备:
编译前先安装dotconf软件包。
libman.so拷贝到/usr/lib64/下
pkgadd dotconf#1.0.13-1.pkg.tar.gz
编译说明：
在Rocky 4.2上编译
执行： sh build.sh
将在当前的目录下生成安装包：
sys_nicmonitor#1.9-x86_64-Linx-Rocky4.2.pkg.tar.gz
========
安装说明：
1)安装，以root的用户执行安装命令：
pkgadd sys_nicmonitor#1.9-x86_64-Linx-Rocky4.2.pkg.tar.gz
如果之前已经安装，则可先卸载旧的然后再安装，或者通过更新方式安装
卸载命令: pkgrm sys_nicmonitor
更新方式安装命令：
pkgadd －u sys_nicmonitor#1.9-x86_64-Linx-Rocky4.2.pkg.tar.gz
2）查看安装是否成功
pkginfo -i|grep sys_nicmonitor
或者
查看d5000用户的目录下lib/libnic_shm.so和bin/sys_nicmonitor的日期是否匹配
=======＝
版本说明：
--V1.9 --
2013-08-12
1）修复问题：占用内存快速累加，导致内存占用很大
问题描述：日志线程资源退出时未回收，导致占用内存快速累加
解决办法：修改为一个日志线程，并且线程退出时设置为自动回收。
将日志写文件的地方放到common.c中，以便动态库和daemon程序使用一个。
2）修复问题：日志文件名在家目录或者var目录下，未在规定位置
问题描述：日志文件命名在一个单独的线程进行，导致日志线程和该线程对log_path存在同时访问的情况。
导致在换天或者换月时，日志文件名变更一半时，日志写线程此时写日志，用未更新完成的
log_path创建日志，导致日志文件不再规定的位置。
解决办法：增加线程互斥锁pthread_mutex对log_path进行保护，修复该问题。
--V1.8.1--
2013-06-05
1)修改BUG：ping_gw函数当PING失败时没有尝试对余下的GW进行PING操作
2)增加环境变量SYS_NIC_DEBUG用于调试流量抖动问题。
--V1.8 --
2013－05－27
对系统高磁盘IO情况下，应用如果进行IO将可能会被阻塞。本版本为此作出调整。
cs-fes1上编译测试OK。
1） 去掉shm和sem的实体文件
#define SHM_PATH "$D5000_HOME/share/sys_netcard_shm_path"
#define SEM_PATH "$D5000_HOME/share/sys_netcard_sem_path"
用key=0x1d5200 代替 sem
用key=0x1d5010 代替 shm
2）去掉动态库中get_nic_info接口中，判断路径的opendir调用，采用实际路径
上层应用每秒可能调用3次这个接口，每判断一个网卡都调用一次，判断都个网卡的状态时就调用多次。
可改进：一次调用get_nic_info接口，可输入多个网卡，一次返回所有网卡状态信息。
3) record_log函数为日志函数，每次写一次，都重新打开一次文件。
修改为线程模式，当记录日志时，不会被磁盘IO阻塞。
4) 安装目录为d5000用户的HOME目录下的lib和bin目录
----
V1.6与V1.7差异
共享内存路径修改:
由/home/d5000/someone/tmp/sys_netcard_shm_path 改为 /home/d5000/someone/share/sys_netcard_shm_path
信号量路径修改:
由/home/d5000/someone/tmp/sys_netcard_sem_path 改为 /home/d5000/someone/share/sys_netcard_sem_path
注意：在编译过程中，需要动态看libman.so，它存放在目录 tags/下面 ，在进行编译的时候需要将其拷贝到
/lib64/目录下，编译的基础环境是 Rocky 4.2 系统。
pkgmk命令的使用：
将源代码打包成name-version.tar.gz样式，编写Pkgfile文件。
使用命令：
pkgmk -um #更新软件包的md5值
pkgmk -kw #制作pkg安装包

159
src/sys_nicmonitor/common.c Normal file
View File

@@ -0,0 +1,159 @@
static pthread_mutex_t lock_record_logpath = PTHREAD_MUTEX_INITIALIZER;
#define LOGPATH_LOCK pthread_mutex_lock(&lock_record_logpath)
#define LOGPATH_UNLOCK pthread_mutex_unlock(&lock_record_logpath)
static pthread_mutex_t lock_record_log = PTHREAD_MUTEX_INITIALIZER;
#define LOG_LOCK pthread_mutex_lock(&lock_record_log)
#define LOG_UNLOCK pthread_mutex_unlock(&lock_record_log)
#define MAX_LOG_COUNT 5000
static char **log_prepare = NULL;
static char **log_writing = NULL;
static int log_thread_exit = 1;
static int log_idx = 0;
void create_dir(char *create_path)
{
int i,len = strlen(create_path);
for(i=1; i<len; i++)
{
if(create_path[i]=='/')
{
create_path[i] = 0;
if( access(create_path, F_OK)!=0 )
{
if(mkdir(create_path, 0755)==-1)
{
perror("mkdir error");
}
}
create_path[i] = '/';
}
}
}
static void *record_log_thread( void *arg )
{
char *log_str;
FILE *log_fp = NULL;
char **tmp = NULL;
int i = 0;
create_dir( log_path );
log_thread_exit = 0;
// log_fp = fopen(log_path, "a");
while( !log_thread_exit ) {
if( !log_fp ) {
LOGPATH_LOCK;
log_fp = fopen(log_path, "a");
LOGPATH_UNLOCK;
}
//prepare log strings
LOG_LOCK;
tmp = log_writing;
log_writing = log_prepare;
log_prepare = log_writing;
log_idx=0;
LOG_UNLOCK;
i = 0;
while( i < MAX_LOG_COUNT ) {
log_str = log_writing[i];
if( log_str == NULL ) {
break;
}
if( log_fp ) {
fwrite( log_str, 1, strlen(log_str), log_fp ); //write to file
}
free( log_str ); //free
log_writing[i] = NULL; //clear
//next
i++;
}
if(log_fp) {
fclose(log_fp);
log_fp = NULL;
}
usleep(799999);
} //while
if( log_fp ) {
fclose(log_fp);
}
if( log_prepare ) free( log_prepare );
if( log_writing ) free( log_writing );
log_prepare = NULL;
log_writing = NULL;
//free self thread resources
pthread_detach(pthread_self());
return NULL;
}
/* write error in logfile */
void record_log(char *str)
{
static int log_thread_started = 0;
time_t tamp;
char str_tm[4];
char log_str[512];
struct tm tmptr;
struct timeval tv;
struct timezone tz;
pthread_t pid;
// int ret = 0;
char *keepstr = NULL;
tamp = time(NULL);
memset(str_tm, 0, sizeof(str_tm));
memset(log_str, 0, sizeof(log_str));
localtime_r(&tamp, &tmptr);
gettimeofday(&tv, &tz);
snprintf(str_tm, sizeof(str_tm), "%d", (int)tv.tv_usec/1000);
if(str_tm[1] == '\0')str_tm[1] = '0';
if(str_tm[2] == '\0')str_tm[2] = '0';
// ret = strftime(log_str, sizeof(log_str), "%F %T. ", &tmptr );
// snprintf(log_str+ret, sizeof(log_str)-ret, " %s %s %s", str_tm, process_name, str );
//
strftime(log_str, sizeof(log_str), "%F %T.", &tmptr);
strcat(log_str, str_tm);
strcat(log_str, " ");
strcat(log_str, process_name);
strcat(log_str, " ");
strcat(log_str, str);
//check log thread
if( log_thread_started == 0 ) {
log_thread_started = 1;
log_prepare = (char **)malloc( sizeof(char *)*MAX_LOG_COUNT );
log_writing = (char **)malloc( sizeof(char *)*MAX_LOG_COUNT );
memset( log_prepare, 0, sizeof(char *) *MAX_LOG_COUNT );
memset( log_writing, 0, sizeof(char *) *MAX_LOG_COUNT );
log_idx = 0;
pthread_create( &pid, NULL, record_log_thread, (void *)NULL );
}
keepstr = strdup( log_str );
LOG_LOCK;
if( log_prepare ) {
log_prepare[log_idx] = keepstr;
log_idx++;
}
LOG_UNLOCK;
}

51
src/sys_nicmonitor/const.h Normal file
View File

@@ -0,0 +1,51 @@
#ifndef _RTE_CONST_H
#define _RTE_CONST_H
#include <pthread.h>
#define MAX_STRING_LEN 24
#define MAX_EXECMD_LEN 200
#define MAX_FILENAME_LEN 200
#define MAX_CONTEXT 8
#define MAX_HOSTNAME_LEN 24
#define MAX_LOCAL_MESPROC 512
#define MAX_LOCAL_PROCESS MAX_LOCAL_MESPROC
#define MAX_LOCAL_APP 32
#define MAX_LOCAL_NODE 256
#define MAX_SET 256 //max num of event set
#define MAX_EVENT 1300
#define MAX_REG_PROC 20
#define LEN_SHMBLK_BIG 4096
#define MAX_MSGBUF_LEN 32767
#define FREE_PAGE_SIZE 65536
#define MAX_PAGE_NUM 1024
#define MAX_QUE MAX_LOCAL_MESPROC
#define MAX_SEMPHORE_SET MAX_LOCAL_MESPROC*2
#define RTE_HAN 0 // queue number for event handeler0(RTE)
#define EX_EVENT_HAN RTE_HAN // queue number for extrnal event handeler
#define DOMAIN_I 1
#define DOMAIN_II 2
#define DOMAIN_III 3
//Add 20090225
const int PROC_TYPE_RPT =1;
const int PROC_TYPE_UNRPT =0;
//add end
//status for proc and app
const int NON_ACTIVE = 0;
const int ACTIVE = 1;
const int HANGUP = 2;
const int FAILURE = 5;
const int START = 6;
const int STOP = 7;
#endif

1781
src/sys_nicmonitor/mnic.c Normal file
View File

File diff suppressed because it is too large Load Diff

44
src/sys_nicmonitor/mnic.h Normal file
View File

@@ -0,0 +1,44 @@
#ifndef __MNIC_H
#define __MNIC_H
//#define _GNU_SOURCE
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <stddef.h>
#include <unistd.h>
#include <ctype.h>
#include <errno.h>
#include <netinet/in.h>
#include <net/if.h>
#include <time.h>
#include <sys/ioctl.h>
#include <sys/socket.h>
#include <sys/sem.h>
#include <sys/ipc.h>
#include <sys/param.h>
#include <linux/types.h>
#include <glob.h>
#include <linux/sockios.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <sys/mman.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <signal.h>
#include <sys/time.h>
#include "sys_netcard.h"
#include <pwd.h>
#include <sys/types.h>
#define IPSIZE 16
char *get_name(char *, char *);
int if_fetch(NETCARD_INFO *);
int ioc_get_name(NETCARD_INFO *);
int get_dev_fields(char *p, NETCARD_INFO *);
int get_user_home(int , char *);
void send_alarm(D5000_NIC_ALARM *, int , char *);
void record_log(char *);
#endif

400
src/sys_nicmonitor/nicinfo_shm.c Normal file
View File

@@ -0,0 +1,400 @@
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <sys/mman.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/sem.h>
#include <fcntl.h>
#include <unistd.h>
#include <errno.h>
#include <sys/time.h>
#include <time.h>
#include <dirent.h>
#include <pwd.h>
#include <pthread.h>
#include "nicinfo_shm.h"
#define SHM_PATH "/share/sys_netcard_shm_path"
#define SEM_PATH "/share/sys_netcard_sem_path"
#define LOG_PATH "/var/log/netcard/"
typedef struct net_info{
NETCARD_INFO info[MAXNICNUM];
}SHM;
static int semid = 0;
static char log_path[1024];
static char shm_path[1024];
static char sem_path[1024];
SHM *ptr = NULL;
static char process_name[32] = "get_nic_info";
static void linx_free_shm( void *addr, int size );
#if 0
static pthread_mutex_t lock_record_log = PTHREAD_MUTEX_INITIALIZER;
#define LOG_LOCK pthread_mutex_lock(&lock_record_log)
#define LOG_UNLOCK pthread_mutex_unlock(&lock_record_log)
static int is_checkdir = 0;
static void *record_log_thread( void *arg )
{
char *log_str = (char *)arg;
FILE *log_fp = NULL;
LOG_LOCK;
if( !is_checkdir ) {
create_dir( log_path );
is_checkdir = 1;
}
create_dir( log_path );
if((log_fp = fopen(log_path, "a")) != NULL){
if(fwrite(log_str, 1, strlen(log_str), log_fp) < 1){
}
fclose(log_fp);
}
LOG_UNLOCK;
free(log_str);
return NULL;
}
/* write error in logfile */
void record_log(char *str)
{
#if 0
time_t tamp;
char str_tm[4];
char log_str[512];
FILE *log_fp = NULL;
struct tm tmptr;
struct timeval tv;
struct timezone tz;
if((log_fp = fopen(log_path, "a")) != NULL){
tamp = time(NULL);
memset(str_tm, 0, sizeof(str_tm));
memset(log_str, 0, sizeof(log_str));
localtime_r(&tamp, &tmptr);
gettimeofday(&tv, &tz);
snprintf(str_tm, sizeof(str_tm), "%d", (int)tv.tv_usec/1000);
if(str_tm[1] == '\0')str_tm[1] = '0';
if(str_tm[2] == '\0')str_tm[2] = '0';
strftime(log_str, sizeof(log_str), "%F %T.", &tmptr);
strcat(log_str, str_tm);
strcat(log_str, " ");
strcat(log_str, "get_nic_info");
strcat(log_str, " ");
strcat(log_str, str);
if(fwrite(log_str, 1, strlen(log_str), log_fp) < 1){
}
fclose(log_fp);
}
#else
time_t tamp;
char str_tm[4];
char log_str[512];
// FILE *log_fp = NULL;
struct tm tmptr;
struct timeval tv;
struct timezone tz;
// if((log_fp = fopen(log_path, "a")) != NULL){
tamp = time(NULL);
memset(str_tm, 0, sizeof(str_tm));
memset(log_str, 0, sizeof(log_str));
localtime_r(&tamp, &tmptr);
gettimeofday(&tv, &tz);
snprintf(str_tm, sizeof(str_tm), "%d", (int)tv.tv_usec/1000);
if(str_tm[1] == '\0')str_tm[1] = '0';
if(str_tm[2] == '\0')str_tm[2] = '0';
strftime(log_str, sizeof(log_str), "%F %T.", &tmptr);
strcat(log_str, str_tm);
strcat(log_str, " ");
strcat(log_str, "get_nic_info");
strcat(log_str, " ");
strcat(log_str, str);
// if(fwrite(log_str, 1, strlen(log_str), log_fp) < 1){
// }
// fclose(log_fp);
// }
{
pthread_t pid;
char *keepstr = strdup( log_str );
pthread_create( &pid, NULL, record_log_thread, (void *)keepstr);
}
#endif
}
#else
#include "common.c"
#endif
void get_sem(int semid)
{
char err_str[200];
struct sembuf lock[2];
lock[0].sem_num = 0;
lock[0].sem_op = 0;
lock[0].sem_flg = SEM_UNDO;
lock[1].sem_num = 0;
lock[1].sem_op = 1;
lock[1].sem_flg = SEM_UNDO;
while(semop(semid, lock, 2)){
if (errno == EINTR) {
continue;
}
snprintf(err_str, sizeof(err_str), "EMERG: semop():\n", strerror(errno));
record_log(err_str);
return;
}
}
void release_sem(int semid)
{
int ret;
char err_str[200];
struct sembuf unlock;
unlock.sem_num = 0;
unlock.sem_op = -1;
unlock.sem_flg = SEM_UNDO;
if((ret = semop(semid, &unlock, 1)) == -1){
snprintf(err_str, sizeof(err_str), "EMERG: semop():\n", strerror(errno));
record_log(err_str);
return;
}
}
static int global_share_id = -1;
static void *global_shmptr = NULL;
int init_nic_info(void)
{
int fd = -1;
int sem_val;
char err_str[200];
key_t key;
#if 0
if ((key=ftok(sem_path, SEM_PROJ_ID)) == -1) {
snprintf(err_str, sizeof(err_str), "EMERG: ftok():%s\n", strerror(errno));
record_log(err_str);
return -1;
}
#else
key = 0x1d5200;
#endif
if((semid = semget(key, 1, IPC_CREAT|0666)) == -1){
snprintf(err_str, sizeof(err_str), "EMERG: Create semaphore error: %s\n", strerror(errno));
record_log(err_str);
return -1;
}
/*
if((sem_val = semctl(semid, 0, GETVAL, 0)) == -1){
snprintf(err_str, sizeof(err_str), "EMERG: semctl: %s !\n", strerror(errno));
record_log(err_str);
semctl(semid, 0, IPC_RMID);
return -1;
}
if(!sem_val){
if(semctl(semid, 0, SETVAL, 1) == -1){
snprintf(err_str, sizeof(err_str), "EMERG: semctl: %s !\n", strerror(errno));
record_log(err_str);
semctl(semid, 0, IPC_RMID);
return -1;
}
}
*/
#ifdef USE_OLD_MMSHARE
if((fd = open(shm_path, O_RDONLY)) == -1){
snprintf(err_str, sizeof(err_str), "EMERG: Error open %s: %s!\n",shm_path, strerror(errno));
record_log(err_str);
return -1;
}
ptr = (SHM*)mmap(NULL, sizeof(SHM), PROT_READ, MAP_SHARED, fd, 0);
if(ptr == MAP_FAILED){
snprintf(err_str, sizeof(err_str), "EMERG: mmap():%s\n", strerror(errno));
record_log(err_str);
return -1;
}
close(fd);
#else
{
void* shmptr = NULL;
int size = 0;
key_t share_key;
int share_id = 0;
char *ref_count = NULL;
char *flag_str = NULL;
char *path = shm_path;
size = sizeof(SHM);
size = size + 16;
// share_key = ftok(path, 0x000d5000);
share_key = 0x1d5010;
#if 0
snprintf( err_str, sizeof( err_str ),
"MSG: lib, shm, size:%d, key:0x%x(%d)\n", size, share_key, share_key);
record_log(err_str);
#endif
global_share_id = shmget( share_key, size, IPC_CREAT|0666 );
if( global_share_id == -1 ) {
snprintf( err_str, sizeof( err_str ),
"EMERG: fail shmget, %s, 0x%x\n", strerror(errno), share_key);
record_log(err_str);
return -1;
}
shmptr = shmat( global_share_id, NULL, 0 );
if( shmptr == (void *)-1 ) {
snprintf( err_str, sizeof( err_str ), "EMERG: shmat fail.%s,0x%x\n", strerror(errno), share_key );
record_log( err_str );
return -1;
}
#if 0
flag_str = (char *)shmptr+size-16;
if( strcmp( flag_str, "D5001" ) != 0 ) {
//first, do init.
memset( shmptr, 0, size );
strcpy( flag_str, "D5001" );
}
ref_count = (char *)shmptr+size-1;
(*ref_count)++;
#endif
global_shmptr = shmptr;
ptr = (SHM *)shmptr;
}
#endif
return 0;
}
int get_nic_info(char *nic_name, NETCARD_INFO *net_info)
{
int i,ret;
time_t tamp;
struct tm tmptr;
DIR *dir;
char *s;
char buf[128];
char err_str[200];
struct passwd *user;
#if 0
snprintf(err_str, sizeof(err_str), "NOTICE: get nicinfo:%s !\n", nic_name);
record_log(err_str);
#endif
tamp = time(NULL);
localtime_r(&tamp, &tmptr);
if((user = getpwnam("d5000"))!= NULL){
sprintf(log_path,"%s",user->pw_dir);
sprintf(shm_path,"%s",user->pw_dir);
sprintf(sem_path,"%s",user->pw_dir);
}
strcat(log_path,LOG_PATH);
strcat(shm_path,SHM_PATH);
strcat(sem_path,SEM_PATH);
#if 0
//remove
if((dir = opendir(log_path)) == NULL){
if(errno == ENOENT){
strcpy(log_path, "/tmp/");
}
}
closedir(dir);
#endif
s = strrchr(log_path, '/');
s++;
*s = '\0';
memset(buf, 0, sizeof(buf));
strftime(buf, sizeof(buf), "%Y%m%d_", &tmptr);
strcat(buf, "sys_nicmonitor");
strcat(buf, ".log");
strcat(log_path, buf);
if((ret = init_nic_info()) == -1){
return -1;
}
get_sem(semid);
for(i = 0; ptr->info[i].charname[0] != 0; i++){
if(!strcmp(ptr->info[i].charname, nic_name)){
// get_sem(semid);
memcpy(net_info, &ptr->info[i], sizeof(NETCARD_INFO));
release_sem(semid);
#ifdef USE_OLD_MMSHARE
munmap(ptr, sizeof(SHM));
#else
linx_free_shm( ptr, sizeof(SHM) );
#endif
return 0;
}
}
release_sem(semid);
snprintf(err_str, sizeof(err_str), "NOTICE: No information of %s !\n", nic_name);
record_log(err_str);
#ifdef USE_OLD_MMSHARE
munmap(ptr, sizeof(SHM));
#else
linx_free_shm( ptr, sizeof(SHM) );
#endif
return -1;
}
static void linx_free_shm( void *addr, int size )
{
void *shmptr = addr;
char err_str[200];
#if 0
snprintf(err_str, sizeof(err_str), "NOTICE: free shm 0x%x, size:%d, glo:0x%x\n", addr, size, global_shmptr);
record_log(err_str);
#endif
if( shmptr == global_shmptr ) {
char *ref_count = NULL;
int is_last = 0;
// int size = sizeof(SHM);
ref_count = (char *)shmptr + size + 16 - 1;
is_last = *ref_count == 1?1:0;
#if 0
snprintf(err_str, sizeof(err_str), "NOTICE: lib, sref_count: %d, last:%d\n", *ref_count, is_last);
record_log(err_str);
#endif
#if 0
if( is_last ) {
memset( shmptr, 0, size + 16 );
}
#endif
shmdt( shmptr );
// shmctl( global_share_id, IPC_RMID, NULL );
// if( is_last ) {
// global_shmptr = NULL;
// global_share_id = -1;
// }
}
}

52
src/sys_nicmonitor/nicinfo_shm.h Normal file
View File

@@ -0,0 +1,52 @@
#ifndef NIC_SHM_H
#define NIC_SHM_H
#include <sys/socket.h>
#ifdef __cplusplus
extern "C" {
#endif
#ifndef NIC_NAME_LEN
#define NIC_NAME_LEN 64
#endif
#define SEM_PROJ_ID 's'
#define MAXNICNUM 32
typedef long KEYID;
typedef struct _net_info
{
KEYID ID;
char charname[NIC_NAME_LEN];
char descr[128];
struct sockaddr addr;
struct sockaddr broadaddr;
struct sockaddr netmask;
struct sockaddr hwaddr;
int time_stamp;
short flags;
int mtu;
int tx_queue_len;
unsigned long long average_flow;
unsigned long long rx_packets;
unsigned long long tx_packets;
unsigned long long rx_bytes;
unsigned long long tx_bytes;
unsigned long rx_errors;
unsigned long tx_errors;
unsigned long rx_dropped;
unsigned long tx_dropped;
unsigned long rx_multicast;
unsigned long collisions;
unsigned long rx_fifo_errors;
unsigned long tx_carrier_errors;
unsigned long tx_fifo_errors;
}NETCARD_INFO;
int get_nic_info(char *nic_name, NETCARD_INFO *net_info);
#ifdef __cplusplus
}
#endif
#endif

198
src/sys_nicmonitor/proc_inv.h Normal file
View File

@@ -0,0 +1,198 @@
////////////////////////////////////////////////////////////////////////////////////
//
// Copyright (c) Comets' Grp. of Kedong Corp 2008. All Rights Reserved.
//
// FileName : procconf.h
//
// Function : this class realize some basic functions for process managerment,
// such as initiate process, report status of process, check status of process,
// update status of process, get information of process
//
// Author :
//
// Date :
//
// Modify by :
//
// Mod Date :
//
////////////////////////////////////////////////////////////////////////////////////
#ifndef _PROCCONF_H
#define _PROCCONF_H
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <sys/mman.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
//#include <iostream.h>
#include <signal.h>
#include "const.h"
//for alarm ................................
typedef struct MESS_BH
{
unsigned char mtype;
int length;
};
typedef struct PROCESS_ALM
{
char context_name[MAX_STRING_LEN];
char app_name[MAX_STRING_LEN];
char proc_name[MAX_STRING_LEN];
unsigned char status;
};
//for alarm end .............................
//for mmi....................................
const int MAX_BUFFER_LEN = 500;
typedef struct MESS_BLOCK
{
unsigned char num;
char buffer[MAX_BUFFER_LEN];
};
typedef struct MESS_PROC
{
char context_name[MAX_STRING_LEN];
char app_name[MAX_STRING_LEN];
char proc_name[MAX_STRING_LEN];
char status;
};
//for mmi end ................................
const int DEFAULT_PERIOD = 3;
const int COUNT_LIMIT = 2;
const int START_DEFAULT_PERIOD = 60;
const int START_COUNT_LIMIT = 5;
const int APP_COUNT_LIMIT = 1;
//process critical level
//const int WST_CRITICAL = 1; // Shutdown and reboot workstation when failed
//const int SYS_CRITICAL = 2; // Shutdown and reboot the system on the wst when failed
//const int USER_CRITICAL = 3; // Shutdown and reboot the subsystem when failed
//const int GENERAL = 4; // reboot the process
const int CRUCIAL = 1; // crucial process
const int GENERAL = 0; // general process
extern int srv_init(char *service,int port);
extern int Tcp_close(int sockfd);
extern int Tcp_read(int fd,char *ptr,int nbytes);
extern int Tcp_write(int fd,char *ptr,int nbytes);
extern int srv_accept(int fd,struct sockaddr *cli_addr,int *clilen);
extern int client_tcp_open(char *host,char *service,int port);
typedef struct
{
char context_name[MAX_STRING_LEN];
char app_name[MAX_STRING_LEN];
char proc_name[MAX_STRING_LEN];
pid_t proc_pid;
}PROC_ADM_INFO;
//***************************************************************
// structure name : PROC_INFO
// function : store process informatin
// author :
// date :
// modify by :
// modification :
// mod date :
//***************************************************************
typedef struct
{
int position;
char node_name[MAX_STRING_LEN];
char context_name[MAX_STRING_LEN];
char app_name[MAX_STRING_LEN];
char proc_name[MAX_STRING_LEN];
unsigned char active_flag;
unsigned char master_flag;
time_t startup_time;
time_t refresh_time;
short refresh_peri;
unsigned char monitor_type;
pid_t proc_pid;
unsigned char auto_start;
unsigned char act_timer;
unsigned char start_timer;
unsigned char critical_level;
char exefile_path[MAX_EXECMD_LEN];
}PROC_INFO;
//***************************************************************
// structure name : APP_INFO
// function : store application informatin
// author :
// date :
// modify by :
// modification :
// mod date :
//***************************************************************
typedef struct
{
int position;
char context_name[MAX_STRING_LEN];
int context_id;
char app_name[MAX_STRING_LEN];
int app_id;
unsigned char act_timer;
unsigned char active_flag;
}APP_INFO;
typedef struct
{
int no_proc;
int semdes_cfg;
PROC_INFO proc[MAX_LOCAL_PROCESS];
APP_INFO app[MAX_LOCAL_APP];
}PROCCFG;
class proc_invocation
{
public:
int m_init;
PROCCFG *proccfg_p;
public:
proc_invocation();
~proc_invocation();
int conf_create();
//int check_proc_status();
//int update_rtdb();
//int kill_proc(pid_t pid);
//int start_proc(char *cmdline);
//int send_alarm(char *context_name, char *app_name, char *proc_name, unsigned char status);
//int update_proc_status(char *context_name, char *app_name, char *proc_name, char status);
//int proc_init(char *context_name, char *app_name, char *proc_name, int critical_level);//exefile_path,auto_start
int proc_init(char *context_name, char *app_name, char *proc_name);
int proc_report(int pos, char status, int intertime=3);
int proc_exit(int proc_pos);
int get_pos(char *context_name, char *app_name, char *proc_name);
int is_proc_exist(char *context_name, char *app_name, char *proc_name);
int conf_map();
int get_procinfo(int position, PROC_ADM_INFO *p_info);
int get_active_pid(int &num, int *p_pidlist);
int is_proc_run(pid_t pid);
int is_proc_run(char *context_name, char *app_name, char *proc_name);
};
#endif

133
src/sys_nicmonitor/read_netcard.c Normal file
View File

@@ -0,0 +1,133 @@
#include "mnic.h"
static char *prase_digit(char **s)
{
char *retp = NULL;
char *p = *s;
if(!p)return NULL;
while(!isdigit(*p)){
p++;
if(*p == '\0')return NULL;
}
retp = p;
while(isdigit(*p)){
p++;
if(*p == '\0'){
*s = NULL;
return retp;
}
}
*p = '\0';
p++;
*s = p;
return retp;
}
char *get_name(char *name, char *p)
{
while (isspace(*p))
p++;
while (*p) {
if (isspace(*p))
break;
if (*p == ':') { /* could be an alias */
char *dot = p, *dotname = name;
*name++ = *p++;
while (isdigit(*p))
*name++ = *p++;
if (*p != ':') { /* it wasn't, backup */
p = dot;
name = dotname;
}
if (*p == '\0')
return NULL;
p++;
break;
}
*name++ = *p++;
}
*name++ = '\0';
return p;
}
int get_dev_fields(char *str, NETCARD_INFO *ife)
{
int i = 0;
char *retp[16];
while((retp[i] = prase_digit(&str)) != NULL){i++;if(i > 15)break;}
ife->rx_bytes = atoll(retp[0]);
ife->rx_packets = atoll(retp[1]);
ife->rx_errors = atol(retp[2]);
ife->rx_dropped = atol(retp[3]);
ife->rx_fifo_errors = atol(retp[4]);
ife->rx_multicast = atol(retp[7]);
ife->tx_bytes = atoll(retp[8]);
ife->tx_packets = atoll(retp[9]);
ife->tx_errors = atol(retp[10]);
ife->tx_dropped = atol(retp[11]);
ife->tx_fifo_errors = atol(retp[12]);
ife->collisions = atol(retp[13]);
ife->tx_carrier_errors = atol(retp[14]);
return 0;
}
int if_fetch(NETCARD_INFO *ife)
{
int skfd;
struct ifreq ifr;
if((skfd = socket(PF_INET, SOCK_DGRAM, 0)) == -1)return -1;
strcpy(ifr.ifr_name, ife->charname);
if (!ioctl(skfd, SIOCGIFFLAGS, &ifr))
ife->flags = ifr.ifr_flags;
if (!ioctl(skfd, SIOCGIFHWADDR, &ifr))
ife->hwaddr = ifr.ifr_hwaddr;
if (!ioctl(skfd, SIOCGIFMTU, &ifr))
ife->mtu = ifr.ifr_mtu;
if (!ioctl(skfd, SIOCGIFTXQLEN, &ifr))
ife->tx_queue_len = ifr.ifr_qlen;
if (!ioctl(skfd, SIOCGIFADDR, &ifr))
ife->addr = ifr.ifr_addr;
if (!ioctl(skfd, SIOCGIFBRDADDR, &ifr))
ife->broadaddr = ifr.ifr_broadaddr;
if (!ioctl(skfd, SIOCGIFNETMASK, &ifr))
ife->netmask = ifr.ifr_netmask;
ife->time_stamp = time(NULL);
close(skfd);
return 0;
}
int ioc_get_name(NETCARD_INFO *name)
{
int skfd;
int ifrnum;
int i = 0;
struct ifconf ifc;
struct ifreq buf[MAXNICNUM];
if((skfd = socket(PF_INET, SOCK_DGRAM, 0)) == -1)return -1;
memset(buf, 0, sizeof(buf));
ifc.ifc_len = sizeof(buf);
ifc.ifc_buf = (caddr_t) buf;
ioctl(skfd, SIOCGIFCONF, &ifc);
ifrnum = ifc.ifc_len / sizeof(struct ifreq);
while(ifrnum-- > 0){
strcpy(name[i].charname, buf[ifrnum].ifr_name);
i++;
}
close(skfd);
return i;
}

37
src/sys_nicmonitor/send_alarm.c Normal file
View File

@@ -0,0 +1,37 @@
#include "mnic.h"
void send_alarm(D5000_NIC_ALARM *mesg, int socket_port, char *ipv4)
{
int bytes;
int sock_sd;
int val;
char error_str[200];
struct sockaddr_in recever;
socklen_t sock_len;
if((sock_sd = socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP)) == -1){
snprintf(error_str, sizeof(error_str), "EMERG: socket(): %s\n", strerror(errno));
record_log(error_str);
return;
}
val=1;
if ((setsockopt(sock_sd, SOL_SOCKET, SO_BROADCAST, &val, sizeof(val))) == -1) {
snprintf(error_str, sizeof(error_str), "EMERG: setsockopt(): %s\n", strerror(errno));
record_log(error_str);
return;
}
/* init socket*/
recever.sin_family = AF_INET;
recever.sin_port = htons(socket_port);
inet_pton(AF_INET, ipv4, &recever.sin_addr);
sock_len = sizeof(recever);
/* send alarm*/
if((bytes = sendto(sock_sd, mesg, sizeof(D5000_NIC_ALARM), 0, (const struct sockaddr *)&recever, sock_len)) < 1){
snprintf(error_str, sizeof(error_str), "EMERG: sendto(): %s\n", strerror(errno));
record_log(error_str);
return;
}
//snprintf(error_str, sizeof(error_str), "NOTICE: Alarm information has already send!\n");
//record_log(error_str);
close(sock_sd);
}

88
src/sys_nicmonitor/sys_netcard.h Normal file
View File

@@ -0,0 +1,88 @@
#ifndef _SYS_NETCARD_H
#define _SYS_NETCARD_H
#include <sys/socket.h>
#ifndef NIC_NAME_LEN
#define NIC_NAME_LEN 64
#endif
#define SEM_PROJ_ID 's'
#define MAXNICNUM 32
#ifdef __cplusplus
extern "C"{
#endif
typedef long KEYID;
typedef struct _msg_frame // message frame
{
short len; // message length
short seqno; // send sequence
short serv; // services ID
short event; // event ID
unsigned char domain; // domain ID
unsigned char ctxt; // Context ID
short stid; // SOURCE task id
short dtid; // DESTINATION task ID
unsigned char ver_coding; // 版本号 + 编码
unsigned char mes_type; // 帧类型
}MSG_FRAME, *LPMSG_FRAME;
typedef struct _net_info
{
KEYID ID;
char charname[NIC_NAME_LEN];
char descr[128];
struct sockaddr addr;
struct sockaddr broadaddr;
struct sockaddr netmask;
struct sockaddr hwaddr;
int time_stamp;
short flags;
int mtu;
int tx_queue_len;
unsigned long long average_flow;
unsigned long long rx_packets;
unsigned long long tx_packets;
unsigned long long rx_bytes;
unsigned long long tx_bytes;
unsigned long rx_errors;
unsigned long tx_errors;
unsigned long rx_dropped;
unsigned long tx_dropped;
unsigned long rx_multicast;
unsigned long collisions;
unsigned long rx_fifo_errors;
unsigned long tx_carrier_errors;
unsigned long tx_fifo_errors;
}NETCARD_INFO, *LPNETCARD_INFO;
#define NETCARD_ALARM_FAULT 1
#define NETCARD_ALARM_RESUME 2
#define NETCARD_ALARM_SWITCH 3
#define NETCARD_ALARM_ABNORMAL 4
#define NETCARD_ALARM_NORMAL 5
typedef struct _sys_netcard_alarm
{
char fault_devname[NIC_NAME_LEN]; /*故障设备名称 */
char switch_devname[NIC_NAME_LEN]; /*切换设备名称 */
short flags; /* 状态标记 : 1:网卡故障。2:网卡恢复。3:网卡切换。4:流量异常。*/
short retrytimes; //0，1，2 重发次数
}SYS_NETCARD_ALARM, *LPSYS_NETCARD_ALARM;
typedef struct _d5000_nic_alarm
{
MSG_FRAME tMsgFrame ;
SYS_NETCARD_ALARM tSysNetcardAlarm ;
}D5000_NIC_ALARM, *LPD5000_NIC_ALARM;
#ifdef __cplusplus
}
#endif
#endif

44
src/sys_nicmonitor/test.c Normal file
View File

@@ -0,0 +1,44 @@
#include <stdio.h>
#include <fcntl.h>
#include <sys/time.h>
#include <string.h>
#include "nicinfo_shm.h"
int main(int argc, char *argv[])
{
NETCARD_INFO ni;
int ret = 0;
char dev[10];
struct timeval st,et;
unsigned long uset, stl, etl, to;
if( argc >=2 ) strncpy(dev,argv[1],9);
else strcpy(dev, "eth0");
if( argc >=3 ) to = strtol(argv[2], NULL, 10 );
else to= 500000ull;
while(1) {
gettimeofday(&st, NULL);
ret = get_nic_info( dev, &ni );
gettimeofday(&et, NULL);
stl = st.tv_sec;
stl = stl*1000000 + st.tv_usec;
etl = et.tv_sec;
etl = etl*1000000 + et.tv_usec;
uset = etl - stl;
// printf("%d, %x, %x\n", ret, uset, to);
if( ret != 0 || uset > to) {
///home/d5000/var/log/netcard/testnic.log
char buf[120];
int log = open("/home/d5000/var/log/netcard/testnic.log", O_CREAT|O_RDWR|O_APPEND, 0666);
snprintf(buf,sizeof(buf),"ret:%d, %lld-%lld=%lld\n", ret, etl, stl, uset);
write(log, buf, strlen(buf));
close(log);
}
// sleep(1);
}
}

5
src/sys_nicmonitor/version.h Normal file
View File

@@ -0,0 +1,5 @@
// version=1.9
#ifndef MNIC_VERSION
#define MNIC_VERSION "1.9"
#endif