Added cetara and paella

Author: rafie

.gitignore

@@ -0,0 +1,36 @@
+# Object files
+*.o
+*.ko
+*.obj
+*.elf
+*.lib
+*.a
+*.la
+*.lo
+*.dll
+*.so
+*.so.*
+*.dylib
+*.exe
+*.out
+*.app
+*.i*86
+*.x86_64
+*.hex
+
+# C/C++
+*.gch
+*.pch
+*.d
+
+# Python
+*.pyc
+
+# CMake
+CMakeFiles/
+*.cmake
+CMakeCache.txt
+
+# Eclipse
+.cproject
+.project

LICENSE

@@ -0,0 +1,52 @@
+REDIS SOURCE AVAILABLE LICENSE AGREEMENT
+
+Version 1, February 21, 2019
+ 
+This Agreement sets forth the terms on which the Licensor makes available the Software. BY INSTALLING, DOWNLOADING, ACCESSING, USING OR DISTRIBUTING ANY OF THE SOFTWARE, YOU AGREE TO THE TERMS AND CONDITIONS OF THIS AGREEMENT. IF YOU DO NOT AGREE TO SUCH TERMS AND CONDITIONS, YOU MUST NOT USE THE SOFTWARE. If you are receiving the Software on behalf of a legal entity, you represent and warrant that you have the actual authority to agree to the terms and conditions of this agreement on behalf of such entity.  
+
+
+0.	DEFINITIONS
+
+The terms below have the meanings set forth below for purposes of this Agreement:
+
+Agreement: this Redis Source Available License Agreement.
+
+Database Product: any of the following products or services: (a) database; (b) caching engine; (c) stream processing engine; (d) search engine; (e) indexing engine; (f) machine learning or deep learning or artificial intelligence serving engine; 
+(g) a product or service exposing the Redis API; (h) a product or service exposing the Redis Modules API; or 
+(i) a product or service exposing the Software API.  
+
+License: the Redis Source Available License described in Section 1. 
+
+Licensor: Redis Labs Ltd.
+
+Modification: a modification of the Software made by You under the License, Section 1.1(c). 
+
+Redis: the open source Redis software as described in redis.io. 
+
+Software: certain software components designed to work with Redis and provided to you under this Agreement.
+
+You:  the recipient of this Software, an individual, or the entity on whose behalf you are receiving the Software.
+
+Your Application: an application developed by or for You, where such application is not a Database Product.
+
+1.	LICENSE GRANT AND CONDITIONS  
+
+	1.1 Subject to the terms and conditions of this Section 1, Licensor hereby grants to You a non-exclusive, royalty-free, worldwide, non-transferable license during the term of this Agreement to: 
+		(a) distribute or make available the Software or your Modifications under the terms of this Agreement, only as part of Your Application, so long as you include the following notice on any copy you distribute: "This software is subject to the terms of the Redis Source Available License Agreement".
+		(b) use the Software, or your Modifications, only as part of Your Application, but not in connection with any Database Product that is distributed or otherwise made available by any third party.
+		(c) modify the Software, provided that Modifications remain subject to the terms of this License.  
+		(d) reproduce the Software as necessary for the above. 
+
+	1.2.	Sublicensing. You may sublicense the right to use the Software fully embedded in Your Application as distributed by you in accordance with Section 1.1(a), pursuant to a written license that disclaims all warranties and liabilities on behalf of Licensor.
+
+	1.3.	Notices. On all copies of the Software that you make, you must retain all copyright or other proprietary notices.
+	
+2.	TERM AND TERMINATION.  This Agreement will continue unless and until earlier terminated as set forth herein.  If You breach any of its conditions or obligations under this Agreement, this Agreement will terminate automatically and the licenses granted herein will terminate automatically.
+
+3.	INTELLECTUAL PROPERTY.  As between the parties, Licensor retains all right, title, and interest in the Software, and to Redis or other Licensor trademarks or service marks, and all intellectual property rights therein. Licensor hereby reserves all rights not expressly granted to You in this Agreement.  
+
+4.	DISCLAIMER.  TO THE EXTENT ALLOWABLE UNDER LAW, LICENSOR HEREBY DISCLAIMS ANY AND ALL WARRANTIES AND CONDITIONS, EXPRESS, IMPLIED, STATUTORY, OR OTHERWISE, AND SPECIFICALLY DISCLAIMS ANY WARRANTY OF MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE, WITH RESPECT TO THE SOFTWARE. Licensor has no obligation to support the Software. 
+
+5.	LIMITATION OF LIABILITY.  TO THE EXTENT ALLOWABLE UNDER LAW, LICENSOR WILL NOT BE LIABLE FOR ANY DAMAGES OF ANY KIND, INCLUDING BUT NOT LIMITED TO, LOST PROFITS OR ANY CONSEQUENTIAL, SPECIAL, INCIDENTAL, INDIRECT, OR DIRECT DAMAGES, ARISING OUT OF OR RELATING TO THIS AGREEMENT.  
+
+6.	GENERAL. You are not authorized to assign Your rights under this Agreement to any third party. Licensor may freely assign its rights under this Agreement to any third party. This Agreement is the entire agreement between the parties on the subject matter hereof.  No amendment or modification hereof will be valid or binding upon the parties unless made in writing and signed by the duly authorized representatives of both parties.  In the event that any provision, including without limitation any condition, of this Agreement is held to be unenforceable, this Agreement and all licenses and rights granted hereunder will immediately terminate.  Failure by Licensor to exercise any right hereunder will not be construed as a waiver of any subsequent breach of that right or as a waiver of any other right.  This Agreement will be governed by and interpreted in accordance with the laws of the state of California, without reference to its conflict of laws principles. If You are located within the United States, all disputes arising out of this Agreement are subject to the exclusive jurisdiction of courts located in Santa Clara County, California. USA.  If You are located outside of the United States, any dispute, controversy or claim arising out of or relating to this Agreement will be referred to and finally determined by arbitration in accordance with the JAMS before a single arbitrator in Santa Clara County, California. Judgment upon the award rendered by the arbitrator may be entered in any court having jurisdiction thereof.

