Renaming errors and header defines...
authorGerd Zellweger <zgerd@student.ethz.ch>
Fri, 16 Mar 2012 23:29:50 +0000 (00:29 +0100)
committerGerd Zellweger <zgerd@student.ethz.ch>
Fri, 16 Mar 2012 23:29:50 +0000 (00:29 +0100)
--HG--
branch : octopus.renaming

54 files changed:
errors/errno.fugu
hake/ArchDefaults.hs
if/octopus.if
include/octopus/barrier.h
include/octopus/capability_storage.h
include/octopus/definitions.h
include/octopus/getset.h
include/octopus/init.h
include/octopus/lock.h
include/octopus/octopus.h
include/octopus/parser/ast.h
include/octopus/pubsub.h
include/octopus/semaphores.h
include/octopus/trigger.h
include/octopus_server/debug.h
include/octopus_server/init.h
include/octopus_server/query.h
include/octopus_server/service.h
lib/barrelfish/Hakefile
lib/barrelfish/nameservice_client.c
lib/octopus/client/barriers.c
lib/octopus/client/common.h
lib/octopus/client/getset.c
lib/octopus/client/handler.h
lib/octopus/client/locking.c
lib/octopus/client/nameservice_client.c
lib/octopus/client/octopus.c
lib/octopus/client/pubsub.c
lib/octopus/client/semaphores.c
lib/octopus/client/trigger.c
lib/octopus/parser/ast.c
lib/octopus/parser/flex.h
lib/octopus/parser/parse.c
lib/octopus/parser/parse.y
lib/octopus/parser/read.c
lib/octopus/parser/scan.c
lib/octopus/parser/scan.l
lib/octopus/parser/test_parser.c
lib/octopus/server/capstorage.c
lib/octopus/server/init.c
lib/octopus/server/queue.h
lib/octopus/server/service.c
lib/posixcompat/Hakefile
lib/posixcompat/semaphore.c
lib/posixcompat/shm.c
usr/ioapic/ioapic_main.c
usr/kaluga/common.c
usr/kaluga/main.c
usr/kaluga/start_pci.c
usr/skb/dist/predicates.c
usr/skb/dist/skb_query.c
usr/tests/dist2test/d2getset.c
usr/tests/dist2test/d2pubsub.c
usr/tests/dist2test/d2sem.c

index 0d976a6..2754d66 100644 (file)
@@ -778,8 +778,8 @@ errors dist DIST_ERR_ {
      failure NS_LOOKUP  "Name service lookup failed.",
 };
 
