[VOL-1036] Initial implementation of device lifecycle management
Change-Id: I5aa58fdcbcd852f6f5eef35d48f25f76e20c0418
diff --git a/adapters/kafka/adapter_request_facade.py b/adapters/kafka/adapter_request_facade.py
index 74ed934..2517a31 100644
--- a/adapters/kafka/adapter_request_facade.py
+++ b/adapters/kafka/adapter_request_facade.py
@@ -82,17 +82,17 @@
d = Device()
if device:
device.Unpack(d)
- return (True, self.adapter.adopt_device(d))
+ return True, self.adapter.adopt_device(d)
else:
- return (False, d)
+ return False, d
def get_ofp_device_info(self, device):
d = Device()
if device:
device.Unpack(d)
- return (True, self.adapter.get_ofp_device_info(d))
+ return True, self.adapter.get_ofp_device_info(d)
else:
- return (False, d)
+ return False, d
def get_ofp_port_info(self, device, port_no):
d = Device()
@@ -104,7 +104,7 @@
p = IntType()
port_no.Unpack(p)
- return (True, self.adapter.get_ofp_port_info(d, p.val))
+ return True, self.adapter.get_ofp_port_info(d, p.val)
def reconcile_device(self, device):
@@ -114,10 +114,20 @@
return self.adapter.abandon_device(device)
def disable_device(self, device):
- return self.adapter.disable_device(device)
+ d = Device()
+ if device:
+ device.Unpack(d)
+ return True, self.adapter.disable_device(d)
+ else:
+ return False, d
def reenable_device(self, device):
- return self.adapter.reenable_device(device)
+ d = Device()
+ if device:
+ device.Unpack(d)
+ return True, self.adapter.reenable_device(d)
+ else:
+ return False, d
def reboot_device(self, device):
d = Device()