FS-7500: add partition mode to switch_buffer

diff --git a/src/include/switch_buffer.h b/src/include/switch_buffer.h
index e6cc2ad7d5d3b961dfebdde486fcbd2d1c4991a4..a3c503234313e24345e9f7ded099125aeaee5af2 100644 (file)
--- a/src/include/switch_buffer.h
+++ b/src/include/switch_buffer.h
@@ -52,6 +52,10 @@ SWITCH_BEGIN_EXTERN_C
        struct switch_buffer;
 
 
+SWITCH_DECLARE(switch_status_t) switch_buffer_create_partition(switch_memory_pool_t *pool, switch_buffer_t **buffer, void *data, switch_size_t datalen);
+SWITCH_DECLARE(switch_status_t) switch_buffer_set_partition_data(switch_buffer_t *buffer, void *data, switch_size_t datalen);
+SWITCH_DECLARE(switch_status_t) switch_buffer_reset_partition_data(switch_buffer_t *buffer);
+
 /*! \brief Allocate a new switch_buffer 
  * \param pool Pool to allocate the buffer from
  * \param buffer returned pointer to the new buffer

diff --git a/src/switch_buffer.c b/src/switch_buffer.c
index d9ac5748902de65e8962cba658b9d5953729313a..56b0b94bb109ac925f9d61c7b7f500623ad33668 100644 (file)
--- a/src/switch_buffer.c
+++ b/src/switch_buffer.c
@@ -35,7 +35,8 @@
 static uint32_t buffer_id = 0;
 
 typedef enum {
-       SWITCH_BUFFER_FLAG_DYNAMIC = (1 << 0)
+       SWITCH_BUFFER_FLAG_DYNAMIC = (1 << 0),
+       SWITCH_BUFFER_FLAG_PARTITION = (1 << 1)
 } switch_buffer_flag_t;
 
 struct switch_buffer {
@@ -52,6 +53,43 @@ struct switch_buffer {
        int32_t loops;
 };
 
+SWITCH_DECLARE(switch_status_t) switch_buffer_reset_partition_data(switch_buffer_t *buffer)
+{
+       if (!switch_test_flag(buffer, SWITCH_BUFFER_FLAG_PARTITION)) {
+               return SWITCH_STATUS_FALSE;
+       }
+
+       buffer->head = buffer->data;
+       buffer->used = buffer->actually_used = buffer->datalen;
+
+       return SWITCH_STATUS_SUCCESS;
+}
+
+SWITCH_DECLARE(switch_status_t) switch_buffer_set_partition_data(switch_buffer_t *buffer, void *data, switch_size_t datalen)
+{
+       if (!switch_test_flag(buffer, SWITCH_BUFFER_FLAG_PARTITION)) {
+               return SWITCH_STATUS_FALSE;
+       }
+
+       buffer->data = data;
+       buffer->datalen = datalen;
+       return switch_buffer_reset_partition_data(buffer);
+}
+
+SWITCH_DECLARE(switch_status_t) switch_buffer_create_partition(switch_memory_pool_t *pool, switch_buffer_t **buffer, void *data, switch_size_t datalen)
+{
+       switch_buffer_t *new_buffer;
+
+       if ((new_buffer = switch_core_alloc(pool, sizeof(switch_buffer_t))) != 0) {
+               new_buffer->id = buffer_id++;
+               switch_set_flag(new_buffer, SWITCH_BUFFER_FLAG_PARTITION);
+               switch_buffer_set_partition_data(new_buffer, data, datalen);
+               *buffer = new_buffer;
+               return SWITCH_STATUS_SUCCESS;
+       }
+       return SWITCH_STATUS_MEMERR;
+}
+
 SWITCH_DECLARE(switch_status_t) switch_buffer_create(switch_memory_pool_t *pool, switch_buffer_t **buffer, switch_size_t max_len)
 {
        switch_buffer_t *new_buffer;
@@ -244,6 +282,10 @@ SWITCH_DECLARE(switch_size_t) switch_buffer_write(switch_buffer_t *buffer, const
 {
        switch_size_t freespace, actual_freespace;
 
+       if (switch_test_flag(buffer, SWITCH_BUFFER_FLAG_PARTITION)) {
+               return 0;
+       }
+
        switch_assert(buffer->data != NULL);
 
        if (!datalen) {
@@ -306,6 +348,10 @@ SWITCH_DECLARE(switch_size_t) switch_buffer_zwrite(switch_buffer_t *buffer, cons
 {
        switch_size_t w;
 
+       if (switch_test_flag(buffer, SWITCH_BUFFER_FLAG_PARTITION)) {
+               return 0;
+       }
+
        if (!(w = switch_buffer_write(buffer, data, datalen))) {
                switch_buffer_zero(buffer);
                return switch_buffer_write(buffer, data, datalen);
@@ -318,6 +364,10 @@ SWITCH_DECLARE(switch_size_t) switch_buffer_slide_write(switch_buffer_t *buffer,
 {
        switch_size_t w;
 
+       if (switch_test_flag(buffer, SWITCH_BUFFER_FLAG_PARTITION)) {
+               return 0;
+       }
+
        if (!(w = switch_buffer_write(buffer, data, datalen))) {
                switch_buffer_toss(buffer, datalen);
                return switch_buffer_write(buffer, data, datalen);