Lines Matching refs:session

363 setupsels(ndmpd_session_t *session, ndmpd_module_params_t *params,  in setupsels()  argument
372 n = session->ns_data.dd_nlist_len; in setupsels()
789 log_bk_params_v3(ndmpd_session_t *session, ndmpd_module_params_t *params, in log_bk_params_v3() argument
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()
1438 backup_alloc_structs_v3(ndmpd_session_t *session, char *jname) in backup_alloc_structs_v3() argument
1445 nlp = ndmp_get_nlp(session); in backup_alloc_structs_v3()
1460 xfer_size = ndmp_buffer_get_size(session); in backup_alloc_structs_v3()
1481 nlp->nlp_logcallbacks = lbrlog_callbacks_init(session, in backup_alloc_structs_v3()
1513 restore_alloc_structs_v3(ndmpd_session_t *session, char *jname) in restore_alloc_structs_v3() argument
1519 nlp = ndmp_get_nlp(session); in restore_alloc_structs_v3()
1537 xfer_size = ndmp_buffer_get_size(session); in restore_alloc_structs_v3()
1544 nlp->nlp_logcallbacks = lbrlog_callbacks_init(session, in restore_alloc_structs_v3()
1582 free_structs_v3(ndmpd_session_t *session, char *jname) in free_structs_v3() argument
1587 nlp = ndmp_get_nlp(session); in free_structs_v3()
1618 if (session->ns_data.dd_operation == NDMP_DATA_OP_RECOVER) { in free_structs_v3()
2366 tar_backup_v3(ndmpd_session_t *session, ndmpd_module_params_t *params, in tar_backup_v3() argument
2383 if (session->ns_eof) in tar_backup_v3()
2386 if (!session->ns_data.dd_abort) { in tar_backup_v3()
2387 if (backup_alloc_structs_v3(session, jname) < 0) { in tar_backup_v3()
2392 if (ndmpd_mark_inodes_v3(session, nlp) != 0) { in tar_backup_v3()
2397 free_structs_v3(session, jname); in tar_backup_v3()
2411 free_structs_v3(session, jname); in tar_backup_v3()
2426 nctx.nc_ddata = (void *) session; in tar_backup_v3()
2448 free_structs_v3(session, jname); in tar_backup_v3()
2453 if ((err = ndmp_tar_writer(session, params, cmds)) != 0) in tar_backup_v3()
2461 session->ns_data.dd_module.dm_stats.ms_bytes_processed, in tar_backup_v3()
2462 session->ns_data.dd_module.dm_stats.ms_bytes_processed, in tar_backup_v3()
2471 if (session->ns_eof) { in tar_backup_v3()
2475 if (!session->ns_data.dd_abort) { in tar_backup_v3()
2476 ndmpd_audit_backup(session->ns_connection, in tar_backup_v3()
2478 session->ns_data.dd_data_addr.addr_type, in tar_backup_v3()
2479 session->ns_tape.td_adapter_name, result); in tar_backup_v3()
2485 if (session->ns_data.dd_abort) { in tar_backup_v3()
2486 ndmpd_audit_backup(session->ns_connection, in tar_backup_v3()
2488 session->ns_data.dd_data_addr.addr_type, in tar_backup_v3()
2489 session->ns_tape.td_adapter_name, EINTR); in tar_backup_v3()
2505 free_structs_v3(session, jname); in tar_backup_v3()
2635 fix_nlist_v3(ndmpd_session_t *session, ndmpd_module_params_t *params, in fix_nlist_v3() argument
2659 n = session->ns_data.dd_nlist_len; in fix_nlist_v3()
2793 allvalidfh(ndmpd_session_t *session, ndmpd_module_params_t *params) in allvalidfh() argument
2800 n = session->ns_data.dd_nlist_len; in allvalidfh()
2831 log_rs_params_v3(ndmpd_session_t *session, ndmpd_module_params_t *params, in log_rs_params_v3() argument
2837 if (session->ns_data.dd_data_addr.addr_type == NDMP_ADDR_LOCAL) { in log_rs_params_v3()
2841 session->ns_mover.md_record_size); in log_rs_params_v3()
2842 } else if (session->ns_data.dd_data_addr.addr_type == NDMP_ADDR_TCP) in log_rs_params_v3()
2845 inet_ntoa(IN_ADDR(session->ns_data.dd_data_addr.tcp_ip_v3)), in log_rs_params_v3()
2846 session->ns_data.dd_data_addr.tcp_port_v3); in log_rs_params_v3()
2918 restore_dar_alloc_structs_v3(ndmpd_session_t *session, char *jname) in restore_dar_alloc_structs_v3() argument
2924 nlp = ndmp_get_nlp(session); in restore_dar_alloc_structs_v3()
2933 xfer_size = ndmp_buffer_get_size(session); in restore_dar_alloc_structs_v3()
2959 free_dar_structs_v3(ndmpd_session_t *session, char *jname) in free_dar_structs_v3() argument
2964 nlp = ndmp_get_nlp(session); in free_dar_structs_v3()
3001 static char *ndmpd_dar_tar_init_v3(ndmpd_session_t *session, in ndmpd_dar_tar_init_v3() argument
3029 nlp->nlp_logcallbacks = lbrlog_callbacks_init(session, in ndmpd_dar_tar_init_v3()
3051 ndmp_data_get_mover_mode(session)); in ndmpd_dar_tar_init_v3()
3072 static int ndmpd_dar_tar_end_v3(ndmpd_session_t *session, in ndmpd_dar_tar_end_v3() argument
3099 if (session->ns_data.dd_abort) { in ndmpd_dar_tar_end_v3()
3109 if (session->ns_data.dd_operation == NDMP_DATA_OP_RECOVER) { in ndmpd_dar_tar_end_v3()
3145 ndmpd_dar_tar_v3(ndmpd_session_t *session, ndmpd_module_params_t *params, in ndmpd_dar_tar_v3() argument
3154 int data_addr_type = session->ns_data.dd_data_addr.addr_type; in ndmpd_dar_tar_v3()
3166 if (restore_dar_alloc_structs_v3(session, jname) < 0) in ndmpd_dar_tar_v3()
3169 sels = setupsels(session, params, nlp, dar_index); in ndmpd_dar_tar_v3()
3171 free_dar_structs_v3(session, jname); in ndmpd_dar_tar_v3()
3179 if (!session->ns_data.dd_abort) { in ndmpd_dar_tar_v3()
3185 arg.tr_session = session; in ndmpd_dar_tar_v3()
3207 nctx.nc_ddata = (void *) session; in ndmpd_dar_tar_v3()
3215 ndmp_stop_local_reader(session, cmds); in ndmpd_dar_tar_v3()
3218 ndmp_stop_remote_reader(session); in ndmpd_dar_tar_v3()
3229 session->hardlink_q); in ndmpd_dar_tar_v3()
3245 ndmp_stop_local_reader(session, cmds); in ndmpd_dar_tar_v3()
3255 (dar_index == (int)session->ns_data.dd_nlist_len)) { in ndmpd_dar_tar_v3()
3257 ndmp_stop_remote_reader(session); in ndmpd_dar_tar_v3()
3261 if (session->ns_eof) in ndmpd_dar_tar_v3()
3275 free_dar_structs_v3(session, jname); in ndmpd_dar_tar_v3()
3298 ndmpd_dar_locate_window_v3(ndmpd_session_t *session, in ndmpd_dar_locate_window_v3() argument
3305 ret = (*params->mp_seek_func)(session, fh_info, len); in ndmpd_dar_locate_window_v3()
3346 ndmpd_rs_dar_tar_v3(ndmpd_session_t *session, ndmpd_module_params_t *params, in ndmpd_rs_dar_tar_v3() argument
3352 int n = session->ns_data.dd_nlist_len; in ndmpd_rs_dar_tar_v3()
3356 jname = ndmpd_dar_tar_init_v3(session, nlp); in ndmpd_rs_dar_tar_v3()
3385 ret = ndmpd_dar_locate_window_v3(session, params, in ndmpd_rs_dar_tar_v3()
3394 if ((ret = ndmpd_dar_tar_v3(session, params, nlp, jname, i+1)) in ndmpd_rs_dar_tar_v3()
3397 ndmpd_audit_restore(session->ns_connection, in ndmpd_rs_dar_tar_v3()
3399 session->ns_data.dd_data_addr.addr_type, in ndmpd_rs_dar_tar_v3()
3400 session->ns_tape.td_adapter_name, result); in ndmpd_rs_dar_tar_v3()
3405 (void) ndmpd_dar_tar_end_v3(session, params, nlp, jname); in ndmpd_rs_dar_tar_v3()
3506 ndmpd_rs_sar_tar_v3(ndmpd_session_t *session, ndmpd_module_params_t *params, in ndmpd_rs_sar_tar_v3() argument
3523 if (restore_alloc_structs_v3(session, jname) < 0) in ndmpd_rs_sar_tar_v3()
3526 sels = setupsels(session, params, nlp, 0); in ndmpd_rs_sar_tar_v3()
3528 free_structs_v3(session, jname); in ndmpd_rs_sar_tar_v3()
3539 if (!session->ns_data.dd_abort && !session->ns_data.dd_abort) { in ndmpd_rs_sar_tar_v3()
3548 arg.tr_session = session; in ndmpd_rs_sar_tar_v3()
3557 free_structs_v3(session, jname); in ndmpd_rs_sar_tar_v3()
3573 nctx.nc_ddata = (void *) session; in ndmpd_rs_sar_tar_v3()
3578 ndmp_stop_local_reader(session, cmds); in ndmpd_rs_sar_tar_v3()
3581 ndmp_stop_remote_reader(session); in ndmpd_rs_sar_tar_v3()
3594 nlp->nlp_backup_path, session->hardlink_q); in ndmpd_rs_sar_tar_v3()
3614 ndmp_stop_local_reader(session, cmds); in ndmpd_rs_sar_tar_v3()
3618 ndmp_stop_remote_reader(session); in ndmpd_rs_sar_tar_v3()
3621 if (session->ns_eof) in ndmpd_rs_sar_tar_v3()
3628 if (session->ns_data.dd_abort) { in ndmpd_rs_sar_tar_v3()
3632 ndmpd_audit_restore(session->ns_connection, in ndmpd_rs_sar_tar_v3()
3634 session->ns_data.dd_data_addr.addr_type, in ndmpd_rs_sar_tar_v3()
3635 session->ns_tape.td_adapter_name, result); in ndmpd_rs_sar_tar_v3()
3641 ndmpd_audit_restore(session->ns_connection, in ndmpd_rs_sar_tar_v3()
3643 session->ns_data.dd_data_addr.addr_type, in ndmpd_rs_sar_tar_v3()
3644 session->ns_tape.td_adapter_name, result); in ndmpd_rs_sar_tar_v3()
3657 free_structs_v3(session, jname); in ndmpd_rs_sar_tar_v3()
3679 ndmp_backup_get_params_v3(ndmpd_session_t *session, in ndmp_backup_get_params_v3() argument
3684 if (!session || !params) in ndmp_backup_get_params_v3()
3687 nlp = ndmp_get_nlp(session); in ndmp_backup_get_params_v3()
3754 ndmpd_session_t *session; in ndmpd_tar_backup_starter_v3() local
3760 session = (ndmpd_session_t *)(params->mp_daemon_cookie); in ndmpd_tar_backup_starter_v3()
3761 *(params->mp_module_cookie) = nlp = ndmp_get_nlp(session); in ndmpd_tar_backup_starter_v3()
3762 ndmp_session_ref(session); in ndmpd_tar_backup_starter_v3()
3778 sarg.bs_session = session; in ndmpd_tar_backup_starter_v3()
3791 log_bk_params_v3(session, params, nlp); in ndmpd_tar_backup_starter_v3()
3792 err = tar_backup_v3(session, params, nlp, jname); in ndmpd_tar_backup_starter_v3()
3812 ndmp_session_unref(session); in ndmpd_tar_backup_starter_v3()
3864 ndmp_restore_get_params_v3(ndmpd_session_t *session, in ndmp_restore_get_params_v3() argument
3870 if (!(nlp = ndmp_get_nlp(session))) { in ndmp_restore_get_params_v3()
3875 else if ((nlp->nlp_nfiles = session->ns_data.dd_nlist_len) == 0) { in ndmp_restore_get_params_v3()
3880 } else if ((rv = fix_nlist_v3(session, params, nlp)) != NDMP_NO_ERR) { in ndmp_restore_get_params_v3()
3897 if (allvalidfh(session, params)) { in ndmp_restore_get_params_v3()
3898 ndmp_sort_nlist_v3(session); in ndmp_restore_get_params_v3()
3907 log_rs_params_v3(session, params, nlp); in ndmp_restore_get_params_v3()
3932 ndmpd_session_t *session; in ndmpd_tar_restore_starter_v3() local
3936 session = (ndmpd_session_t *)(params->mp_daemon_cookie); in ndmpd_tar_restore_starter_v3()
3937 *(params->mp_module_cookie) = nlp = ndmp_get_nlp(session); in ndmpd_tar_restore_starter_v3()
3938 ndmp_session_ref(session); in ndmpd_tar_restore_starter_v3()
3941 err = ndmpd_rs_dar_tar_v3(session, params, nlp); in ndmpd_tar_restore_starter_v3()
3943 err = ndmpd_rs_sar_tar_v3(session, params, nlp); in ndmpd_tar_restore_starter_v3()
3950 ndmp_session_unref(session); in ndmpd_tar_restore_starter_v3()