-// dist2 library errors
-errors libdist2  DIST2_ERR_ {
+// octopus library errors
+errors octopus  OCT_ERR_ {
     failure NO_RECORD           "No record exists matching the specified query.",
     failure NO_RECORD_NAME      "Your query needs to specify a designated record name (no regex/variable allowed).",
     failure CONSTRAINT_MISMATCH "The constraints you specified on set do not match the record in the database.",
@@ -797,7 +797,7 @@ errors libdist2  DIST2_ERR_ {
     failure CAP_OVERWRITE       "Capability storage: Cap already exists.",
 };
 
-// dist2 library errors
+// kaluga library errors
 errors kaluga  KALUGA_ERR_ {
     failure PARSE_MODULES          "Cannot parse menu.lst.",
     failure MODULE_NOT_FOUND       "Boot module not found.",
index d2c1e1b..189c281 100644 (file)
@@ -79,7 +79,7 @@ ldCxxFlags arch =
 
 stdLibs arch = 
     [ In InstallTree arch "/lib/libbarrelfish.a",
-      In InstallTree arch "/lib/libdist_parser.a", -- XXX: For NS client in libbarrelfish
+      In InstallTree arch "/lib/liboctopus_parser.a", -- XXX: For NS client in libbarrelfish
       In InstallTree arch "/errors/errno.o",
       In InstallTree arch "/lib/libc.a",
       In InstallTree arch "/lib/crtend.o" ,
index c1de948..d78c880 100644 (file)
@@ -7,7 +7,7 @@
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-interface dist2 "dist2 RPC Interface" {
+interface octopus "octopus RPC Interface" {
 
     alias mode uint64;
     alias trigger_id uint64;
index 73d8823..44d5e50 100644 (file)
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef DIST2_BARRIER_H_
-#define DIST2_BARRIER_H_
+#ifndef OCTOPUS_BARRIER_H_
+#define OCTOPUS_BARRIER_H_
 
 errval_t oct_barrier_enter(const char*, char**, size_t);
 errval_t oct_barrier_leave(const char*);
 
-#endif /* DIST2_BARRIER_H_ */
+#endif /* OCTOPUS_BARRIER_H_ */
index 06687d7..b1f5924 100644 (file)
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef CAPABILITY_STORAGE_H_
-#define CAPABILITY_STORAGE_H_
+#ifndef OCTOPUS_CAPABILITY_STORAGE_H_
+#define OCTOPUS_CAPABILITY_STORAGE_H_
 
 errval_t oct_get_capability(const char*, struct capref*);
 errval_t oct_put_capability(const char*, struct capref);
 errval_t oct_remove_capability(const char*);
 
-#endif /* CAPABILITY_STORAGE_H_ */
+#endif /* OCTOPUS_CAPABILITY_STORAGE_H_ */
index d741006..d4b72d6 100644 (file)
@@ -15,8 +15,8 @@
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef DIST2_DEFINITIONS_H_
-#define DIST2_DEFINITIONS_H_
+#ifndef OCTOPUS_DEFINITIONS_H_
+#define OCTOPUS_DEFINITIONS_H_
 
 #define MAX_QUERY_LENGTH (5*1024)
 
@@ -37,4 +37,4 @@
                                          this trigger is safe in case this
                                          flag is set. */
 
-#endif /* DIST2_DEFINITIONS_H_ */
+#endif /* OCTOPUS_DEFINITIONS_H_ */
index 884c251..7095230 100644 (file)
@@ -1,6 +1,6 @@
 /**
  * \file
- * \brief Header file for the dist2 get/set API.
+ * \brief Header file for the octopus get/set API.
  */
 
 /*
@@ -12,8 +12,8 @@
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef DIST2_GETSET_H_
-#define DIST2_GETSET_H_
+#ifndef OCTOPUS_GETSET_H_
+#define OCTOPUS_GETSET_H_
 
 #include <barrelfish/barrelfish.h>
 
@@ -41,4 +41,4 @@ errval_t oct_exists(const char*, ...);
 
 errval_t oct_read(const char*, const char*, ...);
 
-#endif /* DIST2_GETSET_H_ */
+#endif /* OCTOPUS_GETSET_H_ */
index 88e9dfc..44c6161 100644 (file)
@@ -1,6 +1,6 @@
 /**
  * \file
- * \brief Header file for the dist2 initialization/general functions.
+ * \brief Header file for the octopus initialization/general functions.
  */
 
 /*
@@ -12,8 +12,8 @@
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef DIST2_INIT_H_
-#define DIST2_INIT_H_
+#ifndef OCTOPUS_INIT_H_
+#define OCTOPUS_INIT_H_
 
 #include <barrelfish/barrelfish.h>
 #include <if/octopus_defs.h>
@@ -28,4 +28,4 @@ errval_t oct_thc_init(void);
 struct octopus_thc_client_binding_t* oct_get_thc_client(void);
 struct octopus_binding* oct_get_event_binding(void);
 
-#endif /* DIST2_INIT_H_ */
+#endif /* OCTOPUS_INIT_H_ */
index d1b53bf..935b4e3 100644 (file)
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef DIST2_LOCK_H_
-#define DIST2_LOCK_H_
+#ifndef OCTOPUS_LOCK_H_
+#define OCTOPUS_LOCK_H_
 
 errval_t oct_lock(const char*, char**);
 errval_t oct_unlock(const char*);
 
-#endif /* DIST2_LOCK_H_ */
+#endif /* OCTOPUS_LOCK_H_ */
index 3e30210..9d613a1 100644 (file)
@@ -1,6 +1,6 @@
 /**
  * \file
- * \brief Header file for the dist2 client library.
+ * \brief Header file for the octopus client library.
  */
 
 /*
@@ -12,8 +12,8 @@
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef DIST2_H_
-#define DIST2_H_
+#ifndef OCTOPUS_H_
+#define OCTOPUS_H_
 
 #include <octopus/init.h>
 #include <octopus/getset.h>
@@ -23,4 +23,4 @@
 #include <octopus/semaphores.h>
 #include <octopus/trigger.h>
 
-#endif /* DIST2_H_ */
+#endif /* OCTOPUS_H_ */
index 5d65554..fcffbe7 100644 (file)
@@ -12,8 +12,8 @@
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef AST_H_
-#define AST_H_
+#ifndef OCTOPUS_AST_H_
+#define OCTOPUS_AST_H_
 
 #include <stdlib.h>
 #include <string.h>
@@ -24,7 +24,7 @@
 #else
 #define MAX_QUERY_LENGTH (5*1024)
 #define SYS_ERR_OK 0
-#define DIST2_ERR_PARSER_FAIL 2
+#define OCT_ERR_PARSER_FAIL 2
 typedef long errval_t;
 typedef long int64_t;
 static int err_is_ok(errval_t err)
@@ -273,4 +273,4 @@ static inline struct ast_object* ast_num(int64_t value)
     return p;
 }
 
-#endif // AST_H_
+#endif // OCTOPUS_AST_H_
index f43a78b..9d6c125 100644 (file)
@@ -12,8 +12,8 @@
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef DIST2_PUBSUB_H_
-#define DIST2_PUBSUB_H_
+#ifndef OCTOPUS_PUBSUB_H_
+#define OCTOPUS_PUBSUB_H_
 
 #include <stdint.h>
 #include <if/octopus_defs.h>
@@ -28,4 +28,4 @@ errval_t oct_subscribe(subscription_handler_fn, const void*, subscription_t*,
 errval_t oct_unsubscribe(subscription_t);
 errval_t oct_publish(const char*, ...);
 
-#endif /* DIST2_PUBSUB_H_ */
+#endif /* OCTOPUS_PUBSUB_H_ */
index 4874f8e..6a51c36 100644 (file)
@@ -1,6 +1,6 @@
 /**
  * \file
- * \brief Header file for the dist2 semaphores API.
+ * \brief Header file for the octopus semaphores API.
  *
  * This API was written to replace the semaphore API
  * in chips in order to support posixcompat.
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef DIST2_SEMAPHORES_H_
-#define DIST2_SEMAPHORES_H_
+#ifndef OCTOPUS_SEMAPHORES_H_
+#define OCTOPUS_SEMAPHORES_H_
 
 errval_t oct_sem_new(uint32_t*, size_t);
 errval_t oct_sem_post(uint32_t);
 errval_t oct_sem_wait(uint32_t);
 errval_t oct_sem_trywait(uint32_t);
 
-#endif /* DIST2_SEMAPHORES_H_ */
+#endif /* OCTOPUS_SEMAPHORES_H_ */
index 75f5205..c4a8594 100644 (file)
@@ -12,8 +12,8 @@
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef DIST2_TRIGGER_H_
-#define DIST2_TRIGGER_H_
+#ifndef OCTOPUS_TRIGGER_H_
+#define OCTOPUS_TRIGGER_H_
 
 #include <barrelfish/barrelfish.h>
 #include <if/octopus_defs.h>
@@ -27,4 +27,4 @@ octopus_trigger_t oct_mktrigger(errval_t, octopus_binding_type_t, octopus_mode_t
         trigger_handler_fn, void*);
 errval_t oct_remove_trigger(octopus_trigger_id_t);
 
-#endif /* DIST2_TRIGGER_H_ */
+#endif /* OCTOPUS_TRIGGER_H_ */
index 6a73ac0..0bbadaf 100644 (file)
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef DIST2_DEBUG_H_
-#define DIST2_DEBUG_H_
+#ifndef OCTOPUS_DEBUG_H_
+#define OCTOPUS_DEBUG_H_
 
 //#define DIST_SERVICE_DEBUG 1
 
 #if defined(DIST_SERVICE_DEBUG) || defined(GLOBAL_DEBUG)
-#define DIST2_DEBUG(x...) debug_printf("octopus_service: " x)
+#define OCT_DEBUG(x...) debug_printf("octopus_service: " x)
 #else
-#define DIST2_DEBUG(x...) ((void)0)
+#define OCT_DEBUG(x...) ((void)0)
 #endif
 
-#endif // DIST2_DEBUG_H_
+#endif // OCTOPUS_DEBUG_H_
index e90643e..6f152e5 100644 (file)
@@ -1,6 +1,6 @@
 /**
  * \file
- * \brief Header file for dist2 server initialization.
+ * \brief Header file for octopus server initialization.
  */
 
 /*
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef DIST2_INIT_H_
-#define DIST2_INIT_H_
+#ifndef OCTOPUS_INIT_H_
+#define OCTOPUS_INIT_H_
 
 #include <barrelfish/barrelfish.h>
 
 errval_t init_capstorage(void);
-
 errval_t rpc_server_init(void);
-
 errval_t oct_server_init(void);
 
-#endif /* DIST2_INIT_H_ */
+#endif /* OCTOPUS_INIT_H_ */
index ada2be4..1f011d7 100644 (file)
@@ -1,6 +1,6 @@
 /**
  * \file
- * \brief dist2 Query Interface Header file
+ * \brief octopus Query Interface Header file
  *
  * The server must implement this interface in order for dist2
  * to work accordingly.
@@ -15,8 +15,8 @@
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef DIST2_QUERY_H_
-#define DIST2_QUERY_H_
+#ifndef OCTOPUS_QUERY_H_
+#define OCTOPUS_QUERY_H_
 
 #include <barrelfish/barrelfish.h>
 #include <if/octopus_defs.h>
@@ -36,8 +36,8 @@
  * \param binding Pointer value of binding
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_UNSUPPORTED_BINDING
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_UNSUPPORTED_BINDING
+ * \retval OCT_ERR_ENGINE_FAIL
  * \retval LIB_ERR_MALLOC_FAIL
  */
 errval_t set_binding(octopus_binding_type_t type, uint64_t id, void* binding);
@@ -51,8 +51,8 @@ errval_t set_binding(octopus_binding_type_t type, uint64_t id, void* binding);
  * \param dqs Contains the result of the query invocation.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_NO_RECORD
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_NO_RECORD
+ * \retval OCT_ERR_ENGINE_FAIL
  */
 errval_t get_record_names(struct ast_object* ast, struct oct_query_state* dqs);
 
@@ -63,8 +63,8 @@ errval_t get_record_names(struct ast_object* ast, struct oct_query_state* dqs);
  * \param dqs Contains the result of the query invocation.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_NO_RECORD
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_NO_RECORD
+ * \retval OCT_ERR_ENGINE_FAIL
  */
 errval_t get_record(struct ast_object* ast, struct oct_query_state* dqs);
 
@@ -76,7 +76,7 @@ errval_t get_record(struct ast_object* ast, struct oct_query_state* dqs);
  * \param dqs Returned result of query invocation.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_ENGINE_FAIL
  */
 errval_t set_record(struct ast_object* ast, uint64_t mode,
         struct oct_query_state* dqs);
@@ -88,8 +88,8 @@ errval_t set_record(struct ast_object* ast, uint64_t mode,
  * \param dqs Returned result of query invocation.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_NO_RECORD
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_NO_RECORD
+ * \retval OCT_ERR_ENGINE_FAIL
  */
 errval_t del_record(struct ast_object*, struct oct_query_state*);
 
@@ -105,7 +105,7 @@ errval_t del_record(struct ast_object*, struct oct_query_state*);
  * \param wid ID of the installed watch (used for remove).
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_ENGINE_FAIL
  */
 errval_t set_watch(struct octopus_binding* b, struct ast_object* ast,
         uint64_t mode, struct oct_reply_state* drs, uint64_t* wid);
@@ -118,8 +118,8 @@ errval_t set_watch(struct octopus_binding* b, struct ast_object* ast,
  * \param dqs Query state
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_INVALID_ID
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_INVALID_ID
+ * \retval OCT_ERR_ENGINE_FAIL
  */
 errval_t del_watch(struct octopus_binding* b, octopus_trigger_id_t id,
         struct oct_query_state* dqs);
@@ -134,8 +134,8 @@ errval_t del_watch(struct octopus_binding* b, octopus_trigger_id_t id,
  * \param drs Returned result of query invocation.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_MAX_SUBSCRIPTIONS
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_MAX_SUBSCRIPTIONS
+ * \retval OCT_ERR_ENGINE_FAIL
  * \retval LIB_ERR_MALLOC_FAIL
  */
 errval_t add_subscription(struct octopus_binding* b, struct ast_object* ast,
@@ -149,8 +149,8 @@ errval_t add_subscription(struct octopus_binding* b, struct ast_object* ast,
  * \param dqs Returned result of query invocation.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_NO_SUBSCRIPTION
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_NO_SUBSCRIPTION
+ * \retval OCT_ERR_ENGINE_FAIL
  */
 errval_t del_subscription(struct octopus_binding* b, uint64_t id,
         struct oct_query_state* dqs);
@@ -163,8 +163,8 @@ errval_t del_subscription(struct octopus_binding* b, uint64_t id,
  * \param dqs Returned result of query invocation.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_NO_SUBSCRIBERS
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_NO_SUBSCRIBERS
+ * \retval OCT_ERR_ENGINE_FAIL
  */
 errval_t find_subscribers(struct ast_object* ast, struct oct_query_state* dqs);
 
@@ -176,4 +176,4 @@ errval_t find_subscribers(struct ast_object* ast, struct oct_query_state* dqs);
  */
 struct octopus_binding* get_event_binding(struct octopus_binding* binding);
 
-#endif /* DIST2_QUERY_H_ */
+#endif /* OCTOPUS_QUERY_H_ */
index e058b46..c7aadfe 100644 (file)
@@ -1,6 +1,6 @@
 /**
  * \file
- * \brief dist2 service handler header file.
+ * \brief octopus service handler header file.
  */
 
 /*
@@ -12,8 +12,8 @@
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef DIST2_SERVICE_H_
-#define DIST2_SERVICE_H_
+#ifndef OCTOPUS_SERVICE_H_
+#define OCTOPUS_SERVICE_H_
 
 #include <barrelfish/barrelfish.h>
 #include <if/octopus_defs.h>
@@ -76,4 +76,4 @@ void get_cap_handler(struct octopus_binding*, char*);
 void put_cap_handler(struct octopus_binding*, char*, struct capref);
 void remove_cap_handler(struct octopus_binding*, char*);
 
-#endif /* DIST2_SERVICE_H_ */
+#endif /* OCTOPUS_SERVICE_H_ */
index 3cae7cd..af33626 100644 (file)
                     cFiles = arch_srcs arch ++ archfam_srcs (archFamily arch)
                              ++ common_srcs ++ idc_srcs,
                     assemblyFiles = arch_assembly (archFamily arch),
-                    flounderBindings = [ "mem", "dist2", "serial",
+                    flounderBindings = [ "mem", "octopus", "serial",
                                          "interdisp", "spawn", "keyboard" ],
                     -- only makes sense to compile monitor binding for lmp
                     flounderExtraBindings = [ ("monitor", ["lmp"]),
                                              ("monitor_blocking", ["lmp", "rpcclient"]),
                                               ("mem", ["rpcclient"]),
-                                              ("dist2", ["rpcclient"]),
+                                              ("octopus", ["rpcclient"]),
                                               ("spawn", ["rpcclient"]),
                                               ("serial", ["rpcclient"])],
                     addIncludes = [ "include", "include" ./. arch_dir ],
index d2a92c9..f2f1178 100644 (file)
@@ -46,7 +46,7 @@ errval_t nameservice_lookup(const char *iface, iref_t *retiref)
     }
     err = error_code;
     if (err_is_fail(err)) {
-        if (err_no(err) == DIST2_ERR_NO_RECORD) {
+        if (err_no(err) == OCT_ERR_NO_RECORD) {
             err = err_push(err, LIB_ERR_NAMESERVICE_UNKNOWN_NAME);
         }
         goto out;
@@ -90,7 +90,7 @@ errval_t nameservice_blocking_lookup(const char *iface, iref_t *retiref)
     }
     err = error_code;
     if (err_is_fail(err)) {
-        if (err_no(err) == DIST2_ERR_NO_RECORD) {
+        if (err_no(err) == OCT_ERR_NO_RECORD) {
             err = err_push(err, LIB_ERR_NAMESERVICE_UNKNOWN_NAME);
         }
         goto out;
index 2cc7517..6a9bcec 100644 (file)
@@ -46,7 +46,7 @@ errval_t oct_barrier_enter(const char* name, char** barrier_record, size_t wait_
     uint64_t fn = 0;
     octopus_trigger_id_t tid;
     size_t current_barriers = 0;
-    octopus_trigger_t t = oct_mktrigger(DIST2_ERR_NO_RECORD, octopus_BINDING_RPC,
+    octopus_trigger_t t = oct_mktrigger(OCT_ERR_NO_RECORD, octopus_BINDING_RPC,
             DIST_ON_SET, NULL, NULL);
 
     err = oct_set_get(SET_SEQUENTIAL, barrier_record,
@@ -71,7 +71,7 @@ errval_t oct_barrier_enter(const char* name, char** barrier_record, size_t wait_
         if (err_is_ok(err)) {
             // Barrier already exists
         }
-        if (err_no(err) == DIST2_ERR_NO_RECORD) {
+        if (err_no(err) == OCT_ERR_NO_RECORD) {
             // Wait until barrier record is created
             err = cl->recv.trigger(cl, &tid, &fn, &mode, &record, &state);
             free(record);
@@ -147,12 +147,12 @@ errval_t oct_barrier_leave(const char* barrier_record)
                 err = cl->recv.trigger(cl, &tid, &fn, &mode, &record, &state);
                 assert(mode & DIST_REMOVED);
             }
-            else if (err_no(err) == DIST2_ERR_NO_RECORD) {
+            else if (err_no(err) == OCT_ERR_NO_RECORD) {
                 // barrier already deleted
                 err = SYS_ERR_OK;
             }
         }
-        else if (err_no(err) == DIST2_ERR_NO_RECORD) {
+        else if (err_no(err) == OCT_ERR_NO_RECORD) {
             // We are the last one to leave the barrier,
             // wake-up all others
             err = oct_del("%s", barrier_name);
index a254639..f0fdb27 100644 (file)
@@ -1,7 +1,7 @@
 /**
  * \file
  * \brief Contains common functions/macros/defines used throughout
- * the dist2 client library.
+ * the octopus client library.
  */
 
 /*
@@ -13,8 +13,8 @@
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef DIST2_COMMON_H_
-#define DIST2_COMMON_H_
+#ifndef OCTOPUS_COMMON_H_
+#define OCTOPUS_COMMON_H_
 
 #include <stdlib.h>
 #include <stdio.h>
@@ -54,7 +54,7 @@ static inline errval_t allocate_string(const char *fmt, va_list args,
     *length = vsnprintf(NULL, 0, fmt, args);
 
     if (*length >= MAX_QUERY_LENGTH) {
-        return DIST2_ERR_QUERY_SIZE;
+        return OCT_ERR_QUERY_SIZE;
     }
 
     *buf = malloc((*length) + 1); // include \0
@@ -88,4 +88,4 @@ static inline char* strtok_r(char *s, const char *delim, char **saveptr)
     return s;
 }
 
-#endif /* DIST2_COMMON_H_ */
+#endif /* OCTOPUS_COMMON_H_ */
index 3c6003b..9621c75 100644 (file)
@@ -3,7 +3,7 @@
  * \brief Get/Set client API implementation
  *
  * This file provides convenience functions to interface with the
- * dist2.if RPC calls.
+ * octopus.if RPC calls.
  */
 
 /*
@@ -125,9 +125,9 @@ out:
  * \param ... Parameters used to build query with help of vsprintf.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_NO_RECORD
- * \retval DIST2_ERR_PARSER_FAIL
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_NO_RECORD
+ * \retval OCT_ERR_PARSER_FAIL
+ * \retval OCT_ERR_ENGINE_FAIL
  * \retval LIB_ERR_MALLOC_FAIL
  */
 errval_t oct_get_names(char*** names, size_t* len, const char* query, ...)
@@ -191,10 +191,10 @@ void oct_free_names(char** names, size_t len)
  * \param ... Additional arguments to format the query using vsprintf.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_NO_RECORD
- * \retval DIST2_ERR_AMBIGOUS_QUERY TODO!
- * \retval DIST2_ERR_PARSER_FAIL
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_NO_RECORD
+ * \retval OCT_ERR_AMBIGOUS_QUERY TODO!
+ * \retval OCT_ERR_PARSER_FAIL
+ * \retval OCT_ERR_ENGINE_FAIL
  */
 errval_t oct_get(char** data, const char* query, ...)
 {
@@ -227,9 +227,9 @@ errval_t oct_get(char** data, const char* query, ...)
  * \param ... Additional arguments to format the query using vsprintf.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_NO_RECORD_NAME
- * \retval DIST2_ERR_PARSER_FAIL
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_NO_RECORD_NAME
+ * \retval OCT_ERR_PARSER_FAIL
+ * \retval OCT_ERR_ENGINE_FAIL
  */
 errval_t oct_set(const char* query, ...)
 {
@@ -266,9 +266,9 @@ errval_t oct_set(const char* query, ...)
  * \param ... Additional arguments to format the query using vsprintf.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_NO_RECORD_NAME
- * \retval DIST2_ERR_PARSER_FAIL
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_NO_RECORD_NAME
+ * \retval OCT_ERR_PARSER_FAIL
+ * \retval OCT_ERR_ENGINE_FAIL
  */
 errval_t oct_mset(oct_mode_t mode, const char* query, ...)
 {
@@ -309,9 +309,9 @@ errval_t oct_mset(oct_mode_t mode, const char* query, ...)
  * \param ... Additional arguments to format the query using vsprintf.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_NO_RECORD_NAME
- * \retval DIST2_ERR_PARSER_FAIL
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_NO_RECORD_NAME
+ * \retval OCT_ERR_PARSER_FAIL
+ * \retval OCT_ERR_ENGINE_FAIL
  *
  * TODO maybe remove this function completely and let all use rpc call for set
  * directly if they want to a non-trivial set?
@@ -346,10 +346,10 @@ errval_t oct_set_get(oct_mode_t mode, char** record, const char* query, ...)
  * \param ... Additional arguments to format the query using vsprintf.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_NO_RECORD
- * \retval DIST2_ERR_NO_RECORD_NAME
- * \retval DIST2_ERR_ENGINE_FAIL
- * \retval DIST2_ERR_PARSER_FAIL
+ * \retval OCT_ERR_NO_RECORD
+ * \retval OCT_ERR_NO_RECORD_NAME
+ * \retval OCT_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_PARSER_FAIL
  *
  * TODO: Atm only name of record is included in del query on server.
  */
@@ -381,9 +381,9 @@ errval_t oct_del(const char* query, ...)
  * \param ... Additional arguments to format the query using vsprintf.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_NO_RECORD
- * \retval DIST2_ERR_PARSER_FAIL
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_NO_RECORD
+ * \retval OCT_ERR_PARSER_FAIL
+ * \retval OCT_ERR_ENGINE_FAIL
  **/
 errval_t oct_exists(const char* query, ...)
 {
index c369740..971dfbb 100644 (file)
@@ -13,8 +13,8 @@
  */
 
 
-#ifndef DIST2_HANDLER_H_
-#define DIST2_HANDLER_H_
+#ifndef OCT_HANDLER_H_
+#define OCT_HANDLER_H_
 
 #include <if/octopus_defs.h>
 #include <octopus/trigger.h>
@@ -25,4 +25,4 @@ void trigger_handler(struct octopus_binding*, octopus_trigger_id_t,
 void subscription_handler(struct octopus_binding*, subscription_t,
         uint64_t, octopus_mode_t, char*, uint64_t);
 
-#endif /* DIST2_HANDLER_H_ */
+#endif /* OCT_HANDLER_H_ */
index ffee1f0..57d265c 100644 (file)
@@ -1,6 +1,6 @@
 /**
  * \file
- * \brief Implementation of a synchronous locking API using the dist2 Interface.
+ * \brief Implementation of a synchronous locking API using the octopus Interface.
  */
 
 /*
@@ -103,7 +103,7 @@ errval_t oct_lock(const char* lock_name, char** lock_record)
                 free(record);
                 assert(mode & DIST_REMOVED);
             }
-            else if (err_no(exist_err) != DIST2_ERR_NO_RECORD) {
+            else if (err_no(exist_err) != OCT_ERR_NO_RECORD) {
                 err = exist_err;
                 goto out;
             }
index c276396..1ff6408 100644 (file)
@@ -29,7 +29,7 @@ errval_t nameservice_lookup(const char *iface, iref_t *retiref)
 
     char* record = NULL;
     err = oct_get(&record, iface);
-    if (err_no(err) == DIST2_ERR_NO_RECORD) {
+    if (err_no(err) == OCT_ERR_NO_RECORD) {
         return err_push(err, LIB_ERR_NAMESERVICE_UNKNOWN_NAME);
     }
 
@@ -61,13 +61,13 @@ errval_t nameservice_blocking_lookup(const char *iface, iref_t *retiref)
         return LIB_ERR_NAMESERVICE_NOT_BOUND;
     }
 
-    octopus_trigger_t t = oct_mktrigger(DIST2_ERR_NO_RECORD, DIST_ON_SET, 0, 0);
+    octopus_trigger_t t = oct_mktrigger(OCT_ERR_NO_RECORD, DIST_ON_SET, 0, 0);
     err = cl->call_seq.get(cl, iface, &record, t, &error_code);
     if (err_is_ok(err)) {
         err = error_code;
     }
 
-    if (err_no(err) == DIST2_ERR_NO_RECORD) {
+    if (err_no(err) == OCT_ERR_NO_RECORD) {
         assert(record == NULL);
         cl->recv.trigger(cl, &mode, &fn, &state, &record);
         err = SYS_ERR_OK;
index eb2585e..1ba67cd 100644 (file)
@@ -1,6 +1,6 @@
 /**
  * \file
- * \brief Initialization functions for the dist2 client library.
+ * \brief Initialization functions for the octopus client library.
  *
  * We use two bindings: One for communication with the server using RPC calls,
  * and one for asynchronous events coming from the server.
@@ -80,7 +80,7 @@ static int event_handler_thread(void* st)
         err = event_dispatch(&event.ws);
         if (err_is_fail(err)) {
             USER_PANIC_ERR(err,
-                    "error in event_dispatch for dist2 event binding");
+                    "error in event_dispatch for octopus event binding");
         }
     }
 
@@ -201,13 +201,13 @@ errval_t oct_thc_init(void)
 }
 
 /**
- * \brief Initializes the dist2 client library.
+ * \brief Initializes the octopus client library.
  *
- * Note the dist rpc binding is most likely already initialized
+ * Note the octopus rpc binding is most likely already initialized
  * by libbarrelfish (used for nameservice). This function
  * will set up the event thread to handle asynchronous events.
  *
- * \note This is a GCC constructor because we need dist2 calls in
+ * \note This is a GCC constructor because we need octopus calls in
  * posixcompat.
  */
 //__attribute__((constructor))
index b47f78b..c6ff136 100644 (file)
@@ -56,9 +56,9 @@ void subscription_handler(struct octopus_binding *b, subscription_t id,
  * \param ... Additional arguments to format the record using vsprintf.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_MAX_SUBSCRIPTIONS
- * \retval DIST2_ERR_PARSER_FAIL
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_MAX_SUBSCRIPTIONS
+ * \retval OCT_ERR_PARSER_FAIL
+ * \retval OCT_ERR_ENGINE_FAIL
  */
 errval_t oct_subscribe(subscription_handler_fn function, const void *state,
         subscription_t *id, const char *query, ...)
@@ -92,8 +92,8 @@ errval_t oct_subscribe(subscription_handler_fn function, const void *state,
  * \param id Id of the subscription (as provided by oct_subscribe).
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_PARSER_FAIL
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_PARSER_FAIL
+ * \retval OCT_ERR_ENGINE_FAIL
  */
 errval_t oct_unsubscribe(subscription_t id)
 {
@@ -115,8 +115,8 @@ errval_t oct_unsubscribe(subscription_t id)
  * \param ... Additional arguments to format the record using vsprintf.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_PARSER_FAIL
- * \retval DIST2_ERR_ENGINE_FAIL
+ * \retval OCT_ERR_PARSER_FAIL
+ * \retval OCT_ERR_ENGINE_FAIL
  */
 errval_t oct_publish(const char *record, ...)
 {
index 87aee0c..1f2d0e9 100644 (file)
@@ -40,7 +40,7 @@ static uint32_t get_next_id(void)
         err = oct_read(record, "_ { current_id: %d }", &id);
         assert(err_is_ok(err));
     }
-    else if (err_no(err) == DIST2_ERR_NO_RECORD) {
+    else if (err_no(err) == OCT_ERR_NO_RECORD) {
         err = oct_set("sem.ids { current_id: 0 }");
         assert(err_is_ok(err));
     }
@@ -88,7 +88,7 @@ errval_t oct_sem_wait(uint32_t id)
     errval_t err = SYS_ERR_OK;
     char* result = NULL;
     octopus_trigger_id_t tid;
-    octopus_trigger_t t = oct_mktrigger(DIST2_ERR_NO_RECORD,
+    octopus_trigger_t t = oct_mktrigger(OCT_ERR_NO_RECORD,
             octopus_BINDING_RPC, DIST_ON_SET, NULL, NULL);
     struct octopus_thc_client_binding_t* cl = oct_get_thc_client();
 
@@ -111,14 +111,14 @@ errval_t oct_sem_wait(uint32_t id)
             if (err_is_ok(del_err)) {
                 break; // Decreased successfully
             }
-            else if (err_no(del_err) == DIST2_ERR_NO_RECORD) {
+            else if (err_no(del_err) == OCT_ERR_NO_RECORD) {
                 continue; // Need to start over
             }
             else {
                 break; // Unexpected error
             }
         }
-        else if (err_no(err) == DIST2_ERR_NO_RECORD) {
+        else if (err_no(err) == OCT_ERR_NO_RECORD) {
             // No record found, wait until one is posted
             char* trigger_result = NULL;
             uint64_t fn, mode, state;
@@ -144,7 +144,7 @@ errval_t oct_sem_trywait(uint32_t id)
     if (err_is_ok(err)) {
         err = oct_del(result);
     }
-    else if (err_no(err) == DIST2_ERR_NO_RECORD) {
+    else if (err_no(err) == OCT_ERR_NO_RECORD) {
         // Return with no record error to caller
     }
 
index 9854fba..1871362 100644 (file)
@@ -54,7 +54,7 @@ octopus_trigger_t oct_mktrigger(errval_t in_case, octopus_binding_type_t send_to
 }
 
 /**
- * \brief Removes a trigger in the dist2 server.
+ * \brief Removes a trigger in the octopus server.
  *
  * In any case a valid watch id is specified this
  * causes a trigger event to be sent with the
@@ -64,7 +64,7 @@ octopus_trigger_t oct_mktrigger(errval_t in_case, octopus_binding_type_t send_to
  * \param trigger_id ID of trigger we want to remove
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_INVALID_ID
+ * \retval OCT_INVALID_ID
  */
 errval_t oct_remove_trigger(octopus_trigger_id_t trigger_id)
 {
index 9787d2c..0dbde8c 100644 (file)
@@ -16,7 +16,7 @@
 #include <assert.h>
 
 #ifdef TEST_PARSER
-#include "../../../include/dist2/parser/ast.h"
+#include "../../../include/octopus/parser/ast.h"
 #else
 #include <octopus/parser/ast.h>
 #endif
@@ -159,5 +159,5 @@ errval_t generate_ast(const char* input, struct ast_object** record)
     out:
     // Memory got cleaned up by bison destructors...
     *record = NULL;
-    return DIST2_ERR_PARSER_FAIL;
+    return OCT_ERR_PARSER_FAIL;
 }
index e02cf0f..b17ca95 100644 (file)
@@ -345,7 +345,7 @@ extern int yylex \
 #undef YY_DECL
 #endif
 
-#line 164 "scan.l"
+#line 150 "scan.l"
 
 
 #line 352 "flex.h"
index ad83b99..77616e6 100644 (file)
 /* Copy the first part of user declarations.  */
 
 /* Line 189 of yacc.c  */
-#line 1 "../lib/dist2/parser/parse.y"
+#line 1 "parse.y"
 
 #include <stdlib.h>
 #include <stdio.h>
 #include <assert.h>
 
 #ifdef TEST_PARSER
-#include "../../../include/dist2/parser/ast.h"
+#include "../../../include/octopus/parser/ast.h"
 #else
 #include <octopus/parser/ast.h>
 #endif
@@ -173,7 +173,7 @@ typedef union YYSTYPE
 {
 
 /* Line 214 of yacc.c  */
-#line 24 "../lib/dist2/parser/parse.y"
+#line 24 "parse.y"
 
     long long int integer;
     double dl;
@@ -1115,7 +1115,7 @@ yydestruct (yymsg, yytype, yyvaluep)
       case 21: /* "IDENT" */
 
 /* Line 1000 of yacc.c  */
-#line 64 "../lib/dist2/parser/parse.y"
+#line 64 "parse.y"
        { free((yyvaluep->str)); };
 
 /* Line 1000 of yacc.c  */
@@ -1124,7 +1124,7 @@ yydestruct (yymsg, yytype, yyvaluep)
       case 22: /* "REGEX" */
 
 /* Line 1000 of yacc.c  */
-#line 64 "../lib/dist2/parser/parse.y"
+#line 64 "parse.y"
        { free((yyvaluep->str)); };
 
 /* Line 1000 of yacc.c  */
@@ -1133,7 +1133,7 @@ yydestruct (yymsg, yytype, yyvaluep)
       case 23: /* "STRING" */
 
 /* Line 1000 of yacc.c  */
-#line 64 "../lib/dist2/parser/parse.y"
+#line 64 "parse.y"
        { free((yyvaluep->str)); };
 
 /* Line 1000 of yacc.c  */
@@ -1142,7 +1142,7 @@ yydestruct (yymsg, yytype, yyvaluep)
       case 27: /* "record" */
 
 /* Line 1000 of yacc.c  */
-#line 63 "../lib/dist2/parser/parse.y"
+#line 63 "parse.y"
        { free_ast((yyvaluep->nPtr)); };
 
 /* Line 1000 of yacc.c  */
@@ -1151,7 +1151,7 @@ yydestruct (yymsg, yytype, yyvaluep)
       case 28: /* "name" */
 
 /* Line 1000 of yacc.c  */
-#line 63 "../lib/dist2/parser/parse.y"
+#line 63 "parse.y"
        { free_ast((yyvaluep->nPtr)); };
 
 /* Line 1000 of yacc.c  */
@@ -1160,7 +1160,7 @@ yydestruct (yymsg, yytype, yyvaluep)
       case 29: /* "attributes" */
 
 /* Line 1000 of yacc.c  */
-#line 63 "../lib/dist2/parser/parse.y"
+#line 63 "parse.y"
        { free_ast((yyvaluep->nPtr)); };
 
 /* Line 1000 of yacc.c  */
@@ -1169,7 +1169,7 @@ yydestruct (yymsg, yytype, yyvaluep)
       case 30: /* "attribute" */
 
 /* Line 1000 of yacc.c  */
-#line 63 "../lib/dist2/parser/parse.y"
+#line 63 "parse.y"
        { free_ast((yyvaluep->nPtr)); };
 
 /* Line 1000 of yacc.c  */
@@ -1178,7 +1178,7 @@ yydestruct (yymsg, yytype, yyvaluep)
       case 31: /* "constraint" */
 
 /* Line 1000 of yacc.c  */
-#line 63 "../lib/dist2/parser/parse.y"
+#line 63 "parse.y"
        { free_ast((yyvaluep->nPtr)); };
 
 /* Line 1000 of yacc.c  */
@@ -1187,7 +1187,7 @@ yydestruct (yymsg, yytype, yyvaluep)
       case 32: /* "value" */
 
 /* Line 1000 of yacc.c  */
-#line 63 "../lib/dist2/parser/parse.y"
+#line 63 "parse.y"
        { free_ast((yyvaluep->nPtr)); };
 
 /* Line 1000 of yacc.c  */
@@ -1495,182 +1495,182 @@ yyreduce:
         case 2:
 
 /* Line 1455 of yacc.c  */
-#line 68 "../lib/dist2/parser/parse.y"
+#line 68 "parse.y"
     { ((struct oct_parser_state*) data)->ast = (yyvsp[(1) - (1)].nPtr); YYACCEPT;  }
     break;
 
   case 3:
 
 /* Line 1455 of yacc.c  */
-#line 71 "../lib/dist2/parser/parse.y"
+#line 71 "parse.y"
     { (yyval.nPtr) = ast_object((yyvsp[(1) - (2)].nPtr), NULL); }
     break;
 
   case 4:
 
 /* Line 1455 of yacc.c  */
-#line 72 "../lib/dist2/parser/parse.y"
+#line 72 "parse.y"
     { (yyval.nPtr) = ast_object((yyvsp[(1) - (3)].nPtr), NULL); }
     break;
 
   case 5:
 
 /* Line 1455 of yacc.c  */
-#line 73 "../lib/dist2/parser/parse.y"
+#line 73 "parse.y"
     { (yyval.nPtr) = ast_object((yyvsp[(1) - (4)].nPtr), (yyvsp[(3) - (4)].nPtr)); }
     break;
 
   case 6:
 
 /* Line 1455 of yacc.c  */
-#line 76 "../lib/dist2/parser/parse.y"
+#line 76 "parse.y"
     { (yyval.nPtr) = ast_ident((yyvsp[(1) - (1)].str)); }
     break;
 
   case 7:
 
 /* Line 1455 of yacc.c  */
-#line 77 "../lib/dist2/parser/parse.y"
+#line 77 "parse.y"
     { (yyval.nPtr) = ast_variable(); }
     break;
 
   case 8:
 
 /* Line 1455 of yacc.c  */
-#line 78 "../lib/dist2/parser/parse.y"
+#line 78 "parse.y"
     { (yyval.nPtr) = ast_scan((yyvsp[(1) - (1)].c)); }
     break;
 
   case 9:
 
 /* Line 1455 of yacc.c  */
-#line 79 "../lib/dist2/parser/parse.y"
+#line 79 "parse.y"
     { (yyval.nPtr) = ast_constraints(constraint_REGEX, ast_string((yyvsp[(1) - (1)].str))); }
     break;
 
   case 10:
 
 /* Line 1455 of yacc.c  */
-#line 82 "../lib/dist2/parser/parse.y"
+#line 82 "parse.y"
     { (yyval.nPtr) = ast_attribute((yyvsp[(1) - (1)].nPtr), NULL); }
     break;
 
   case 11:
 
 /* Line 1455 of yacc.c  */
-#line 83 "../lib/dist2/parser/parse.y"
+#line 83 "parse.y"
     { (yyval.nPtr) = ast_attribute((yyvsp[(1) - (3)].nPtr), (yyvsp[(3) - (3)].nPtr)); }
     break;
 
   case 12:
 
 /* Line 1455 of yacc.c  */
-#line 86 "../lib/dist2/parser/parse.y"
+#line 86 "parse.y"
     { (yyval.nPtr) = ast_pair(ast_ident((yyvsp[(1) - (3)].str)), (yyvsp[(3) - (3)].nPtr)); }
     break;
 
   case 13:
 
 /* Line 1455 of yacc.c  */
-#line 87 "../lib/dist2/parser/parse.y"
+#line 87 "parse.y"
     { (yyval.nPtr) = ast_pair(ast_ident((yyvsp[(1) - (2)].str)), (yyvsp[(2) - (2)].nPtr)); }
     break;
 
   case 14:
 
 /* Line 1455 of yacc.c  */
-#line 90 "../lib/dist2/parser/parse.y"
+#line 90 "parse.y"
     { (yyval.nPtr) = ast_constraints(constraint_GT, (yyvsp[(2) - (2)].nPtr));  }
     break;
 
   case 15:
 
 /* Line 1455 of yacc.c  */
-#line 91 "../lib/dist2/parser/parse.y"
+#line 91 "parse.y"
     { (yyval.nPtr) = ast_constraints(constraint_GE, (yyvsp[(2) - (2)].nPtr)); }
     break;
 
   case 16:
 
 /* Line 1455 of yacc.c  */
-#line 92 "../lib/dist2/parser/parse.y"
+#line 92 "parse.y"
     { (yyval.nPtr) = ast_constraints(constraint_LT, (yyvsp[(2) - (2)].nPtr)); }
     break;
 
   case 17:
 
 /* Line 1455 of yacc.c  */
-#line 93 "../lib/dist2/parser/parse.y"
+#line 93 "parse.y"
     { (yyval.nPtr) = ast_constraints(constraint_LE, (yyvsp[(2) - (2)].nPtr)); }
     break;
 
   case 18:
 
 /* Line 1455 of yacc.c  */
-#line 94 "../lib/dist2/parser/parse.y"
+#line 94 "parse.y"
     { (yyval.nPtr) = ast_constraints(constraint_EQ, (yyvsp[(2) - (2)].nPtr)); }
     break;
 
   case 19:
 
 /* Line 1455 of yacc.c  */
-#line 95 "../lib/dist2/parser/parse.y"
+#line 95 "parse.y"
     { (yyval.nPtr) = ast_constraints(constraint_NE, (yyvsp[(2) - (2)].nPtr)); }
     break;
 
   case 20:
 
 /* Line 1455 of yacc.c  */
-#line 96 "../lib/dist2/parser/parse.y"
+#line 96 "parse.y"
     { (yyval.nPtr) = ast_constraints(constraint_REGEX, ast_string((yyvsp[(2) - (2)].str))); }
     break;
 
   case 21:
 
 /* Line 1455 of yacc.c  */
-#line 97 "../lib/dist2/parser/parse.y"
+#line 97 "parse.y"
     { (yyval.nPtr) = ast_variable(); }
     break;
 
   case 22:
 
 /* Line 1455 of yacc.c  */
-#line 100 "../lib/dist2/parser/parse.y"
+#line 100 "parse.y"
     { (yyval.nPtr) = ast_ident((yyvsp[(1) - (1)].str)); }
     break;
 
   case 23:
 
 /* Line 1455 of yacc.c  */
-#line 101 "../lib/dist2/parser/parse.y"
+#line 101 "parse.y"
     { (yyval.nPtr) = ast_string((yyvsp[(1) - (1)].str)); }
     break;
 
   case 24:
 
 /* Line 1455 of yacc.c  */
-#line 102 "../lib/dist2/parser/parse.y"
+#line 102 "parse.y"
     { (yyval.nPtr) = ast_num((yyvsp[(1) - (1)].integer)); }
     break;
 
   case 25:
 
 /* Line 1455 of yacc.c  */
-#line 103 "../lib/dist2/parser/parse.y"
+#line 103 "parse.y"
     { (yyval.nPtr) = ast_boolean((yyvsp[(1) - (1)].integer)); }
     break;
 
   case 26:
 
 /* Line 1455 of yacc.c  */
-#line 104 "../lib/dist2/parser/parse.y"
+#line 104 "parse.y"
     { (yyval.nPtr) = ast_floatingpoint((yyvsp[(1) - (1)].dl)); }
     break;
 
   case 27:
 
 /* Line 1455 of yacc.c  */
-#line 105 "../lib/dist2/parser/parse.y"
+#line 105 "parse.y"
     { (yyval.nPtr) = ast_scan((yyvsp[(1) - (1)].c)); }
     break;
 
@@ -1889,12 +1889,12 @@ yyreturn:
 
 
 /* Line 1675 of yacc.c  */
-#line 106 "../lib/dist2/parser/parse.y"
+#line 106 "parse.y"
 
 
 void yyerror(char *s)
 {
-#ifdef DIST2_DEBUG
+#ifdef OCT_DEBUG
     fprintf(stderr, "octopus_parser: %s\n", s);
 #endif
 }
index 1345143..534f6dc 100644 (file)
@@ -107,7 +107,7 @@ value:
 
 void yyerror(char *s)
 {
-#ifdef DIST2_DEBUG
+#ifdef OCT_DEBUG
     fprintf(stderr, "octopus_parser: %s\n", s);
 #endif
 }
index 3132720..2215964 100644 (file)
  * \param ... Values read are stored in the provided arguments.
  *
  * \retval SYS_ERR_OK
- * \retval DIST2_ERR_ATTRIBUTE_NOT_FOUND
- * \retval DIST2_ERR_TYPE_MISMATCH
- * \retval DIST2_ERR_RECORD_NAME_MISMATCH
- * \retval DIST2_ERR_ATTRIBUTE_MISMATCH
+ * \retval OCT_ERR_ATTRIBUTE_NOT_FOUND
+ * \retval OCT_ERR_TYPE_MISMATCH
+ * \retval OCT_ERR_RECORD_NAME_MISMATCH
+ * \retval OCT_ERR_ATTRIBUTE_MISMATCH
  */
 errval_t oct_read(const char* record, const char* format, ...)
 {
@@ -64,7 +64,7 @@ errval_t oct_read(const char* record, const char* format, ...)
        switch(format_name->type) {
        case nodeType_Scan:
                if(format_name->u.scn.c != 's') {
-                       err = DIST2_ERR_INVALID_FORMAT;
+                       err = OCT_ERR_INVALID_FORMAT;
                        goto out;
                }
                s = va_arg(args, char**);
@@ -78,7 +78,7 @@ errval_t oct_read(const char* record, const char* format, ...)
                break;
 
        default:
-               err = DIST2_ERR_INVALID_FORMAT;
+               err = OCT_ERR_INVALID_FORMAT;
                goto out;
                break;
        }
@@ -93,7 +93,7 @@ errval_t oct_read(const char* record, const char* format, ...)
                assert(format_attr->type == nodeType_Pair);
                assert(format_attr->u.pn.left->type == nodeType_Ident);
                if(format_attr->u.pn.right->type != nodeType_Scan) {
-                       err = DIST2_ERR_INVALID_FORMAT;
+                       err = OCT_ERR_INVALID_FORMAT;
                        goto out;
                }
 
@@ -101,7 +101,7 @@ errval_t oct_read(const char* record, const char* format, ...)
                struct ast_object* record_attr = ast_find_attribute(ast,
                        format_attr->u.pn.left->u.in.str);
                if(record_attr == NULL) {
-                       err = DIST2_ERR_UNKNOWN_ATTRIBUTE;
+                       err = OCT_ERR_UNKNOWN_ATTRIBUTE;
                        goto out;
                }
                struct ast_object* value = record_attr->u.pn.right;
@@ -118,7 +118,7 @@ errval_t oct_read(const char* record, const char* format, ...)
                                value->u.sn.str = NULL;
                        }
                        else {
-                               err = DIST2_ERR_INVALID_FORMAT;
+                               err = OCT_ERR_INVALID_FORMAT;
                                goto out;
                        }
                        break;
@@ -130,7 +130,7 @@ errval_t oct_read(const char* record, const char* format, ...)
                        }
                        else {
                                *i = 0;
-                               err = DIST2_ERR_INVALID_FORMAT;
+                               err = OCT_ERR_INVALID_FORMAT;
                                goto out;
                        }
                        break;
@@ -142,13 +142,13 @@ errval_t oct_read(const char* record, const char* format, ...)
                        }
                        else {
                                *d = 0.0;
-                               err = DIST2_ERR_INVALID_FORMAT;
+                               err = OCT_ERR_INVALID_FORMAT;
                                goto out;
                        }
                        break;
 
                default:
-                       err = DIST2_ERR_INVALID_FORMAT;
+                       err = OCT_ERR_INVALID_FORMAT;
                        goto out;
                        break;
                }
index 0718b23..63de0ab 100644 (file)
@@ -480,8 +480,8 @@ static yyconst flex_int16_t yy_chk[126] =
 #define yymore() yymore_used_but_not_detected
 #define YY_MORE_ADJ 0
 #define YY_RESTORE_YY_MORE_OFFSET
-#line 1 "../lib/dist2/parser/scan.l"
-#line 2 "../lib/dist2/parser/scan.l"
+#line 1 "scan.l"
+#line 2 "scan.l"
 #include <stdlib.h>
 #include <stdio.h>
 #include <string.h>
@@ -489,7 +489,7 @@ static yyconst flex_int16_t yy_chk[126] =
 #include "y.tab.h"
 
 #ifdef TEST_PARSER
-#include "../../../include/dist2/parser/ast.h"
+#include "../../../include/octopus/parser/ast.h"
 #else
 #include <octopus/parser/ast.h>
 #endif
@@ -735,7 +735,7 @@ YY_DECL
        register int yy_act;
     struct yyguts_t * yyg = (struct yyguts_t*)yyscanner;
 
-#line 62 "../lib/dist2/parser/scan.l"
+#line 62 "scan.l"
 
 #line 741 "<stdout>"
 
@@ -820,7 +820,7 @@ do_action:  /* This label is used only to access EOF actions. */
 
 case 1:
 YY_RULE_SETUP
-#line 63 "../lib/dist2/parser/scan.l"
+#line 63 "scan.l"
 {
                 yylval->integer = (strcmp(yytext, "true") == 0) ? 1 : 0;
                 return BOOL;
@@ -828,7 +828,7 @@ YY_RULE_SETUP
        YY_BREAK
 case 2:
 YY_RULE_SETUP
-#line 68 "../lib/dist2/parser/scan.l"
+#line 68 "scan.l"
 {
                 yylval->dl = atof(yytext);
                 return FLOAT;
@@ -836,7 +836,7 @@ YY_RULE_SETUP
        YY_BREAK
 case 3:
 YY_RULE_SETUP
-#line 74 "../lib/dist2/parser/scan.l"
+#line 74 "scan.l"
 { 
                 yylval->str = strdup(yytext);
                 return IDENT; 
@@ -844,7 +844,7 @@ YY_RULE_SETUP
        YY_BREAK
 case 4:
 YY_RULE_SETUP
-#line 79 "../lib/dist2/parser/scan.l"
+#line 79 "scan.l"
 {
                 yylval->c = yytext[1];
                 return SCAN;
@@ -852,19 +852,19 @@ YY_RULE_SETUP
        YY_BREAK
 case 5:
 YY_RULE_SETUP
-#line 84 "../lib/dist2/parser/scan.l"
+#line 84 "scan.l"
 {
                 return VARIABLE;
             }
        YY_BREAK
 case 6:
 YY_RULE_SETUP
-#line 88 "../lib/dist2/parser/scan.l"
+#line 88 "scan.l"
 { yyextra->ptr = yyextra->buffer; BEGIN(REG); }
        YY_BREAK
 case 7:
 YY_RULE_SETUP
-#line 90 "../lib/dist2/parser/scan.l"
+#line 90 "scan.l"
 { /* saw closing quote - all done */
      BEGIN(INITIAL);
      *yyextra->ptr = '\0';
@@ -875,7 +875,7 @@ YY_RULE_SETUP
 case 8:
 /* rule 8 can match eol */
 YY_RULE_SETUP
-#line 97 "../lib/dist2/parser/scan.l"
+#line 97 "scan.l"
 {
      char *yptr = yytext;
 
@@ -885,12 +885,12 @@ YY_RULE_SETUP
        YY_BREAK
 case 9:
 YY_RULE_SETUP
-#line 105 "../lib/dist2/parser/scan.l"
+#line 105 "scan.l"
 { yyextra->ptr = yyextra->buffer; BEGIN(STR); }
        YY_BREAK
 case 10:
 YY_RULE_SETUP
-#line 107 "../lib/dist2/parser/scan.l"
+#line 107 "scan.l"
 { /* saw closing quote - all done */
      BEGIN(INITIAL);
      *yyextra->ptr = '\0';
@@ -901,7 +901,7 @@ YY_RULE_SETUP
 case 11:
 /* rule 11 can match eol */
 YY_RULE_SETUP
-#line 114 "../lib/dist2/parser/scan.l"
+#line 114 "scan.l"
 {
      char *yptr = yytext;
 
@@ -911,7 +911,7 @@ YY_RULE_SETUP
        YY_BREAK
 case 12:
 YY_RULE_SETUP
-#line 121 "../lib/dist2/parser/scan.l"
+#line 121 "scan.l"
 {
                 yylval->integer = atoll(yytext);
                 return NUMBER;
@@ -919,92 +919,92 @@ YY_RULE_SETUP
        YY_BREAK
 case 13:
 YY_RULE_SETUP
-#line 126 "../lib/dist2/parser/scan.l"
+#line 126 "scan.l"
 return RCURLY; 
        YY_BREAK
 case 14:
 YY_RULE_SETUP
-#line 127 "../lib/dist2/parser/scan.l"
+#line 127 "scan.l"
 return LCURLY;
        YY_BREAK
 case 15:
 YY_RULE_SETUP
-#line 128 "../lib/dist2/parser/scan.l"
+#line 128 "scan.l"
 return RBRACKET;
        YY_BREAK
 case 16:
 YY_RULE_SETUP
-#line 129 "../lib/dist2/parser/scan.l"
+#line 129 "scan.l"
 return COMMA;
        YY_BREAK
 case 17:
 YY_RULE_SETUP
-#line 130 "../lib/dist2/parser/scan.l"
+#line 130 "scan.l"
 return LBRACKET; 
        YY_BREAK
 case 18:
 YY_RULE_SETUP
-#line 131 "../lib/dist2/parser/scan.l"
+#line 131 "scan.l"
 return COLON;
        YY_BREAK
 case 19:
 YY_RULE_SETUP
-#line 133 "../lib/dist2/parser/scan.l"
+#line 133 "scan.l"
 return GT;
        YY_BREAK
 case 20:
 YY_RULE_SETUP
-#line 134 "../lib/dist2/parser/scan.l"
+#line 134 "scan.l"
 return GE;
        YY_BREAK
 case 21:
 YY_RULE_SETUP
-#line 135 "../lib/dist2/parser/scan.l"
+#line 135 "scan.l"
 return LT;
        YY_BREAK
 case 22:
 YY_RULE_SETUP
-#line 136 "../lib/dist2/parser/scan.l"
+#line 136 "scan.l"
 return LE;
        YY_BREAK
 case 23:
 YY_RULE_SETUP
-#line 137 "../lib/dist2/parser/scan.l"
+#line 137 "scan.l"
 return EQ;
        YY_BREAK
 case 24:
 YY_RULE_SETUP
-#line 138 "../lib/dist2/parser/scan.l"
+#line 138 "scan.l"
 return NE;
        YY_BREAK
 case 25:
 /* rule 25 can match eol */
 YY_RULE_SETUP
-#line 141 "../lib/dist2/parser/scan.l"
+#line 141 "scan.l"
 { }
        YY_BREAK
 case 26:
 /* rule 26 can match eol */
 YY_RULE_SETUP
-#line 142 "../lib/dist2/parser/scan.l"
+#line 142 "scan.l"
 { /* eat up whitespace */ }
        YY_BREAK
 case YY_STATE_EOF(INITIAL):
 case YY_STATE_EOF(REG):
 case YY_STATE_EOF(STR):
-#line 144 "../lib/dist2/parser/scan.l"
+#line 144 "scan.l"
 return END_OF_INPUT;
        YY_BREAK
 case 27:
 YY_RULE_SETUP
-#line 146 "../lib/dist2/parser/scan.l"
+#line 146 "scan.l"
 {
                 yyerror("Unexpected input!");
             }
        YY_BREAK
 case 28:
 YY_RULE_SETUP
-#line 150 "../lib/dist2/parser/scan.l"
+#line 150 "scan.l"
 ECHO;
        YY_BREAK
 #line 1011 "<stdout>"
@@ -2131,7 +2131,7 @@ void yyfree (void * ptr , yyscan_t yyscanner)
 
 #define YYTABLES_NAME "yytables"
 
-#line 150 "../lib/dist2/parser/scan.l"
+#line 150 "scan.l"
 
 
 
index 076c5c5..8cb5c81 100644 (file)
@@ -6,9 +6,9 @@
 #include "y.tab.h"
 
 #ifdef TEST_PARSER
-#include "../../../include/dist2/parser/ast.h"
+#include "../../../include/octopus/parser/ast.h"
 #else
-#include <dist2/parser/ast.h>
+#include <octopus/parser/ast.h>
 #endif
 
 // not in C99 :-(
index c37868b..2f68e67 100644 (file)
@@ -21,7 +21,7 @@
 
 
 #ifdef TEST_PARSER
-#include "../../../include/dist2/parser/ast.h"
+#include "../../../include/octopus/parser/ast.h"
 #else
 #include <octopus/parser/ast.h>
 #endif
index abefa23..6022d17 100644 (file)
@@ -61,7 +61,7 @@ void get_cap_handler(struct octopus_binding *b, char *key)
     capdb->d.get_capability(&capdb->d, key, &cap);
 
     if(capcmp(cap, NULL_CAP)) {
-        reterr = DIST2_ERR_CAP_NAME_UNKNOWN;
+        reterr = OCT_ERR_CAP_NAME_UNKNOWN;
     }
 
     struct oct_reply_state* ns = NULL;
@@ -97,7 +97,7 @@ void put_cap_handler(struct octopus_binding *b, char *key,
 
     capdb->d.get_capability(&capdb->d, key, &dbcap);
     if(!capcmp(dbcap, NULL_CAP)) {
-        reterr = DIST2_ERR_CAP_OVERWRITE;
+        reterr = OCT_ERR_CAP_OVERWRITE;
         err = cap_delete(cap);
         assert(err_is_ok(err));
     } else {
@@ -136,7 +136,7 @@ void remove_cap_handler(struct octopus_binding *b, char *key)
     struct capref cap;
     capdb->d.get_capability(&capdb->d, key, &cap);
     if(capcmp(cap, NULL_CAP)) {
-        reterr = DIST2_ERR_CAP_NAME_UNKNOWN;
+        reterr = OCT_ERR_CAP_NAME_UNKNOWN;
     }
     else {
         cap_delete(cap);
index adc82ec..ecde51c 100644 (file)
@@ -1,6 +1,6 @@
 /**
  * \file
- * \brief Code to initialize the dist2 server.
+ * \brief Code to initialize the octopus server.
  *
  * Sets up bindings and vtables.
  */
@@ -24,7 +24,7 @@
 #include <octopus_server/service.h>
 #include <octopus_server/debug.h>
 
-#define DIST2_RPC_SERVICE_NAME "octopus_rpc"
+#define OCT_RPC_SERVICE_NAME "octopus_rpc"
 
 static struct export_state {
     bool is_done;
@@ -60,7 +60,7 @@ static void rpc_export_cb(void *st, errval_t err, iref_t iref)
 
     if (err_is_ok(err)) {
         struct monitor_binding *mb = get_monitor_binding();
-        DIST2_DEBUG("dist2 rpc iref is: %d\n", iref);
+        OCT_DEBUG("octopus rpc iref is: %d\n", iref);
         err = mb->tx_vtbl.set_name_iref_request(mb, NOP_CONT, iref);
         if(err_is_fail(err)) {
             USER_PANIC_ERR(err, "failed to send set_name_iref_request to monitor");
@@ -101,7 +101,7 @@ errval_t rpc_server_init(void)
 }
 
 /**
- * \brief Sets up bindings for the dist2 server and registers them in the
+ * \brief Sets up bindings for the octopus server and registers them in the
  * nameserver.
  *
  * \retval SYS_ERR_OK
index 1cfcd35..c234ad2 100644 (file)
@@ -1,6 +1,6 @@
 /**
  * \file
- * \brief Queue for stack-ripped dist2 server-side handler code
+ * \brief Queue for stack-ripped octopus server-side handler code
  */
 
 /*
@@ -12,8 +12,8 @@
  * ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
  */
 
-#ifndef DIST2_QUEUE_H
-#define DIST2_QUEUE_H
+#ifndef OCTOPUS_QUEUE_H
+#define OCTOPUS_QUEUE_H
 
 #include <barrelfish/barrelfish.h>
 #include <if/octopus_defs.h>
@@ -24,4 +24,4 @@ void oct_rpc_enqueue_reply(struct octopus_binding *b,
         struct oct_reply_state* st);
 struct oct_reply_state* oct_rpc_dequeue_reply(struct octopus_binding *b);
 
-#endif // DIST2_QUEUE_H
+#endif // OCTOPUS_QUEUE_H
index f8d9aa1..961c9ec 100644 (file)
@@ -1,6 +1,6 @@
 /**
  * \file
- * \brief Contains handler functions for server-side dist2 interface RPC call.
+ * \brief Contains handler functions for server-side octopus interface RPC call.
  */
 
 /*
@@ -35,7 +35,7 @@ static uint64_t current_id = 1;
 
 static inline errval_t check_query_length(char* query) {
     if (strlen(query) >= MAX_QUERY_LENGTH) {
-        return DIST2_ERR_QUERY_SIZE;
+        return OCT_ERR_QUERY_SIZE;
     }
 
     return SYS_ERR_OK;
@@ -244,7 +244,7 @@ static void get_names_reply(struct octopus_binding* b,
 
 void get_names_handler(struct octopus_binding *b, char *query, octopus_trigger_t t)
 {
-    DIST2_DEBUG(" get_names_handler: %s\n", query);
+    OCT_DEBUG(" get_names_handler: %s\n", query);
 
     errval_t err = SYS_ERR_OK;
 
@@ -293,7 +293,7 @@ static void set_reply(struct octopus_binding* b, struct oct_reply_state* drs)
 void set_handler(struct octopus_binding *b, char *query, uint64_t mode,
         octopus_trigger_t trigger, bool get)
 {
-    DIST2_DEBUG(" set_handler: %s\n", query);
+    OCT_DEBUG(" set_handler: %s\n", query);
     errval_t err = SYS_ERR_OK;
 
     struct oct_reply_state* drs = NULL;
@@ -318,7 +318,7 @@ void set_handler(struct octopus_binding *b, char *query, uint64_t mode,
             // allow name to be a regex/variable, because
             // we it's not guaranteed which records get
             // modified in this case.
-            err = DIST2_ERR_NO_RECORD_NAME;
+            err = OCT_ERR_NO_RECORD_NAME;
         }
     }
 
@@ -347,7 +347,7 @@ static void del_reply(struct octopus_binding* b, struct oct_reply_state* drs)
 
 void del_handler(struct octopus_binding* b, char* query, octopus_trigger_t trigger)
 {
-    DIST2_DEBUG(" del_handler: %s\n", query);
+    OCT_DEBUG(" del_handler: %s\n", query);
     errval_t err = SYS_ERR_OK;
 
     struct oct_reply_state* drs = NULL;
@@ -371,7 +371,7 @@ void del_handler(struct octopus_binding* b, char* query, octopus_trigger_t trigg
             // Since we don't have any ACLs atm. we do not
             // allow name to be a regex/variable
             // (see set_handler).
-            err = DIST2_ERR_NO_RECORD_NAME;
+            err = OCT_ERR_NO_RECORD_NAME;
         }
     }
 
@@ -463,7 +463,7 @@ void wait_for_handler(struct octopus_binding* b, char* query) {
     err = generate_ast(query, &ast);
     if (err_is_ok(err)) {
         err = get_record(ast, &drs->query_state);
-        if (err_no(err) == DIST2_ERR_NO_RECORD) {
+        if (err_no(err) == OCT_ERR_NO_RECORD) {
             debug_printf("waiting for: %s\n", query);
             uint64_t wid;
             set_watch_err = set_watch(b, ast, DIST_ON_SET, drs, &wid);
@@ -471,10 +471,10 @@ void wait_for_handler(struct octopus_binding* b, char* query) {
     }
 
 out:
-    if (err_no(err) != DIST2_ERR_NO_RECORD || err_is_fail(set_watch_err)) {
+    if (err_no(err) != OCT_ERR_NO_RECORD || err_is_fail(set_watch_err)) {
         drs->error = err;
         if (err_is_fail(set_watch_err)) {
-            // implies err = DIST2_ERR_NO_RECORD
+            // implies err = OCT_ERR_NO_RECORD
             drs->error = set_watch_err;
         }
         drs->reply(b, drs);
@@ -503,7 +503,7 @@ static void subscribe_reply(struct octopus_binding* b,
 void subscribe_handler(struct octopus_binding *b, char* query,
         uint64_t trigger_fn, uint64_t state)
 {
-    DIST2_DEBUG("subscribe: query = %s\n", query);
+    OCT_DEBUG("subscribe: query = %s\n", query);
     errval_t err = SYS_ERR_OK;
 
     struct oct_reply_state* drs = NULL;
@@ -568,7 +568,7 @@ void unsubscribe_handler(struct octopus_binding *b, uint64_t id)
 {
     errval_t err = SYS_ERR_OK;
 
-    DIST2_DEBUG("unsubscribe: id = %lu\n", id);
+    OCT_DEBUG("unsubscribe: id = %lu\n", id);
 
     struct oct_reply_state* srs = NULL;
     err = new_oct_reply_state(&srs, unsubscribe_reply);
@@ -596,7 +596,7 @@ void unsubscribe_handler(struct octopus_binding *b, uint64_t id)
         subscriber->server_id = server_id;
         subscriber->mode = DIST_REMOVED;
 
-        DIST2_DEBUG("publish msg to: recipient:%lu id:%lu\n", binding, server_id);
+        OCT_DEBUG("publish msg to: recipient:%lu id:%lu\n", binding, server_id);
         subscriber->reply(subscriber->binding, subscriber);
     }
 
@@ -620,7 +620,7 @@ static void publish_reply(struct octopus_binding* b, struct oct_reply_state* drs
 
 void publish_handler(struct octopus_binding *b, char* record)
 {
-    DIST2_DEBUG("publish_handler query: %s\n", record);
+    OCT_DEBUG("publish_handler query: %s\n", record);
     errval_t err = SYS_ERR_OK;
 
     struct oct_reply_state* drs = NULL;
@@ -676,7 +676,7 @@ void publish_handler(struct octopus_binding *b, char* record)
                 subscriber->server_id = server_id;
                 subscriber->mode = DIST_ON_PUBLISH;
 
-                DIST2_DEBUG("publish msg to: recipient:%lu id:%lu\n", binding, server_id);
+                OCT_DEBUG("publish msg to: recipient:%lu id:%lu\n", binding, server_id);
                 subscriber->reply(subscriber->binding, subscriber);
             }
         }
@@ -719,7 +719,7 @@ void identify_binding(struct octopus_binding* b, uint64_t id,
     errval_t err = new_oct_reply_state(&drs, identify_binding_reply);
     assert(err_is_ok(err));
 
-    DIST2_DEBUG("set binding: id=%lu type=%d\n", id, type);
+    OCT_DEBUG("set binding: id=%lu type=%d\n", id, type);
     drs->error = set_binding(type, id, b);
     drs->reply(b, drs);
 }
index 4a94c61..243ae81 100644 (file)
@@ -24,8 +24,8 @@
                              "shm.c", "getpid.c", "ioctl.c", "fcntl.c",
                              "sockets.c", "select.c", "grp.c", "rename.c",
                             "remove.c", "time.c", "random.c", "inheritance.c" ],
-                  flounderDefs = [ "unixsock", "dist2", "monitor" ],
-                 flounderBindings = [ "unixsock" ],
-                  flounderExtraBindings = [ ("dist2", ["rpcclient"]) ]
+                  flounderDefs = [ "unixsock", "octopus", "monitor" ],
+                 flounderBindings = [ "unixsock", "octopus" ],
+                  flounderTHCStubs = [ "octopus" ]
                 }
 ]
index 1772925..011c1ea 100644 (file)
@@ -94,7 +94,7 @@ int sem_trywait(sem_t *sem)
                        POSIXCOMPAT_DEBUG("%d: sem_trywait(%p, %u) success!\n", disp_get_domain_id(), sem, sem->id);
             return 0;
         }
-        else if (err_no(err) == DIST2_ERR_NO_RECORD) {
+        else if (err_no(err) == OCT_ERR_NO_RECORD) {
                        POSIXCOMPAT_DEBUG("%d: sem_trywait(%p, %u) no success\n", disp_get_domain_id(), sem, sem->id);
             errno = EAGAIN;
             return -1;
index 244069e..07409df 100644 (file)
@@ -141,11 +141,11 @@ int shmget(key_t key, size_t size, int shmflg)
         errval_t err = oct_get_capability(skey, &s->frame);
         POSIXCOMPAT_DEBUG("returned!\n");
 
-        if(err_is_fail(err) && err_no(err) != DIST2_ERR_CAP_NAME_UNKNOWN) {
+        if(err_is_fail(err) && err_no(err) != OCT_ERR_CAP_NAME_UNKNOWN) {
             USER_PANIC_ERR(err, "nameservice_get_capability");
         }
 
-        if(err == DIST2_ERR_CAP_NAME_UNKNOWN) {
+        if(err == OCT_ERR_CAP_NAME_UNKNOWN) {
             if(!(shmflg & IPC_CREAT)) {
                 errno = ENOENT;
                 return -1;
index 8d9d963..7fd8b8c 100644 (file)
@@ -135,7 +135,7 @@ int main(int argc, char *argv[])
     errval_t err;
     err = oct_init();
     if (err_is_fail(err)) {
-        USER_PANIC_ERR(err, "Connect to dist Service");
+        USER_PANIC_ERR(err, "Connect to octopus Service");
     }
 
     // Connect to the SKB
index 22b07af..25682d4 100644 (file)
@@ -40,7 +40,7 @@ errval_t trigger_existing_and_watch(const char* query,
                 event_handler(DIST_ON_SET, record, state);
                 break;
 
-            case DIST2_ERR_NO_RECORD:
+            case OCT_ERR_NO_RECORD:
                 assert(record == NULL);
                 break;
 
@@ -51,7 +51,7 @@ errval_t trigger_existing_and_watch(const char* query,
             }
         }
         break;
-    case DIST2_ERR_NO_RECORD:
+    case OCT_ERR_NO_RECORD:
         err = SYS_ERR_OK; // Overwrite (trigger is set)
         break;
 
index 16414b1..daf2ca2 100644 (file)
@@ -90,7 +90,7 @@ int main(int argc, char** argv)
 
     err = oct_init();
     if (err_is_fail(err)) {
-        USER_PANIC_ERR(err, "Initialize dist library.");
+        USER_PANIC_ERR(err, "Initialize octopus service.");
     }
 
     err = init_boot_modules();
index aad8d9b..388ef1d 100644 (file)
@@ -48,7 +48,7 @@ static errval_t wait_for_spawnd(coreid_t core, void* state)
     char* iref_record = NULL;
     octopus_trigger_id_t tid;
     errval_t error_code;
-    octopus_trigger_t t = oct_mktrigger(DIST2_ERR_NO_RECORD,
+    octopus_trigger_t t = oct_mktrigger(OCT_ERR_NO_RECORD,
             octopus_BINDING_EVENT, DIST_ON_SET, spawnd_up_event, state);
 
     // Construct service name
@@ -111,7 +111,7 @@ static void pci_change_event(octopus_mode_t mode, char* device_record, void* st)
         // is ready
         if (st == NULL && core != my_core_id) {
             err = wait_for_spawnd(core, device_record);
-            if (err_no(err) == DIST2_ERR_NO_RECORD) {
+            if (err_no(err) == OCT_ERR_NO_RECORD) {
                 KALUGA_DEBUG("Core where driver %s runs is not up yet.\n",
                         mi->binary);
                 // Don't want to free device record yet...
index 4de9f18..8b6df77 100644 (file)
@@ -95,7 +95,7 @@ static char* skip_index_remove(hash_table* ht, uint64_t key, char* value)
 
 int p_save_index(void)
 {
-    DIST2_DEBUG("p_save_index\n");
+    OCT_DEBUG("p_save_index\n");
     init_index();
 
     char* value = NULL;
@@ -113,7 +113,7 @@ int p_save_index(void)
         char* attribute;
         ec_get_string(attribute_term, &attribute);
 
-        DIST2_DEBUG("insert %s(%p) into index[%s]=", record_name, record_name, attribute);
+        OCT_DEBUG("insert %s(%p) into index[%s]=", record_name, record_name, attribute);
         uint64_t key = fnv_64a_str(attribute, FNV1A_64_INIT);
         int res = skip_index_insert(record_index, key, record_name);
         assert(res == PSUCCEED);
@@ -148,7 +148,7 @@ int p_remove_index(void)
 
         uint64_t key = fnv_64a_str(attribute, FNV1A_64_INIT);
         to_free = skip_index_remove(record_index, key, name);
-        DIST2_DEBUG("removed %s(%p) from index[%s]=", name, to_free, attribute);
+        OCT_DEBUG("removed %s(%p) from index[%s]=", name, to_free, attribute);
         //assert(to_free != NULL);
     }
 
@@ -158,7 +158,7 @@ int p_remove_index(void)
 
 int p_index_intersect(void) /* p_index_intersect(type, -[Attributes], -Current, +Next) */
 {
-    DIST2_DEBUG("p_index_intersect\n");
+    OCT_DEBUG("p_index_intersect\n");
     static struct skip_list** sets = NULL;
     static char* next = NULL;
     static size_t elems = 0;
@@ -177,7 +177,7 @@ int p_index_intersect(void) /* p_index_intersect(type, -[Attributes], -Current,
 
     res = ec_get_string(ec_arg(3), &next);
     if (res != PSUCCEED) {
-        DIST2_DEBUG("state is not a string, find skip lists\n");
+        OCT_DEBUG("state is not a string, find skip lists\n");
         free(sets);
         pword list, cur, rest;
 
@@ -199,7 +199,7 @@ int p_index_intersect(void) /* p_index_intersect(type, -[Attributes], -Current,
             if (sl == NULL) {
                 return PFAIL;
             }
-            DIST2_DEBUG("skip_intersect found skip list for key: %s\n", key);
+            OCT_DEBUG("skip_intersect found skip list for key: %s\n", key);
             //skip_print_list(sl);
 
             sets[i] = sl;
@@ -209,7 +209,7 @@ int p_index_intersect(void) /* p_index_intersect(type, -[Attributes], -Current,
     }
 
     next = skip_intersect(sets, elems, next);
-    DIST2_DEBUG("skip_intersect found next: %s\n", next);
+    OCT_DEBUG("skip_intersect found next: %s\n", next);
     if(next != NULL) {
         dident item = ec_did(next, 0);
         return ec_unify_arg(4, ec_atom(item));
@@ -220,7 +220,7 @@ int p_index_intersect(void) /* p_index_intersect(type, -[Attributes], -Current,
 
 int p_index_union(void) /* p_index_union(type, -[Attributes], -Current, +Next) */
 {
-    DIST2_DEBUG("p_index_union\n");
+    OCT_DEBUG("p_index_union\n");
     static hash_table* union_ht = NULL;
     static char* next = NULL;
 
@@ -238,7 +238,7 @@ int p_index_union(void) /* p_index_union(type, -[Attributes], -Current, +Next) *
 
     res = ec_get_string(ec_arg(3), &next);
     if (res != PSUCCEED) {
-        DIST2_DEBUG("state is not a string, find skip lists\n");
+        OCT_DEBUG("state is not a string, find skip lists\n");
         if (union_ht != NULL) {
             hash_release(union_ht);
             union_ht = NULL;
@@ -257,14 +257,14 @@ int p_index_union(void) /* p_index_union(type, -[Attributes], -Current, +Next) *
 
             // Insert all entries in union hash table
             if (sl != NULL) {
-                DIST2_DEBUG("p_index_union found skip list for key: %s\n", key);
+                OCT_DEBUG("p_index_union found skip list for key: %s\n", key);
                 //skip_print_list(sl);
 
                 struct skip_node* sentry = sl->header->forward[0];
                 while(sentry != NULL) {
                     uint64_t hash_key = fnv_64a_str(sentry->element, FNV1A_64_INIT);
                     if(hash_find(union_ht, hash_key) == NULL) {
-                        DIST2_DEBUG("p_index_union insert: %s\n", sentry->element);
+                        OCT_DEBUG("p_index_union insert: %s\n", sentry->element);
                         hash_insert(union_ht, hash_key, sentry->element);
                     }
                     sentry = sentry->forward[0];
@@ -278,7 +278,7 @@ int p_index_union(void) /* p_index_union(type, -[Attributes], -Current, +Next) *
 
     uint64_t hash_key;
     next = hash_traverse_next(union_ht, &hash_key);
-    DIST2_DEBUG("skip_union found next: %s\n", next);
+    OCT_DEBUG("skip_union found next: %s\n", next);
     if(next != NULL) {
         dident item = ec_did(next, 0);
         return ec_unify_arg(4, ec_atom(item));
@@ -412,7 +412,7 @@ int p_bitfield_remove(void) /* p_bitfield_remove(Storage, +Name, +[AttributeList
 
 int p_bitfield_union(void) /* p_index_union(Storage, -[Attributes], -Current, +Next) */
 {
-    DIST2_DEBUG("p_bitfield_union\n");
+    OCT_DEBUG("p_bitfield_union\n");
     static struct bitfield** sets = NULL;
     static long int next = -1;
     static size_t elems = 0;
@@ -437,7 +437,7 @@ int p_bitfield_union(void) /* p_index_union(Storage, -[Attributes], -Current, +N
 
     res = ec_get_long(ec_arg(3), &next);
     if (res != PSUCCEED) {
-        DIST2_DEBUG("state is not a id, find bitmaps\n");
+        OCT_DEBUG("state is not a id, find bitmaps\n");
         free(sets);
         pword list, cur, rest;
 
@@ -458,7 +458,7 @@ int p_bitfield_union(void) /* p_index_union(Storage, -[Attributes], -Current, +N
             uint64_t hash_key = fnv_64a_str(key, FNV1A_64_INIT);
             struct bitfield* sl = hash_find(ht, hash_key);
             if (sl != NULL) {
-                DIST2_DEBUG("bitfield_union found bitfield for key: %s\n", key);
+                OCT_DEBUG("bitfield_union found bitfield for key: %s\n", key);
                 sets[elems++] = sl;
             }
             // else: no record with this attribute, just ignore
@@ -468,7 +468,7 @@ int p_bitfield_union(void) /* p_index_union(Storage, -[Attributes], -Current, +N
     }
 
     next = bitfield_union(sets, elems, next);
-    DIST2_DEBUG("bitfield_union found next: %ld\n", next);
+    OCT_DEBUG("bitfield_union found next: %ld\n", next);
     if(next != -1) {
         pword item = ec_long(next);
         return ec_unify_arg(4, item);
@@ -483,7 +483,7 @@ extern struct bitfield* trigger_ids;
 int p_trigger_watch(void) /* p_trigger_watch(+String, +Mode, +Recipient, +WatchId, -Retract) */
 {
     int res;
-    DIST2_DEBUG("\n*** p_trigger_watch: start\n");
+    OCT_DEBUG("\n*** p_trigger_watch: start\n");
 
     // Get arguments
     char* record = NULL;
@@ -514,7 +514,7 @@ int p_trigger_watch(void) /* p_trigger_watch(+String, +Mode, +Recipient, +WatchI
         return res;
     }
     assert(drs != NULL);
-    DIST2_DEBUG("drs is: %p\n", drs);
+    OCT_DEBUG("drs is: %p\n", drs);
 
     long int watch_id = 0;
     res = ec_get_long(ec_arg(5), &watch_id);
@@ -522,9 +522,9 @@ int p_trigger_watch(void) /* p_trigger_watch(+String, +Mode, +Recipient, +WatchI
         return res;
     }
 
-    DIST2_DEBUG("p_trigger_watch: %s\n", record);
-    DIST2_DEBUG("drs->binding: %p\n", drs->binding);
-    DIST2_DEBUG("drs->reply: %p\n", drs->reply);
+    OCT_DEBUG("p_trigger_watch: %s\n", record);
+    OCT_DEBUG("drs->binding: %p\n", drs->binding);
+    OCT_DEBUG("drs->reply: %p\n", drs->reply);
 
 
     drs->error = SYS_ERR_OK;
@@ -550,7 +550,7 @@ int p_trigger_watch(void) /* p_trigger_watch(+String, +Mode, +Recipient, +WatchI
         }
         else {
             assert(trigger_ids != NULL);
-            DIST2_DEBUG("turn off trigger id: %lu\n", watch_id);
+            OCT_DEBUG("turn off trigger id: %lu\n", watch_id);
             bitfield_off(trigger_ids, watch_id);
         }
 
@@ -567,6 +567,6 @@ int p_trigger_watch(void) /* p_trigger_watch(+String, +Mode, +Recipient, +WatchI
         USER_PANIC("No binding set for watch_id: %lu", watch_id);
     }
 
-    DIST2_DEBUG("p_trigger_watch: done");
+    OCT_DEBUG("p_trigger_watch: done");
     return ec_unify_arg(6, ec_long(retract));
 }
index 37e00db..d47cf84 100644 (file)
@@ -65,7 +65,7 @@ static errval_t transform_ec_error(int res)
         break;
 
     default:
-        DIST2_DEBUG("Unexpected Eclipse error: %d", res);
+        OCT_DEBUG("Unexpected Eclipse error: %d", res);
         assert(!"Should not happen");
         break;
     }
@@ -119,7 +119,7 @@ static errval_t run_eclipse(struct oct_query_state* st)
 
     errval_t err = transform_ec_error(st->exec_res);
     if (err_no(err) == SKB_ERR_EXECUTION) {
-        err = err_push(err, DIST2_ERR_ENGINE_FAIL);
+        err = err_push(err, OCT_ERR_ENGINE_FAIL);
     }
 
     return err;
@@ -127,7 +127,7 @@ static errval_t run_eclipse(struct oct_query_state* st)
 
 static void debug_skb_output(struct oct_query_state* st)
 {
-    DIST2_DEBUG(
+    OCT_DEBUG(
             " output: %s error: %s error_code: %d\n", st->stdout.buffer, st->stderr.buffer, st->exec_res);
 }
 
@@ -153,10 +153,10 @@ errval_t get_record(struct ast_object* ast, struct oct_query_state* sqs)
 
         err = run_eclipse(sqs);
         if (err_no(err) == SKB_ERR_GOAL_FAILURE) {
-            err = err_push(err, DIST2_ERR_NO_RECORD);
+            err = err_push(err, OCT_ERR_NO_RECORD);
         }
 
-        DIST2_DEBUG(" get_record:\n");
+        OCT_DEBUG(" get_record:\n");
         debug_skb_output(sqs);
     }
 
@@ -194,14 +194,14 @@ errval_t get_record_names(struct ast_object* ast, struct oct_query_state* dqs)
 
         err = run_eclipse(dqs);
         if (err_is_ok(err) && dqs->stdout.buffer[0] == '\0') {
-            err = DIST2_ERR_NO_RECORD;
+            err = OCT_ERR_NO_RECORD;
         }
         else if (err_no(err) == SKB_ERR_GOAL_FAILURE) {
             assert(!"findall failed - should not happen!");
             // see http://eclipseclp.org/doc/bips/kernel/allsols/findall-3.html
         }
 
-        DIST2_DEBUG(" get_record_names:\n");
+        OCT_DEBUG(" get_record_names:\n");
         debug_skb_output(dqs);
     }
 
@@ -231,13 +231,13 @@ errval_t set_record(struct ast_object* ast, uint64_t mode,
         ec_post_goal(add_object_term);
 
         err = run_eclipse(sqs);
-        DIST2_DEBUG(" set_record:\n");
+        OCT_DEBUG(" set_record:\n");
         debug_skb_output(sqs);
 
         if (err_no(err) == SKB_ERR_GOAL_FAILURE) {
-            /*DIST2_DEBUG("Goal failure during set record. Should not happen!\n");
+            /*OCT_DEBUG("Goal failure during set record. Should not happen!\n");
             assert(!"SKB_ERR_GOAL_FAILURE during set?");*/
-            err = err_push(err, DIST2_ERR_CONSTRAINT_MISMATCH);
+            err = err_push(err, OCT_ERR_CONSTRAINT_MISMATCH);
         }
     }
 
@@ -263,9 +263,9 @@ errval_t del_record(struct ast_object* ast, struct oct_query_state* dqs)
 
         err = run_eclipse(dqs);
         if (err_no(err) == SKB_ERR_GOAL_FAILURE) {
-            err = err_push(err, DIST2_ERR_NO_RECORD);
+            err = err_push(err, OCT_ERR_NO_RECORD);
         }
-        DIST2_DEBUG(" del_record:\n");
+        OCT_DEBUG(" del_record:\n");
         debug_skb_output(dqs);
     }
 
@@ -283,7 +283,7 @@ static errval_t find_free_id(struct bitfield* bf, uint64_t* id)
         }
     }
 
-    return DIST2_ERR_MAX_SUBSCRIPTIONS;
+    return OCT_ERR_MAX_SUBSCRIPTIONS;
 }
 
 static errval_t init_bitmap(struct bitfield** bf)
@@ -347,7 +347,7 @@ errval_t set_watch(struct octopus_binding* b, struct ast_object* ast,
             bitfield_off(trigger_ids, *wid);
         }
 
-        DIST2_DEBUG("set watch\n");
+        OCT_DEBUG("set watch\n");
         debug_skb_output(&drs->query_state);
     }
 
@@ -365,10 +365,10 @@ errval_t del_watch(struct octopus_binding* b, octopus_trigger_id_t id,
 
     errval_t err = run_eclipse(dqs);
     if (err_no(err) == SKB_ERR_GOAL_FAILURE) {
-        err = err_push(err, DIST2_ERR_INVALID_ID);
+        err = err_push(err, OCT_ERR_INVALID_ID);
     }
 
-    DIST2_DEBUG(" del_trigger id is %lu:\n", id);
+    OCT_DEBUG(" del_trigger id is %lu:\n", id);
     debug_skb_output(dqs);
 
     return err;
@@ -379,7 +379,7 @@ struct octopus_binding* get_event_binding(struct octopus_binding* b)
     errval_t err = SYS_ERR_OK;
     struct oct_query_state* dqs = calloc(1, sizeof(struct oct_query_state));
     if (dqs == NULL) {
-        DIST2_DEBUG("Server out of memory.");
+        OCT_DEBUG("Server out of memory.");
         return NULL;
     }
 
@@ -398,13 +398,13 @@ struct octopus_binding* get_event_binding(struct octopus_binding* b)
 
     err = run_eclipse(dqs);
     if (err_is_fail(err)) {
-        DIST2_DEBUG("No event binding found for client.");
+        OCT_DEBUG("No event binding found for client.");
         assert(!"Should not happen - check client initialization code!");
 
         return NULL;
     }
 
-    DIST2_DEBUG("get_event_binding\n");
+    OCT_DEBUG("get_event_binding\n");
     debug_skb_output(dqs);
 
     struct octopus_binding* recipient = NULL;
@@ -449,7 +449,7 @@ errval_t add_subscription(struct octopus_binding* b, struct ast_object* ast,
             bitfield_off(subscriber_ids, drs->server_id);
         }
 
-        DIST2_DEBUG("add_subscription\n");
+        OCT_DEBUG("add_subscription\n");
         debug_skb_output(&drs->query_state);
     }
 
@@ -475,10 +475,10 @@ errval_t del_subscription(struct octopus_binding* b, uint64_t id,
         bitfield_off(subscriber_ids, id);
     }
     if (err_no(err) == SKB_ERR_GOAL_FAILURE) {
-        err = err_push(err, DIST2_ERR_NO_SUBSCRIPTION);
+        err = err_push(err, OCT_ERR_NO_SUBSCRIPTION);
     }
 
-    DIST2_DEBUG("del_subscription:\n");
+    OCT_DEBUG("del_subscription:\n");
     debug_skb_output(sqs);
 
     return err;
@@ -509,11 +509,11 @@ errval_t find_subscribers(struct ast_object* ast, struct oct_query_state* sqs)
 
         err = run_eclipse(sqs);
         if (err_no(err) == SKB_ERR_GOAL_FAILURE) {
-            err = err_push(err, DIST2_ERR_NO_SUBSCRIBERS);
+            err = err_push(err, OCT_ERR_NO_SUBSCRIBERS);
         }
     }
 
-    DIST2_DEBUG("find_subscribers\n");
+    OCT_DEBUG("find_subscribers\n");
     debug_skb_output(sqs);
 
     return err;
@@ -537,7 +537,7 @@ errval_t set_binding(octopus_binding_type_t type, uint64_t id, void* binding)
         break;
 
     default:
-        return DIST2_ERR_UNSUPPORTED_BINDING;
+        return OCT_ERR_UNSUPPORTED_BINDING;
         break;
     }
 
@@ -547,8 +547,8 @@ errval_t set_binding(octopus_binding_type_t type, uint64_t id, void* binding)
     ec_post_goal(set_term);
 
     errval_t err = run_eclipse(dqs);
-    DIST2_DEBUG("set_binding: %p\n", binding);
-    DIST2_DEBUG("error: %s\n", dqs->stderr.buffer);
+    OCT_DEBUG("set_binding: %p\n", binding);
+    OCT_DEBUG("error: %s\n", dqs->stderr.buffer);
 
     free(dqs);
     return err;
index fdadfa8..a0df9d3 100644 (file)
@@ -61,12 +61,12 @@ static void get_names(void)
     err = oct_get_names(&names, &size, "asdfasd", 20);
     assert(names == NULL);
     assert(size == 0);
-    ASSERT_ERR(err, DIST2_ERR_NO_RECORD);
+    ASSERT_ERR(err, OCT_ERR_NO_RECORD);
 
     err = oct_get_names(&names, &size, "}+_df}");
     assert(names == NULL);
     assert(size == 0);
-    ASSERT_ERR(err, DIST2_ERR_PARSER_FAIL);
+    ASSERT_ERR(err, OCT_ERR_PARSER_FAIL);
 
     printf("get_names() done!\n");
 }
@@ -77,11 +77,11 @@ static void get_records(void)
     char* data = NULL;
 
     err = oct_get(&data, "recordDoesNotExist");
-    ASSERT_ERR(err, DIST2_ERR_NO_RECORD);
+    ASSERT_ERR(err, OCT_ERR_NO_RECORD);
     assert(data == NULL);
 
     err = oct_get(&data, "parser { error, m, }");
-    ASSERT_ERR(err, DIST2_ERR_PARSER_FAIL);
+    ASSERT_ERR(err, OCT_ERR_PARSER_FAIL);
     assert(data == NULL);
 
 
@@ -109,7 +109,7 @@ static void get_records(void)
     ASSERT_ERR_OK(err);
 
     err = oct_get(&data, "object4");
-    ASSERT_ERR(err, DIST2_ERR_NO_RECORD);
+    ASSERT_ERR(err, OCT_ERR_NO_RECORD);
     //free(data); TODO??
 
     err = oct_set("object4 { attr: 'Somestring', fl: 12.0, weight: 20 }");
@@ -125,7 +125,7 @@ static void get_records(void)
 
     err = oct_get(&data, "object1");
     //printf("data: %s\n", data);
-    ASSERT_ERR(err, DIST2_ERR_NO_RECORD);
+    ASSERT_ERR(err, OCT_ERR_NO_RECORD);
     // TODO free(data);?
 
     /*err = oct_get(&data, "object2 { weight: 25 }");
@@ -160,10 +160,10 @@ static void get_records(void)
 static void exist_records(void)
 {
     errval_t err = oct_exists("././12");
-    ASSERT_ERR(err, DIST2_ERR_PARSER_FAIL);
+    ASSERT_ERR(err, OCT_ERR_PARSER_FAIL);
 
     err = oct_exists("recordDoesNotExist");
-    ASSERT_ERR(err, DIST2_ERR_NO_RECORD);
+    ASSERT_ERR(err, OCT_ERR_NO_RECORD);
 
     err = oct_exists("object3 { fl > 10, weight: _ }");
     ASSERT_ERR_OK(err);
@@ -172,7 +172,7 @@ static void exist_records(void)
 static void set_records(void)
 {
     errval_t err = oct_set("q{weqw1,.");
-    ASSERT_ERR(err, DIST2_ERR_PARSER_FAIL);
+    ASSERT_ERR(err, OCT_ERR_PARSER_FAIL);
 
     err = oct_set("object1 { weight: %d }", 20);
     ASSERT_ERR_OK(err);
@@ -228,7 +228,7 @@ static void regex_name(void)
     ASSERT_ERR_OK(err);
 
     err = oct_set("r'obj.$' { attr: 12 }");
-    ASSERT_ERR(err, DIST2_ERR_NO_RECORD_NAME);
+    ASSERT_ERR(err, OCT_ERR_NO_RECORD_NAME);
 
     char** names = NULL;
     size_t len = 0;
@@ -239,7 +239,7 @@ static void regex_name(void)
     oct_free_names(names, len);
 
     err = oct_del("r'obj.$' { attr: 12}");
-    ASSERT_ERR(err, DIST2_ERR_NO_RECORD_NAME);
+    ASSERT_ERR(err, OCT_ERR_NO_RECORD_NAME);
 
     printf("regex_name() done!\n");
 }
index a3ca829..744251a 100644 (file)
@@ -62,7 +62,7 @@ static void subscriber(void)
     thread_sem_init(&ts, 0);
 
     err = oct_subscribe(message_handler, &received, &id1, "111 [] attr: 10 }");
-    ASSERT_ERR(err, DIST2_ERR_PARSER_FAIL);
+    ASSERT_ERR(err, OCT_ERR_PARSER_FAIL);
 
     err = oct_subscribe(message_handler, &received, &id1,
             "_ { fl: 1.01, attr: 10 }");
index 7b69c71..009c724 100644 (file)
@@ -36,7 +36,7 @@ int main(int argc, char *argv[])
     ASSERT_ERR_OK(err);
 
     err = oct_sem_trywait(id);
-    ASSERT_ERR(err, DIST2_ERR_NO_RECORD);
+    ASSERT_ERR(err, OCT_ERR_NO_RECORD);
 
     err = oct_sem_post(id);
     ASSERT_ERR_OK(err);
@@ -51,7 +51,7 @@ int main(int argc, char *argv[])
     ASSERT_ERR_OK(err);
 
     err = oct_sem_trywait(id);
-    ASSERT_ERR(err, DIST2_ERR_NO_RECORD);
+    ASSERT_ERR(err, OCT_ERR_NO_RECORD);
 
     printf("d2sem SUCCESS!\n");
     return EXIT_SUCCESS;