1 //=- RPCChannel.inc - LLVM out-of-process JIT execution for Unix --=//
3 // The LLVM Compiler Infrastructure
5 // This file is distributed under the University of Illinois Open Source
6 // License. See LICENSE.TXT for details.
8 //===----------------------------------------------------------------------===//
10 // Implementation of the Unix-specific parts of the RPCChannel class
11 // which executes JITed code in a separate process from where it was built.
13 //===----------------------------------------------------------------------===//
22 struct ConnectionData_t {
26 ConnectionData_t(int in, int out) : InputPipe(in), OutputPipe(out) {}
33 bool RPCChannel::createServer() {
38 if (pipe(PipeFD[0]) != 0 || pipe(PipeFD[1]) != 0)
39 perror("Error creating pipe: ");
46 // Close the parent ends of the pipes
50 // Use our pipes as stdin and stdout
51 if (PipeFD[0][0] != STDIN_FILENO) {
52 dup2(PipeFD[0][0], STDIN_FILENO);
55 if (PipeFD[1][1] != STDOUT_FILENO) {
56 dup2(PipeFD[1][1], STDOUT_FILENO);
60 // Execute the child process.
61 char *args[1] = { NULL };
62 int rc = execv(ChildName.c_str(), args);
64 perror("Error executing child process: ");
68 // Close the child ends of the pipes
72 // Store the parent ends of the pipes
73 ConnectionData = (void *)new ConnectionData_t(PipeFD[1][0], PipeFD[0][1]);
79 bool RPCChannel::createClient() {
80 // Store the parent ends of the pipes
81 ConnectionData = (void *)new ConnectionData_t(STDIN_FILENO, STDOUT_FILENO);
85 void RPCChannel::ReportError(int rc, size_t Size, std::string &ErrorMsg) {
88 ErrorMsg += "pipe closed";
89 else if (errno == EINTR)
90 ErrorMsg += "interrupted";
92 ErrorMsg += "file descriptor error";
94 char Number[10] = { 0 };
95 ErrorMsg += "Expecting ";
96 sprintf(Number, "%d", (uint32_t)Size);
98 ErrorMsg += " bytes, Got ";
99 sprintf(Number, "%d", rc);
104 int RPCChannel::WriteBytes(const void *Data, size_t Size) {
105 return write(((ConnectionData_t *)ConnectionData)->OutputPipe, Data, Size);
108 int RPCChannel::ReadBytes(void *Data, size_t Size) {
109 return read(((ConnectionData_t *)ConnectionData)->InputPipe, Data, Size);
112 void RPCChannel::Wait() { wait(NULL); }
114 RPCChannel::~RPCChannel() {
115 delete static_cast<ConnectionData_t *>(ConnectionData);