code: def test_queue_large():
      max_int32 = 2**31 - 1
      max_uint32 = 2**32 - 1
      max_uint64 = 2**64 - 1
      msgs = [
          (max_int32, max_int32, max_int32, max_int32, max_int32),
          (max_int32, max_int32, max_uint32, max_uint32, max_uint32),
          (max_int32, max_int32, max_uint64, max_uint64, max_uint64),
      ]
      for start_method in ("spawn", "fork"):
          for msg in msgs:
              yield _test_queue_large, start_method, [msg]
  
imports: import os
  import multiprocessing
  import socket
  from contextlib import closing, contextmanager
  import numpy
  from nvidia.dali._multiproc.shared_batch import BufShmChunk, SharedBatchWriter, SharedBatchMeta, deserialize_batch
  from nvidia.dali._multiproc.shared_queue import ShmQueue
  from nvidia.dali._multiproc.messages import ShmMessageDesc
  from test_utils import RandomlyShapedDataIterator
  from nose_utils import raises
label_desc: Use image node_id 12 for calling a global function with example usage: test_queue_large() without return types