code: def test_rpc_timeout():
      reset_envs()
      os.environ["DGL_DIST_MODE"] = "distributed"
      ip_config = "rpc_ip_config.txt"
      generate_ip_config(ip_config, 1, 1)
      ctx = mp.get_context("spawn")
      pserver = ctx.Process(
          target=start_server, args=(1, ip_config, 0, 1)
      )
      pclient = ctx.Process(
          target=start_client_timeout, args=(ip_config, 0, 1)
      )
      pserver.start()
      pclient.start()
      pserver.join()
      pclient.join()
  
imports: import multiprocessing
  import os
  import socket
  import time
  import unittest
  import backend
  import dgl
  import pytest
  from numpy.testing import assert_array_equal
  from utils import generate_ip_config, reset_envs
label_desc: Use image node_id 6 for calling a global function with example usage: test_rpc_timeout() without return types