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)

公共属性

int64_t timestamp_ = UNSET

int node_id_

PacketQueueMap inputs_queue_

PacketQueueMap outputs_queue_

Friends

void swap ( Task &target, Task &source)

构造函数和析构函数

 Task() [1/3]

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

构造 Task

Parameters

  • node_id：正在运行的 task 的 id
  • input_stream_id_list：输入流的 id list
  • output_stream_id_list：输出流的 id list

 Task() [2/3]

Task::Task ( const Task &rhs )

 Task() [3/3]

Task::Task (  Task &&rhs )

成员函数文档

 fill_input_packet()

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

将 packet 填入输入流队列。

Parameters

  • stream_id：输入流的 id
  • packet：填入输入流队列的 packet

Returns

 fill_output_packet()

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

将 packet 填入输出流队列。

Parameters

  • stream_id：输出流的 id
  • packet：填入输出流队列的 packet

Returns

 get_input_stream_ids()

 (  )

获取输入流的 id list.

Returns

 get_inputs()

 PacketQueueMap & Task::get_inputs(  )

获取输入流队列。

Returns

 get_node()

int Task::get_node (  )

 get_output_stream_ids()

 (  )

获取输出流的 id list。

Returns

 get_outputs()

 PacketQueueMap & Task::get_outputs(  )

获取输出流队列。

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 
 )

从输入队列的给定 stream id 中弹出 packet。

Parameters

  • stream_id：输入流的 id
  • packet：从输入流队列中弹出的 packet。

Returns

 pop_packet_from_out_queue()

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

从输出队列的给定 stream id 中弹出 packet。

Parameters

  • stream_id：输出流的 id
  • packet：从输出流队列中弹出的 packet。

Returns

 set_timestamp()

void Task::set_timestamp ( int64_t t )

设置该task的timestamp

Parameters

  • t：该 task 的 timestamp

Returns

 timestamp()

int64_t Task::timestamp (  ) const

获取该 task 的 timestamp

Returns

 swap

void swap (  Task &target, 
  Task &source 
)

friendfriend

成员数据文档

 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

最后修改 September 30, 2024 : Python docs done (14a4999)