Implementation of a simple linked list queue. More...
#include "ink_config.h"#include "ink_memory.h"#include <stdio.h>#include <stdlib.h>#include <assert.h>#include <limits.h>#include "ink_llqueue.h"#include "errno.h"
Go to the source code of this file.
Defines | |
| #define | RECORD_CHUNK 1024 |
Functions | |
| LLQ * | create_queue () |
| void | delete_queue (LLQ *Q) |
| int | enqueue (LLQ *Q, void *data) |
| uint64_t | queue_len (LLQ *Q) |
| uint64_t | queue_highwater (LLQ *Q) |
| int | queue_is_empty (LLQ *Q) |
| void * | dequeue (LLQ *Q) |
Detailed Description
Implementation of a simple linked list queue.
License
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Definition in file llqueue.cc.
Define Documentation
| #define RECORD_CHUNK 1024 |
Definition at line 35 of file llqueue.cc.
Function Documentation
| LLQ* create_queue | ( | void | ) |
Definition at line 75 of file llqueue.cc.
References ats_malloc(), llq_s::free, llq_s::head, llq_s::highwater, ink_mutex_init(), ink_sem_init(), llq_s::len, llq_s::mux, llq_s::sema, and llq_s::tail.
Referenced by RecConfigFileInit().
| void delete_queue | ( | LLQ * | Q | ) |
Definition at line 90 of file llqueue.cc.
References ats_free(), ink_mutex_destroy(), ink_sem_destroy(), llq_s::mux, and llq_s::sema.
| void* dequeue | ( | LLQ * | Q | ) |
Definition at line 186 of file llqueue.cc.
References ats_free(), llqrec_s::data, llq_s::head, ink_mutex_acquire(), ink_mutex_release(), ink_sem_wait(), llq_s::len, llq_s::mux, llqrec_s::next, llq_s::sema, and llq_s::tail.
Referenced by PacketQueue::FreeCancelledPackets(), and RecConfigFileParse().
| int enqueue | ( | LLQ * | Q, | |
| void * | data | |||
| ) |
Definition at line 103 of file llqueue.cc.
References ats_malloc(), llqrec_s::data, llq_s::head, llq_s::highwater, ink_mutex_acquire(), ink_mutex_release(), ink_sem_post(), llq_s::len, llq_s::mux, llqrec_s::next, llq_s::sema, and llq_s::tail.
Referenced by RecConfigFileParse(), and RecSyncConfigToTB().
| uint64_t queue_highwater | ( | LLQ * | Q | ) |
Definition at line 140 of file llqueue.cc.
References llq_s::highwater.
| int queue_is_empty | ( | LLQ * | Q | ) |
Definition at line 173 of file llqueue.cc.
References queue_len().
Referenced by RecConfigFileParse().
| uint64_t queue_len | ( | LLQ * | Q | ) |
