code: def _batched_unpack_params(params_data, buffer, dtype, stream=None):
      n_params = params_data.n_params
      n_elems = params_data.n_elems
      params_dptr = params_data.dptr
      params_dtype = params_data.dtype
      params_size_csum = params_data.size_csum
      buf_dtype = _communication_utility._get_nccl_type_id(dtype)
      n_threads = 128
      n_blocks = (n_elems + n_threads - 1) // n_threads
      if stream is None:
          stream = cp.cuda.get_current_stream()
      with stream:
          _cupy_batched_unpack_params()(
              (n_blocks,),
              (n_threads,),
              (
                  buffer.memory.ptr,
                  buf_dtype,
                  n_elems,
                  params_dptr,
                  params_dtype,
                  params_size_csum,
                  n_params,
              ),
          )
  
imports: import ctypes
  import mpi4py.MPI
  import numpy
  from chainermn.communicators import _communication_utility
  import chainer.backends
  import chainerx
label_desc: Use image node_id 10 for calling a global function with example usage: _batched_unpack_params(params_data, buffer, dtype, stream) without return types