Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Tree: a73998d6f4
Fetching contributors…

Cannot retrieve contributors at this time

181 lines (139 sloc) 4.88 kB
#ifndef node_net_h
#define node_net_h
#include "node.h"
#include "events.h"
#include <v8.h>
#include <evcom.h>
#include <string.h>
namespace node {
class Server;
class Connection : public EventEmitter {
public:
static void Initialize (v8::Handle<v8::Object> target);
protected:
/* v8 interface */
static v8::Persistent<v8::FunctionTemplate> constructor_template;
static v8::Handle<v8::Value> New (const v8::Arguments& args);
static v8::Handle<v8::Value> Connect (const v8::Arguments& args);
static v8::Handle<v8::Value> Send (const v8::Arguments& args);
static v8::Handle<v8::Value> SendUtf8 (const v8::Arguments& args);
static v8::Handle<v8::Value> Close (const v8::Arguments& args);
static v8::Handle<v8::Value> ForceClose (const v8::Arguments& args);
static v8::Handle<v8::Value> SetEncoding (const v8::Arguments& args);
static v8::Handle<v8::Value> ReadPause (const v8::Arguments& args);
static v8::Handle<v8::Value> ReadResume (const v8::Arguments& args);
static v8::Handle<v8::Value> ReadyStateGetter (v8::Local<v8::String> _,
const v8::AccessorInfo& info);
Connection (void) : EventEmitter()
{
encoding_ = RAW;
host_ = NULL;
port_ = NULL;
Init();
}
virtual ~Connection (void);
int Connect (struct sockaddr *address) {
return evcom_stream_connect (&stream_, address);
}
void Send (const char *buf, size_t len) { evcom_stream_write(&stream_, buf, len); }
void Close (void) { evcom_stream_close(&stream_); }
void ForceClose (void) { evcom_stream_force_close(&stream_); }
void ReadPause (void) { evcom_stream_read_pause(&stream_); }
void ReadResume (void) { evcom_stream_read_resume(&stream_); }
virtual void OnConnect (void);
virtual void OnReceive (const void *buf, size_t len);
virtual void OnEOF (void);
virtual void OnClose (void);
virtual void OnTimeout (void);
v8::Local<v8::Object> GetProtocol (void);
enum evcom_stream_state ReadyState ( ) {
return evcom_stream_state(&stream_);
}
enum encoding encoding_;
bool resolving_;
private:
/* liboi callbacks */
static void on_connect (evcom_stream *s) {
Connection *connection = static_cast<Connection*> (s->data);
connection->OnConnect();
}
static void on_read (evcom_stream *s, const void *buf, size_t len) {
Connection *connection = static_cast<Connection*> (s->data);
assert(connection->attached_);
if (len == 0)
connection->OnEOF();
else
connection->OnReceive(buf, len);
}
static void on_close (evcom_stream *s) {
Connection *connection = static_cast<Connection*> (s->data);
evcom_stream_detach(s);
assert(connection->stream_.recvfd < 0);
assert(connection->stream_.sendfd < 0);
connection->OnClose();
if (s->errorno) {
printf("socket died: %s\n", strerror(s->errorno));
}
assert(connection->attached_);
connection->Detach();
}
static void on_timeout (evcom_stream *s) {
Connection *connection = static_cast<Connection*> (s->data);
connection->OnTimeout();
}
void Init (void); // constructor helper.
static int Resolve (eio_req *req);
static int AfterResolve (eio_req *req);
char *host_;
char *port_;
evcom_stream stream_;
friend class Server;
};
class Server : public EventEmitter {
public:
static void Initialize (v8::Handle<v8::Object> target);
protected:
static v8::Persistent<v8::FunctionTemplate> constructor_template;
static v8::Handle<v8::Value> New (const v8::Arguments& args);
static v8::Handle<v8::Value> Listen (const v8::Arguments& args);
static v8::Handle<v8::Value> Close (const v8::Arguments& args);
Server (void) : EventEmitter()
{
evcom_server_init(&server_);
server_.on_connection = Server::on_connection;
server_.on_close = Server::on_close;
server_.data = this;
}
virtual ~Server () {
assert(server_.fd >= 0);
}
int Listen (struct sockaddr *address, int backlog) {
int r = evcom_server_listen (&server_, address, backlog);
if(r != 0) return r;
evcom_server_attach (EV_DEFAULT_ &server_);
Attach();
return 0;
}
void Close ( ) {
evcom_server_close (&server_);
}
virtual v8::Handle<v8::FunctionTemplate> GetConnectionTemplate (void);
virtual Connection* UnwrapConnection (v8::Local<v8::Object> connection);
private:
Connection* OnConnection (struct sockaddr *addr);
static evcom_stream* on_connection (evcom_server *s, struct sockaddr *addr) {
Server *server = static_cast<Server*> (s->data);
Connection *connection = server->OnConnection (addr);
return &connection->stream_;
}
void OnClose (int errorno);
static void on_close (evcom_server *s) {
Server *server = static_cast<Server*> (s->data);
evcom_server_detach(s);
server->OnClose(s->errorno);
server->Detach();
}
evcom_server server_;
};
} // namespace node
#endif
Jump to Line
Something went wrong with that request. Please try again.