Lines Matching refs:cmds

2515 	tlm_commands_t *cmds;	/* Commands structure */  in mover_tape_reader()  local
2522 cmds = &nlp->nlp_cmds; in mover_tape_reader()
2523 lcmd = cmds->tcs_command; in mover_tape_reader()
2527 cmds->tcs_reader_count++; in mover_tape_reader()
2532 tlm_cmd_signal(cmds->tcs_command, TLM_TAPE_READER); in mover_tape_reader()
2535 while (cmds->tcs_reader == TLM_RESTORE_RUN && in mover_tape_reader()
2582 cmds->tcs_reader_count--; in mover_tape_reader()
2663 tlm_commands_t *cmds; /* Commands structure */ in mover_socket_writer() local
2670 cmds = &nlp->nlp_cmds; in mover_socket_writer()
2671 lcmd = cmds->tcs_command; in mover_socket_writer()
2675 cmds->tcs_writer_count++; in mover_socket_writer()
2680 tlm_cmd_signal(cmds->tcs_command, TLM_SOCK_WRITER); in mover_socket_writer()
2683 while (cmds->tcs_writer != (int)TLM_ABORT && in mover_socket_writer()
2714 if (cmds->tcs_writer == (int)TLM_ABORT) in mover_socket_writer()
2725 cmds->tcs_writer_count--; in mover_socket_writer()
2749 tlm_commands_t *cmds; in start_mover_for_restore() local
2758 cmds = &nlp->nlp_cmds; in start_mover_for_restore()
2759 (void) memset(cmds, 0, sizeof (*cmds)); in start_mover_for_restore()
2760 cmds->tcs_reader = cmds->tcs_writer = TLM_RESTORE_RUN; in start_mover_for_restore()
2762 cmds->tcs_command = tlm_create_reader_writer_ipc(FALSE, xfer_size); in start_mover_for_restore()
2763 if (cmds->tcs_command == NULL) in start_mover_for_restore()
2766 cmds->tcs_command->tc_reader = TLM_RESTORE_RUN; in start_mover_for_restore()
2767 cmds->tcs_command->tc_writer = TLM_RESTORE_RUN; in start_mover_for_restore()
2777 tlm_cmd_wait(cmds->tcs_command, TLM_TAPE_READER); in start_mover_for_restore()
2786 tlm_cmd_wait(cmds->tcs_command, TLM_SOCK_WRITER); in start_mover_for_restore()
2793 tlm_release_reader_writer_ipc(cmds->tcs_command); in start_mover_for_restore()
2885 tlm_commands_t *cmds; /* Commands structure */ in mover_socket_reader() local
2893 cmds = &nlp->nlp_cmds; in mover_socket_reader()
2894 lcmd = cmds->tcs_command; in mover_socket_reader()
2898 cmds->tcs_reader_count++; in mover_socket_reader()
2903 tlm_cmd_signal(cmds->tcs_command, TLM_SOCK_READER); in mover_socket_reader()
2906 while (cmds->tcs_reader == TLM_BACKUP_RUN && in mover_socket_reader()
2939 if (cmds->tcs_reader != TLM_BACKUP_RUN) in mover_socket_reader()
2951 cmds->tcs_reader_count--; in mover_socket_reader()
3025 tlm_commands_t *cmds; in mover_tape_writer() local
3033 cmds = &nlp->nlp_cmds; in mover_tape_writer()
3034 lcmd = cmds->tcs_command; in mover_tape_writer()
3038 cmds->tcs_writer_count++; in mover_tape_writer()
3043 tlm_cmd_signal(cmds->tcs_command, TLM_TAPE_WRITER); in mover_tape_writer()
3047 while (cmds->tcs_writer != (int)TLM_ABORT && in mover_tape_writer()
3077 if (cmds->tcs_writer == (int)TLM_ABORT) in mover_tape_writer()
3096 cmds->tcs_writer_count--; in mover_tape_writer()
3121 tlm_commands_t *cmds; in start_mover_for_backup() local
3129 cmds = &nlp->nlp_cmds; in start_mover_for_backup()
3130 (void) memset(cmds, 0, sizeof (*cmds)); in start_mover_for_backup()
3131 cmds->tcs_reader = cmds->tcs_writer = TLM_BACKUP_RUN; in start_mover_for_backup()
3132 cmds->tcs_command = tlm_create_reader_writer_ipc(TRUE, in start_mover_for_backup()
3134 if (cmds->tcs_command == NULL) in start_mover_for_backup()
3137 cmds->tcs_command->tc_reader = TLM_BACKUP_RUN; in start_mover_for_backup()
3138 cmds->tcs_command->tc_writer = TLM_BACKUP_RUN; in start_mover_for_backup()
3148 tlm_cmd_wait(cmds->tcs_command, TLM_SOCK_READER); in start_mover_for_backup()
3157 tlm_cmd_wait(cmds->tcs_command, TLM_TAPE_WRITER); in start_mover_for_backup()
3164 tlm_release_reader_writer_ipc(cmds->tcs_command); in start_mover_for_backup()