1013     MpiEncMtCtxInfo *ctxs = NULL;  in enc_test_mt()  local
1018     ctxs = mpp_calloc(MpiEncMtCtxInfo, cmd->nthreads);  in enc_test_mt()
1019     if (NULL == ctxs) {  in enc_test_mt()
1025         ctxs[i].cmd = cmd;  in enc_test_mt()
1026         ctxs[i].name = name;  in enc_test_mt()
1027         ctxs[i].chn = i;  in enc_test_mt()
1029         ret = mt_test_ctx_init(&ctxs[i]);  in enc_test_mt()
1035         ret = mt_test_res_init(&ctxs[i]);  in enc_test_mt()
1041         ret = pthread_create(&ctxs[i].thd_out, NULL, enc_test_output, &ctxs[i]);  in enc_test_mt()
1047         ret = pthread_create(&ctxs[i].thd_in, NULL, enc_test_input, &ctxs[i]);  in enc_test_mt()
1064             ctxs[i].ctx.loop_end = 1;  in enc_test_mt()
1068         pthread_join(ctxs[i].thd_in, NULL);  in enc_test_mt()
1069         pthread_join(ctxs[i].thd_out, NULL);  in enc_test_mt()
1071         ret = mt_test_res_deinit(&ctxs[i]);  in enc_test_mt()
1077         ret = mt_test_ctx_deinit(&ctxs[i]);  in enc_test_mt()
1085         MpiEncMtCtxRet *enc_ret = &ctxs[i].ret;  in enc_test_mt()
1094     MPP_FREE(ctxs);  in enc_test_mt()