summaryrefslogtreecommitdiff
path: root/src/http_decoder/http_decoder_result_queue.c
diff options
context:
space:
mode:
authoryangwei <[email protected]>2024-05-28 02:07:20 +0800
committeryangwei <[email protected]>2024-05-28 04:40:31 +0800
commitba8450caed9876a463fbfefc7a521cc62bce432e (patch)
tree552986583d706751572d39b180422811d5bb3e03 /src/http_decoder/http_decoder_result_queue.c
parent0737ab92295eca2690e875db240f1b0af495d7dc (diff)
🧪 test(remove http decoder): rm related source code
Diffstat (limited to 'src/http_decoder/http_decoder_result_queue.c')
-rw-r--r--src/http_decoder/http_decoder_result_queue.c155
1 files changed, 0 insertions, 155 deletions
diff --git a/src/http_decoder/http_decoder_result_queue.c b/src/http_decoder/http_decoder_result_queue.c
deleted file mode 100644
index eb7b2d1..0000000
--- a/src/http_decoder/http_decoder_result_queue.c
+++ /dev/null
@@ -1,155 +0,0 @@
-/*
-**********************************************************************************************
-* File: http_decoder_result_queue.c
-* Description:
-* Authors: Liuwentan <[email protected]>
-* Date: 2024-01-15
-* Copyright: (c) Since 2022 Geedge Networks, Ltd. All rights reserved.
-***********************************************************************************************
-*/
-
-#include <assert.h>
-
-#include "stellar/utils.h"
-#include "http_decoder_half.h"
-#include "http_decoder_result_queue.h"
-
-struct http_decoder_result_queue *
-http_decoder_result_queue_new(size_t queue_size)
-{
- struct http_decoder_result_queue *queue =
- CALLOC(struct http_decoder_result_queue, 1);
- assert(queue);
-
- queue->req_index = 0;
- queue->res_index = 0;
- queue->queue_size = queue_size;
-
- queue->array = CALLOC(struct http_decoder_result, queue->queue_size);
- assert(queue->array);
-
- return queue;
-}
-
-void http_decoder_result_queue_free(struct http_decoder_result_queue *queue)
-{
- if (NULL == queue) {
- return;
- }
-
- if (queue->array != NULL) {
- for (size_t i = 0; i < queue->queue_size; i++) {
- if (queue->array[i].req_data != NULL) {
- http_decoder_half_data_free(queue->array[i].req_data);
- queue->array[i].req_data = NULL;
- }
-
- if (queue->array[i].res_data != NULL) {
- http_decoder_half_data_free(queue->array[i].res_data);
- queue->array[i].res_data = NULL;
- }
- }
-
- FREE(queue->array);
- }
-
- FREE(queue);
-}
-
-void http_decoder_result_queue_inc_req_index(struct http_decoder_result_queue *queue)
-{
- assert(queue);
-
- queue->req_index++;
- queue->req_index = queue->req_index % queue->queue_size;
-}
-
-void http_decoder_result_queue_inc_res_index(struct http_decoder_result_queue *queue)
-{
- assert(queue);
-
- queue->res_index++;
- queue->res_index = queue->res_index % queue->queue_size;
-}
-
-int http_decoder_result_queue_push_req(struct http_decoder_result_queue *queue,
- struct http_decoder_half_data *req_data)
-{
- if (NULL == queue || NULL == req_data) {
- return -1;
- }
-
- assert(queue->array[queue->req_index].req_data == NULL);
- if (queue->array[queue->req_index].req_data != NULL) {
- return -1;
- }
-
- queue->array[queue->req_index].req_data = req_data;
- return 0;
-}
-
-int http_decoder_result_queue_push_res(struct http_decoder_result_queue *queue,
- struct http_decoder_half_data *res_data)
-{
- if (NULL == queue || NULL == res_data) {
- return -1;
- }
-
- assert(queue->array[queue->res_index].res_data == NULL);
- if (queue->array[queue->res_index].res_data != NULL) {
- return -1;
- }
-
- queue->array[queue->res_index].res_data = res_data;
- return 0;
-}
-
-struct http_decoder_half_data *
-http_decoder_result_queue_pop_req(struct http_decoder_result_queue *queue)
-{
- if (NULL == queue) {
- return NULL;
- }
-
- struct http_decoder_half_data *req_data =
- queue->array[queue->req_index].req_data;
- queue->array[queue->req_index].req_data = NULL;
-
- return req_data;
-}
-
-struct http_decoder_half_data *
-http_decoder_result_queue_pop_res(struct http_decoder_result_queue *queue)
-{
- if (NULL == queue) {
- return NULL;
- }
-
- struct http_decoder_half_data *res_data =
- queue->array[queue->res_index].res_data;
- queue->array[queue->res_index].res_data = NULL;
-
- return res_data;
-}
-
-struct http_decoder_half_data *
-http_decoder_result_queue_peek_req(struct http_decoder_result_queue *queue)
-{
- if (NULL == queue) {
- return NULL;
- }
-
- assert(queue->req_index < queue->queue_size);
- return queue->array[queue->req_index].req_data;
-}
-
-struct http_decoder_half_data *
-http_decoder_result_queue_peek_res(struct http_decoder_result_queue *queue)
-{
- if (NULL == queue) {
- return NULL;
- }
-
- assert(queue->res_index < queue->queue_size);
- return queue->array[queue->res_index].res_data;
-} \ No newline at end of file