add group negotiations to frescan and change all the requests and messages to map...

[frescor/fna.git] / src_frescan / frescan_bwres_requests.c

diff --git a/src_frescan/frescan_bwres_requests.c b/src_frescan/frescan_bwres_requests.c
index b32b227cf30e2dfdc543ec399ee2da7e97d45d3e..16a1b00b1f46cd32b11a37a580db2fba870bdf7b 100644 (file)
--- a/src_frescan/frescan_bwres_requests.c
+++ b/src_frescan/frescan_bwres_requests.c
@@ -83,7 +83,7 @@ static bool is_initialized = false;
  **/
 
 struct request_t {
-        frescan_request_data_t request_data;
+        frescan_bwres_request_data_t request_data;
         struct list_head       request_list;
         int pool_pos;
 };
@@ -91,19 +91,19 @@ struct request_t {
 static fosa_mutex_t requests_mutex;
 static fosa_cond_t  requests_cond;
 
-static struct request_t the_requests_pool[FRESCAN_MX_REQUESTS];
+static struct request_t the_requests_pool[FRESCAN_BWRES_MX_REQUESTS];
 static freelist_t freelist;
 
 static struct request_t the_requests_list;
 
 /**
- * frescan_requests_init()
+ * frescan_bwres_requests_init()
  *
  * Init the freelist, requests list, cond var and mutex.
  *
  **/
 
-int frescan_requests_init(int max_ceiling)
+int frescan_bwres_requests_init(int max_ceiling)
 {
         int err;
 
@@ -113,7 +113,7 @@ int frescan_requests_init(int max_ceiling)
         err = fosa_cond_init(&requests_cond);
         if (err != 0) return err;
 
-        err = freelist_init(&freelist, FRESCAN_MX_REQUESTS);
+        err = freelist_init(&freelist, FRESCAN_BWRES_MX_REQUESTS);
         if (err != 0) return err;
 
         INIT_LIST_HEAD(&the_requests_list.request_list);
@@ -123,17 +123,17 @@ int frescan_requests_init(int max_ceiling)
 }
 
 /**
- * frescan_requests_alloc()
+ * frescan_bwres_requests_alloc()
  *
  * Allocate a request with the mutex locked
  *
  **/
 
-int frescan_requests_alloc(frescan_request_id_t *req)
+int frescan_bwres_requests_alloc(frescan_bwres_request_id_t *req)
 {
         int err, pos;
 
-        DEBUG(FRESCAN_REQUESTS_ENABLE_DEBUG, "alloc\n");
+        DEBUG(FRESCAN_BWRES_REQUESTS_ENABLE_DEBUG, "alloc\n");
 
         if (is_initialized == false) return -1;
 
@@ -157,17 +157,17 @@ locked_error:
 }
 
 /**
- * frescan_requests_free()
+ * frescan_bwres_requests_free()
  *
  * free the request from the pool
  *
  **/
 
-int frescan_requests_free(frescan_request_id_t req)
+int frescan_bwres_requests_free(frescan_bwres_request_id_t req)
 {
         int err;
 
-        DEBUG(FRESCAN_REQUESTS_ENABLE_DEBUG, "free\n");
+        DEBUG(FRESCAN_BWRES_REQUESTS_ENABLE_DEBUG, "free\n");
 
         if (is_initialized == false) return -1;
 
@@ -188,38 +188,38 @@ locked_error:
 }
 
 /**
- * frescan_requests_get_data() - gets the data of the request
+ * frescan_bwres_requests_get_data() - gets the data of the request
  *
  */
 
-int frescan_requests_get_data(frescan_request_id_t   req,
-                              frescan_request_data_t **data)
+int frescan_bwres_requests_get_data(frescan_bwres_request_id_t   req,
+                              frescan_bwres_request_data_t **data)
 {
-        DEBUG(FRESCAN_REQUESTS_ENABLE_DEBUG, "request id:%d\n", req);
+        DEBUG(FRESCAN_BWRES_REQUESTS_ENABLE_DEBUG, "request id:%d\n", req);
         *data = &the_requests_pool[req].request_data;
         return 0;
 }
 
 /**
- * frescan_requests_enqueue()
+ * frescan_bwres_requests_enqueue()
  *
  **/
 
-int frescan_requests_enqueue(frescan_request_id_t req)
+int frescan_bwres_requests_enqueue(frescan_bwres_request_id_t req)
 {
         int err;
 
         err = fosa_mutex_lock(&requests_mutex);
         if (err != 0) return err;
 
-        DEBUG(FRESCAN_REQUESTS_ENABLE_DEBUG,
+        DEBUG(FRESCAN_BWRES_REQUESTS_ENABLE_DEBUG,
               "is list empty A? %d\n",
               list_empty(&the_requests_list.request_list));
 
         list_add_tail(&the_requests_pool[req].request_list,
                       &the_requests_list.request_list);
 
-        DEBUG(FRESCAN_REQUESTS_ENABLE_DEBUG,
+        DEBUG(FRESCAN_BWRES_REQUESTS_ENABLE_DEBUG,
               "is list empty B? %d\n",
               list_empty(&the_requests_list.request_list));
 
@@ -237,11 +237,11 @@ locked_error:
 }
 
 /**
- * frescan_requestqueue_dequeue()
+ * frescan_bwres_requestqueue_dequeue()
  *
  **/
 
-int frescan_requests_dequeue(frescan_request_id_t *req)
+int frescan_bwres_requests_dequeue(frescan_bwres_request_id_t *req)
 {
         int err;
         struct list_head *pos;
@@ -250,15 +250,15 @@ int frescan_requests_dequeue(frescan_request_id_t *req)
         err = fosa_mutex_lock(&requests_mutex);
         if (err != 0) return err;
 
-        DEBUG(FRESCAN_REQUESTS_ENABLE_DEBUG, "entering\n");
+        DEBUG(FRESCAN_BWRES_REQUESTS_ENABLE_DEBUG, "entering\n");
 
         while (list_empty(&the_requests_list.request_list)) {
                 err = fosa_cond_wait(&requests_cond, &requests_mutex);
                 if (err != 0) goto locked_error;
-                DEBUG(FRESCAN_REQUESTS_ENABLE_DEBUG, "received signal\n");
+                DEBUG(FRESCAN_BWRES_REQUESTS_ENABLE_DEBUG, "received signal\n");
         }
 
-        DEBUG(FRESCAN_REQUESTS_ENABLE_DEBUG, "dequeueing a request\n");
+        DEBUG(FRESCAN_BWRES_REQUESTS_ENABLE_DEBUG, "dequeueing a request\n");
 
         list_for_each(pos, &the_requests_list.request_list) {
                 request = list_entry(pos, struct request_t, request_list);
@@ -269,7 +269,7 @@ int frescan_requests_dequeue(frescan_request_id_t *req)
 
         *req = request->pool_pos;
 
-        DEBUG(FRESCAN_REQUESTS_ENABLE_DEBUG,
+        DEBUG(FRESCAN_BWRES_REQUESTS_ENABLE_DEBUG,
               "is list empty now? %d\n",
               list_empty(&the_requests_list.request_list));