Home
last modified time | relevance | path

Searched refs:ns_mover (Results 1 – 11 of 11) sorted by relevance

/titanic_50/usr/src/cmd/ndmpd/ndmp/
H A Dndmpd_mover.c143 reply.state = session->ns_mover.md_state; in ndmpd_mover_get_state_v2()
144 reply.pause_reason = session->ns_mover.md_pause_reason; in ndmpd_mover_get_state_v2()
145 reply.halt_reason = session->ns_mover.md_halt_reason; in ndmpd_mover_get_state_v2()
146 reply.record_size = session->ns_mover.md_record_size; in ndmpd_mover_get_state_v2()
147 reply.record_num = session->ns_mover.md_record_num; in ndmpd_mover_get_state_v2()
149 long_long_to_quad(session->ns_mover.md_data_written); in ndmpd_mover_get_state_v2()
151 long_long_to_quad(session->ns_mover.md_seek_position); in ndmpd_mover_get_state_v2()
153 long_long_to_quad(session->ns_mover.md_bytes_left_to_read); in ndmpd_mover_get_state_v2()
155 long_long_to_quad(session->ns_mover.md_window_offset); in ndmpd_mover_get_state_v2()
157 long_long_to_quad(session->ns_mover.md_window_length); in ndmpd_mover_get_state_v2()
[all …]
H A Dndmpd_connect.c153 if (session->ns_mover.md_state != NDMP_MOVER_STATE_IDLE || in ndmpd_connect_open_v2()
833 ndmp_door_put_int32(enc_ctx, session->ns_mover.md_state); in ndmp_connect_get_mover_v2()
834 ndmp_door_put_int32(enc_ctx, session->ns_mover.md_mode); in ndmp_connect_get_mover_v2()
835 ndmp_door_put_int32(enc_ctx, session->ns_mover.md_pause_reason); in ndmp_connect_get_mover_v2()
836 ndmp_door_put_int32(enc_ctx, session->ns_mover.md_halt_reason); in ndmp_connect_get_mover_v2()
837 ndmp_door_put_uint64(enc_ctx, session->ns_mover.md_record_size); in ndmp_connect_get_mover_v2()
838 ndmp_door_put_uint64(enc_ctx, session->ns_mover.md_record_num); in ndmp_connect_get_mover_v2()
839 ndmp_door_put_uint64(enc_ctx, session->ns_mover.md_position); in ndmp_connect_get_mover_v2()
840 ndmp_door_put_uint64(enc_ctx, session->ns_mover.md_window_offset); in ndmp_connect_get_mover_v2()
841 ndmp_door_put_uint64(enc_ctx, session->ns_mover.md_window_length); in ndmp_connect_get_mover_v2()
[all …]
H A Dndmpd_tape.c321 (session->ns_mover.md_record_size / dtp.bsize); in ndmpd_tape_get_state_v2()
654 (session->ns_mover.md_record_size / dtp.bsize); in ndmpd_tape_get_state_v3()
792 (session->ns_mover.md_state == NDMP_MOVER_STATE_LISTEN || in ndmpd_tape_write_v3()
793 session->ns_mover.md_state == NDMP_MOVER_STATE_ACTIVE)) { in ndmpd_tape_write_v3()
874 (session->ns_mover.md_state == NDMP_MOVER_STATE_LISTEN || in ndmpd_tape_read_v3()
875 session->ns_mover.md_state == NDMP_MOVER_STATE_ACTIVE)) { in ndmpd_tape_read_v3()
1016 (session->ns_mover.md_record_size / dtp.bsize); in ndmpd_tape_get_state_v4()
1064 if (session->ns_mover.md_state == NDMP_MOVER_STATE_LISTEN || in ndmpd_tape_close_v4()
1065 session->ns_mover.md_state == NDMP_MOVER_STATE_ACTIVE) { in ndmpd_tape_close_v4()
H A Dndmpd_callbacks.c138 if (session->ns_mover.md_sock != session->ns_data.dd_sock) { in ndmpd_api_done_v2()
266 session->ns_mover.md_discard_length = in ndmpd_api_seek_v2()
267 session->ns_mover.md_bytes_left_to_read; in ndmpd_api_seek_v2()
268 session->ns_mover.md_bytes_left_to_read = length; in ndmpd_api_seek_v2()
269 session->ns_mover.md_position = offset; in ndmpd_api_seek_v2()
H A Dndmpd_data.c679 } else if (session->ns_mover.md_state != NDMP_MOVER_STATE_IDLE) { in ndmpd_data_listen_v3()
777 if (session->ns_mover.md_state != NDMP_MOVER_STATE_LISTEN || in ndmpd_data_connect_v3()
778 session->ns_mover.md_listen_sock != -1) { in ndmpd_data_connect_v3()
783 session->ns_mover.md_state = NDMP_MOVER_STATE_ACTIVE; in ndmpd_data_connect_v3()
950 if (session->ns_mover.md_state != NDMP_MOVER_STATE_LISTEN || in ndmpd_data_connect_v4()
951 session->ns_mover.md_listen_sock != -1) { in ndmpd_data_connect_v4()
956 session->ns_mover.md_state = NDMP_MOVER_STATE_ACTIVE; in ndmpd_data_connect_v4()
1008 } else if (session->ns_mover.md_state != NDMP_MOVER_STATE_IDLE) { in ndmpd_data_listen_v4()
1215 session->ns_mover.md_sock) in ndmpd_data_error()
1993 if (session->ns_data.dd_sock != session->ns_mover.md_sock) in ndmpd_data_cleanup()
[all …]
H A Dndmpd_tar.c995 bidx, session->ns_mover.md_position); in ndmp_tar_writer()
1133 bidx, session->ns_mover.md_position); in ndmp_tar_reader()
1235 nlp->nlp_backup_path, session->ns_mover.md_data_written, in ndmpd_tar_backup()
1236 session->ns_mover.md_data_written, in ndmpd_tar_backup()
1241 nlp->nlp_backup_path, session->ns_mover.md_data_written, in ndmpd_tar_backup()
1242 session->ns_mover.md_data_written, in ndmpd_tar_backup()
1735 MOD_LOG(params, "Record size: %d\n", session->ns_mover.md_record_size); in log_bk_params_v2()
1850 MOD_LOG(params, "Record size: %d\n", session->ns_mover.md_record_size); in ndmp_restore_extract_params()
H A Dndmpd_util.c301 moverfd = session->ns_mover.md_sock; in ndmp_check_mover_state()
304 session->ns_mover.md_mode == NDMP_MOVER_MODE_WRITE) { in ndmp_check_mover_state()
1005 "Local operation: %lu", session->ns_mover.md_record_size); in ndmp_buffer_get_size()
1006 if ((xfer_size = session->ns_mover.md_record_size) == 0) in ndmp_buffer_get_size()
1102 while (session->ns_mover.md_state == NDMP_MOVER_STATE_PAUSED) { in ndmp_wait_for_mover()
1113 if (session->ns_mover.md_sock == -1 && in ndmp_wait_for_mover()
1114 session->ns_mover.md_listen_sock == -1) { in ndmp_wait_for_mover()
1137 return ((session->ns_mover.md_state == NDMP_MOVER_STATE_ACTIVE) ? in ndmp_wait_for_mover()
H A Dndmpd.h495 ndmpd_session_mover_desc_t ns_mover; member
H A Dndmpd_tar3.c795 if (session->ns_mover.md_data_addr.addr_type == NDMP_ADDR_LOCAL) in log_bk_params_v3()
798 session->ns_mover.md_record_size); in log_bk_params_v3()
2841 session->ns_mover.md_record_size); in log_rs_params_v3()
H A Dndmpd_comm.c851 session.ns_mover.md_record_size = MAX_RECORD_SIZE; in connection_handler()
H A Dndmpd_zfs.c196 ndmpd_zfs_args->nz_window_len = session->ns_mover.md_window_length; in ndmpd_zfs_init()