Allow to set per service ring buffer, with configurable size.

Guenther

Signed-off-by: Simo Sorce <simo@redhat.com>

1 files changed, 45 insertions, 0 deletions

diff --git a/proxy/src/gp_config.c b/proxy/src/gp_config.c
index 7e9de68..0e81de6 100644
--- a/proxy/src/gp_config.c
+++ b/proxy/src/gp_config.c
@@ -126,6 +126,42 @@ static int get_krb5_mech_cfg(struct gp_service *svc,
     return 0;
 }
 
+static int setup_service_ring_buffer(struct gp_config *cfg,
+                                     struct gp_service *svc,
+                                     int buffer_size)
+{
+    uint32_t ret_maj, ret_min;
+    struct gp_ring_buffer **newrb;
+    uint32_t num;
+
+    if (buffer_size == -1) {
+        /* a reasonable default ? */
+        buffer_size = GP_RING_BUFFER_SIZE;
+    }
+
+    num = cfg->num_ring_buffers;
+    newrb = realloc(cfg->ring_buffers,
+                    sizeof(struct gp_ring_buffer *) * (num + 1));
+    if (!newrb) {
+        return ENOMEM;
+    }
+    cfg->ring_buffers = newrb;
+
+    ret_maj = gp_init_ring_buffer(&ret_min,
+                                  svc->name,
+                                  buffer_size,
+                                  &cfg->ring_buffers[num]);
+    if (ret_maj) {
+        return ret_min;
+    }
+
+    cfg->num_ring_buffers++;
+
+    svc->ring_buffer = cfg->ring_buffers[num];
+
+    return 0;
+}
+
 static int load_services(struct gp_config *cfg, dictionary *dict)
 {
     int num_sec;
@@ -191,6 +227,15 @@ static int load_services(struct gp_config *cfg, dictionary *dict)
                 cfg->svcs[n]->ring_buffer = cfg->ring_buffers[1];
             }
 
+            value = get_char_value(dict, secname, "dedicated_ring_buffer");
+            if (value && option_is_set(value)) {
+                valnum = get_int_value(dict, secname, "ring_buffer_size");
+                ret = setup_service_ring_buffer(cfg, cfg->svcs[n], valnum);
+                if (ret) {
+                    goto done;
+                }
+            }
+
             value = get_char_value(dict, secname, "mechs");
             if (value == NULL) {
                 /* malformed section, mech is missing */