cetara/diag/gdb.c

@@ -0,0 +1,130 @@
+
+#include <stdio.h>
+#include <stdlib.h>
+
+#include "readies/cetara/diag/gdb.h"
+
+#include <string.h>
+#include <errno.h>
+#include <unistd.h>
+#include <stdint.h>
+#include <sys/ptrace.h>
+#include <sys/wait.h>
+
+///////////////////////////////////////////////////////////////////////////////////////////////
+
+#ifdef __linux__
+
+#if 1
+
+static inline bool _via_gdb()
+{
+    int pid;
+    int from_child[2] = {-1, -1};
+
+    if (pipe(from_child) < 0) {
+        fprintf(stderr, "Debugger check failed: Error opening internal pipe: %s", strerror(errno));
+        return false;
+    }
+
+    pid = fork();
+    if (pid == -1) {
+        fprintf(stderr, "Debugger check failed: Error forking: %s", strerror(errno));
+        return false;
+    }
+
+    if (pid == 0) // child
+	{
+        uint8_t ret = 0;
+        int ppid = getppid();
+
+        close(from_child[0]); // close parent's side
+
+        if (ptrace(PTRACE_ATTACH, ppid, NULL, NULL) == 0) 
+		{
+            waitpid(ppid, NULL, 0); // wait for the parent to stop
+            write(from_child[1], &ret, sizeof(ret)); // tell the parent what happened
+
+			ptrace(PTRACE_DETACH, ppid, NULL, NULL);
+            exit(0);
+        }
+
+        ret = 1;
+        write(from_child[1], &ret, sizeof(ret)); // tell the parent what happened
+
+        exit(0);
+   
+    }
+	else // parent
+	{ 
+        uint8_t ret = -1;
+
+        // child writes a 1 if pattach failed else 0.
+        // read may be interrupted by pattach, hence the loop.
+        while (read(from_child[0], &ret, sizeof(ret)) < 0 && errno == EINTR)
+			;
+
+        // ret not updated
+        if (ret < 0)
+            fprintf(stderr, "Debugger check failed: Error getting status from child: %s", strerror(errno));
+
+        // close the pipes here, to avoid races with pattach (if we did it above)
+        close(from_child[1]);
+        close(from_child[0]);
+
+        waitpid(pid, NULL, 0); // collect the status of the child
+
+        return ret == 1;
+    }
+}
+
+#else
+
+static inline bool _via_gdb()
+{
+    const int status_fd = open("/proc/self/status", O_RDONLY);
+    if (status_fd == -1)
+        return false;
+
+    char buf[4096];
+    const ssize_t num_read = read(status_fd, buf, sizeof(buf) - 1);
+    if (num_read <= 0)
+        return false;
+
+    buf[num_read] = '\0';
+    constexpr char tracer_pid[] = "TracerPid:";
+    const auto tracer_pid_p = strstr(buf, tracer_pid);
+    if (!tracer_pid_p)
+        return false;
+
+    for (const char *p = tracer_pid_p + sizeof(tracer_pid) - 1; p <= buf + num_read; ++p)
+    {
+        if (isspace(*p))
+            continue;
+        return isdigit(*p) && *p != '0';
+    }
+
+    return false;
+}
+
+#endif // 1
+
+#elif defined(__APPLE__)
+
+static inline bool _via_gdb()
+{
+}
+
+#endif
+
+//---------------------------------------------------------------------------------------------
+
+bool __via_gdb = false;
+
+__attribute__((constructor))
+static void initialize(void) 
+{
+    __via_gdb = _via_gdb();
+}
+
+///////////////////////////////////////////////////////////////////////////////////////////////

