arrow Namespace Reference

Functions
key_t	get_and_copy_to_shm (const std::shared_ptr< Buffer > &data)

Function Documentation

get_and_copy_to_shm()

key_t arrow::get_and_copy_to_shm

(

const std::shared_ptr< Buffer > &

data

)

Definition at line 297 of file ArrowResultSetConverter.cpp.

References anonymous_namespace{ArrowResultSetConverter.cpp}::get_shm().

Referenced by ArrowResultSetConverter::getArrowResult().

                                                             {
#ifdef _MSC_VER
  throw std::runtime_error("Arrow IPC not yet supported on Windows.");
#else
  auto [key, ipc_ptr] = get_shm(data->size());
  // copy the arrow records buffer to shared memory
  // TODO(ptaylor): I'm sure it's possible to tell Arrow's RecordBatchStreamWriter to
  // write directly to the shared memory segment as a sink
  memcpy(ipc_ptr, data->data(), data->size());
  // detach from the shared memory segment
  shmdt(ipc_ptr);
  return key;
#endif
}

Here is the call graph for this function:

Here is the caller graph for this function: