81 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_done_v2()  local
84 	if (session == NULL)  in ndmpd_api_done_v2()
87 	if (session->ns_data.dd_state == NDMP_DATA_STATE_IDLE ||  in ndmpd_api_done_v2()
88 	    session->ns_data.dd_state == NDMP_DATA_STATE_HALTED)  in ndmpd_api_done_v2()
92 	    session->ns_data.dd_operation);  in ndmpd_api_done_v2()
94 	if (session->ns_data.dd_operation == NDMP_DATA_OP_BACKUP) {  in ndmpd_api_done_v2()
98 		ndmpd_file_history_cleanup(session, (err == 0 ? TRUE : FALSE));  in ndmpd_api_done_v2()
104 		if (session->ns_data.dd_mover.addr_type == NDMP_ADDR_LOCAL &&  in ndmpd_api_done_v2()
106 			if (ndmpd_local_write(session, 0, 0) < 0)  in ndmpd_api_done_v2()
111 	session->ns_data.dd_state = NDMP_DATA_STATE_HALTED;  in ndmpd_api_done_v2()
115 		session->ns_data.dd_halt_reason = NDMP_DATA_HALT_SUCCESSFUL;  in ndmpd_api_done_v2()
118 		session->ns_data.dd_halt_reason = NDMP_DATA_HALT_ABORTED;  in ndmpd_api_done_v2()
121 		session->ns_data.dd_halt_reason = NDMP_DATA_HALT_CONNECT_ERROR;  in ndmpd_api_done_v2()
124 		session->ns_data.dd_halt_reason = NDMP_DATA_HALT_INTERNAL_ERROR;  in ndmpd_api_done_v2()
127 	req_v2.reason = session->ns_data.dd_halt_reason;  in ndmpd_api_done_v2()
132 	if (ndmp_send_request_lock(session->ns_connection,  in ndmpd_api_done_v2()
136 	if (session->ns_data.dd_mover.addr_type == NDMP_ADDR_TCP) {  in ndmpd_api_done_v2()
138 		if (session->ns_mover.md_sock != session->ns_data.dd_sock) {  in ndmpd_api_done_v2()
139 			(void) close(session->ns_data.dd_sock);  in ndmpd_api_done_v2()
144 		session->ns_data.dd_sock = -1;  in ndmpd_api_done_v2()
146 		ndmpd_mover_error(session, NDMP_MOVER_HALT_CONNECT_CLOSED);  in ndmpd_api_done_v2()
170 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_log_v2()  local
175 	if (session == NULL)  in ndmpd_api_log_v2()
187 	if (ndmp_send_request(session->ns_connection, _NDMP_LOG_LOG,  in ndmpd_api_log_v2()
218 	ndmpd_session_t *session = (ndmpd_session_t *)client_data;  in ndmpd_api_read_v2()  local
220 	if (session == NULL)  in ndmpd_api_read_v2()
226 	if (session->ns_data.dd_mover.addr_type == NDMP_ADDR_TCP)  in ndmpd_api_read_v2()
227 		return (ndmpd_remote_read(session, data, length));  in ndmpd_api_read_v2()
229 		return (ndmpd_local_read(session, data, length));  in ndmpd_api_read_v2()
251 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_seek_v2()  local
254 	if (session == NULL)  in ndmpd_api_seek_v2()
257 	session->ns_data.dd_read_offset = offset;  in ndmpd_api_seek_v2()
258 	session->ns_data.dd_read_length = length;  in ndmpd_api_seek_v2()
263 	if (session->ns_data.dd_mover.addr_type == NDMP_ADDR_TCP) {  in ndmpd_api_seek_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()
274 		if (ndmp_send_request_lock(session->ns_connection,  in ndmpd_api_seek_v2()
286 	err = ndmpd_mover_seek(session, offset, length);  in ndmpd_api_seek_v2()
288 		ndmpd_mover_error(session, NDMP_MOVER_HALT_INTERNAL_ERROR);  in ndmpd_api_seek_v2()
299 	return (ndmp_wait_for_mover(session));  in ndmpd_api_seek_v2()
320 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_file_recovered_v2()  local
323 	if (session == NULL)  in ndmpd_api_file_recovered_v2()
340 	if (ndmp_send_request_lock(session->ns_connection, NDMP_LOG_FILE,  in ndmpd_api_file_recovered_v2()
370 	ndmpd_session_t *session = (ndmpd_session_t *)client_data;  in ndmpd_api_write_v2()  local
372 	if (session == NULL)  in ndmpd_api_write_v2()
378 	if (session->ns_data.dd_mover.addr_type == NDMP_ADDR_TCP)  in ndmpd_api_write_v2()
379 		return (ndmpd_remote_write(session, data, length));  in ndmpd_api_write_v2()
381 		return (ndmpd_local_write(session, data, length));  in ndmpd_api_write_v2()
407 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_done_v3()  local
427 	ndmpd_data_error(session, reason);  in ndmpd_api_done_v3()
449 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_log_v3()  local
454 	if (session == NULL)  in ndmpd_api_log_v3()
467 	if (ndmp_send_request(session->ns_connection, NDMP_LOG_MESSAGE,  in ndmpd_api_log_v3()
497 	ndmpd_session_t *session = (ndmpd_session_t *)client_data;  in ndmpd_api_write_v3()  local
499 	if (session == NULL)  in ndmpd_api_write_v3()
510 	if (session->ns_data.dd_data_addr.addr_type == NDMP_ADDR_LOCAL)  in ndmpd_api_write_v3()
511 		return (ndmpd_local_write_v3(session, data, length));  in ndmpd_api_write_v3()
513 		return (ndmpd_remote_write(session, data, length));  in ndmpd_api_write_v3()
538 	ndmpd_session_t *session = (ndmpd_session_t *)client_data;  in ndmpd_api_read_v3()  local
540 	if (session == NULL)  in ndmpd_api_read_v3()
546 	if (session->ns_data.dd_data_addr.addr_type == NDMP_ADDR_LOCAL)  in ndmpd_api_read_v3()
547 		return (ndmpd_local_read_v3(session, data, length));  in ndmpd_api_read_v3()
549 		return (ndmpd_remote_read_v3(session, data, length));  in ndmpd_api_read_v3()
570 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_get_name_v3()  local
572 	if (session == NULL)  in ndmpd_api_get_name_v3()
575 	if (name_index >= session->ns_data.dd_nlist_len)  in ndmpd_api_get_name_v3()
578 	return (&session->ns_data.dd_nlist_v3[name_index]);  in ndmpd_api_get_name_v3()
601 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_file_recovered_v3()  local
604 	if (session == NULL)  in ndmpd_api_file_recovered_v3()
620 	if (ndmp_send_request_lock(session->ns_connection, NDMP_LOG_FILE,  in ndmpd_api_file_recovered_v3()
649 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_seek_v3()  local
653 	if (session == NULL)  in ndmpd_api_seek_v3()
656 	session->ns_data.dd_read_offset = offset;  in ndmpd_api_seek_v3()
657 	session->ns_data.dd_read_length = length;  in ndmpd_api_seek_v3()
662 	if (session->ns_data.dd_data_addr.addr_type != NDMP_ADDR_LOCAL) {  in ndmpd_api_seek_v3()
663 		session->ns_data.dd_discard_length =  in ndmpd_api_seek_v3()
664 		    session->ns_data.dd_bytes_left_to_read;  in ndmpd_api_seek_v3()
665 		session->ns_data.dd_bytes_left_to_read = length;  in ndmpd_api_seek_v3()
666 		session->ns_data.dd_position = offset;  in ndmpd_api_seek_v3()
671 		if (ndmp_send_request_lock(session->ns_connection,  in ndmpd_api_seek_v3()
684 	err = ndmpd_mover_seek(session, offset, length);  in ndmpd_api_seek_v3()
686 		ndmpd_mover_error(session, NDMP_MOVER_HALT_INTERNAL_ERROR);  in ndmpd_api_seek_v3()
698 	err = ndmp_wait_for_mover(session);  in ndmpd_api_seek_v3()
737 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_log_v4()  local
742 	if (session == NULL)  in ndmpd_api_log_v4()
757 	if (ndmp_send_request(session->ns_connection, NDMP_LOG_MESSAGE,  in ndmpd_api_log_v4()
784 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_file_recovered_v4()  local
787 	if (session == NULL)  in ndmpd_api_file_recovered_v4()
819 	if (ndmp_send_request_lock(session->ns_connection, NDMP_LOG_FILE,  in ndmpd_api_file_recovered_v4()
853 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_find_env()  local
857 	if (session == NULL)  in ndmpd_api_find_env()
860 	envp = session->ns_data.dd_env;  in ndmpd_api_find_env()
861 	for (i = 0; envp && i < session->ns_data.dd_env_len; envp++, i++)  in ndmpd_api_find_env()
914 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_add_env()  local
918 	if (session == NULL)  in ndmpd_api_add_env()
921 	session->ns_data.dd_env = realloc((void *)session->ns_data.dd_env,  in ndmpd_api_add_env()
922 	    sizeof (ndmp_pval) * (session->ns_data.dd_env_len + 1));  in ndmpd_api_add_env()
924 	if (session->ns_data.dd_env == NULL) {  in ndmpd_api_add_env()
938 	(void) mutex_lock(&session->ns_lock);  in ndmpd_api_add_env()
939 	session->ns_data.dd_env[session->ns_data.dd_env_len].name = namebuf;  in ndmpd_api_add_env()
940 	session->ns_data.dd_env[session->ns_data.dd_env_len].value = valbuf;  in ndmpd_api_add_env()
941 	session->ns_data.dd_env_len++;  in ndmpd_api_add_env()
942 	(void) mutex_unlock(&session->ns_lock);  in ndmpd_api_add_env()
1003 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_get_name()  local
1005 	if (session == NULL)  in ndmpd_api_get_name()
1008 	if (name_index >= session->ns_data.dd_nlist_len)  in ndmpd_api_get_name()
1011 	return (&session->ns_data.dd_nlist[name_index]);  in ndmpd_api_get_name()
1035 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_dispatch()  local
1038 	if (session == NULL)  in ndmpd_api_dispatch()
1042 		err = ndmpd_select(session, block, HC_ALL);  in ndmpd_api_dispatch()
1043 		if (err < 0 || session->ns_data.dd_abort == TRUE ||  in ndmpd_api_dispatch()
1044 		    session->ns_eof)  in ndmpd_api_dispatch()
1086 	ndmpd_session_t *session = (ndmpd_session_t *)daemon_cookie;  in ndmpd_api_add_file_handler()  local
1088 	return (ndmpd_add_file_handler(session, cookie, fd, mode, HC_MODULE,  in ndmpd_api_add_file_handler()
1109 	ndmpd_session_t *session = (ndmpd_session_t *)cookie;  in ndmpd_api_remove_file_handler()  local
1111 	return (ndmpd_remove_file_handler(session, fd));  in ndmpd_api_remove_file_handler()