cetara/diag/gdb.h

@@ -0,0 +1,8 @@
+
+#pragma once
+
+#include <stdbool.h>
+
+extern bool __via_gdb;
+
+#define BB do { if (__via_gdb) { __asm__("int $3"); } } while(0);

paella/__init__.py

@@ -0,0 +1,29 @@
+
+from .debug import *
+from .utils import *
+from .files import *
+# from .docopt import docopt
+from .log import *
+
+#----------------------------------------------------------------------------------------------
+
+import sys
+
+class global_injector:
+    def __init__(self):
+        try:
+			# Python 2
+            self.__dict__['builtin'] = sys.modules['__builtin__'].__dict__
+        except KeyError:
+			# Python 3
+            self.__dict__['builtin'] = sys.modules['builtins'].__dict__
+    def __setattr__(self,name,value):
+        self.builtin[name] = value
+
+Global = global_injector()
+
+#----------------------------------------------------------------------------------------------
+
+Global.bb = bb
+Global.eprint = eprint
+Global.fatal = fatal

paella/debug.py

@@ -0,0 +1,11 @@
+
+import os
+
+#----------------------------------------------------------------------------------------------
+
+if 'PYDEBUG' in os.environ:
+	from pdb import set_trace as bb
+else:
+	def bb(): pass
+
+#----------------------------------------------------------------------------------------------

paella/docopt1.py

@@ -0,0 +1,25 @@
+
+from docopt import docopt as docopt1
+from collections import namedtuple
+import re
+
+def dict_to_obj(d):
+	def add_to_dict_if_match(r, k, v, d):
+		m = re.match(r, k)
+		if m:
+			d[m[1].replace('-', '_')] = v
+		return not not m
+
+	d1 = dict()
+	for k, v in d.items():
+		if isinstance(v, dict):
+			d1[k] = dict_to_obj(v)
+		elif add_to_dict_if_match('--(.*)', k, v, d1):
+			pass
+		elif add_to_dict_if_match('\<(.*)\>', k, v, d1):
+			pass
+	return namedtuple('object', d1.keys())(*d1.values())
+
+def docopt(*args, **kwargs):
+	a = docopt1(*args, **kwargs)
+	return dict_to_obj(a)

paella/files.py

@@ -0,0 +1,4 @@
+
+def fread(fname, mode = 'rb'):
+	with open(fname, mode) as file:
+		return file.read()

paella/log.py

@@ -0,0 +1,6 @@
+
+import os
+
+def fatal(text):
+	eprint("%s: %s" %(os.path.basename(__file__), text))
+	exit(1)

paella/utils.py

@@ -0,0 +1,7 @@
+
+import sys
+
+if (sys.version_info > (3, 0)):
+	from .utils3 import *
+else:
+	from .utils2 import *