/var/www/myprog.com.ua/server/node/node_modules/ws/src/
/var/www/myprog.com.ua/server/node/node_modules/ws/src
NameSizeModeActions
bufferutil.cc35100644editdlrm
validation.cc42280644editdlrm
Edit: /var/www/myprog.com.ua/server/node/node_modules/ws/src/bufferutil.cc (3510B)
/*! * ws: a node.js websocket client * Copyright(c) 2011 Einar Otto Stangvik * MIT Licensed */ #include #include #include #include #include #include #include #include #include "nan.h" using namespace v8; using namespace node; class BufferUtil : public ObjectWrap { public: static void Initialize(v8::Handle target) { NanScope(); Local t = FunctionTemplate::New(New); t->InstanceTemplate()->SetInternalFieldCount(1); NODE_SET_METHOD(t, "unmask", BufferUtil::Unmask); NODE_SET_METHOD(t, "mask", BufferUtil::Mask); NODE_SET_METHOD(t, "merge", BufferUtil::Merge); target->Set(String::NewSymbol("BufferUtil"), t->GetFunction()); } protected: static NAN_METHOD(New) { NanScope(); BufferUtil* bufferUtil = new BufferUtil(); bufferUtil->Wrap(args.This()); NanReturnValue(args.This()); } static NAN_METHOD(Merge) { NanScope(); Local bufferObj = args[0]->ToObject(); char* buffer = Buffer::Data(bufferObj); Local array = Local::Cast(args[1]); unsigned int arrayLength = array->Length(); size_t offset = 0; unsigned int i; for (i = 0; i < arrayLength; ++i) { Local src = array->Get(i)->ToObject(); size_t length = Buffer::Length(src); memcpy(buffer + offset, Buffer::Data(src), length); offset += length; } NanReturnValue(True()); } static NAN_METHOD(Unmask) { NanScope(); Local buffer_obj = args[0]->ToObject(); size_t length = Buffer::Length(buffer_obj); Local mask_obj = args[1]->ToObject(); unsigned int *mask = (unsigned int*)Buffer::Data(mask_obj); unsigned int* from = (unsigned int*)Buffer::Data(buffer_obj); size_t len32 = length / 4; unsigned int i; for (i = 0; i < len32; ++i) *(from + i) ^= *mask; from += i; switch (length % 4) { case 3: *((unsigned char*)from+2) = *((unsigned char*)from+2) ^ ((unsigned char*)mask)[2]; case 2: *((unsigned char*)from+1) = *((unsigned char*)from+1) ^ ((unsigned char*)mask)[1]; case 1: *((unsigned char*)from ) = *((unsigned char*)from ) ^ ((unsigned char*)mask)[0]; case 0:; } NanReturnValue(True()); } static NAN_METHOD(Mask) { NanScope(); Local buffer_obj = args[0]->ToObject(); Local mask_obj = args[1]->ToObject(); unsigned int *mask = (unsigned int*)Buffer::Data(mask_obj); Local output_obj = args[2]->ToObject(); unsigned int dataOffset = args[3]->Int32Value(); unsigned int length = args[4]->Int32Value(); unsigned int* to = (unsigned int*)(Buffer::Data(output_obj) + dataOffset); unsigned int* from = (unsigned int*)Buffer::Data(buffer_obj); unsigned int len32 = length / 4; unsigned int i; for (i = 0; i < len32; ++i) *(to + i) = *(from + i) ^ *mask; to += i; from += i; switch (length % 4) { case 3: *((unsigned char*)to+2) = *((unsigned char*)from+2) ^ *((unsigned char*)mask+2); case 2: *((unsigned char*)to+1) = *((unsigned char*)from+1) ^ *((unsigned char*)mask+1); case 1: *((unsigned char*)to ) = *((unsigned char*)from ) ^ *((unsigned char*)mask); case 0:; } NanReturnValue(True()); } }; extern "C" void init (Handle target) { NanScope(); BufferUtil::Initialize(target); } NODE_MODULE(bufferutil, init)