Job::detail Namespace Reference

Functions
QueueType	taskQType (const Task *task) noexcept
void *	taskGetPrivateUserData (Task *const task, const std::size_t alignment) noexcept
void *	taskReservePrivateUserData (Task *const task, const std::size_t num_bytes, const std::size_t alignment) noexcept
bool	mainQueueTryRunTask (void) noexcept
void	assertHandler (const bool condition, const char *const filename, const int line_number, const char *const msg)

Function Documentation

taskQType()

QueueType Job::detail::taskQType ( const Task *  task )

noexcept

Definition at line 1214 of file job_system.cpp.

{
  return task->q_type;
}

Referenced by Job::ParallelFor(), Job::ParallelInvoke(), and Job::ParallelReduce().

taskGetPrivateUserData()

void * Job::detail::taskGetPrivateUserData ( Task *const  task, const std::size_t  alignment  )

noexcept

Definition at line 1219 of file job_system.cpp.

{
  return AlignPointer(task->user_data, alignment);
}

Referenced by Job::TaskMake().

taskReservePrivateUserData()

void * Job::detail::taskReservePrivateUserData ( Task *const  task, const std::size_t  num_bytes, const std::size_t  alignment  )

noexcept

Definition at line 1224 of file job_system.cpp.

{
  const Byte* const user_storage_end        = std::end(task->user_data);
  Byte* const       requested_storage_start = static_cast<Byte*>(AlignPointer(task->user_data, alignment));
  const Byte* const requested_storage_end   = requested_storage_start + num_bytes;
 
  JobAssert(requested_storage_end <= user_storage_end, "Cannot store object within the task's user storage. ");
 
  task->user_data_start = static_cast<std::uint8_t>(requested_storage_end - task->user_data);
 
  return requested_storage_start;
}

References JobAssert.

Referenced by Job::TaskMake().

mainQueueTryRunTask()

bool Job::detail::mainQueueTryRunTask ( void  )

noexcept

Definition at line 1237 of file job_system.cpp.

{
  JobAssert(worker::IsMainThread(worker::GetCurrent()), "Must only be called by main thread.");
 
  TaskPtr task_ptr;
  if (g_JobSystem->main_queue.Pop(&task_ptr))
  {
    Task* const task = task::TaskPtrToPointer(task_ptr);
    task::RunTaskFunction(task);
    return true;
  }
 
  return false;
}

References g_JobSystem, Job::IsMainThread(), JobAssert, and Job::JobSystemContext::main_queue.

Referenced by Job::TickMainQueue().

assertHandler()

void Job::detail::assertHandler	(	const bool	condition,
		const char *const	filename,
		const int	line_number,
		const char *const	msg
	)