Task

Public Member Functions | Public Attributes | Friends | List of all members # Task Class Reference

task.h ## Public Member Functions

Task (int node_id=-1, std::vector< int > input_stream_id_list={}, std::vector< int > output_stream_id_list={})

Task (const Task &rhs)

Task ( Task &&rhs)

Task & operator= ( Task rhs)

bool fill_input_packet (int stream_id, Packet packet)

bool fill_output_packet (int stream_id, Packet packet)

bool pop_packet_from_out_queue (int stream_id, Packet &packet)

bool pop_packet_from_input_queue (int stream_id, Packet &packet)

bool input_queue_empty (int stream_id)

bool output_queue_empty (int stream_id)

int64_t timestamp () const

void set_timestamp (int64_t t)

PacketQueueMap & get_outputs ()

PacketQueueMap & get_inputs ()

std::vector< int > get_input_stream_ids ()

std::vector< int > get_output_stream_ids ()

int get_node ()

void init (int node_id, std::vector< int > input_stream_id_list, std::vector< int > output_stream_id_list)

Public Attributes

int64_t timestamp_ = UNSET

int node_id_

PacketQueueMap inputs_queue_

PacketQueueMap outputs_queue_

Friends

void swap ( Task &target, Task &source)

Constructor & Destructor Documentation

 Task() [1/3]

Task::Task ( int node_id = -1, 
  std::vector< int > input_stream_id_list = {}, 
  std::vector< int > output_stream_id_list = {} 
 )

construct Task .

Parameters

  • node_id The id of the running task.
  • input_stream_id_list input stream id list.
  • output_stream_id_list output stream id list.

 Task() [2/3]

Task::Task ( const Task &rhs )

 Task() [3/3]

Task::Task (  Task &&rhs )

Member Function Documentation

 fill_input_packet()

bool Task::fill_input_packet ( int stream_id, 
  Packet packet 
 )

fill packet into the input stream queue.

Parameters

  • stream_id The id of the input stream.
  • packet the packet add to the input stream queue.

Returns

 fill_output_packet()

bool Task::fill_output_packet ( int stream_id, 
  Packet packet 
 )

fill packet into the output stream queue.

Parameters

  • stream_id The id of the output stream.
  • packet the packet add to the output stream queue.

Returns

 get_input_stream_ids()

 (  )

get input stream id list.

Returns

 get_inputs()

 PacketQueueMap & Task::get_inputs(  )

get input stream queue.

Returns

 get_node()

int Task::get_node (  )

 get_output_stream_ids()

 (  )

get output stream id list.

Returns

 get_outputs()

 PacketQueueMap & Task::get_outputs(  )

get output stream queue.

Returns

 init()

void Task::init ( int node_id, 
  std::vector< int > input_stream_id_list, 
  std::vector< int > output_stream_id_list 
 )

 input_queue_empty()

bool Task::input_queue_empty ( int stream_id )

 operator=()

 Task & Task::operator=(  Task rhs )

 output_queue_empty()

bool Task::output_queue_empty ( int stream_id )

 pop_packet_from_input_queue()

bool Task::pop_packet_from_input_queue ( int stream_id, 
  Packet & packet 
 )

pop packet from the given stream id of input queue.

Parameters

  • stream_id The id of the input stream.
  • packet the packet poped from the input stream queue.

Returns

 pop_packet_from_out_queue()

bool Task::pop_packet_from_out_queue ( int stream_id, 
  Packet & packet 
 )

pop packet from the given stream id of output queue.

Parameters

  • stream_id The id of the output stream.
  • packet the packet poped from the output stream queue.

Returns

 set_timestamp()

void Task::set_timestamp ( int64_t t )

set the timestamp of the task.

Parameters

  • t the timestamp of the task.

Returns

 timestamp()

int64_t Task::timestamp (  ) const

get the timestamp of the task

Returns

 swap

void swap (  Task &target, 
  Task &source 
)

friendfriend

Member Data Documentation

 inputs_queue_

 PacketQueueMap Task::inputs_queue_

 node_id_

int Task::node_id_

 outputs_queue_

 PacketQueueMap Task::outputs_queue_

 timestamp_

int64_t Task::timestamp_ = UNSET
  • /20230627/doxygen_converter/bmf/bmf/sdk/cpp_sdk/include/bmf/sdk/ task.h

Last modified September 30, 2024 : Python docs done (14a4999)