cozis/Noja
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

added sliceBuffer built-in

Browse Source
This commit is contained in:
cozis
2021-12-05 19:28:59 +01:00
parent eb15233a76
commit 60b871be55
4 changed files with 112 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files
samples/server2.noja
+27 -11
View File
@@ -21,7 +21,13 @@ fun startServer(callbacks, port, backlog)
return none;
}
if net.bind(fd, {sin_family: net.AF_INET, sin_port: net.htons(port), sin_addr: {s_addr: net.htonl(net.INADDR_ANY)}}) != 0:
if net.bind(fd, {
sin_family: net.AF_INET,
sin_port: net.htons(port),
sin_addr: {
s_addr: net.htonl(net.INADDR_ANY)
}
}) != 0:
{
print('Failed to bind.\n');
return none;
@@ -33,15 +39,25 @@ fun startServer(callbacks, port, backlog)
return none;
}
on_datain = callbacks.on_datain;
on_connect = callbacks.on_connect;
on_disconnect = callbacks.on_disconnect;
{
on_datain = callbacks.on_datain;
on_connect = callbacks.on_connect;
on_disconnect = callbacks.on_disconnect;
if on_datain == none: fun on_datain() none;
if on_connect == none: fun on_connect() none;
if on_disconnect == none: fun on_disconnect() none;
if on_datain == none:
fun on_datain()
none;
buffer = newBuffer(16);
if on_connect == none:
fun on_connect()
none;
if on_disconnect == none:
fun on_disconnect()
none;
}
buffer = newBuffer(1024);
while true:
{
@@ -67,7 +83,7 @@ fun startServer(callbacks, port, backlog)
else if n == 0:
on_disconnect(addr_str);
else
on_datain(addr_str, buffer, n);
on_datain(addr_str, sliceBuffer(buffer, 0, n));
}
while n > 0;
}
@@ -78,9 +94,9 @@ fun on_connect(addr)
print(addr, ' connected.\n');
}
fun on_datain(addr, buf, len)
fun on_datain(addr, data)
{
print('Received ', len, ' bytes from ', addr);
print('Received ', count(data), ' bytes from ', addr, '\n');
}
fun on_disconnect(addr)
src/o_builtins.c
+23 -1
View File
@@ -14,6 +14,7 @@ static Object *bin_count (Runtime *runtime, Object **argv, unsigned int argc, Er
static Object *bin_assert(Runtime *runtime, Object **argv, unsigned int argc, Error *error);
static Object *bin_strcat(Runtime *runtime, Object **argv, unsigned int argc, Error *error);
static Object *bin_newBuffer(Runtime *runtime, Object **argv, unsigned int argc, Error *error);
static Object *bin_sliceBuffer(Runtime *runtime, Object **argv, unsigned int argc, Error *error);
typedef struct {
Object base;
@@ -79,6 +80,14 @@ static Object *select_(Object *self, Object *key, Heap *heap, Error *err)
return NULL;
}
case PAIR(sizeof("sliceBuffer")-1, 's'):
{
if(!strcmp(s, "sliceBuffer"))
return Object_FromNativeFunction(bm->runtime, bin_sliceBuffer, 3, heap, err);
return NULL;
}
case PAIR(sizeof("net")-1, 'n'):
{
if(!strcmp(s, "net"))
@@ -210,10 +219,23 @@ static Object *bin_newBuffer(Runtime *runtime, Object **argv, unsigned int argc,
{
assert(argc == 1);
int size = Object_ToInt(argv[0], error);
long long int size = Object_ToInt(argv[0], error);
if(error->occurred == 1)
return NULL;
return Object_NewBuffer(size, Runtime_GetHeap(runtime), error);
}
static Object *bin_sliceBuffer(Runtime *runtime, Object **argv, unsigned int argc, Error *error)
{
assert(argc == 3);
long long int offset = Object_ToInt(argv[1], error);
if(error->occurred == 1) return NULL;
long long int length = Object_ToInt(argv[2], error);
if(error->occurred == 1) return NULL;
return Object_SliceBuffer(argv[0], offset, length, Runtime_GetHeap(runtime), error);
}
src/objects/o_buffer.c
+61 -16
View File
@@ -4,9 +4,15 @@
#include "objects.h"
typedef struct {
Object base;
int size;
unsigned char *body;
int size,
refs;
unsigned char data[];
} BufferBody;
typedef struct {
Object base;
BufferBody *body;
int offset, length;
} BufferObject;
static Object *select(Object *self, Object *key, Heap *heap, Error *err);
@@ -36,18 +42,57 @@ Object *Object_NewBuffer(int size, Heap *heap, Error *error)
if(obj == NULL)
return NULL;
obj->size = size;
obj->body = Heap_RawMalloc(heap, sizeof(unsigned char) * size, error);
obj->offset = 0;
obj->length = size;
obj->body = Heap_RawMalloc(heap, sizeof(BufferBody) + sizeof(unsigned char) * size, error);
if(obj->body == NULL)
return NULL;
memset(obj->body, 0, size);
obj->body->size = size;
obj->body->refs = 1;
memset(obj->body->data, 0, size);
}
return (Object*) obj;
}
Object *Object_SliceBuffer(Object *buffer, int offset, int length, Heap *heap, Error *error)
{
if(buffer->type != &t_buffer)
{
Error_Report(error, 0, "Not a buffer");
return NULL;
}
BufferObject *original = (BufferObject*) buffer;
BufferObject *slice = (BufferObject*) Heap_Malloc(heap, &t_buffer, error);
if(offset < 0 || offset >= original->length)
{
Error_Report(error, 0, "offset out of range");
return NULL;
}
if(length < 0 || length >= original->length)
{
Error_Report(error, 0, "length out of range");
return NULL;
}
if(offset + length > original->length)
{
Error_Report(error, 0, "slice out of range");
return NULL;
}
slice->offset = original->offset + offset;
slice->length = length;
slice->body = original->body;
slice->body->refs += 1;
return (Object*) slice;
}
void *Object_GetBufferAddrAndSize(Object *obj, int *size, Error *error)
{
if(obj->type != &t_buffer)
@@ -59,8 +104,8 @@ void *Object_GetBufferAddrAndSize(Object *obj, int *size, Error *error)
BufferObject *buf = (BufferObject*) obj;
if(size)
*size = buf->size;
return buf->body;
*size = buf->length;
return buf->body->data + buf->offset;
}
static Object *select(Object *self, Object *key, Heap *heap, Error *error)
@@ -82,13 +127,13 @@ static Object *select(Object *self, Object *key, Heap *heap, Error *error)
BufferObject *buffer = (BufferObject*) self;
if(idx < 0 || idx >= buffer->size)
if(idx < 0 || idx >= buffer->length)
{
Error_Report(error, 0, "Out of range index");
return NULL;
}
unsigned char byte = buffer->body[idx];
unsigned char byte = buffer->body->data[buffer->offset + idx];
return Object_FromInt(byte, heap, error);
}
@@ -113,7 +158,7 @@ static _Bool insert(Object *self, Object *key, Object *val, Heap *heap, Error *e
int idx = Object_ToInt(key, error);
assert(error->occurred == 0);
if(idx < 0 || idx >= buffer->size)
if(idx < 0 || idx >= buffer->length)
{
Error_Report(error, 0, "Out of range index");
return NULL;
@@ -124,7 +169,7 @@ static _Bool insert(Object *self, Object *key, Object *val, Heap *heap, Error *e
if(error->occurred == 1)
return 0;
buffer->body[idx] = byte;
buffer->body->data[buffer->offset + idx] = byte;
return 1;
}
@@ -132,7 +177,7 @@ static int count(Object *self)
{
BufferObject *buffer = (BufferObject*) self;
return buffer->size;
return buffer->length;
}
static void print(Object *self, FILE *fp)
@@ -141,11 +186,11 @@ static void print(Object *self, FILE *fp)
fprintf(fp, "[");
for(int i = 0; i < buffer->size; i += 1)
for(int i = 0; i < buffer->length; i += 1)
{
unsigned char byte, low, high;
byte = buffer->body[i];
byte = buffer->body->data[buffer->offset + i];
low = byte & 0xf;
high = byte >> 4;
@@ -159,7 +204,7 @@ static void print(Object *self, FILE *fp)
fprintf(fp, "%c%c", c1, c2);
if(i+1 < buffer->size)
if(i+1 < buffer->length)
fprintf(fp, ", ");
}
fprintf(fp, "]");
src/objects/objects.h
+1
View File
@@ -89,6 +89,7 @@ Object* Object_NewList(int capacity, Heap *heap, Error *error);
Object* Object_NewNone(Heap *heap, Error *error);
Object* Object_NewBuffer(int size, Heap *heap, Error *error);
Object* Object_NewClosure(Object *parent, Object *new_map, Heap *heap, Error *error);
Object* Object_SliceBuffer(Object *buffer, int offset, int length, Heap *heap, Error *error);
Object* Object_FromInt (long long int val, Heap *heap, Error *error);
Object* Object_FromBool (_Bool val, Heap *heap, Error *error);