Lines Matching refs:cmds

84 	tlm_commands_t *cmds;  in backup_create_structs()  local
96 cmds = &nlp->nlp_cmds; in backup_create_structs()
97 (void) memset(cmds, 0, sizeof (*cmds)); in backup_create_structs()
112 cmds->tcs_command = tlm_create_reader_writer_ipc(TRUE, xfer_size); in backup_create_structs()
113 if (cmds->tcs_command == NULL) { in backup_create_structs()
124 tlm_release_reader_writer_ipc(cmds->tcs_command); in backup_create_structs()
153 tlm_commands_t *cmds; in restore_create_structs() local
164 cmds = &nlp->nlp_cmds; in restore_create_structs()
165 (void) memset(cmds, 0, sizeof (*cmds)); in restore_create_structs()
168 cmds->tcs_command = tlm_create_reader_writer_ipc(FALSE, xfer_size); in restore_create_structs()
169 if (cmds->tcs_command == NULL) { in restore_create_structs()
178 tlm_release_reader_writer_ipc(cmds->tcs_command); in restore_create_structs()
187 tlm_release_reader_writer_ipc(cmds->tcs_command); in restore_create_structs()
272 tlm_commands_t *cmds; in backup_release_structs() local
278 cmds = &nlp->nlp_cmds; in backup_release_structs()
279 if (cmds == NULL) { in backup_release_structs()
291 if (cmds->tcs_command != NULL) { in backup_release_structs()
292 if (cmds->tcs_command->tc_buffers != NULL) in backup_release_structs()
293 tlm_release_reader_writer_ipc(cmds->tcs_command); in backup_release_structs()
296 cmds->tcs_command = NULL; in backup_release_structs()
955 tlm_commands_t *cmds) in ndmp_tar_writer() argument
970 } else if (cmds == NULL) { in ndmp_tar_writer()
978 lcmd = cmds->tcs_command; in ndmp_tar_writer()
982 cmds->tcs_writer_count++; in ndmp_tar_writer()
986 while (cmds->tcs_writer != (int)TLM_ABORT && in ndmp_tar_writer()
1019 if (cmds->tcs_writer != (int)TLM_ABORT) { in ndmp_tar_writer()
1030 cmds->tcs_writer_count--; in ndmp_tar_writer()
1080 tlm_commands_t *cmds; in ndmp_tar_reader() local
1087 cmds = argp->tr_cmds; in ndmp_tar_reader()
1093 } else if (cmds == NULL) { in ndmp_tar_reader()
1099 tlm_cmd_signal(cmds->tcs_command, TLM_TAR_READER); in ndmp_tar_reader()
1103 lcmd = cmds->tcs_command; in ndmp_tar_reader()
1107 cmds->tcs_reader_count++; in ndmp_tar_reader()
1112 tlm_cmd_signal(cmds->tcs_command, TLM_TAR_READER); in ndmp_tar_reader()
1115 while (cmds->tcs_reader == TLM_RESTORE_RUN && in ndmp_tar_reader()
1161 cmds->tcs_reader_count--; in ndmp_tar_reader()
1179 tlm_commands_t *cmds; in ndmpd_tar_backup() local
1207 cmds = &nlp->nlp_cmds; in ndmpd_tar_backup()
1208 cmds->tcs_reader = cmds->tcs_writer = TLM_BACKUP_RUN; in ndmpd_tar_backup()
1209 cmds->tcs_command->tc_reader = TLM_BACKUP_RUN; in ndmpd_tar_backup()
1210 cmds->tcs_command->tc_writer = TLM_BACKUP_RUN; in ndmpd_tar_backup()
1212 if (ndmp_write_utf8magic(cmds->tcs_command) < 0) { in ndmpd_tar_backup()
1220 err = ndmp_backup_reader(cmds, nlp, jname); in ndmpd_tar_backup()
1229 err = ndmp_tar_writer(session, mod_params, cmds); in ndmpd_tar_backup()
1276 tlm_commands_t *cmds; in ndmpd_tar_restore() local
1304 cmds = &nlp->nlp_cmds; in ndmpd_tar_restore()
1305 cmds->tcs_reader = cmds->tcs_writer = TLM_RESTORE_RUN; in ndmpd_tar_restore()
1306 cmds->tcs_command->tc_reader = TLM_RESTORE_RUN; in ndmpd_tar_restore()
1307 cmds->tcs_command->tc_writer = TLM_RESTORE_RUN; in ndmpd_tar_restore()
1315 arg.tr_cmds = cmds; in ndmpd_tar_restore()
1320 tlm_cmd_wait(cmds->tcs_command, TLM_TAR_READER); in ndmpd_tar_restore()
1326 if (!ndmp_check_utf8magic(cmds->tcs_command)) { in ndmpd_tar_restore()
1338 tlm_arg.ba_commands = cmds; in ndmpd_tar_restore()
1339 tlm_arg.ba_cmd = cmds->tcs_command; in ndmpd_tar_restore()
1374 ndmp_stop_local_reader(session, cmds); in ndmpd_tar_restore()
1375 ndmp_wait_for_reader(cmds); in ndmpd_tar_restore()