code: 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.cpusf 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
docs: Establish a connection with the event pull socket
          Default timeout is 1 s