Lines Matching defs:session
173 ndmpd_zfs_init(ndmpd_session_t *session)
175 ndmpd_zfs_args_t *ndmpd_zfs_args = &session->ns_ndmpd_zfs_args;
176 int version = session->ns_protocol_version;
195 ndmpd_zfs_args->nz_bufsize = ndmp_buffer_get_size(session);
196 ndmpd_zfs_args->nz_window_len = session->ns_mover.md_window_length;
198 ndmpd_zfs_args->nz_nlp = ndmp_get_nlp(session);
204 session->ns_data.dd_module.dm_module_cookie = ndmpd_zfs_args;
205 session->ns_data.dd_data_size = 0;
206 session->ns_data.dd_module.dm_stats.ms_est_bytes_remaining = 0;
207 session->ns_data.dd_module.dm_stats.ms_est_time_remaining = 0;
209 session->ns_data.dd_bytes_left_to_read = 0;
210 session->ns_data.dd_position = 0;
211 session->ns_data.dd_discard_length = 0;
212 session->ns_data.dd_read_offset = 0;
213 session->ns_data.dd_read_length = 0;
219 ndmpd_zfs_params->mp_daemon_cookie = (void *)session;
220 ndmpd_zfs_params->mp_protocol_version = session->ns_protocol_version;
221 ndmpd_zfs_params->mp_stats = &session->ns_data.dd_module.dm_stats;
288 ndmpd_session_t *session = (ndmpd_session_t *)
293 if (session->ns_data.dd_state != NDMP_DATA_STATE_ACTIVE) {
335 ndmpd_zfs_header_write(ndmpd_session_t *session)
337 ndmpd_zfs_args_t *ndmpd_zfs_args = &session->ns_ndmpd_zfs_args;
370 session->ns_data.dd_module.dm_stats.ms_bytes_processed = bufsize;
466 ndmpd_session_t *session = (ndmpd_session_t *)
471 ndmp_session_ref(session);
484 session->ns_data.dd_module.dm_stats.ms_bytes_processed);
492 ndmp_session_unref(session);
501 ndmpd_session_t *session = (ndmpd_session_t *)
525 if (ndmpd_api_file_history_dir_v3(session, ".", ROOT_INODE,
528 if (ndmpd_api_file_history_dir_v3(session, "..", ROOT_INODE,
531 if (ndmpd_api_file_history_node_v3(session, ROOT_INODE, &st, 0) != 0)
534 ndmpd_file_history_cleanup(session, TRUE);
541 ndmpd_session_t *session = (ndmpd_session_t *)
548 if (session->ns_eof)
551 if (!session->ns_data.dd_abort) {
552 if (ndmpd_zfs_header_write(session)) {
561 if (err || read_err || write_err || session->ns_eof)
565 if (session->ns_data.dd_abort) {
566 ndmpd_audit_backup(session->ns_connection,
568 session->ns_data.dd_data_addr.addr_type,
576 ndmpd_audit_backup(session->ns_connection,
578 session->ns_data.dd_data_addr.addr_type,
613 ndmpd_session_t *session = (ndmpd_session_t *)
624 if (!session->ns_data.dd_abort)
659 if (err && !session->ns_data.dd_abort)
678 ndmpd_session_t *session = (ndmpd_session_t *)
692 &(session->ns_data.dd_module.dm_stats.ms_bytes_processed);
757 ndmpd_session_t *session = (ndmpd_session_t *)
761 ndmp_session_ref(session);
769 ndmp_session_unref(session);
779 ndmpd_session_t *session = (ndmpd_session_t *)
786 if (!session->ns_data.dd_abort) {
796 if (err || read_err || write_err || session->ns_eof)
800 if (session->ns_data.dd_abort) {
803 ndmpd_audit_restore(session->ns_connection,
805 session->ns_data.dd_data_addr.addr_type,
810 ndmpd_audit_restore(session->ns_connection,
812 session->ns_data.dd_data_addr.addr_type,
833 ndmpd_session_t *session = (ndmpd_session_t *)
878 if (session->ns_data.dd_abort)
904 ndmpd_session_t *session = (ndmpd_session_t *)
921 if (err && !session->ns_data.dd_abort)
1026 ndmpd_session_t *session = (ndmpd_session_t *)
1037 nctxp->nc_ddata = (void *) session;
1071 ndmpd_session_t *session = (ndmpd_session_t *)
1096 nctxp->nc_ddata = (void *) session;
1708 ndmpd_session_t *session = (ndmpd_session_t *)
1713 if (session->ns_data.dd_abort) {
1769 ndmpd_session_t *session = (ndmpd_session_t *)
1779 if (ndmpd_zfs_args->nz_update && !session->ns_data.dd_abort && !err) {
1808 if (session->ns_data.dd_abort)