* ev_ref -> uv_ref

* remove 0.2.x Buffer compatibility

src/async.h

@@ -30,14 +30,14 @@ public:
         rows.swap(async->data);
         pthread_mutex_unlock(&async->mutex);
         for (unsigned int i = 0, size = rows.size(); i < size; i++) {
-            ev_unref(EV_DEFAULT_UC);
+            uv_unref(uv_default_loop());
             async->callback(async->parent, rows[i]);
         }
     }
 
     inline void add(Item* item) {
         // Make sure node runs long enough to deliver the messages.
-        ev_ref(EV_DEFAULT_UC);
+        uv_ref(uv_default_loop());
         pthread_mutex_lock(&mutex);
         data.push_back(item);
         pthread_mutex_unlock(&mutex);

src/database.cc

@@ -657,7 +657,7 @@ void Database::Destruct(Persistent<Value> value, void *data) {
 
     if (db->handle) {
         eio_custom(EIO_Destruct, EIO_PRI_DEFAULT, EIO_AfterDestruct, db);
-        ev_ref(EV_DEFAULT_UC);
+        uv_ref(uv_default_loop());
     }
     else {
         delete db;
@@ -673,7 +673,7 @@ void Database::EIO_Destruct(eio_req *req) {
 
 int Database::EIO_AfterDestruct(eio_req *req) {
     Database* db = static_cast<Database*>(req->data);
-    ev_unref(EV_DEFAULT_UC);
+    uv_unref(uv_default_loop());
     delete db;
     return 0;
 }

src/database.h

@@ -38,12 +38,12 @@ public:
         Baton(Database* db_, Handle<Function> cb_) :
                 db(db_), status(SQLITE_OK) {
             db->Ref();
-            ev_ref(EV_DEFAULT_UC);
+            uv_ref(uv_default_loop());
             callback = Persistent<Function>::New(cb_);
         }
         virtual ~Baton() {
             db->Unref();
-            ev_unref(EV_DEFAULT_UC);
+            uv_unref(uv_default_loop());
             callback.Dispose();
         }
     };

src/statement.cc

@@ -2,7 +2,6 @@
 #include <v8.h>
 #include <node.h>
 #include <node_buffer.h>
-#include <node_version.h>
 
 #include "macros.h"
 #include "database.h"
@@ -185,13 +184,8 @@ template <class T> Values::Field*
         return new Values::Null(pos);
     }
     else if (Buffer::HasInstance(source)) {
-#if NODE_VERSION_AT_LEAST(0,3,0)
         Local<Object> buffer = source->ToObject();
         return new Values::Blob(pos, Buffer::Length(buffer), Buffer::Data(buffer));
-#else
-        Buffer* buffer = ObjectWrap::Unwrap<Buffer>(source->ToObject());
-        return new Values::Blob(pos, buffer->length(), buffer->data());
-#endif
     }
     else if (source->IsDate()) {
         return new Values::Float(pos, source->NumberValue());
@@ -774,12 +768,7 @@ Local<Object> Statement::RowToJS(Row* row) {
                 value = Local<Value>(String::New(((Values::Text*)field)->value.c_str(), ((Values::Text*)field)->value.size()));
             } break;
             case SQLITE_BLOB: {
-#if NODE_VERSION_AT_LEAST(0,3,0)
                 Buffer *buffer = Buffer::New(((Values::Blob*)field)->value, ((Values::Blob*)field)->length);
-#else
-                Buffer *buffer = Buffer::New(((Values::Blob*)field)->length);
-                memcpy(buffer->data(), ((Values::Blob*)field)->value, buffer->length());
-#endif
                 value = Local<Value>::New(buffer->handle_);
             } break;
             case SQLITE_NULL: {

src/statement.h

@@ -85,7 +85,7 @@ public:
 
         Baton(Statement* stmt_, Handle<Function> cb_) : stmt(stmt_) {
             stmt->Ref();
-            ev_ref(EV_DEFAULT_UC);
+            uv_ref(uv_default_loop());
             callback = Persistent<Function>::New(cb_);
         }
         virtual ~Baton() {
@@ -94,7 +94,7 @@ public:
                 DELETE_FIELD(field);
             }
             stmt->Unref();
-            ev_unref(EV_DEFAULT_UC);
+            uv_unref(uv_default_loop());
             callback.Dispose();
         }
     };