1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
|
// Copyright (C) 2013 Romain Francois
//
// This file is part of Rcpp.
//
// Rcpp is free software: you can redistribute it and/or modify it
// under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 2 of the License, or
// (at your option) any later version.
//
// Rcpp is distributed in the hope that it will be useful, but
// WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with Rcpp. If not, see <http://www.gnu.org/licenses/>.
#ifndef Rcpp_api_meat_Rcpp_eval_h
#define Rcpp_api_meat_Rcpp_eval_h
#include <Rcpp/Interrupt.h>
namespace Rcpp {
inline SEXP Rcpp_eval(SEXP expr, SEXP env) {
// 'identity' function used to capture errors, interrupts
SEXP identity = Rf_findFun(
::Rf_install("identity"),
R_BaseNamespace
);
if (identity == R_UnboundValue) {
stop("Failed to find 'base::identity()'");
}
// define the evalq call -- the actual R evaluation we
// want to execute
Shield<SEXP> evalqCall(Rf_lang3(
::Rf_install("evalq"),
expr,
env
));
// define the call -- enclose with `tryCatch` so we can record
// and later forward error messages
Shield<SEXP> call(Rf_lang4(
::Rf_install("tryCatch"),
evalqCall,
identity,
identity
));
SET_TAG(CDDR(call), ::Rf_install("error"));
SET_TAG(CDDR(CDR(call)), ::Rf_install("interrupt"));
// execute the call
Shield<SEXP> res(::Rf_eval(call, R_GlobalEnv));
// check for condition results (errors, interrupts)
if (Rf_inherits(res, "condition")) {
if (Rf_inherits(res, "error")) {
Shield<SEXP> conditionMessageCall(::Rf_lang2(
::Rf_install("conditionMessage"),
res
));
Shield<SEXP> conditionMessage(::Rf_eval(conditionMessageCall, R_GlobalEnv));
throw eval_error(CHAR(STRING_ELT(conditionMessage, 0)));
}
// check for interrupt
if (Rf_inherits(res, "interrupt")) {
throw internal::InterruptedException();
}
}
return res;
}
} // namespace Rcpp
#endif
|
