root/lang/cplusplus/llv8call/branches/subprocess/ext/subprocess/subprocess.cc @ 21653

#include <v8.h>
#include <cassert>
#include <cstring>
#include <cstdio>
#include <errno.h>
#include <string>
#include <sstream>
#include "v8ext.h"
#include <llv8-macros.h>
#include <signal.h>

using namespace v8;

#define EXTERNAL_pid() pid_t pid = (pid_t) args.This()->GetInternalField(0)->Int32Value()

static inline Handle<Value> throw_stderr(const char *msg) {
    std::string buf(msg);
    buf += " error: ";
    buf += strerror(errno);
    return ThrowException(String::New(buf.c_str()));
}

/////////////////////////////////////////////////////////////
// methods
//

FUNCTION(_open)
    ARG_BETWEEN(1, 2);
    Handle<Array> ary = Handle<Array>::Cast( args[0] );
    assert(ary->Length() >= 1);

    pid_t pid = fork();
    if (pid > 0) {
        // parent
        return args.This();
    } else if (pid == 0) {
        // child
        String::Utf8Value file(ary->Get(Int32::New(0))->ToString());
        char ** argv = new char*[args.Length()];
        int i;
        for (i=1; i<args.Length(); i++) {
            String::Utf8Value buf(ary->Get(Int32::New(i)));
            char *bbuf = new char [strlen(*buf)];
            strcmp(bbuf, *buf);
            argv[i-1] = bbuf;
        }
        argv[i] = NULL;
        int ret = execvp(*file, argv);
        if (ret == -1) {
            return throw_stderr("new SubProcess");
        }
        assert(!"SHOULD NOT REACHE HERE");
    } else {
        // error
        return throw_stderr("new SubProcess");
    }
END

FUNCTION(_kill)
    ARG_COUNT(0);
    EXTERNAL_pid();
    kill(pid, SIGKILL);
    return Undefined();
END

/////////////////////////////////////////////////////////////
// initialize

MODULE()
    {
        CLASS_WITH_CONSTRUCTOR(_open);
        BIND_IM("kill",      _kill);
        INTERNALCOUNT(1);
        EXPORT_CLASS("SubProcess");
    }
ENDMODULE