initial commit

Author: chrisguiney

.gitignore

@@ -0,0 +1,5 @@
+tests/heap_t_tests.dSYM/
+build/
+tests/tests.log
+*.o
+*xcode*

Makefile

@@ -0,0 +1,61 @@
+CFLAGS=-g -O2 -Wall -Wextra -Isrc -rdynamic -DNDEBUG $(OPTFLAGS)
+LIBS=-ldl $(OPTLIBS)
+PREFIX?=/usr/local
+
+SOURCES=$(wildcard src/**/*.c src/*.c)
+OBJECTS=$(patsubst %.c,%.o,$(SOURCES))
+
+TEST_SRC=$(wildcard tests/*_tests.c)
+TESTS=$(patsubst %.c,%,$(TEST_SRC))
+
+TARGET=build/libsketch.a
+SO_TARGET=$(patsubst %.a,%.so,$(TARGET))
+
+BINARY=cmsketch
+# The Target Build
+all: $(TARGET) $(SO_TARGET) $(BINARY) tests
+
+dev: CFLAGS=-g -Wall -Isrc -Wall -Wextra $(OPTFLAGS)
+dev: all
+
+$(TARGET): CFLAGS += -fPIC
+$(TARGET): build $(OBJECTS)
+		ar rcs $@ $(OBJECTS)
+		ranlib $@
+
+$(SO_TARGET): $(TARGET) $(OBJECTS)
+		$(CC) -shared -o $@ $(OBJECTS)
+
+$(BINARY): $(SO_TARGET)
+	$(CC) $(CFLAGS) -v -o build/$(BINARY) $(TARGET)
+
+build:
+		@mkdir -p build
+		@mkdir -p bin
+
+# The Unit Tests
+.PHONY: tests
+tests: CFLAGS += $(TARGET)
+tests: $(TESTS)
+		sh ./tests/runtests.sh
+
+valgrind:
+		VALGRIND="valgrind --log-file=/tmp/valgrind-%p.log" $(MAKE)
+
+# The Cleaner
+clean:
+		rm -rf build $(OBJECTS) $(TESTS)
+		rm -f tests/tests.log
+		find . -name "*.gc*" -exec rm {} \;
+		rm -rf `find . -name "*.dSYM" -print`
+
+# The Install
+install: all
+		install -d $(DESTDIR)/$(PREFIX)/lib/
+		install $(TARGET) $(DESTDIR)/$(PREFIX)/lib/
+
+# The Checker
+BADFUNCS='[^_.>a-zA-Z0-9](str(n?cpy|n?cat|xfrm|n?dup|str|pbrk|tok|_)|stpn?cpy|a?sn?printf|byte_)'
+check:
+		@echo Files with potentially dangerous functions.
+		@egrep $(BADFUNCS) $(SOURCES) || true

include/dbg.h

@@ -0,0 +1,44 @@
+//
+//  dbg.h
+//  cmsketch
+//
+//  Created by Chris Guiney on 4/18/14.
+//  Courtousy of Zed Shaw's Learn C the Hard Way
+//
+
+#ifndef cmsketch_dbg_h
+#define cmsketch_dbg_h
+
+#ifndef __dbg_h__
+#define __dbg_h__
+
+#include <stdio.h>
+#include <errno.h>
+#include <string.h>
+
+#ifdef NDEBUG
+#define debug(M, ...)
+#else
+#define debug(M, ...) fprintf(stderr, "DEBUG %s:%d: " M "\n", __FILE__, __LINE__, ##__VA_ARGS__)
+#endif
+
+#define clean_errno() (errno == 0 ? "None" : strerror(errno))
+
+#define log_err(M, ...) fprintf(stderr, "[ERROR] (%s:%d: errno: %s) " M "\n", __FILE__, __LINE__, clean_errno(), ##__VA_ARGS__)
+
+#define log_warn(M, ...) fprintf(stderr, "[WARN] (%s:%d: errno: %s) " M "\n", __FILE__, __LINE__, clean_errno(), ##__VA_ARGS__)
+
+#define log_info(M, ...) fprintf(stderr, "[INFO] (%s:%d) " M "\n", __FILE__, __LINE__, ##__VA_ARGS__)
+
+#define check(A, M, ...) if(!(A)) { log_err(M, ##__VA_ARGS__); errno=0; goto error; }
+
+#define sentinel(M, ...)  { log_err(M, ##__VA_ARGS__); errno=0; goto error; }
+
+#define check_mem(A) check((A), "Out of memory.")
+
+#define check_debug(A, M, ...) if(!(A)) { debug(M, ##__VA_ARGS__); errno=0; goto error; }
+
+#endif
+
+
+#endif

include/heap_t.h

@@ -0,0 +1,29 @@
+//
+//  heap_t.h
+//  cmsketch
+//
+//  Created by Chris Guiney on 4/18/14.
+//  Copyright (c) 2014 Chris Guiney. All rights reserved.
+//
+
+#ifndef cmsketch_heap_t_h
+#define cmsketch_heap_t_h
+
+typedef int (*comparator) (void* item, void* item2);
+
+typedef struct {
+    comparator cmp;                                   // Comparator function
+    int size;                                         // Max size
+    int items;                                        // Items currently in heap
+    size_t item_size;                                 // Size of item
+    void **list;                                      // Array of items
+} heap_t;
+
+heap_t* heap_create(int size, size_t type_size, comparator cmp);
+void heap_clear(heap_t* heap);
+void heap_destroy(heap_t* heap);
+void heap_push(heap_t* heap, void* item);
+void* heap_pop(heap_t* heap);
+void* heap_pushpop(heap_t* heap, void* item);
+void heap_sort(heap_t* heap);
+#endif

include/sketch_t.h

@@ -0,0 +1,27 @@
+//
+//  cmsketch.h
+//  cmsketch
+//
+//  Created by Chris Guiney on 4/18/14.
+//  Copyright (c) 2014 Chris Guiney. All rights reserved.
+//
+#include "heap_t.h"
+#ifndef cmsketch_sketch_t_h
+#define cmsketch_sketch_t_h
+
+typedef struct {
+    int k;        // Number of top-k items to keep track of
+    int width;    // Width of field
+    int depth;    // Depth of field
+    int *field;   // Int field -- width * depth length
+    heap_t *heap; // Heap for sorting
+} sketch_t;
+
+sketch_t* sketch_create(size_t data_size,
+                        double delta,
+                        double epsilon,
+                        int k,
+                        comparator cmp);
+void sketch_destroy(sketch_t *s);
+
+#endif

include/util.h

@@ -0,0 +1,14 @@
+//
+//  util.h
+//  cmsketch
+//
+//  Created by Chris Guiney on 4/18/14.
+//  Copyright (c) 2014 Chris Guiney. All rights reserved.
+//
+
+#ifndef cmsketch_util_h
+#define cmsketch_util_h
+
+void swap(void* a, void* b);
+
+#endif