Skip to content

O
OpenXG-NRF
Commit 7bdcfe04 authored by Mosaical's avatar Mosaical
Browse files
Options

20210601

parent 1851b81b
Hide whitespace changes
Inline Side-by-side
Showing with 126 additions and 16 deletions
build/api-server
View file @ 7bdcfe04
No preview for this file type
build/duklAMF.json
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.0.0"
"127.0.0.1:6666"
],
"nfInstanceId": "duklAMF",
"nfServices": [
......
build/gmon.out
View file @ 7bdcfe04
No preview for this file type
build/liuyuSMF.json
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.211.67:8080"
"127.0.0.1:8080"
],
"nfInstanceId": "liuyuSMF",
"nfStatus": "REGISTERED",
......
build/liuyuSMF17.json
View file @ 7bdcfe04
......@@ -3,6 +3,6 @@
"192.168.211.67:8080"
],
"nfInstanceId": "liuyuSMF17",
"nfStatus": "SUSPENDED",
"nfStatus": "REGISTERED",
"nfType": "SMF"
}
build/liuyuSMF18.json 0 → 100644
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.211.67:8080"
],
"nfInstanceId": "liuyuSMF18",
"nfStatus": "REGISTERED",
"nfType": "SMF"
}
build/liuyuSMF19.json 0 → 100644
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.211.67:8080"
],
"nfInstanceId": "liuyuSMF19",
"nfStatus": "REGISTERED",
"nfType": "SMF"
}
build/liuyuSMF2.json
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.211.67:8080"
"127.0.0.1:8080"
],
"nfInstanceId": "liuyuSMF2",
"nfStatus": "REGISTERED",
......
build/liuyuSMF20.json 0 → 100644
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.211.67:8080"
],
"nfInstanceId": "liuyuSMF20",
"nfStatus": "REGISTERED",
"nfType": "SMF"
}
build/liuyuSMF21.json 0 → 100644
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.211.67:8080"
],
"nfInstanceId": "liuyuSMF21",
"nfStatus": "REGISTERED",
"nfType": "SMF"
}
build/liuyuSMF22.json 0 → 100644
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.211.67:8080"
],
"nfInstanceId": "liuyuSMF22",
"nfStatus": "REGISTERED",
"nfType": "SMF"
}
build/liuyuSMF23.json 0 → 100644
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.211.67:8080"
],
"nfInstanceId": "liuyuSMF23",
"nfStatus": "REGISTERED",
"nfType": "SMF"
}
build/liuyuSMF24.json 0 → 100644
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.211.67:8080"
],
"nfInstanceId": "liuyuSMF24",
"nfStatus": "SUSPENDED",
"nfType": "SMF"
}
build/liuyuSMF25.json 0 → 100644
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.211.67:8080"
],
"nfInstanceId": "liuyuSMF25",
"nfStatus": "SUSPENDED",
"nfType": "SMF"
}
build/liuyuSMF26.json 0 → 100644
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.211.67:8080"
],
"nfInstanceId": "liuyuSMF26",
"nfStatus": "SUSPENDED",
"nfType": "SMF"
}
build/liuyuSMF27.json 0 → 100644
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.211.67:8080"
],
"nfInstanceId": "liuyuSMF27",
"nfStatus": "REGISTERED",
"nfType": "SMF"
}
build/liuyuSMF28.json 0 → 100644
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.211.67:8080"
],
"nfInstanceId": "liuyuSMF28",
"nfStatus": "REGISTERED",
"nfType": "SMF"
}
build/liuyuSMF29.json 0 → 100644
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.211.67:8080"
],
"nfInstanceId": "liuyuSMF29",
"nfStatus": "SUSPENDED",
"nfType": "SMF"
}
build/liuyuSMF3.json
View file @ 7bdcfe04
{
"ipv4Addresses": [
"192.168.211.67:8080"
"127.0.0.1:8080"
],
"nfInstanceId": "liuyuSMF3",
"nfStatus": "REGISTERED",
......
impl/NFInstanceIDDocumentApiImpl.cpp
View file @ 7bdcfe04
......@@ -231,9 +231,14 @@ void NFInstanceIDDocumentApiImpl::register_nf_instance(const std::string &nfInst
}
threadData[nfInstanceIdLength] = '\0';
for(int i = 0; i <= nfInstanceIdLength; i++ ){
std::cout << "threadData is : " << threadData[i] << std::endl;
}
pthread_t thread_id;
//pthread_create( &thread_id, NULL, print_message, NULL );
pthread_create( &thread_id, NULL, print_message, &threadData );
pthread_create( &thread_id, NULL, print_message, (void*)&nfInstanceId);
pthread_detach(thread_id);
//sleep(1);
printf("Leave main thread!\n");
......
impl/NFInstanceIDDocumentApiImpl.h
View file @ 7bdcfe04
......@@ -69,17 +69,26 @@ static void* print_message( void* data )
// }
// pthread_exit(0) ;//pthread_exit时自动会被释放
int flag = 1;
std::string dataString = (char*)data;
//std::cout << "data is :" << dataString <<std::endl;(已成功取出)
std::string dataString = *((std::string*)data);
std::cout << "data is :" << *((std::string*)data) <<std::endl;//(已成功取出)
std::string heartBeatString;
zookeeperClient zooK;
bool atest = zooK.connect2ZKServer("192.168.211.128:2181");
utility::zk_cpp* zk;
zk = zooK.getZk();
std::string path = "/HeartBeat";
while (1)
{
get2rdNodeMessage *Get2rdNodeMessage = new get2rdNodeMessage;
std::string path = "/HeartBeat";
std::string heartBeatString = Get2rdNodeMessage->getNodeMessage(path);
free(Get2rdNodeMessage);
utility::zoo_rc ret = zk->get_node(path.c_str(), heartBeatString, nullptr, true);
//get2rdNodeMessage *Get2rdNodeMessage = new get2rdNodeMessage;
//std::string path = "/HeartBeat";
//std::string heartBeatString = Get2rdNodeMessage->getNodeMessage(path);
//free(Get2rdNodeMessage);
if(heartBeatString == dataString){
//将心跳zookeeper归零
std::cout << "进入归零程序!" << std::endl;
zookeeperClient zooK;
bool atest = zooK.connect2ZKServer("192.168.211.128:2181");
utility::zk_cpp* zk;
......@@ -92,15 +101,15 @@ static void* print_message( void* data )
flag = 0;
usleep(1000 * 1000);
usleep(100 * 1000);
printf("thread1 running...!\n");
}else{
usleep(1000 * 1000);
usleep(100 * 1000);
printf("thread1 running...!\n");
flag++;
if(flag>=6) break;
if(flag>=60) break;
}
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment