52     MpiDecMtLoopData *data = (MpiDecMtLoopData *)arg;  in thread_input()  local
53     MppCtx ctx  = data->ctx;  in thread_input()
54     MppApi *mpi = data->mpi;  in thread_input()
55     MppPacket packet = data->packet;  in thread_input()
56     FileReader reader = data->reader;  in thread_input()
57     RK_U32 quiet = data->quiet;  in thread_input()
68         mpp_packet_set_data(packet, slot->data);  in thread_input()
70         mpp_packet_set_pos(packet, slot->data);  in thread_input()
76             if (data->frame_num < 0 || data->frame_count < data->frame_num) {  in thread_input()
96         } while (!data->loop_end);  in thread_input()
100     } while (!data->loop_end);  in thread_input()
109     MpiDecMtLoopData *data = (MpiDecMtLoopData *)arg;  in thread_output()  local
110     MpiDecTestCmd *cmd = data->cmd;  in thread_output()
111     MppCtx ctx  = data->ctx;  in thread_output()
112     MppApi *mpi = data->mpi;  in thread_output()
113     RK_U32 quiet = data->quiet;  in thread_output()
163             grp = dec_buf_mgr_setup(data->buf_mgr, buf_size, 24, cmd->buf_mode);  in thread_output()
170             data->frm_grp = grp;  in thread_output()
185                                 "decode get frame %d", data->frame_count);  in thread_output()
203             data->frame_count++;  in thread_output()
204             if (data->fp_output && !err_info)  in thread_output()
205                 dump_mpp_frame_to_file(frame, data->fp_output);  in thread_output()
213         if ((data->frame_num > 0 && (data->frame_count >= data->frame_num)) ||  in thread_output()
214             ((data->frame_num == 0) && frm_eos))  in thread_output()
215             data->loop_end = 1;  in thread_output()
216     } while (!data->loop_end);  in thread_output()
248     MpiDecMtLoopData data;  in mt_dec_decode()  local
251     memset(&data, 0, sizeof(data));  in mt_dec_decode()
254         data.fp_output = fopen(cmd->file_output, "w+b");  in mt_dec_decode()
255         if (NULL == data.fp_output) {  in mt_dec_decode()
261     ret = dec_buf_mgr_init(&data.buf_mgr);  in mt_dec_decode()
328     data.cmd            = cmd;  in mt_dec_decode()
329     data.ctx            = ctx;  in mt_dec_decode()
330     data.mpi            = mpi;  in mt_dec_decode()
331     data.loop_end       = 0;  in mt_dec_decode()
332     data.packet         = packet;  in mt_dec_decode()
333     data.frame          = frame;  in mt_dec_decode()
334     data.frame_count    = 0;  in mt_dec_decode()
335     data.frame_num      = cmd->frame_num;  in mt_dec_decode()
336     data.reader         = reader;  in mt_dec_decode()
337     data.quiet          = cmd->quiet;  in mt_dec_decode()
342     ret = pthread_create(&thd_in, &attr, thread_input, &data);  in mt_dec_decode()
348     ret = pthread_create(&thd_out, &attr, thread_output, &data);  in mt_dec_decode()
361         data.loop_end = 1;  in mt_dec_decode()
392     data.frm_grp = NULL;  in mt_dec_decode()
393     if (data.buf_mgr) {  in mt_dec_decode()
394         dec_buf_mgr_deinit(data.buf_mgr);  in mt_dec_decode()
395         data.buf_mgr = NULL;  in mt_dec_decode()
398     if (data.fp_output) {  in mt_dec_decode()
399         fclose(data.fp_output);  in mt_dec_decode()
400         data.fp_output = NULL;  in mt_dec_decode()