Searched refs:ns_mover (Results 1 – 11 of 11) sorted by relevance
/illumos-gate/usr/src/cmd/ndmpd/ndmp/ |
H A D | ndmpd_mover.c | 521 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 D | ndmpd_connect.c | 153 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 D | ndmpd_tape.c | 321 (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 D | ndmpd_callbacks.c | 138 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 D | ndmpd_data.c | 679 } 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 D | ndmpd_tar.c | 994 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 D | ndmpd_util.c | 301 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 D | ndmpd.h | 495 ndmpd_session_mover_desc_t ns_mover; member
|
H A D | ndmpd_tar3.c | 795 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 D | ndmpd_comm.c | 851 session.ns_mover.md_record_size = MAX_RECORD_SIZE; in connection_handler()
|
H A D | ndmpd_zfs.c | 196 ndmpd_zfs_args->nz_window_len = session->ns_mover.md_window_length; in ndmpd_zfs_init()
|