Lines Matching refs:cmds
1443 tlm_commands_t *cmds; in backup_alloc_structs_v3() local
1457 cmds = &nlp->nlp_cmds; in backup_alloc_structs_v3()
1458 (void) memset(cmds, 0, sizeof (*cmds)); in backup_alloc_structs_v3()
1475 cmds->tcs_command = tlm_create_reader_writer_ipc(TRUE, xfer_size); in backup_alloc_structs_v3()
1476 if (!cmds->tcs_command) { in backup_alloc_structs_v3()
1484 tlm_release_reader_writer_ipc(cmds->tcs_command); in backup_alloc_structs_v3()
1517 tlm_commands_t *cmds; in restore_alloc_structs_v3() local
1534 cmds = &nlp->nlp_cmds; in restore_alloc_structs_v3()
1535 (void) memset(cmds, 0, sizeof (*cmds)); in restore_alloc_structs_v3()
1538 cmds->tcs_command = tlm_create_reader_writer_ipc(FALSE, xfer_size); in restore_alloc_structs_v3()
1539 if (!cmds->tcs_command) { in restore_alloc_structs_v3()
1547 tlm_release_reader_writer_ipc(cmds->tcs_command); in restore_alloc_structs_v3()
1557 tlm_release_reader_writer_ipc(cmds->tcs_command); in restore_alloc_structs_v3()
1585 tlm_commands_t *cmds; in free_structs_v3() local
1592 cmds = &nlp->nlp_cmds; in free_structs_v3()
1593 if (!cmds) { in free_structs_v3()
1604 if (cmds->tcs_command) { in free_structs_v3()
1605 if (cmds->tcs_command->tc_buffers != NULL) in free_structs_v3()
1606 tlm_release_reader_writer_ipc(cmds->tcs_command); in free_structs_v3()
1609 cmds->tcs_command = NULL; in free_structs_v3()
2236 tlm_commands_t *cmds; in backup_reader_v3() local
2243 cmds = argp->br_cmds; in backup_reader_v3()
2246 lcmd = cmds->tcs_command; in backup_reader_v3()
2248 cmds->tcs_reader_count++; in backup_reader_v3()
2258 bp.bp_cmds = cmds; in backup_reader_v3()
2340 cmds->tcs_reader_count--; in backup_reader_v3()
2369 tlm_commands_t *cmds; in tar_backup_v3() local
2405 cmds = &nlp->nlp_cmds; in tar_backup_v3()
2406 cmds->tcs_reader = cmds->tcs_writer = TLM_BACKUP_RUN; in tar_backup_v3()
2407 cmds->tcs_command->tc_reader = TLM_BACKUP_RUN; in tar_backup_v3()
2408 cmds->tcs_command->tc_writer = TLM_BACKUP_RUN; in tar_backup_v3()
2410 if (ndmp_write_utf8magic(cmds->tcs_command) < 0) { in tar_backup_v3()
2424 nctx.nc_cmds = cmds; in tar_backup_v3()
2437 arg.br_cmds = cmds; in tar_backup_v3()
2453 if ((err = ndmp_tar_writer(session, params, cmds)) != 0) in tar_backup_v3()
2467 ndmp_wait_for_reader(cmds); in tar_backup_v3()
2922 tlm_commands_t *cmds; in restore_dar_alloc_structs_v3() local
2930 cmds = &nlp->nlp_cmds; in restore_dar_alloc_structs_v3()
2931 (void) memset(cmds, 0, sizeof (*cmds)); in restore_dar_alloc_structs_v3()
2934 cmds->tcs_command = tlm_create_reader_writer_ipc(FALSE, xfer_size); in restore_dar_alloc_structs_v3()
2935 if (!cmds->tcs_command) { in restore_dar_alloc_structs_v3()
2962 tlm_commands_t *cmds; in free_dar_structs_v3() local
2969 cmds = &nlp->nlp_cmds; in free_dar_structs_v3()
2970 if (!cmds) { in free_dar_structs_v3()
2975 if (cmds->tcs_command) { in free_dar_structs_v3()
2976 if (cmds->tcs_command->tc_buffers != NULL) in free_dar_structs_v3()
2977 tlm_release_reader_writer_ipc(cmds->tcs_command); in free_dar_structs_v3()
2980 cmds->tcs_command = NULL; in free_dar_structs_v3()
3152 tlm_commands_t *cmds; in ndmpd_dar_tar_v3() local
3180 cmds = &nlp->nlp_cmds; in ndmpd_dar_tar_v3()
3181 cmds->tcs_reader = cmds->tcs_writer = TLM_RESTORE_RUN; in ndmpd_dar_tar_v3()
3182 cmds->tcs_command->tc_reader = TLM_RESTORE_RUN; in ndmpd_dar_tar_v3()
3183 cmds->tcs_command->tc_writer = TLM_RESTORE_RUN; in ndmpd_dar_tar_v3()
3187 arg.tr_cmds = cmds; in ndmpd_dar_tar_v3()
3192 tlm_cmd_wait(cmds->tcs_command, TLM_TAR_READER); in ndmpd_dar_tar_v3()
3198 cmds->tcs_command->tc_ref++; in ndmpd_dar_tar_v3()
3199 cmds->tcs_writer_count++; in ndmpd_dar_tar_v3()
3205 nctx.nc_cmds = cmds; in ndmpd_dar_tar_v3()
3215 ndmp_stop_local_reader(session, cmds); in ndmpd_dar_tar_v3()
3216 ndmp_wait_for_reader(cmds); in ndmpd_dar_tar_v3()
3226 err = (tm_tar_ops.tm_getdir)(cmds, cmds->tcs_command, in ndmpd_dar_tar_v3()
3242 cmds->tcs_writer_count--; in ndmpd_dar_tar_v3()
3243 cmds->tcs_command->tc_ref--; in ndmpd_dar_tar_v3()
3245 ndmp_stop_local_reader(session, cmds); in ndmpd_dar_tar_v3()
3247 ndmp_wait_for_reader(cmds); in ndmpd_dar_tar_v3()
3514 tlm_commands_t *cmds; in ndmpd_rs_sar_tar_v3() local
3540 cmds = &nlp->nlp_cmds; in ndmpd_rs_sar_tar_v3()
3541 cmds->tcs_reader = cmds->tcs_writer = TLM_RESTORE_RUN; in ndmpd_rs_sar_tar_v3()
3542 cmds->tcs_command->tc_reader = TLM_RESTORE_RUN; in ndmpd_rs_sar_tar_v3()
3543 cmds->tcs_command->tc_writer = TLM_RESTORE_RUN; in ndmpd_rs_sar_tar_v3()
3550 arg.tr_cmds = cmds; in ndmpd_rs_sar_tar_v3()
3554 tlm_cmd_wait(cmds->tcs_command, TLM_TAR_READER); in ndmpd_rs_sar_tar_v3()
3561 if (!ndmp_check_utf8magic(cmds->tcs_command)) { in ndmpd_rs_sar_tar_v3()
3571 nctx.nc_cmds = cmds; in ndmpd_rs_sar_tar_v3()
3578 ndmp_stop_local_reader(session, cmds); in ndmpd_rs_sar_tar_v3()
3579 ndmp_wait_for_reader(cmds); in ndmpd_rs_sar_tar_v3()
3586 cmds->tcs_command->tc_ref++; in ndmpd_rs_sar_tar_v3()
3587 cmds->tcs_writer_count++; in ndmpd_rs_sar_tar_v3()
3592 err = (tm_tar_ops.tm_getdir)(cmds, cmds->tcs_command, in ndmpd_rs_sar_tar_v3()
3607 cmds->tcs_writer_count--; in ndmpd_rs_sar_tar_v3()
3608 cmds->tcs_command->tc_ref--; in ndmpd_rs_sar_tar_v3()
3614 ndmp_stop_local_reader(session, cmds); in ndmpd_rs_sar_tar_v3()
3615 ndmp_wait_for_reader(cmds); in ndmpd_rs_sar_tar_v3()