Home
last modified time | relevance | path

Searched refs:tcs_command (Results 1 – 7 of 7) sorted by relevance

/onnv-gate/usr/src/cmd/ndmpd/ndmp/
H A Dndmpd_tar.c111 cmds->tcs_command = tlm_create_reader_writer_ipc(TRUE, xfer_size); in backup_create_structs()
112 if (cmds->tcs_command == NULL) { in backup_create_structs()
123 tlm_release_reader_writer_ipc(cmds->tcs_command); in backup_create_structs()
167 cmds->tcs_command = tlm_create_reader_writer_ipc(FALSE, xfer_size); in restore_create_structs()
168 if (cmds->tcs_command == NULL) { in restore_create_structs()
177 tlm_release_reader_writer_ipc(cmds->tcs_command); in restore_create_structs()
186 tlm_release_reader_writer_ipc(cmds->tcs_command); in restore_create_structs()
290 if (cmds->tcs_command != NULL) { in backup_release_structs()
291 if (cmds->tcs_command->tc_buffers != NULL) in backup_release_structs()
292 tlm_release_reader_writer_ipc(cmds->tcs_command); in backup_release_structs()
[all …]
H A Dndmpd_tar3.c1473 cmds->tcs_command = tlm_create_reader_writer_ipc(TRUE, xfer_size); in backup_alloc_structs_v3()
1474 if (!cmds->tcs_command) { in backup_alloc_structs_v3()
1482 tlm_release_reader_writer_ipc(cmds->tcs_command); in backup_alloc_structs_v3()
1536 cmds->tcs_command = tlm_create_reader_writer_ipc(FALSE, xfer_size); in restore_alloc_structs_v3()
1537 if (!cmds->tcs_command) { in restore_alloc_structs_v3()
1545 tlm_release_reader_writer_ipc(cmds->tcs_command); in restore_alloc_structs_v3()
1555 tlm_release_reader_writer_ipc(cmds->tcs_command); in restore_alloc_structs_v3()
1602 if (cmds->tcs_command) { in free_structs_v3()
1603 if (cmds->tcs_command->tc_buffers != NULL) in free_structs_v3()
1604 tlm_release_reader_writer_ipc(cmds->tcs_command); in free_structs_v3()
[all …]
H A Dndmpd_mover.c2687 lcmd = cmds->tcs_command; in mover_tape_reader()
2696 tlm_cmd_signal(cmds->tcs_command, TLM_TAPE_READER); in mover_tape_reader()
2835 lcmd = cmds->tcs_command; in mover_socket_writer()
2844 tlm_cmd_signal(cmds->tcs_command, TLM_SOCK_WRITER); in mover_socket_writer()
2926 cmds->tcs_command = tlm_create_reader_writer_ipc(FALSE, xfer_size); in start_mover_for_restore()
2927 if (cmds->tcs_command == NULL) in start_mover_for_restore()
2930 cmds->tcs_command->tc_reader = TLM_RESTORE_RUN; in start_mover_for_restore()
2931 cmds->tcs_command->tc_writer = TLM_RESTORE_RUN; in start_mover_for_restore()
2941 tlm_cmd_wait(cmds->tcs_command, TLM_TAPE_READER); in start_mover_for_restore()
2950 tlm_cmd_wait(cmds->tcs_command, TLM_SOCK_WRITER); in start_mover_for_restore()
[all …]
H A Dndmpd_util.c1723 if (cmds->tcs_command == NULL) { in ndmp_stop_buffer_worker()
1727 cmds->tcs_command->tc_reader = TLM_ABORT; in ndmp_stop_buffer_worker()
1728 cmds->tcs_command->tc_writer = TLM_ABORT; in ndmp_stop_buffer_worker()
1761 if (cmds->tcs_command == NULL) { in ndmp_stop_reader_thread()
1765 cmds->tcs_command->tc_reader = TLM_ABORT; in ndmp_stop_reader_thread()
1797 if (cmds->tcs_command == NULL) { in ndmp_stop_writer_thread()
1801 cmds->tcs_command->tc_writer = TLM_ABORT; in ndmp_stop_writer_thread()
1832 if (cmds->tcs_command != NULL) { in ndmp_free_reader_writer_ipc()
1834 cmds->tcs_command->tc_ref); in ndmp_free_reader_writer_ipc()
1835 tlm_release_reader_writer_ipc(cmds->tcs_command); in ndmp_free_reader_writer_ipc()
/onnv-gate/usr/src/cmd/ndmpd/include/
H A Dtlm_buffers.h128 tlm_cmd_t *tcs_command; /* IPC area between read-write */ member
/onnv-gate/usr/src/cmd/ndmpd/tlm/
H A Dtlm_restore_writer.c2281 if ((lcmd = cmds->tcs_command) == NULL || in ndmp_iter_zfs()
2461 if ((lcmd = cmds->tcs_command) == NULL || in ndmp_context_get_version()
H A Dtlm_backup_reader.c1375 if ((lcmd = cmds->tcs_command) == NULL || in ndmp_include_zfs()