code: def _server_loop(self, host, port):
      # This is for minimum info exchange during initialization
      # a single connection allows to implement locking mechanics easily
      with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
          s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
          s.bind((host, port))
          s.listen()
          s.settimeout(0.5)
          while self._run.value == 1:
              try:
                  c_socket, addr = s.accept()
              except socket.timeout:
                  continue
  
              t = threading.Thread(
                  target=self._process_request,
                  args=(c_socket,),
                  daemon=True,
              )
              t.start()
  
imports: import atexit
  from ctypes import sizeof
  import multiprocessing
  import threading
  import socket
  import time
  from cupyx.distributed import _klv_utils
  from cupyx.distributed import _store_actions
label_desc: Use image node_id 5 for calling the TCPStore obj's underlying member method code with example usage: obj._server_loop(host, port) without return types