Lines Matching refs:reply
100 ndmp_data_get_state_reply_v2 reply; in ndmpd_data_get_state_v2() local
103 reply.error = NDMP_NO_ERR; in ndmpd_data_get_state_v2()
104 reply.operation = session->ns_data.dd_operation; in ndmpd_data_get_state_v2()
105 reply.state = session->ns_data.dd_state; in ndmpd_data_get_state_v2()
106 reply.halt_reason = session->ns_data.dd_halt_reason; in ndmpd_data_get_state_v2()
108 reply.est_time_remain = in ndmpd_data_get_state_v2()
110 reply.est_bytes_remain = in ndmpd_data_get_state_v2()
114 reply.bytes_processed = in ndmpd_data_get_state_v2()
117 reply.mover = session->ns_data.dd_mover; in ndmpd_data_get_state_v2()
118 reply.read_offset = long_long_to_quad(session->ns_data.dd_read_offset); in ndmpd_data_get_state_v2()
119 reply.read_length = long_long_to_quad(session->ns_data.dd_read_length); in ndmpd_data_get_state_v2()
121 ndmp_send_reply(connection, &reply, in ndmpd_data_get_state_v2()
142 ndmp_data_start_backup_reply_v2 reply; in ndmpd_data_start_backup_v2() local
148 reply.error = NDMP_NO_ERR; in ndmpd_data_start_backup_v2()
160 reply.error = err; in ndmpd_data_start_backup_v2()
161 ndmp_send_reply(connection, &reply, in ndmpd_data_start_backup_v2()
183 ndmp_data_start_recover_reply_v2 reply; in ndmpd_data_start_recover_v2() local
199 reply.error = err; in ndmpd_data_start_recover_v2()
200 ndmp_send_reply(connection, &reply, in ndmpd_data_start_recover_v2()
224 ndmp_data_get_env_reply reply; in ndmpd_data_get_env_v2() local
227 (void) memset((void*)&reply, 0, sizeof (reply)); in ndmpd_data_get_env_v2()
230 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_get_env_v2()
231 reply.env.env_len = 0; in ndmpd_data_get_env_v2()
233 reply.error = NDMP_NO_ERR; in ndmpd_data_get_env_v2()
234 reply.env.env_len = session->ns_data.dd_env_len; in ndmpd_data_get_env_v2()
235 reply.env.env_val = session->ns_data.dd_env; in ndmpd_data_get_env_v2()
238 ndmp_send_reply(connection, &reply, "sending data_get_env reply"); in ndmpd_data_get_env_v2()
258 ndmp_data_stop_reply reply; in ndmpd_data_stop_v2() local
263 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_stop_v2()
264 ndmp_send_reply(connection, &reply, in ndmpd_data_stop_v2()
278 reply.error = NDMP_NO_ERR; in ndmpd_data_stop_v2()
279 ndmp_send_reply(connection, &reply, "sending data_stop reply"); in ndmpd_data_stop_v2()
301 ndmp_data_abort_reply reply; in ndmpd_data_abort_v2() local
307 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_abort_v2()
308 ndmp_send_reply(connection, &reply, in ndmpd_data_abort_v2()
321 reply.error = NDMP_NO_ERR; in ndmpd_data_abort_v2()
322 ndmp_send_reply(connection, &reply, "sending data_abort reply"); in ndmpd_data_abort_v2()
347 ndmp_data_get_state_reply_v3 reply; in ndmpd_data_get_state_v3() local
350 (void) memset((void*)&reply, 0, sizeof (reply)); in ndmpd_data_get_state_v3()
352 reply.error = NDMP_NO_ERR; in ndmpd_data_get_state_v3()
353 reply.invalid = NDMP_DATA_STATE_EST_BYTES_REMAIN_INVALID in ndmpd_data_get_state_v3()
355 reply.operation = session->ns_data.dd_operation; in ndmpd_data_get_state_v3()
356 reply.state = session->ns_data.dd_state; in ndmpd_data_get_state_v3()
357 reply.halt_reason = session->ns_data.dd_halt_reason; in ndmpd_data_get_state_v3()
359 if (reply.operation == NDMP_DATA_OP_BACKUP) in ndmpd_data_get_state_v3()
360 reply.bytes_processed = in ndmpd_data_get_state_v3()
364 reply.bytes_processed = in ndmpd_data_get_state_v3()
367 reply.est_bytes_remain = long_long_to_quad(0LL); in ndmpd_data_get_state_v3()
368 reply.est_time_remain = 0; in ndmpd_data_get_state_v3()
370 ndmp_copy_addr_v3(&reply.data_connection_addr, in ndmpd_data_get_state_v3()
372 reply.read_offset = long_long_to_quad(session->ns_data.dd_read_offset); in ndmpd_data_get_state_v3()
373 reply.read_length = long_long_to_quad(session->ns_data.dd_read_length); in ndmpd_data_get_state_v3()
375 ndmp_send_reply(connection, &reply, in ndmpd_data_get_state_v3()
396 ndmp_data_start_backup_reply_v3 reply; in ndmpd_data_start_backup_v3() local
401 (void) memset((void*)&reply, 0, sizeof (reply)); in ndmpd_data_start_backup_v3()
408 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_start_backup_v3()
415 reply.error = NDMP_WRITE_PROTECT_ERR; in ndmpd_data_start_backup_v3()
442 reply.error = NDMP_ILLEGAL_ARGS_ERR; in ndmpd_data_start_backup_v3()
447 reply.error = ndmpd_zfs_start_op(session, request->env.env_val, in ndmpd_data_start_backup_v3()
450 reply.error = ndmpd_tar_start_backup_v3(session, in ndmpd_data_start_backup_v3()
463 if (reply.error != NDMP_NO_ERR) { in ndmpd_data_start_backup_v3()
464 ndmp_send_reply(connection, &reply, in ndmpd_data_start_backup_v3()
486 ndmp_data_start_recover_reply_v3 reply; in ndmpd_data_start_recover_v3() local
491 (void) memset((void*)&reply, 0, sizeof (reply)); in ndmpd_data_start_recover_v3()
495 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_start_recover_v3()
521 reply.error = NDMP_ILLEGAL_ARGS_ERR; in ndmpd_data_start_recover_v3()
526 reply.error = ndmpd_zfs_start_op(session, request->env.env_val, in ndmpd_data_start_recover_v3()
530 reply.error = ndmpd_tar_start_recover_v3(session, in ndmpd_data_start_recover_v3()
543 if (reply.error != NDMP_NO_ERR) { in ndmpd_data_start_recover_v3()
544 ndmp_send_reply(connection, &reply, in ndmpd_data_start_recover_v3()
569 ndmp_data_abort_reply reply; in ndmpd_data_abort_v3() local
574 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_abort_v3()
584 reply.error = NDMP_NO_ERR; in ndmpd_data_abort_v3()
594 reply.error = NDMP_NO_ERR; in ndmpd_data_abort_v3()
599 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_abort_v3()
604 ndmp_send_reply(connection, &reply, in ndmpd_data_abort_v3()
625 ndmp_data_stop_reply reply; in ndmpd_data_stop_v3() local
630 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_stop_v3()
631 ndmp_send_reply(connection, &reply, in ndmpd_data_stop_v3()
643 reply.error = NDMP_NO_ERR; in ndmpd_data_stop_v3()
644 ndmp_send_reply(connection, &reply, in ndmpd_data_stop_v3()
666 ndmp_data_listen_reply_v3 reply; in ndmpd_data_listen_v3() local
673 (void) memset((void*)&reply, 0, sizeof (reply)); in ndmpd_data_listen_v3()
676 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_listen_v3()
680 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_listen_v3()
684 reply.error = NDMP_NO_ERR; in ndmpd_data_listen_v3()
687 if (reply.error != NDMP_NO_ERR) { in ndmpd_data_listen_v3()
688 ndmp_send_reply(connection, &reply, in ndmpd_data_listen_v3()
695 reply.data_connection_addr.addr_type = request->addr_type; in ndmpd_data_listen_v3()
700 reply.error = NDMP_IO_ERR; in ndmpd_data_listen_v3()
704 reply.error = NDMP_NO_ERR; in ndmpd_data_listen_v3()
705 reply.data_connection_addr.addr_type = request->addr_type; in ndmpd_data_listen_v3()
706 reply.data_connection_addr.tcp_ip_v3 = htonl(addr); in ndmpd_data_listen_v3()
707 reply.data_connection_addr.tcp_port_v3 = htons(port); in ndmpd_data_listen_v3()
718 reply.error = NDMP_ILLEGAL_ARGS_ERR; in ndmpd_data_listen_v3()
722 if (reply.error == NDMP_NO_ERR) in ndmpd_data_listen_v3()
725 ndmp_send_reply(connection, &reply, in ndmpd_data_listen_v3()
747 ndmp_data_connect_reply_v3 reply; in ndmpd_data_connect_v3() local
752 (void) memset((void*)&reply, 0, sizeof (reply)); in ndmpd_data_connect_v3()
755 reply.error = NDMP_ILLEGAL_ARGS_ERR; in ndmpd_data_connect_v3()
759 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_connect_v3()
762 reply.error = NDMP_NO_ERR; in ndmpd_data_connect_v3()
765 if (reply.error != NDMP_NO_ERR) { in ndmpd_data_connect_v3()
766 ndmp_send_reply(connection, &reply, in ndmpd_data_connect_v3()
779 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_connect_v3()
788 reply.error = data_connect_sock_v3(session, in ndmpd_data_connect_v3()
793 reply.error = NDMP_ILLEGAL_ARGS_ERR; in ndmpd_data_connect_v3()
798 if (reply.error == NDMP_NO_ERR) in ndmpd_data_connect_v3()
801 ndmp_send_reply(connection, &reply, in ndmpd_data_connect_v3()
830 ndmp_data_get_env_reply reply; in ndmpd_data_get_env_v4() local
833 (void) memset((void*)&reply, 0, sizeof (reply)); in ndmpd_data_get_env_v4()
838 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_get_env_v4()
839 reply.env.env_len = 0; in ndmpd_data_get_env_v4()
842 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_get_env_v4()
843 reply.env.env_len = 0; in ndmpd_data_get_env_v4()
845 reply.error = NDMP_NO_ERR; in ndmpd_data_get_env_v4()
846 reply.env.env_len = session->ns_data.dd_env_len; in ndmpd_data_get_env_v4()
847 reply.env.env_val = session->ns_data.dd_env; in ndmpd_data_get_env_v4()
850 ndmp_send_reply(connection, &reply, "sending data_get_env reply"); in ndmpd_data_get_env_v4()
869 ndmp_data_get_state_reply_v4 reply; in ndmpd_data_get_state_v4() local
872 (void) memset((void*)&reply, 0, sizeof (reply)); in ndmpd_data_get_state_v4()
874 reply.error = NDMP_NO_ERR; in ndmpd_data_get_state_v4()
875 reply.unsupported = NDMP_DATA_STATE_EST_BYTES_REMAIN_INVALID in ndmpd_data_get_state_v4()
877 reply.operation = session->ns_data.dd_operation; in ndmpd_data_get_state_v4()
878 reply.state = session->ns_data.dd_state; in ndmpd_data_get_state_v4()
879 reply.halt_reason = session->ns_data.dd_halt_reason; in ndmpd_data_get_state_v4()
881 if (reply.operation == NDMP_DATA_OP_BACKUP) in ndmpd_data_get_state_v4()
882 reply.bytes_processed = long_long_to_quad( in ndmpd_data_get_state_v4()
885 reply.bytes_processed = in ndmpd_data_get_state_v4()
888 reply.est_bytes_remain = long_long_to_quad(0LL); in ndmpd_data_get_state_v4()
889 reply.est_time_remain = 0; in ndmpd_data_get_state_v4()
891 ndmp_copy_addr_v4(&reply.data_connection_addr, in ndmpd_data_get_state_v4()
894 reply.read_offset = long_long_to_quad(session->ns_data.dd_read_offset); in ndmpd_data_get_state_v4()
895 reply.read_length = long_long_to_quad(session->ns_data.dd_read_length); in ndmpd_data_get_state_v4()
897 ndmp_send_reply(connection, &reply, in ndmpd_data_get_state_v4()
899 free(reply.data_connection_addr.tcp_addr_v4); in ndmpd_data_get_state_v4()
920 ndmp_data_connect_reply_v4 reply; in ndmpd_data_connect_v4() local
925 (void) memset((void*)&reply, 0, sizeof (reply)); in ndmpd_data_connect_v4()
928 reply.error = NDMP_ILLEGAL_ARGS_ERR; in ndmpd_data_connect_v4()
932 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_connect_v4()
935 reply.error = NDMP_NO_ERR; in ndmpd_data_connect_v4()
938 if (reply.error != NDMP_NO_ERR) { in ndmpd_data_connect_v4()
939 ndmp_send_reply(connection, &reply, in ndmpd_data_connect_v4()
952 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_connect_v4()
961 reply.error = data_connect_sock_v3(session, in ndmpd_data_connect_v4()
966 reply.error = NDMP_ILLEGAL_ARGS_ERR; in ndmpd_data_connect_v4()
971 if (reply.error == NDMP_NO_ERR) in ndmpd_data_connect_v4()
974 ndmp_send_reply(connection, &reply, in ndmpd_data_connect_v4()
995 ndmp_data_listen_reply_v4 reply; in ndmpd_data_listen_v4() local
1002 (void) memset((void*)&reply, 0, sizeof (reply)); in ndmpd_data_listen_v4()
1005 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_listen_v4()
1009 reply.error = NDMP_ILLEGAL_STATE_ERR; in ndmpd_data_listen_v4()
1013 reply.error = NDMP_NO_ERR; in ndmpd_data_listen_v4()
1016 if (reply.error != NDMP_NO_ERR) { in ndmpd_data_listen_v4()
1017 ndmp_send_reply(connection, &reply, in ndmpd_data_listen_v4()
1024 reply.connect_addr.addr_type = request->addr_type; in ndmpd_data_listen_v4()
1029 reply.error = NDMP_IO_ERR; in ndmpd_data_listen_v4()
1033 reply.error = NDMP_NO_ERR; in ndmpd_data_listen_v4()
1034 reply.connect_addr.addr_type = request->addr_type; in ndmpd_data_listen_v4()
1035 reply.connect_addr.tcp_addr_v4 = in ndmpd_data_listen_v4()
1038 reply.connect_addr.tcp_ip_v4(0) = htonl(addr); in ndmpd_data_listen_v4()
1039 reply.connect_addr.tcp_port_v4(0) = htons(port); in ndmpd_data_listen_v4()
1040 reply.connect_addr.tcp_len_v4 = 1; in ndmpd_data_listen_v4()
1061 reply.error = NDMP_ILLEGAL_ARGS_ERR; in ndmpd_data_listen_v4()
1065 if (reply.error == NDMP_NO_ERR) in ndmpd_data_listen_v4()
1068 ndmp_send_reply(connection, &reply, in ndmpd_data_listen_v4()
1090 ndmp_data_start_recover_filehist_reply_v4 reply; in ndmpd_data_start_recover_filehist_v4() local
1093 reply.error = NDMP_NOT_SUPPORTED_ERR; in ndmpd_data_start_recover_filehist_v4()
1095 ndmp_send_reply(connection, &reply, in ndmpd_data_start_recover_filehist_v4()
1375 ndmp_data_start_backup_reply_v3 reply; in ndmpd_tar_start_backup_v3() local
1377 (void) memset((void*)&reply, 0, sizeof (reply)); in ndmpd_tar_start_backup_v3()
1443 reply.error = ndmp_backup_get_params_v3(session, params); in ndmpd_tar_start_backup_v3()
1444 if (reply.error != NDMP_NO_ERR) { in ndmpd_tar_start_backup_v3()
1447 return (reply.error); in ndmpd_tar_start_backup_v3()
1450 reply.error = NDMP_NO_ERR; in ndmpd_tar_start_backup_v3()
1452 &reply) < 0) { in ndmpd_tar_start_backup_v3()
1501 ndmp_data_start_recover_reply_v3 reply; in ndmpd_tar_start_recover_v3() local
1506 (void) memset((void*)&reply, 0, sizeof (reply)); in ndmpd_tar_start_recover_v3()
1515 reply.error = ndmpd_save_env(session, env_val, env_len); in ndmpd_tar_start_recover_v3()
1516 if (reply.error != NDMP_NO_ERR) { in ndmpd_tar_start_recover_v3()
1521 reply.error = ndmpd_save_nlist_v3(session, nlist_val, nlist_len); in ndmpd_tar_start_recover_v3()
1522 if (reply.error != NDMP_NO_ERR) { in ndmpd_tar_start_recover_v3()
1575 reply.error = NDMP_NO_ERR; in ndmpd_tar_start_recover_v3()
1577 &reply) < 0) { in ndmpd_tar_start_recover_v3()
1617 void *reply; in ndmpd_zfs_start_op() local
1678 reply = &backup_reply; in ndmpd_zfs_start_op()
1682 reply = &recover_reply; in ndmpd_zfs_start_op()
1686 reply) < 0) { in ndmpd_zfs_start_op()
2068 ndmp_data_start_backup_reply reply; in ndmpd_tar_start_backup_v2() local
2161 reply.error = NDMP_NO_ERR; in ndmpd_tar_start_backup_v2()
2163 &reply) < 0) { in ndmpd_tar_start_backup_v2()
2217 ndmp_data_start_recover_reply_v2 reply; in ndmpd_tar_start_recover_v2() local
2234 reply.error = ndmpd_save_env(session, env_val, env_len); in ndmpd_tar_start_recover_v2()
2235 if (reply.error != NDMP_NO_ERR) in ndmpd_tar_start_recover_v2()
2238 reply.error = ndmpd_save_nlist_v2(session, nlist_val, nlist_len); in ndmpd_tar_start_recover_v2()
2239 if (reply.error != NDMP_NO_ERR) in ndmpd_tar_start_recover_v2()
2296 reply.error = NDMP_NO_ERR; in ndmpd_tar_start_recover_v2()
2298 &reply) < 0) { in ndmpd_tar_start_recover_v2()