EMS/svc.ems
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add:spgw kpi

Browse Source
This commit is contained in:
simonzhangsz
2024-11-14 17:17:48 +08:00
parent 2e658c5839
commit 48f0493d4e
1 changed files with 33 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
src/performanceMgr/c_program/cstaCollector/csta.c
View File

@@ -1260,6 +1260,8 @@ int csta_record(csta_src *pcsta,csta_sys *psys,snmp_pdu *pdu)
}
}
else
{
if (pcsta->sysTypeNo != 362)
{
for(i=0;i<pobj->detail_field_count;i++)
{
@@ -1267,6 +1269,37 @@ int csta_record(csta_src *pcsta,csta_sys *psys,snmp_pdu *pdu)
sprintf(tmpstr3,"%u,",htonl(*pval4));
strcat(sqlstr,tmpstr3);
}
}else{ //SPGW
for(i=0;i<pobj->detail_field_count-2;i++)
{
pval4=(DWORD*)(pvar->msg + 4 + i * 4);
sprintf(tmpstr3,"%u,",htonl(*pval4));
strcat(sqlstr,tmpstr3);
printf("Field %d: %u\n", i + 1, htonl(*pval4));
} //ǰʮ<C7B0><CAAE><EFBFBD><EFBFBD>
DWORD *uplink_tmp1, *uplink_tmp2;
DWORD *downlink_tmp1, *downlink_tmp2;
uint64_t uplink_total_volume;
uint64_t downlink_total_volume;
// <20><><EFBFBD><EFBFBD> uplink_total_volume
uplink_tmp1 = (DWORD*)(pvar->msg + 4 + (pobj->detail_field_count - 2) * 4); //68
uplink_tmp2 = (DWORD*)(pvar->msg + 4 + (pobj->detail_field_count -1) * 4); // 72
uplink_total_volume = ((uint64_t)ntohl(*uplink_tmp1) << 32) +ntohl(*uplink_tmp2);
sprintf(tmpstr3, "%llu,", uplink_total_volume);
strcat(sqlstr, tmpstr3);
// <20><><EFBFBD><EFBFBD> downlink_total_volume
downlink_tmp1 = (DWORD*)(pvar->msg + 4 + (pobj->detail_field_count ) * 4); //76<37><36>ʼ
downlink_tmp2 = (DWORD*)(pvar->msg + 4 + (pobj->detail_field_count +1) * 4); //80<38><30>ʼ
downlink_total_volume = ((uint64_t)ntohl(*downlink_tmp1) << 32) +ntohl(*downlink_tmp2);
sprintf(tmpstr3, "%llu,", downlink_total_volume);
strcat(sqlstr, tmpstr3);
}
}
sprintf(tmpstr3,"FROM_UNIXTIME(%ld))",d_timestamp);
strcat(sqlstr,tmpstr3);