99 	ndmp_data_get_state_reply_v2 reply;  in ndmpd_data_get_state_v2()  local
102 	reply.error = NDMP_NO_ERR;  in ndmpd_data_get_state_v2()
103 	reply.operation = session->ns_data.dd_operation;  in ndmpd_data_get_state_v2()
104 	reply.state = session->ns_data.dd_state;  in ndmpd_data_get_state_v2()
105 	reply.halt_reason = session->ns_data.dd_halt_reason;  in ndmpd_data_get_state_v2()
107 	reply.est_time_remain =  in ndmpd_data_get_state_v2()
109 	reply.est_bytes_remain =  in ndmpd_data_get_state_v2()
113 	reply.bytes_processed =  in ndmpd_data_get_state_v2()
116 	reply.mover = session->ns_data.dd_mover;  in ndmpd_data_get_state_v2()
117 	reply.read_offset = long_long_to_quad(session->ns_data.dd_read_offset);  in ndmpd_data_get_state_v2()
118 	reply.read_length = long_long_to_quad(session->ns_data.dd_read_length);  in ndmpd_data_get_state_v2()
120 	ndmp_send_reply(connection, &reply,  in ndmpd_data_get_state_v2()
141 	ndmp_data_start_backup_reply_v2 reply;  in ndmpd_data_start_backup_v2()  local
147 	reply.error = NDMP_NO_ERR;  in ndmpd_data_start_backup_v2()
159 		reply.error = err;  in ndmpd_data_start_backup_v2()
160 		ndmp_send_reply(connection, &reply,  in ndmpd_data_start_backup_v2()
182 	ndmp_data_start_recover_reply_v2 reply;  in ndmpd_data_start_recover_v2()  local
198 		reply.error = err;  in ndmpd_data_start_recover_v2()
199 		ndmp_send_reply(connection, &reply,  in ndmpd_data_start_recover_v2()
223 	ndmp_data_get_env_reply reply;  in ndmpd_data_get_env_v2()  local
226 	(void) memset((void*)&reply, 0, sizeof (reply));  in ndmpd_data_get_env_v2()
229 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_get_env_v2()
230 		reply.env.env_len = 0;  in ndmpd_data_get_env_v2()
232 		reply.error = NDMP_NO_ERR;  in ndmpd_data_get_env_v2()
233 		reply.env.env_len = session->ns_data.dd_env_len;  in ndmpd_data_get_env_v2()
234 		reply.env.env_val = session->ns_data.dd_env;  in ndmpd_data_get_env_v2()
237 	ndmp_send_reply(connection, &reply, "sending data_get_env reply");  in ndmpd_data_get_env_v2()
257 	ndmp_data_stop_reply reply;  in ndmpd_data_stop_v2()  local
262 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_stop_v2()
263 		ndmp_send_reply(connection, &reply,  in ndmpd_data_stop_v2()
277 	reply.error = NDMP_NO_ERR;  in ndmpd_data_stop_v2()
278 	ndmp_send_reply(connection, &reply, "sending data_stop reply");  in ndmpd_data_stop_v2()
300 	ndmp_data_abort_reply reply;  in ndmpd_data_abort_v2()  local
306 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_abort_v2()
307 		ndmp_send_reply(connection, &reply,  in ndmpd_data_abort_v2()
320 	reply.error = NDMP_NO_ERR;  in ndmpd_data_abort_v2()
321 	ndmp_send_reply(connection, &reply, "sending data_abort reply");  in ndmpd_data_abort_v2()
346 	ndmp_data_get_state_reply_v3 reply;  in ndmpd_data_get_state_v3()  local
349 	(void) memset((void*)&reply, 0, sizeof (reply));  in ndmpd_data_get_state_v3()
351 	reply.error = NDMP_NO_ERR;  in ndmpd_data_get_state_v3()
352 	reply.invalid = NDMP_DATA_STATE_EST_BYTES_REMAIN_INVALID  in ndmpd_data_get_state_v3()
354 	reply.operation = session->ns_data.dd_operation;  in ndmpd_data_get_state_v3()
355 	reply.state = session->ns_data.dd_state;  in ndmpd_data_get_state_v3()
356 	reply.halt_reason = session->ns_data.dd_halt_reason;  in ndmpd_data_get_state_v3()
358 	if (reply.operation == NDMP_DATA_OP_BACKUP)  in ndmpd_data_get_state_v3()
359 		reply.bytes_processed =  in ndmpd_data_get_state_v3()
363 		reply.bytes_processed =  in ndmpd_data_get_state_v3()
366 	reply.est_bytes_remain = long_long_to_quad(0LL);  in ndmpd_data_get_state_v3()
367 	reply.est_time_remain = 0;  in ndmpd_data_get_state_v3()
369 		ndmp_copy_addr_v3(&reply.data_connection_addr,  in ndmpd_data_get_state_v3()
371 	reply.read_offset = long_long_to_quad(session->ns_data.dd_read_offset);  in ndmpd_data_get_state_v3()
372 	reply.read_length = long_long_to_quad(session->ns_data.dd_read_length);  in ndmpd_data_get_state_v3()
374 	ndmp_send_reply(connection, &reply,  in ndmpd_data_get_state_v3()
395 	ndmp_data_start_backup_reply_v3 reply;  in ndmpd_data_start_backup_v3()  local
400 	(void) memset((void*)&reply, 0, sizeof (reply));  in ndmpd_data_start_backup_v3()
407 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_start_backup_v3()
414 			reply.error = NDMP_WRITE_PROTECT_ERR;  in ndmpd_data_start_backup_v3()
441 		reply.error = NDMP_ILLEGAL_ARGS_ERR;  in ndmpd_data_start_backup_v3()
446 		reply.error = ndmpd_zfs_start_op(session, request->env.env_val,  in ndmpd_data_start_backup_v3()
449 		reply.error = ndmpd_tar_start_backup_v3(session,  in ndmpd_data_start_backup_v3()
462 	if (reply.error != NDMP_NO_ERR) {  in ndmpd_data_start_backup_v3()
463 		ndmp_send_reply(connection, &reply,  in ndmpd_data_start_backup_v3()
485 	ndmp_data_start_recover_reply_v3 reply;  in ndmpd_data_start_recover_v3()  local
490 	(void) memset((void*)&reply, 0, sizeof (reply));  in ndmpd_data_start_recover_v3()
494 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_start_recover_v3()
520 		reply.error = NDMP_ILLEGAL_ARGS_ERR;  in ndmpd_data_start_recover_v3()
525 		reply.error = ndmpd_zfs_start_op(session, request->env.env_val,  in ndmpd_data_start_recover_v3()
529 		reply.error = ndmpd_tar_start_recover_v3(session,  in ndmpd_data_start_recover_v3()
542 	if (reply.error != NDMP_NO_ERR) {  in ndmpd_data_start_recover_v3()
543 		ndmp_send_reply(connection, &reply,  in ndmpd_data_start_recover_v3()
568 	ndmp_data_abort_reply reply;  in ndmpd_data_abort_v3()  local
573 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_abort_v3()
583 		reply.error = NDMP_NO_ERR;  in ndmpd_data_abort_v3()
593 		reply.error = NDMP_NO_ERR;  in ndmpd_data_abort_v3()
598 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_abort_v3()
603 	ndmp_send_reply(connection, &reply,  in ndmpd_data_abort_v3()
624 	ndmp_data_stop_reply reply;  in ndmpd_data_stop_v3()  local
629 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_stop_v3()
630 		ndmp_send_reply(connection, &reply,  in ndmpd_data_stop_v3()
642 	reply.error = NDMP_NO_ERR;  in ndmpd_data_stop_v3()
643 	ndmp_send_reply(connection, &reply,  in ndmpd_data_stop_v3()
665 	ndmp_data_listen_reply_v3 reply;  in ndmpd_data_listen_v3()  local
672 	(void) memset((void*)&reply, 0, sizeof (reply));  in ndmpd_data_listen_v3()
675 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_listen_v3()
679 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_listen_v3()
683 		reply.error = NDMP_NO_ERR;  in ndmpd_data_listen_v3()
686 	if (reply.error != NDMP_NO_ERR) {  in ndmpd_data_listen_v3()
687 		ndmp_send_reply(connection, &reply,  in ndmpd_data_listen_v3()
694 		reply.data_connection_addr.addr_type = request->addr_type;  in ndmpd_data_listen_v3()
699 			reply.error = NDMP_IO_ERR;  in ndmpd_data_listen_v3()
703 		reply.error = NDMP_NO_ERR;  in ndmpd_data_listen_v3()
704 		reply.data_connection_addr.addr_type = request->addr_type;  in ndmpd_data_listen_v3()
705 		reply.data_connection_addr.tcp_ip_v3 = htonl(addr);  in ndmpd_data_listen_v3()
706 		reply.data_connection_addr.tcp_port_v3 = htons(port);  in ndmpd_data_listen_v3()
717 		reply.error = NDMP_ILLEGAL_ARGS_ERR;  in ndmpd_data_listen_v3()
721 	if (reply.error == NDMP_NO_ERR)  in ndmpd_data_listen_v3()
724 	ndmp_send_reply(connection, &reply,  in ndmpd_data_listen_v3()
746 	ndmp_data_connect_reply_v3 reply;  in ndmpd_data_connect_v3()  local
751 	(void) memset((void*)&reply, 0, sizeof (reply));  in ndmpd_data_connect_v3()
754 		reply.error = NDMP_ILLEGAL_ARGS_ERR;  in ndmpd_data_connect_v3()
758 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_connect_v3()
761 		reply.error = NDMP_NO_ERR;  in ndmpd_data_connect_v3()
764 	if (reply.error != NDMP_NO_ERR) {  in ndmpd_data_connect_v3()
765 		ndmp_send_reply(connection, &reply,  in ndmpd_data_connect_v3()
778 			reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_connect_v3()
787 		reply.error = data_connect_sock_v3(session,  in ndmpd_data_connect_v3()
792 		reply.error = NDMP_ILLEGAL_ARGS_ERR;  in ndmpd_data_connect_v3()
797 	if (reply.error == NDMP_NO_ERR)  in ndmpd_data_connect_v3()
800 	ndmp_send_reply(connection, &reply,  in ndmpd_data_connect_v3()
829 	ndmp_data_get_env_reply reply;  in ndmpd_data_get_env_v4()  local
832 	(void) memset((void*)&reply, 0, sizeof (reply));  in ndmpd_data_get_env_v4()
837 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_get_env_v4()
838 		reply.env.env_len = 0;  in ndmpd_data_get_env_v4()
841 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_get_env_v4()
842 		reply.env.env_len = 0;  in ndmpd_data_get_env_v4()
844 		reply.error = NDMP_NO_ERR;  in ndmpd_data_get_env_v4()
845 		reply.env.env_len = session->ns_data.dd_env_len;  in ndmpd_data_get_env_v4()
846 		reply.env.env_val = session->ns_data.dd_env;  in ndmpd_data_get_env_v4()
849 	ndmp_send_reply(connection, &reply, "sending data_get_env reply");  in ndmpd_data_get_env_v4()
868 	ndmp_data_get_state_reply_v4 reply;  in ndmpd_data_get_state_v4()  local
871 	(void) memset((void*)&reply, 0, sizeof (reply));  in ndmpd_data_get_state_v4()
873 	reply.error = NDMP_NO_ERR;  in ndmpd_data_get_state_v4()
874 	reply.unsupported = NDMP_DATA_STATE_EST_BYTES_REMAIN_INVALID  in ndmpd_data_get_state_v4()
876 	reply.operation = session->ns_data.dd_operation;  in ndmpd_data_get_state_v4()
877 	reply.state = session->ns_data.dd_state;  in ndmpd_data_get_state_v4()
878 	reply.halt_reason = session->ns_data.dd_halt_reason;  in ndmpd_data_get_state_v4()
880 	if (reply.operation == NDMP_DATA_OP_BACKUP)  in ndmpd_data_get_state_v4()
881 		reply.bytes_processed = long_long_to_quad(  in ndmpd_data_get_state_v4()
884 		reply.bytes_processed =  in ndmpd_data_get_state_v4()
887 	reply.est_bytes_remain = long_long_to_quad(0LL);  in ndmpd_data_get_state_v4()
888 	reply.est_time_remain = 0;  in ndmpd_data_get_state_v4()
890 		ndmp_copy_addr_v4(&reply.data_connection_addr,  in ndmpd_data_get_state_v4()
893 	reply.read_offset = long_long_to_quad(session->ns_data.dd_read_offset);  in ndmpd_data_get_state_v4()
894 	reply.read_length = long_long_to_quad(session->ns_data.dd_read_length);  in ndmpd_data_get_state_v4()
896 	ndmp_send_reply(connection, &reply,  in ndmpd_data_get_state_v4()
898 	free(reply.data_connection_addr.tcp_addr_v4);  in ndmpd_data_get_state_v4()
919 	ndmp_data_connect_reply_v4 reply;  in ndmpd_data_connect_v4()  local
924 	(void) memset((void*)&reply, 0, sizeof (reply));  in ndmpd_data_connect_v4()
927 		reply.error = NDMP_ILLEGAL_ARGS_ERR;  in ndmpd_data_connect_v4()
931 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_connect_v4()
934 		reply.error = NDMP_NO_ERR;  in ndmpd_data_connect_v4()
937 	if (reply.error != NDMP_NO_ERR) {  in ndmpd_data_connect_v4()
938 		ndmp_send_reply(connection, &reply,  in ndmpd_data_connect_v4()
951 			reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_connect_v4()
960 		reply.error = data_connect_sock_v3(session,  in ndmpd_data_connect_v4()
965 		reply.error = NDMP_ILLEGAL_ARGS_ERR;  in ndmpd_data_connect_v4()
970 	if (reply.error == NDMP_NO_ERR)  in ndmpd_data_connect_v4()
973 	ndmp_send_reply(connection, &reply,  in ndmpd_data_connect_v4()
994 	ndmp_data_listen_reply_v4 reply;  in ndmpd_data_listen_v4()  local
1001 	(void) memset((void*)&reply, 0, sizeof (reply));  in ndmpd_data_listen_v4()
1004 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_listen_v4()
1008 		reply.error = NDMP_ILLEGAL_STATE_ERR;  in ndmpd_data_listen_v4()
1012 		reply.error = NDMP_NO_ERR;  in ndmpd_data_listen_v4()
1015 	if (reply.error != NDMP_NO_ERR) {  in ndmpd_data_listen_v4()
1016 		ndmp_send_reply(connection, &reply,  in ndmpd_data_listen_v4()
1023 		reply.connect_addr.addr_type = request->addr_type;  in ndmpd_data_listen_v4()
1028 			reply.error = NDMP_IO_ERR;  in ndmpd_data_listen_v4()
1032 		reply.error = NDMP_NO_ERR;  in ndmpd_data_listen_v4()
1033 		reply.connect_addr.addr_type = request->addr_type;  in ndmpd_data_listen_v4()
1034 		reply.connect_addr.tcp_addr_v4 =  in ndmpd_data_listen_v4()
1037 		reply.connect_addr.tcp_ip_v4(0) = htonl(addr);  in ndmpd_data_listen_v4()
1038 		reply.connect_addr.tcp_port_v4(0) = htons(port);  in ndmpd_data_listen_v4()
1039 		reply.connect_addr.tcp_len_v4 = 1;  in ndmpd_data_listen_v4()
1060 		reply.error = NDMP_ILLEGAL_ARGS_ERR;  in ndmpd_data_listen_v4()
1064 	if (reply.error == NDMP_NO_ERR)  in ndmpd_data_listen_v4()
1067 	ndmp_send_reply(connection, &reply,  in ndmpd_data_listen_v4()
1089 	ndmp_data_start_recover_filehist_reply_v4 reply;  in ndmpd_data_start_recover_filehist_v4()  local
1092 	reply.error = NDMP_NOT_SUPPORTED_ERR;  in ndmpd_data_start_recover_filehist_v4()
1094 	ndmp_send_reply(connection, &reply,  in ndmpd_data_start_recover_filehist_v4()
1385 	ndmp_data_start_backup_reply_v3 reply;  in ndmpd_tar_start_backup_v3()  local
1387 	(void) memset((void*)&reply, 0, sizeof (reply));  in ndmpd_tar_start_backup_v3()
1453 	reply.error = ndmp_backup_get_params_v3(session, params);  in ndmpd_tar_start_backup_v3()
1454 	if (reply.error != NDMP_NO_ERR) {  in ndmpd_tar_start_backup_v3()
1457 		return (reply.error);  in ndmpd_tar_start_backup_v3()
1460 	reply.error = NDMP_NO_ERR;  in ndmpd_tar_start_backup_v3()
1462 	    &reply) < 0) {  in ndmpd_tar_start_backup_v3()
1511 	ndmp_data_start_recover_reply_v3 reply;  in ndmpd_tar_start_recover_v3()  local
1516 	(void) memset((void*)&reply, 0, sizeof (reply));  in ndmpd_tar_start_recover_v3()
1525 	reply.error = ndmpd_save_env(session, env_val, env_len);  in ndmpd_tar_start_recover_v3()
1526 	if (reply.error != NDMP_NO_ERR) {  in ndmpd_tar_start_recover_v3()
1531 	reply.error = ndmpd_save_nlist_v3(session, nlist_val, nlist_len);  in ndmpd_tar_start_recover_v3()
1532 	if (reply.error != NDMP_NO_ERR) {  in ndmpd_tar_start_recover_v3()
1585 	reply.error = NDMP_NO_ERR;  in ndmpd_tar_start_recover_v3()
1587 	    &reply) < 0) {  in ndmpd_tar_start_recover_v3()
1627 	void *reply;  in ndmpd_zfs_start_op()  local
1688 		reply = &backup_reply;  in ndmpd_zfs_start_op()
1692 		reply = &recover_reply;  in ndmpd_zfs_start_op()
1696 	    reply) < 0) {  in ndmpd_zfs_start_op()
2077 	ndmp_data_start_backup_reply reply;  in ndmpd_tar_start_backup_v2()  local
2170 	reply.error = NDMP_NO_ERR;  in ndmpd_tar_start_backup_v2()
2172 	    &reply) < 0) {  in ndmpd_tar_start_backup_v2()
2226 	ndmp_data_start_recover_reply_v2 reply;  in ndmpd_tar_start_recover_v2()  local
2243 	reply.error = ndmpd_save_env(session, env_val, env_len);  in ndmpd_tar_start_recover_v2()
2244 	if (reply.error != NDMP_NO_ERR)  in ndmpd_tar_start_recover_v2()
2247 	reply.error = ndmpd_save_nlist_v2(session, nlist_val, nlist_len);  in ndmpd_tar_start_recover_v2()
2248 	if (reply.error != NDMP_NO_ERR)  in ndmpd_tar_start_recover_v2()
2305 	reply.error = NDMP_NO_ERR;  in ndmpd_tar_start_recover_v2()
2307 	    &reply) < 0) {  in ndmpd_tar_start_recover_v2()