Lines Matching full:ri
173 zcp_run_info_t *ri = zcp_run_info(state); in zcp_register_cleanup() local
178 list_insert_head(&ri->zri_cleanup_handlers, zch); in zcp_register_cleanup()
186 zcp_run_info_t *ri = zcp_run_info(state); in zcp_deregister_cleanup() local
187 list_remove(&ri->zri_cleanup_handlers, zch); in zcp_deregister_cleanup()
198 zcp_run_info_t *ri = zcp_run_info(state); in zcp_cleanup() local
201 list_remove_head(&ri->zri_cleanup_handlers); zch != NULL; in zcp_cleanup()
202 zch = list_remove_head(&ri->zri_cleanup_handlers)) { in zcp_cleanup()
651 zcp_run_info_t *ri = zcp_run_info(state); in zcp_debug() local
658 zfs_dbgmsg("txg %lld ZCP: %s", (longlong_t)ri->zri_tx->tx_txg, in zcp_debug()
680 zcp_run_info_t *ri = zcp_run_info(state); in zcp_exists() local
681 dsl_pool_t *dp = ri->zri_pool; in zcp_exists()
778 zcp_run_info_t *ri = lua_touserdata(state, -1); in zcp_lua_counthook() local
784 if (ri->zri_canceled || (!ri->zri_sync && issig())) { in zcp_lua_counthook()
785 ri->zri_canceled = B_TRUE; in zcp_lua_counthook()
795 ri->zri_curinstrs += zfs_lua_check_instrlimit_interval; in zcp_lua_counthook()
796 if (ri->zri_maxinstrs != 0 && ri->zri_curinstrs > ri->zri_maxinstrs) { in zcp_lua_counthook()
797 ri->zri_timed_out = B_TRUE; in zcp_lua_counthook()
814 zcp_eval_impl(dmu_tx_t *tx, zcp_run_info_t *ri) in zcp_eval_impl() argument
817 lua_State *state = ri->zri_state; in zcp_eval_impl()
822 ri->zri_pool = dmu_tx_pool(tx); in zcp_eval_impl()
823 ri->zri_tx = tx; in zcp_eval_impl()
824 list_create(&ri->zri_cleanup_handlers, sizeof (zcp_cleanup_handler_t), in zcp_eval_impl()
832 lua_pushlightuserdata(state, ri); in zcp_eval_impl()
849 ri->zri_allocargs->aa_must_succeed = B_FALSE; in zcp_eval_impl()
861 ri->zri_allocargs->aa_must_succeed = B_TRUE; in zcp_eval_impl()
868 list_destroy(&ri->zri_cleanup_handlers); in zcp_eval_impl()
888 ri->zri_result = 0; in zcp_eval_impl()
889 zcp_convert_return_values(state, ri->zri_outnvl, in zcp_eval_impl()
890 ZCP_RET_RETURN, &ri->zri_result); in zcp_eval_impl()
892 ri->zri_result = SET_ERROR(ECHRNG); in zcp_eval_impl()
896 zcp_convert_return_values(state, ri->zri_outnvl, in zcp_eval_impl()
897 ZCP_RET_ERROR, &ri->zri_result); in zcp_eval_impl()
911 if (ri->zri_timed_out) { in zcp_eval_impl()
912 ri->zri_result = SET_ERROR(ETIME); in zcp_eval_impl()
913 } else if (ri->zri_canceled) { in zcp_eval_impl()
914 ri->zri_result = SET_ERROR(EINTR); in zcp_eval_impl()
916 ri->zri_result = SET_ERROR(ECHRNG); in zcp_eval_impl()
919 zcp_convert_return_values(state, ri->zri_outnvl, in zcp_eval_impl()
920 ZCP_RET_ERROR, &ri->zri_result); in zcp_eval_impl()
922 if (ri->zri_result == ETIME && ri->zri_outnvl != NULL) { in zcp_eval_impl()
923 (void) nvlist_add_uint64(ri->zri_outnvl, in zcp_eval_impl()
924 ZCP_ARG_INSTRLIMIT, ri->zri_curinstrs); in zcp_eval_impl()
936 if (ri->zri_timed_out) { in zcp_eval_impl()
937 ri->zri_result = SET_ERROR(ETIME); in zcp_eval_impl()
938 } else if (ri->zri_canceled) { in zcp_eval_impl()
939 ri->zri_result = SET_ERROR(EINTR); in zcp_eval_impl()
941 ri->zri_result = SET_ERROR(ECHRNG); in zcp_eval_impl()
944 zcp_convert_return_values(state, ri->zri_outnvl, in zcp_eval_impl()
945 ZCP_RET_ERROR, &ri->zri_result); in zcp_eval_impl()
953 ri->zri_result = SET_ERROR(ENOSPC); in zcp_eval_impl()
961 zcp_pool_error(zcp_run_info_t *ri, const char *poolname, int error) in zcp_pool_error() argument
963 ri->zri_result = SET_ERROR(ECHRNG); in zcp_pool_error()
964 lua_settop(ri->zri_state, 0); in zcp_pool_error()
965 (void) lua_pushfstring(ri->zri_state, "Could not open pool: %s " in zcp_pool_error()
967 zcp_convert_return_values(ri->zri_state, ri->zri_outnvl, in zcp_pool_error()
968 ZCP_RET_ERROR, &ri->zri_result); in zcp_pool_error()
981 zcp_run_info_t *ri = arg; in zcp_eval_sig() local
983 ri->zri_canceled = B_TRUE; in zcp_eval_sig()
989 zcp_run_info_t *ri = arg; in zcp_eval_sync() local
997 VERIFY3U(3, ==, lua_gettop(ri->zri_state)); in zcp_eval_sync()
999 zcp_eval_impl(tx, ri); in zcp_eval_sync()
1003 zcp_eval_open(zcp_run_info_t *ri, const char *poolname) in zcp_eval_open() argument
1012 VERIFY3U(3, ==, lua_gettop(ri->zri_state)); in zcp_eval_open()
1016 zcp_pool_error(ri, poolname, error); in zcp_eval_open()
1031 zcp_eval_impl(tx, ri); in zcp_eval_open()
1191 zcp_run_info_t *ri; in zcp_run_info() local
1194 ri = lua_touserdata(state, -1); in zcp_run_info()
1196 return (ri); in zcp_run_info()