Update the communications between master and slave

Change-Id: I08f0d588f8e009cb6f25f3fe71d8df79d6dfbaf1

1 files changed, 13 insertions, 0 deletions

diff --git a/moonv4/moon_secrouter/moon_secrouter/api/route.py b/moonv4/moon_secrouter/moon_secrouter/api/route.py
index 28a9a65f..2a2c54bc 100644
--- a/moonv4/moon_secrouter/moon_secrouter/api/route.py
+++ b/moonv4/moon_secrouter/moon_secrouter/api/route.py
@@ -135,6 +135,14 @@ class Cache(object):
 
     def __update_pdp(self):
         pdp = call("moon_manager", method="get_pdp", ctx={"user_id": "admin"}, args={})
+        if not pdp["pdps"]:
+            LOG.info("Updating PDP through master")
+            pdp = call("moon_manager", method="get_pdp",
+                       ctx={
+                           "user_id": "admin",
+                           'call_master': True
+                        },
+                       args={})
         for _pdp in pdp["pdps"].values():
             if _pdp['keystone_project_id'] not in self.__CONTAINER_CHAINING:
                 self.__CONTAINER_CHAINING[_pdp['keystone_project_id']] = {}
@@ -418,6 +426,11 @@ class Router(object):
                     return call(component, method=ctx["method"], ctx=ctx, args=args)
                 if component == "manager":
                     result = call("moon_manager", method=ctx["method"], ctx=ctx, args=args)
+                    if ctx["method"] == "get_pdp":
+                        _ctx = copy.deepcopy(ctx)
+                        _ctx["call_master"] = True
+                        result2 = call("moon_manager", method=ctx["method"], ctx=_ctx, args=args)
+                        result["pdps"].update(result2["pdps"])
                     self.send_update(api=ctx["method"], ctx=ctx, args=args)
                     return result
                 if component == "function":