def connect_pull(self, timeout=1):
        '''
        Establish a connection with the event pull socket
        Default timeout is 1 s
        '''
        if self.cpush:
            return True

        if self._run_io_loop_sync:
            with salt.utils.asynchronous.current_ioloop(self.io_loop):
                if self.pusher is None:
                    self.pusher = salt.transport.ipc.IPCMessageClient(
                        self.pulluri,
                        io_loop=self.io_loop
                    )
                try:
                    self.io_loop.run_sync(
                        lambda: self.pusher.connect(timeout=timeout))
                    self.cpush = True
                except Exception:
                    pass
        else:
            if self.pusher is None:
                self.pusher = salt.transport.ipc.IPCMessageClient(
                    self.pulluri,
                    io_loop=self.io_loop
                )
            # For the asynchronous case, the connect will be deferred to when
            # fire_event() is invoked.
            self.cpush = True
        return self.cpush
def connect_pull ( self , timeout = 1 ) : if self . cpush : return True if self . _run_io_loop_sync : with salt . utils . asynchronous . current_ioloop ( self . io_loop ) : if self . pusher is None : self . pusher = salt . transport . ipc . IPCMessageClient ( self . pulluri , io_loop = self . io_loop ) try : self . io_loop . run_sync ( lambda : self . pusher . connect ( timeout = timeout ) ) self . cpush = True except Exception : pass else : if self . pusher is None : self . pusher = salt . transport . ipc . IPCMessageClient ( self . pulluri , io_loop = self . io_loop ) self . cpush = True return self . cpush
Establish a connection with the event pull socket
        Default timeout is 1 s