80 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_done_v2()  local
83 	if (session == NULL)  in ndmpd_api_done_v2()
86 	if (session->ns_data.dd_state == NDMP_DATA_STATE_IDLE ||  in ndmpd_api_done_v2()
87 	    session->ns_data.dd_state == NDMP_DATA_STATE_HALTED)  in ndmpd_api_done_v2()
91 	    session->ns_data.dd_operation);  in ndmpd_api_done_v2()
93 	if (session->ns_data.dd_operation == NDMP_DATA_OP_BACKUP) {  in ndmpd_api_done_v2()
97 		ndmpd_file_history_cleanup(session, (err == 0 ? TRUE : FALSE));  in ndmpd_api_done_v2()
103 		if (session->ns_data.dd_mover.addr_type == NDMP_ADDR_LOCAL &&  in ndmpd_api_done_v2()
105 			if (ndmpd_local_write(session, 0, 0) < 0)  in ndmpd_api_done_v2()
110 	session->ns_data.dd_state = NDMP_DATA_STATE_HALTED;  in ndmpd_api_done_v2()
114 		session->ns_data.dd_halt_reason = NDMP_DATA_HALT_SUCCESSFUL;  in ndmpd_api_done_v2()
117 		session->ns_data.dd_halt_reason = NDMP_DATA_HALT_ABORTED;  in ndmpd_api_done_v2()
120 		session->ns_data.dd_halt_reason = NDMP_DATA_HALT_CONNECT_ERROR;  in ndmpd_api_done_v2()
123 		session->ns_data.dd_halt_reason = NDMP_DATA_HALT_INTERNAL_ERROR;  in ndmpd_api_done_v2()
126 	req_v2.reason = session->ns_data.dd_halt_reason;  in ndmpd_api_done_v2()
131 	if (ndmp_send_request_lock(session->ns_connection,  in ndmpd_api_done_v2()
135 	if (session->ns_data.dd_mover.addr_type == NDMP_ADDR_TCP) {  in ndmpd_api_done_v2()
137 		if (session->ns_mover.md_sock != session->ns_data.dd_sock) {  in ndmpd_api_done_v2()
138 			(void) close(session->ns_data.dd_sock);  in ndmpd_api_done_v2()
143 		session->ns_data.dd_sock = -1;  in ndmpd_api_done_v2()
145 		ndmpd_mover_error(session, NDMP_MOVER_HALT_CONNECT_CLOSED);  in ndmpd_api_done_v2()
169 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_log_v2()  local
174 	if (session == NULL)  in ndmpd_api_log_v2()
186 	if (ndmp_send_request(session->ns_connection, _NDMP_LOG_LOG,  in ndmpd_api_log_v2()
217 	ndmpd_session_t *session = (ndmpd_session_t *)client_data;  in ndmpd_api_read_v2()  local
219 	if (session == NULL)  in ndmpd_api_read_v2()
225 	if (session->ns_data.dd_mover.addr_type == NDMP_ADDR_TCP)  in ndmpd_api_read_v2()
226 		return (ndmpd_remote_read(session, data, length));  in ndmpd_api_read_v2()
228 		return (ndmpd_local_read(session, data, length));  in ndmpd_api_read_v2()
250 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_seek_v2()  local
253 	if (session == NULL)  in ndmpd_api_seek_v2()
256 	session->ns_data.dd_read_offset = offset;  in ndmpd_api_seek_v2()
257 	session->ns_data.dd_read_length = length;  in ndmpd_api_seek_v2()
262 	if (session->ns_data.dd_mover.addr_type == NDMP_ADDR_TCP) {  in ndmpd_api_seek_v2()
265 		session->ns_mover.md_discard_length =  in ndmpd_api_seek_v2()
266 		    session->ns_mover.md_bytes_left_to_read;  in ndmpd_api_seek_v2()
267 		session->ns_mover.md_bytes_left_to_read = length;  in ndmpd_api_seek_v2()
268 		session->ns_mover.md_position = offset;  in ndmpd_api_seek_v2()
273 		if (ndmp_send_request_lock(session->ns_connection,  in ndmpd_api_seek_v2()
285 	err = ndmpd_mover_seek(session, offset, length);  in ndmpd_api_seek_v2()
287 		ndmpd_mover_error(session, NDMP_MOVER_HALT_INTERNAL_ERROR);  in ndmpd_api_seek_v2()
298 	nlp_ref_nw(session);  in ndmpd_api_seek_v2()
300 		nlp_wait_nw(session);  in ndmpd_api_seek_v2()
302 		if (nlp_event_rv_get(session) < 0) {  in ndmpd_api_seek_v2()
303 			nlp_unref_nw(session);  in ndmpd_api_seek_v2()
307 		if (session->ns_eof == TRUE) {  in ndmpd_api_seek_v2()
308 			nlp_unref_nw(session);  in ndmpd_api_seek_v2()
312 		switch (session->ns_mover.md_state) {  in ndmpd_api_seek_v2()
319 			nlp_unref_nw(session);  in ndmpd_api_seek_v2()
326 			nlp_unref_nw(session);  in ndmpd_api_seek_v2()
350 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_file_recovered_v2()  local
353 	if (session == NULL)  in ndmpd_api_file_recovered_v2()
370 	if (ndmp_send_request_lock(session->ns_connection, NDMP_LOG_FILE,  in ndmpd_api_file_recovered_v2()
400 	ndmpd_session_t *session = (ndmpd_session_t *)client_data;  in ndmpd_api_write_v2()  local
402 	if (session == NULL)  in ndmpd_api_write_v2()
408 	if (session->ns_data.dd_mover.addr_type == NDMP_ADDR_TCP)  in ndmpd_api_write_v2()
409 		return (ndmpd_remote_write(session, data, length));  in ndmpd_api_write_v2()
411 		return (ndmpd_local_write(session, data, length));  in ndmpd_api_write_v2()
437 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_done_v3()  local
457 	ndmpd_data_error(session, reason);  in ndmpd_api_done_v3()
479 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_log_v3()  local
484 	if (session == NULL)  in ndmpd_api_log_v3()
497 	if (ndmp_send_request(session->ns_connection, NDMP_LOG_MESSAGE,  in ndmpd_api_log_v3()
527 	ndmpd_session_t *session = (ndmpd_session_t *)client_data;  in ndmpd_api_write_v3()  local
529 	if (session == NULL)  in ndmpd_api_write_v3()
540 	if (session->ns_data.dd_data_addr.addr_type == NDMP_ADDR_LOCAL)  in ndmpd_api_write_v3()
541 		return (ndmpd_local_write_v3(session, data, length));  in ndmpd_api_write_v3()
543 		return (ndmpd_remote_write(session, data, length));  in ndmpd_api_write_v3()
568 	ndmpd_session_t *session = (ndmpd_session_t *)client_data;  in ndmpd_api_read_v3()  local
570 	if (session == NULL)  in ndmpd_api_read_v3()
576 	if (session->ns_data.dd_data_addr.addr_type == NDMP_ADDR_LOCAL)  in ndmpd_api_read_v3()
577 		return (ndmpd_local_read_v3(session, data, length));  in ndmpd_api_read_v3()
579 		return (ndmpd_remote_read_v3(session, data, length));  in ndmpd_api_read_v3()
600 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_get_name_v3()  local
602 	if (session == NULL)  in ndmpd_api_get_name_v3()
605 	if (name_index >= session->ns_data.dd_nlist_len)  in ndmpd_api_get_name_v3()
608 	return (&session->ns_data.dd_nlist_v3[name_index]);  in ndmpd_api_get_name_v3()
631 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_file_recovered_v3()  local
634 	if (session == NULL)  in ndmpd_api_file_recovered_v3()
650 	if (ndmp_send_request_lock(session->ns_connection, NDMP_LOG_FILE,  in ndmpd_api_file_recovered_v3()
679 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_seek_v3()  local
683 	if (session == NULL)  in ndmpd_api_seek_v3()
686 	session->ns_data.dd_read_offset = offset;  in ndmpd_api_seek_v3()
687 	session->ns_data.dd_read_length = length;  in ndmpd_api_seek_v3()
692 	if (session->ns_data.dd_data_addr.addr_type != NDMP_ADDR_LOCAL) {  in ndmpd_api_seek_v3()
693 		session->ns_data.dd_discard_length =  in ndmpd_api_seek_v3()
694 		    session->ns_data.dd_bytes_left_to_read;  in ndmpd_api_seek_v3()
695 		session->ns_data.dd_bytes_left_to_read = length;  in ndmpd_api_seek_v3()
696 		session->ns_data.dd_position = offset;  in ndmpd_api_seek_v3()
701 		if (ndmp_send_request_lock(session->ns_connection,  in ndmpd_api_seek_v3()
714 	err = ndmpd_mover_seek(session, offset, length);  in ndmpd_api_seek_v3()
716 		ndmpd_mover_error(session, NDMP_MOVER_HALT_INTERNAL_ERROR);  in ndmpd_api_seek_v3()
728 	err = ndmpd_mover_wait_v3(session);  in ndmpd_api_seek_v3()
767 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_log_v4()  local
772 	if (session == NULL)  in ndmpd_api_log_v4()
787 	if (ndmp_send_request(session->ns_connection, NDMP_LOG_MESSAGE,  in ndmpd_api_log_v4()
814 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_file_recovered_v4()  local
817 	if (session == NULL)  in ndmpd_api_file_recovered_v4()
849 	if (ndmp_send_request_lock(session->ns_connection, NDMP_LOG_FILE,  in ndmpd_api_file_recovered_v4()
883 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_find_env()  local
887 	if (session == NULL)  in ndmpd_api_find_env()
890 	envp = session->ns_data.dd_env;  in ndmpd_api_find_env()
891 	for (i = 0; envp && i < session->ns_data.dd_env_len; envp++, i++)  in ndmpd_api_find_env()
944 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_add_env()  local
948 	if (session == NULL)  in ndmpd_api_add_env()
951 	session->ns_data.dd_env = realloc((void *)session->ns_data.dd_env,  in ndmpd_api_add_env()
952 	    sizeof (ndmp_pval) * (session->ns_data.dd_env_len + 1));  in ndmpd_api_add_env()
954 	if (session->ns_data.dd_env == NULL) {  in ndmpd_api_add_env()
968 	(void) mutex_lock(&session->ns_lock);  in ndmpd_api_add_env()
969 	session->ns_data.dd_env[session->ns_data.dd_env_len].name = namebuf;  in ndmpd_api_add_env()
970 	session->ns_data.dd_env[session->ns_data.dd_env_len].value = valbuf;  in ndmpd_api_add_env()
971 	session->ns_data.dd_env_len++;  in ndmpd_api_add_env()
972 	(void) mutex_unlock(&session->ns_lock);  in ndmpd_api_add_env()
1033 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_get_name()  local
1035 	if (session == NULL)  in ndmpd_api_get_name()
1038 	if (name_index >= session->ns_data.dd_nlist_len)  in ndmpd_api_get_name()
1041 	return (&session->ns_data.dd_nlist[name_index]);  in ndmpd_api_get_name()
1065 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_dispatch()  local
1068 	if (session == NULL)  in ndmpd_api_dispatch()
1072 		err = ndmpd_select(session, block, HC_ALL);  in ndmpd_api_dispatch()
1073 		if (err < 0 || session->ns_data.dd_abort == TRUE ||  in ndmpd_api_dispatch()
1074 		    session->ns_eof)  in ndmpd_api_dispatch()
1116 	ndmpd_session_t *session = (ndmpd_session_t *)daemon_cookie;  in ndmpd_api_add_file_handler()  local
1118 	return (ndmpd_add_file_handler(session, cookie, fd, mode, HC_MODULE,  in ndmpd_api_add_file_handler()
1139 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_remove_file_handler()  local
1141 	return (ndmpd_remove_file_handler(session, fd));  in ndmpd_api_remove_file_handler()