Home
last modified time | relevance | path

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

/illumos-gate/usr/src/cmd/ndmpd/ndmp/
H A Dndmpd_mover.c521 session->ns_mover.md_buf = realloc(session->ns_mover.md_buf, in ndmpd_mover_set_record_size_v2()
1407 &session->ns_mover.md_buf[session->ns_mover.md_w_index], in ndmpd_local_write()
1459 &session->ns_mover.md_buf[session->ns_mover.md_w_index], in ndmpd_local_write()
2086 (session->ns_mover.md_position % session->ns_mover.md_record_size); in ndmpd_mover_seek()
2102 session->ns_mover.md_r_index = session->ns_mover.md_position - in ndmpd_mover_seek()
3542 session->ns_mover.md_record_size - session->ns_mover.md_w_index); in mover_tape_flush_v3()
3595 ns_mover.md_w_index], 0, session->ns_mover.md_record_size - in ndmpd_local_write_v3()
3700 n = read(fd, &session->ns_mover.md_buf[session->ns_mover.md_w_index], in mover_data_read_v3()
3701 session->ns_mover.md_record_size - session->ns_mover.md_w_index); in mover_data_read_v3()
3990 &session->ns_mover.md_buf[session->ns_mover.md_r_index], len); in mover_data_write_v3()
[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()
842 ndmp_door_put_int32(enc_ctx, session->ns_mover.md_sock); in ndmp_connect_get_mover_v2()
946 ndmp_door_put_int32(enc_ctx, session->ns_mover.md_listen_sock); in ndmp_connect_get_mover_v3()
[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()
1215 session->ns_mover.md_sock) in ndmpd_data_error()
1994 if (session->ns_data.dd_sock != session->ns_mover.md_sock) in ndmpd_data_cleanup()
2172 session->ns_mover.md_sock) in ndmpd_tar_start_backup_v2()
[all …]
H A Dndmpd_tar.c994 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()
1734 MOD_LOG(params, "Record size: %d\n", session->ns_mover.md_record_size); in log_bk_params_v2()
1849 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()
2842 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()