Lines Matching refs:session
77 static void ndmp_connect_get_scsi_v2(ndmpd_session_t *session,
79 static void ndmp_connect_get_tape_v2(ndmpd_session_t *session,
81 static void ndmp_connect_get_mover_v2(ndmpd_session_t *session,
83 static void ndmp_connect_get_data_v2(ndmpd_session_t *session,
87 static void ndmp_connect_get_mover_v3(ndmpd_session_t *session,
89 static void ndmp_connect_get_data_v3(ndmpd_session_t *session,
146 ndmpd_session_t *session; in ndmpd_connect_open_v2() local
150 if (!(session = (ndmpd_session_t *)ndmp_get_client_data(connection))) in ndmpd_connect_open_v2()
153 if (session->ns_mover.md_state != NDMP_MOVER_STATE_IDLE || in ndmpd_connect_open_v2()
154 session->ns_data.dd_state != NDMP_DATA_STATE_IDLE) in ndmpd_connect_open_v2()
172 session->ns_protocol_version = request->protocol_version; in ndmpd_connect_open_v2()
195 ndmpd_session_t *session; in ndmpd_connect_client_auth_v2() local
304 session = ndmp_get_client_data(connection); in ndmpd_connect_client_auth_v2()
306 session->ns_challenge); in ndmpd_connect_client_auth_v2()
407 ndmpd_session_t *session; in ndmpd_connect_close_v2() local
409 if ((session = (ndmpd_session_t *)ndmp_get_client_data(connection))) { in ndmpd_connect_close_v2()
411 session->ns_eof = TRUE; in ndmpd_connect_close_v2()
439 ndmpd_session_t *session; in ndmpd_connect_client_auth_v3() local
497 session = ndmp_get_client_data(connection); in ndmpd_connect_client_auth_v3()
500 md5->auth_digest, session->ns_challenge); in ndmpd_connect_client_auth_v3()
545 ndmpd_session_t *session; in ndmpd_connect_close_v3() local
549 if (!(session = (ndmpd_session_t *)ndmp_get_client_data(connection))) in ndmpd_connect_close_v3()
551 if ((nlp = ndmp_get_nlp(session)) == NULL) in ndmpd_connect_close_v3()
555 session->ns_protocol_version); in ndmpd_connect_close_v3()
559 req.protocol_version = session->ns_protocol_version; in ndmpd_connect_close_v3()
570 session->ns_eof = TRUE; in ndmpd_connect_close_v3()
773 ndmpd_session_t *session; in ndmp_connect_get_conn() local
775 if (!(session = (ndmpd_session_t *)ndmp_get_client_data(clp->cl_conn))) in ndmp_connect_get_conn()
779 ndmp_door_put_int32(enc_ctx, session->ns_protocol_version); in ndmp_connect_get_conn()
781 ndmp_door_put_int32(enc_ctx, session->ns_eof); in ndmp_connect_get_conn()
794 ndmp_connect_get_scsi_v2(ndmpd_session_t *session, ndmp_door_ctx_t *enc_ctx) in ndmp_connect_get_scsi_v2() argument
796 ndmp_door_put_int32(enc_ctx, session->ns_scsi.sd_is_open); in ndmp_connect_get_scsi_v2()
797 ndmp_door_put_string(enc_ctx, session->ns_scsi.sd_adapter_name); in ndmp_connect_get_scsi_v2()
798 ndmp_door_put_int32(enc_ctx, session->ns_scsi.sd_valid_target_set); in ndmp_connect_get_scsi_v2()
799 if (session->ns_scsi.sd_valid_target_set) { in ndmp_connect_get_scsi_v2()
800 ndmp_door_put_int32(enc_ctx, session->ns_scsi.sd_sid); in ndmp_connect_get_scsi_v2()
801 ndmp_door_put_int32(enc_ctx, session->ns_scsi.sd_lun); in ndmp_connect_get_scsi_v2()
809 ndmp_connect_get_tape_v2(ndmpd_session_t *session, ndmp_door_ctx_t *enc_ctx) in ndmp_connect_get_tape_v2() argument
813 ndmp_door_put_int32(enc_ctx, session->ns_tape.td_fd); in ndmp_connect_get_tape_v2()
814 if (session->ns_tape.td_fd != -1) { in ndmp_connect_get_tape_v2()
815 ndmp_door_put_uint64(enc_ctx, session->ns_tape.td_record_count); in ndmp_connect_get_tape_v2()
816 ndmp_door_put_int32(enc_ctx, session->ns_tape.td_mode); in ndmp_connect_get_tape_v2()
818 session->ns_tape.td_adapter_name, session->ns_tape.td_sid, in ndmp_connect_get_tape_v2()
819 session->ns_tape.td_lun); in ndmp_connect_get_tape_v2()
821 ndmp_door_put_string(enc_ctx, session->ns_tape.td_adapter_name); in ndmp_connect_get_tape_v2()
822 ndmp_door_put_int32(enc_ctx, session->ns_tape.td_sid); in ndmp_connect_get_tape_v2()
823 ndmp_door_put_int32(enc_ctx, session->ns_tape.td_lun); in ndmp_connect_get_tape_v2()
831 ndmp_connect_get_mover_v2(ndmpd_session_t *session, ndmp_door_ctx_t *enc_ctx) in ndmp_connect_get_mover_v2() argument
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()
842 ndmp_door_put_int32(enc_ctx, session->ns_mover.md_sock); in ndmp_connect_get_mover_v2()
849 ndmp_connect_get_data_common(ndmpd_session_t *session, ndmp_door_ctx_t *enc_ctx) in ndmp_connect_get_data_common() argument
855 ndmp_door_put_int32(enc_ctx, session->ns_data.dd_operation); in ndmp_connect_get_data_common()
856 ndmp_door_put_int32(enc_ctx, session->ns_data.dd_state); in ndmp_connect_get_data_common()
857 ndmp_door_put_int32(enc_ctx, session->ns_data.dd_halt_reason); in ndmp_connect_get_data_common()
858 ndmp_door_put_int32(enc_ctx, session->ns_data.dd_sock); in ndmp_connect_get_data_common()
859 ndmp_door_put_int32(enc_ctx, session->ns_data.dd_mover.addr_type); in ndmp_connect_get_data_common()
860 ndmp_door_put_int32(enc_ctx, session->ns_data.dd_abort); in ndmp_connect_get_data_common()
861 ndmp_door_put_uint64(enc_ctx, session->ns_data.dd_read_offset); in ndmp_connect_get_data_common()
862 ndmp_door_put_uint64(enc_ctx, session->ns_data.dd_read_length); in ndmp_connect_get_data_common()
863 ndmp_door_put_uint64(enc_ctx, session->ns_data.dd_data_size); in ndmp_connect_get_data_common()
866 ep = session->ns_data.dd_env; in ndmp_connect_get_data_common()
867 for (i = 0; ep && i < session->ns_data.dd_env_len; i++, ep++) in ndmp_connect_get_data_common()
871 (void) mutex_lock(&session->ns_lock); in ndmp_connect_get_data_common()
873 ep = session->ns_data.dd_env; in ndmp_connect_get_data_common()
878 (void) mutex_unlock(&session->ns_lock); in ndmp_connect_get_data_common()
885 ndmp_connect_get_data_v2(ndmpd_session_t *session, ndmp_door_ctx_t *enc_ctx) in ndmp_connect_get_data_v2() argument
891 ndmp_connect_get_data_common(session, enc_ctx); in ndmp_connect_get_data_v2()
893 switch (session->ns_data.dd_mover.addr_type) { in ndmp_connect_get_data_v2()
901 session->ns_data.dd_mover.ndmp_mover_addr_u.addr.ip_addr)), in ndmp_connect_get_data_v2()
902 session->ns_data.dd_mover.ndmp_mover_addr_u.addr.port); in ndmp_connect_get_data_v2()
910 ndmp_door_put_uint64(enc_ctx, session->ns_data.dd_nlist_len); in ndmp_connect_get_data_v2()
911 np = session->ns_data.dd_nlist; in ndmp_connect_get_data_v2()
912 for (i = 0; np && i < (int)session->ns_data.dd_nlist_len; i++, np++) { in ndmp_connect_get_data_v2()
924 ndmpd_session_t *session; in ndmp_connect_get_v2() local
926 if ((session = (ndmpd_session_t *)ndmp_get_client_data(connection))) { in ndmp_connect_get_v2()
927 ndmp_connect_get_scsi_v2(session, enc_ctx); in ndmp_connect_get_v2()
928 ndmp_connect_get_tape_v2(session, enc_ctx); in ndmp_connect_get_v2()
929 ndmp_connect_get_mover_v2(session, enc_ctx); in ndmp_connect_get_v2()
930 ndmp_connect_get_data_v2(session, enc_ctx); in ndmp_connect_get_v2()
938 ndmp_connect_get_mover_v3(ndmpd_session_t *session, ndmp_door_ctx_t *enc_ctx) in ndmp_connect_get_mover_v3() argument
943 ndmp_connect_get_mover_v2(session, enc_ctx); in ndmp_connect_get_mover_v3()
946 ndmp_door_put_int32(enc_ctx, session->ns_mover.md_listen_sock); in ndmp_connect_get_mover_v3()
947 ndmp_door_put_int32(enc_ctx, session->ns_mover.md_data_addr.addr_type); in ndmp_connect_get_mover_v3()
951 inet_ntoa(IN_ADDR(session->ns_mover.md_data_addr.tcp_ip_v3)), in ndmp_connect_get_mover_v3()
952 (int)session->ns_mover.md_data_addr.tcp_port_v3); in ndmp_connect_get_mover_v3()
960 ndmp_connect_get_data_v3(ndmpd_session_t *session, ndmp_door_ctx_t *enc_ctx) in ndmp_connect_get_data_v3() argument
966 ndmp_connect_get_data_common(session, enc_ctx); in ndmp_connect_get_data_v3()
969 (char *)inet_ntoa(IN_ADDR(session->ns_data.dd_data_addr.tcp_ip_v3)), in ndmp_connect_get_data_v3()
970 (int)session->ns_data.dd_data_addr.tcp_port_v3); in ndmp_connect_get_data_v3()
972 ndmp_door_put_int32(enc_ctx, session->ns_data.dd_listen_sock); in ndmp_connect_get_data_v3()
974 session->ns_data.dd_module.dm_stats.ms_bytes_processed); in ndmp_connect_get_data_v3()
975 ndmp_door_put_uint64(enc_ctx, session->ns_data.dd_nlist_len); in ndmp_connect_get_data_v3()
976 np = session->ns_data.dd_nlist_v3; in ndmp_connect_get_data_v3()
977 for (i = 0; np && i < (int)session->ns_data.dd_nlist_len; i++, np++) { in ndmp_connect_get_data_v3()
991 ndmpd_session_t *session; in ndmp_connect_get_v3() local
993 if ((session = (ndmpd_session_t *)ndmp_get_client_data(connection))) { in ndmp_connect_get_v3()
994 ndmp_connect_get_scsi_v2(session, enc_ctx); in ndmp_connect_get_v3()
995 ndmp_connect_get_tape_v2(session, enc_ctx); in ndmp_connect_get_v3()
996 ndmp_connect_get_mover_v3(session, enc_ctx); in ndmp_connect_get_v3()
997 ndmp_connect_get_data_v3(session, enc_ctx); in ndmp_connect_get_v3()
1008 ndmpd_session_t *session; in connection_get() local
1010 session = (ndmpd_session_t *)ndmp_get_client_data(clp->cl_conn); in connection_get()
1011 if (!session) { in connection_get()
1017 switch (session->ns_protocol_version) { in connection_get()
1029 "Invalid session (0x%p) version 0x%x", session, in connection_get()
1030 session->ns_protocol_version); in connection_get()
1049 ndmpd_session_t *session; in ndmpd_connect_kill() local
1051 if (!(session = (ndmpd_session_t *)ndmp_get_client_data(connection))) in ndmpd_connect_kill()
1054 switch (session->ns_protocol_version) { in ndmpd_connect_kill()
1064 "Invalid session (0x%p) version 0x%x", session, in ndmpd_connect_kill()
1065 session->ns_protocol_version); in ndmpd_connect_kill()