

def tunnel_request_handles(self, tunnel):
    ' Incoming tunnel request for storage proxy server\n            Start a socket server and update peer node with control uri\n        '
    self.tunnels[tunnel.peer_node_id] = tunnel
    self.controltunnels[tunnel.peer_node_id] = CalvinControlTunnel(tunnel)
    tunnel.register_tunnel_down(CalvinCB(self.tunnel_down, tunnel))
    tunnel.register_tunnel_up(CalvinCB(self.tunnel_up, tunnel))
    tunnel.register_recv(CalvinCB(self.tunnel_recv_handler, tunnel))
    return True

dataset/ETHPy150Open EricssonResearch/calvin-base/calvin/runtime/north/calvincontrol.py CalvinControlTunnelServer.tunnel_request_handles/original