Commit 19eed82f authored by Thibault VINCENT's avatar Thibault VINCENT
Browse files

add: handler connects to libvirt with unix sockets

parent e9d7ea3f

ccnode/jobs.py

+7 −1
Original line number Diff line number Diff line
@@ -986,7 +986,13 @@ class TCPTunnelJob(BaseJob): 
                ## connect to the endpoint

                timeout = 15 # FIXME must be argument

                retry_interval = 5

                self._sock_client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

                # FIXME detection of socket type

                if isinstance(self._endpoint, str):

                    self._sock_client = socket.socket(socket.AF_UNIX,

                                                        socket.SOCK_STREAM)

                else:

                    self._sock_client = socket.socket(socket.AF_INET,

                                                        socket.SOCK_STREAM)

                self._sock_client.settimeout(timeout)

                connected = False

                while not self._cancelled and not connected: