1 # ==================================================================================
2 # Copyright (c) 2020 HCL Technologies Limited.
4 # Licensed under the Apache License, Version 2.0 (the "License");
5 # you may not use this file except in compliance with the License.
6 # You may obtain a copy of the License at
8 # http://www.apache.org/licenses/LICENSE-2.0
10 # Unless required by applicable law or agreed to in writing, software
11 # distributed under the License is distributed on an "AS IS" BASIS,
12 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 # See the License for the specific language governing permissions and
14 # limitations under the License.
15 # ==================================================================================
17 # This initialization script reads in a json from the specified config map path
18 # to set up the initializations (route config map, variables etc) for the main
28 def signal_handler(signum, frame):
29 print("Received signal {0}\n".format(signum));
30 if(xapp_subprocess == None or xapp_pid == None):
31 print("No xapp running. Quiting without sending signal to xapp\n");
33 print("Sending signal {0} to xapp ...".format(signum));
34 xapp_subprocess.send_signal(signum);
37 def parseConfigJson(config):
39 for k1 in config.keys():
40 if k1 in ParseSection:
41 result = ParseSection[k1](config);
46 # for k2 in config[k1].keys():
48 # if k2 in ParseSection:
49 # result = ParseSection[k2](config[k1]);
55 def getMessagingInfo(config):
56 if 'messaging' in config.keys() and 'ports' in config['messaging'].keys():
57 port_list = config['messaging']['ports']
58 for portdesc in port_list :
59 if 'port' in portdesc.keys() and 'name' in portdesc.keys() and portdesc['name'] == 'rmr-data':
60 lport = portdesc['port']
61 # Set the environment variable
62 os.environ["BOUNCER_PORT"] = str(lport)
65 print("Error! No valid listening port");
68 def getXappName(config):
70 if myKey not in config.keys():
71 print(("Error ! No information found for {0} in config\n".format(myKey)));
74 xapp_name = config[myKey];
75 print("Xapp Name is: " + xapp_name);
76 os.environ["XAPP_NAME"] = xapp_name;
78 default_routing_file = "/tmp/routeinfo/routes.txt";
81 ParseSection["xapp_name"] = getXappName;
82 ParseSection["messaging"] = getMessagingInfo;
85 #================================================================
86 if __name__ == "__main__":
89 cmd = ["/usr/local/bin/b_xapp_main"];
92 config_file = sys.argv[1];
94 print("Error! No configuration file specified\n");
100 with open(config_file, 'r') as f:
102 config = json.load(f);
103 except Exception as e:
104 print(("Error loading json file from {0}. Reason = {1}\n".format(config_file, e)));
107 result = parseConfigJson(config);
110 print("Error parsing json. Not executing xAPP");
115 # Register signal handlers
116 signal.signal(signal.SIGINT, signal_handler);
117 signal.signal(signal.SIGTERM, signal_handler);
120 #print("Executing xAPP ....");
121 xapp_subprocess = subprocess.Popen(cmd, shell = False, stdin=None, stdout=None, stderr = None);
122 xapp_pid = xapp_subprocess.pid;
124 # Periodically poll the process every 5 seconds to check if still alive
126 xapp_status = xapp_subprocess.poll();
127 if xapp_status == None:
130 print("XaPP terminated via signal {0}\n".format(-1 * xapp_status));