1

我的代码尝试通过 C++ 模拟 R shell，它允许用户通过 tcp 连接发送 R 命令，然后在运行时通过 RInside::parseEvalQ 函数将这些命令传递给 R 实例。我必须能够处理格式错误的命令。每当一个错误的命令作为 parseEvalQ 的参数给出时，我就会捕获抛出的运行时错误（查看 RInside.cpp，我的特定错误在 parseEval(const string&, SEXP) 函数中被标记为 'PARSE_ERROR' 'status'），what()给出“St9exception”异常。

我有两个问题，第一个比第二个更紧迫：

1个。在初始解析错误之后，任何对 parseEvalQ 的后续调用都会导致另一个解析错误，即使参数有效也是如此。解析错误是否以某种方式破坏了嵌入式 R 实例？

1b。RInside 文档建议使用 Rcpp::Evaluator::run 处理 C++ 中的 R 异常（我怀疑在调用 parseEval(const string&, SEXP) 期间在 R 实例中的某个地方抛出异常，然后它返回错误状态 'PARSE_ERROR '）。我尝试过尝试使用它，但在网上找不到如何实际使用 Rcpp::Evaluator::run 的示例。

2. 在我的程序中，我将 stdout 和 stderr（在 C++ 级别）重新路由到我的 tcp 连接的文件描述符，来自 RInside 实例的任何错误消息都会发送到控制台，但是常规输出不会。我发送 RInside 命令 'sink(stderr(), type="output")' 以将 stdout 重新路由到 stderr（因为 stderr 似乎出现在我的控制台中），但仍然没有显示常规输出。'print(command)' 有效，但我想要一种更简洁的方式将标准输出直接传递到控制台，就像在普通的 R shell 中一样。

任何帮助和/或想法将不胜感激。我的代码的精简版本如下所示：

～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～ ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

using namespace std;

string request_cpp;

ostringstream oss;

int read(FILE* tcp_fd)  
{
  /* function to read input from FILE* into the 'request_cpp' string */
}  

int write(FILE* tcp_fd, const string& response)  
{
  /* function to write a string to FILE* */
}

int main(int argc, char* argv[])  
{
  // create RInside object
  RInside R(argc,argv);

  //socket  
  int sd = socket(PF_INET, SOCK_STREAM, 0);  
  addr.sin_family = AF_INET;  
  addr.sin_port = htons(40650);

  // set and accept connection on socket  
  inet_pton(AF_INET, "127.0.0.1", &addr.sin_addr);  
  bind(sd,(struct sockaddr*)&addr, sizeof(addr));  
  listen(sd,1);  
  int sd_i = accept(sd, 0, 0);  

  //re-route stdout and stderr to socket  
  close(1);  
  dup(sd_i);  
  close(2);  
  dup(sd_i);  

  // open read/write file descriptor to socket

  FILE* fp = fdopen(sd_i,"r+");  

  // emulate R prompt  

  write(fp,"> ");  

  // (attempt to) redirect R's stdout to stderr
  R.parseEvalQ("sink(stderr(),type=\"output\");");

  // read from socket and pass commands to RInside  
  while( read(fp) )  
  {
    try  
    {
      // skip empty input  
      if(request_cpp == "")  
      {  
        write(fp, "> ");  
        continue;  
      }
      else if(request_cpp == "q()")  
      {  
        break;
      }  
      else  
      {  
        // clear string stream  
        oss.str("");  

        // wrap command in try  
        oss << "try(" << request_cpp << ");" << endl;  

        // send command  
        R.parseEvalQ(oss.str());  
      }  
    }  
    catch(exception e)  
    {  
      // print exception to console  
      write(fp, e.what());  
    }    
 write(fp, "> ");
 }

fclose(fp);  
close(sd_i);  
exit(0);  
}
4

1 回答 1

1

我错过了这几周，因为你没有使用“r”标签。

似乎您正在重新实现 Simon 的受信任rserver。为什么不直接使用呢？

否则，对于 Rcpp 问题，请考虑在我们的 rcpp-devel 列表中提问。

于 2011-05-03T02:48:40.763 回答