1012     MpiEncMtCtxInfo *ctxs = NULL;  in enc_test_mt()  local
1017     ctxs = mpp_calloc(MpiEncMtCtxInfo, cmd->nthreads);  in enc_test_mt()
1018     if (NULL == ctxs) {  in enc_test_mt()
1024         ctxs[i].cmd = cmd;  in enc_test_mt()
1025         ctxs[i].name = name;  in enc_test_mt()
1026         ctxs[i].chn = i;  in enc_test_mt()
1028         ret = mt_test_ctx_init(&ctxs[i]);  in enc_test_mt()
1034         ret = mt_test_res_init(&ctxs[i]);  in enc_test_mt()
1040         ret = pthread_create(&ctxs[i].thd_out, NULL, enc_test_output, &ctxs[i]);  in enc_test_mt()
1046         ret = pthread_create(&ctxs[i].thd_in, NULL, enc_test_input, &ctxs[i]);  in enc_test_mt()
1062             ctxs[i].ctx.loop_end = 1;  in enc_test_mt()
1066         pthread_join(ctxs[i].thd_in, NULL);  in enc_test_mt()
1067         pthread_join(ctxs[i].thd_out, NULL);  in enc_test_mt()
1069         ret = mt_test_res_deinit(&ctxs[i]);  in enc_test_mt()
1075         ret = mt_test_ctx_deinit(&ctxs[i]);  in enc_test_mt()
1083         MpiEncMtCtxRet *enc_ret = &ctxs[i].ret;  in enc_test_mt()
1092     MPP_FREE(ctxs);  in enc_test_mt()