Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/lexborisov/Modest.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
path: root/source/myhtml/utils/mcobject_async.c
diff options
context:
space:
mode:
Diffstat (limited to 'source/myhtml/utils/mcobject_async.c')
-rw-r--r--source/myhtml/utils/mcobject_async.c475
1 files changed, 0 insertions, 475 deletions
diff --git a/source/myhtml/utils/mcobject_async.c b/source/myhtml/utils/mcobject_async.c
deleted file mode 100644
index 21e36e8..0000000
--- a/source/myhtml/utils/mcobject_async.c
+++ /dev/null
@@ -1,475 +0,0 @@
-/*
- Copyright (C) 2015-2016 Alexander Borisov
-
- This library is free software; you can redistribute it and/or
- modify it under the terms of the GNU Lesser General Public
- License as published by the Free Software Foundation; either
- version 2.1 of the License, or (at your option) any later version.
-
- This library is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- Lesser General Public License for more details.
-
- You should have received a copy of the GNU Lesser General Public
- License along with this library; if not, write to the Free Software
- Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
-
- Author: lex.borisov@gmail.com (Alexander Borisov)
-*/
-
-#include "myhtml/utils/mcobject_async.h"
-
-mcobject_async_t * mcobject_async_create(void)
-{
- return (mcobject_async_t*)myhtml_calloc(1, sizeof(mcobject_async_t));
-}
-
-mcobject_async_status_t mcobject_async_chunk_up(mcobject_async_t *mcobj_async)
-{
- mcobj_async->chunks_length = 0;
-
- if(mcobj_async->chunks[ mcobj_async->chunks_pos_length ] == NULL) {
- mcobj_async->chunks[ mcobj_async->chunks_pos_length ] = (mcobject_async_chunk_t*)myhtml_calloc(mcobj_async->chunks_size, sizeof(mcobject_async_chunk_t));
-
- if(mcobj_async->chunks[ mcobj_async->chunks_pos_length ] == NULL)
- return MCOBJECT_ASYNC_STATUS_CHUNK_ERROR_MEMORY_ALLOCATION;
- }
-
- return MCOBJECT_ASYNC_STATUS_OK;
-}
-
-mcobject_async_status_t mcobject_async_init(mcobject_async_t *mcobj_async, size_t chunk_len, size_t obj_size_by_one_chunk, size_t struct_size)
-{
- mcobj_async->origin_size = obj_size_by_one_chunk;
- mcobj_async->struct_size = struct_size;
- mcobj_async->struct_size_sn = struct_size + sizeof(size_t);
-
- mcobj_async->chunks_pos_length = 0;
- mcobj_async->chunks_pos_size = 128;
- mcobj_async->chunks_size = chunk_len;
- mcobj_async->chunks = (mcobject_async_chunk_t**)myhtml_calloc(mcobj_async->chunks_pos_size, sizeof(mcobject_async_chunk_t*));
-
- if(mcobj_async->chunks == NULL)
- return MCOBJECT_ASYNC_STATUS_CHUNK_ERROR_MEMORY_ALLOCATION;
-
- mcobject_async_chunk_up(mcobj_async);
-
- mcobj_async->chunk_cache_size = mcobj_async->chunks_size;
- mcobj_async->chunk_cache = (mcobject_async_chunk_t**)myhtml_calloc(mcobj_async->chunk_cache_size, sizeof(mcobject_async_chunk_t*));
-
- if(mcobj_async->chunk_cache == NULL)
- return MCOBJECT_ASYNC_STATUS_CHUNK_CACHE_ERROR_MEMORY_ALLOCATION;
-
- mcobj_async->nodes_length = 0;
- mcobj_async->nodes_size = 64;
- mcobj_async->nodes = (mcobject_async_node_t*)myhtml_calloc(mcobj_async->nodes_size, sizeof(mcobject_async_node_t));
-
- if(mcobj_async->nodes == NULL)
- return MCOBJECT_ASYNC_STATUS_NODES_ERROR_MEMORY_ALLOCATION;
-
- mcobj_async->nodes_cache_length = 0;
- mcobj_async->nodes_cache_size = mcobj_async->nodes_size;
- mcobj_async->nodes_cache = (size_t*)myhtml_malloc(mcobj_async->nodes_cache_size * sizeof(size_t));
-
- if(mcobj_async->nodes_cache == NULL)
- return MCOBJECT_ASYNC_STATUS_NODES_ERROR_MEMORY_ALLOCATION;
-
- mcobject_async_clean(mcobj_async);
-
- mcobj_async->mcsync = mcsync_create();
-
- return MCOBJECT_ASYNC_STATUS_OK;
-}
-
-void mcobject_async_clean(mcobject_async_t *mcobj_async)
-{
- if(mcobj_async->chunks[0] != NULL)
- mcobj_async->chunks_pos_length = 1;
- else
- mcobj_async->chunks_pos_length = 0;
-
- mcobj_async->chunks_length = 0;
- mcobj_async->chunk_cache_length = 0;
-
- size_t node_idx;
- for (node_idx = 0; node_idx < mcobj_async->nodes_length; node_idx++)
- {
- mcobject_async_node_t *node = &mcobj_async->nodes[node_idx];
- node->cache_length = 0;
-
- if(node->chunk) {
- node->chunk = mcobject_async_chunk_malloc(mcobj_async, mcobj_async->origin_size, NULL);
- }
- }
-}
-
-mcobject_async_t * mcobject_async_destroy(mcobject_async_t *mcobj_async, int destroy_self)
-{
- if(mcobj_async == NULL)
- return NULL;
-
- if(mcobj_async->nodes)
- {
- for (size_t node_idx = 0; node_idx < mcobj_async->nodes_length; node_idx++)
- {
- mcobject_async_node_t *node = &mcobj_async->nodes[node_idx];
-
- if(node->cache)
- myhtml_free(node->cache);
- }
-
- myhtml_free(mcobj_async->nodes);
- }
-
- if(mcobj_async->nodes_cache) {
- myhtml_free(mcobj_async->nodes_cache);
- }
-
- if(mcobj_async->chunks) {
- for (size_t pos_idx = 0; pos_idx < mcobj_async->chunks_pos_length; pos_idx++) {
- if(mcobj_async->chunks[pos_idx])
- {
- for (size_t idx = 0; idx < mcobj_async->chunks_size; idx++) {
- if(mcobj_async->chunks[pos_idx][idx].begin)
- myhtml_free(mcobj_async->chunks[pos_idx][idx].begin);
- }
-
- myhtml_free(mcobj_async->chunks[pos_idx]);
- }
- }
-
- myhtml_free(mcobj_async->chunks);
- }
-
- if(mcobj_async->chunk_cache) {
- myhtml_free(mcobj_async->chunk_cache);
- }
-
- mcobj_async->mcsync = mcsync_destroy(mcobj_async->mcsync, 1);
-
- memset(mcobj_async, 0, sizeof(mcobject_async_t));
-
- if(destroy_self)
- myhtml_free(mcobj_async);
- else
- return mcobj_async;
-
- return NULL;
-}
-
-mcobject_async_status_t mcobject_async_mem_malloc(mcobject_async_t *mcobj_async, mcobject_async_chunk_t *chunk, size_t length)
-{
- if(chunk->begin) {
- if(length > chunk->size) {
- myhtml_free(chunk->begin);
-
- chunk->size = length + mcobj_async->origin_size;
- chunk->begin = (unsigned char*)myhtml_malloc(chunk->size * mcobj_async->struct_size_sn);
- }
- }
- else {
- chunk->size = mcobj_async->origin_size;
-
- if(length > chunk->size)
- chunk->size += length;
-
- chunk->begin = (unsigned char*)myhtml_malloc(chunk->size * mcobj_async->struct_size_sn);
- }
-
- chunk->length = 0;
-
- if(chunk->begin == NULL)
- return MCOBJECT_ASYNC_STATUS_CHUNK_ERROR_MEMORY_ALLOCATION;
-
- return MCOBJECT_ASYNC_STATUS_OK;
-}
-
-mcobject_async_chunk_t * mcobject_async_chunk_malloc_without_lock(mcobject_async_t *mcobj_async, size_t length, mcobject_async_status_t *status)
-{
- if(status)
- *status = MCOBJECT_ASYNC_STATUS_OK;
-
- if(mcobj_async->chunk_cache_length)
- {
- mcobj_async->chunk_cache_length--;
-
- mcobj_async->chunk_cache[ mcobj_async->chunk_cache_length ]->length = 0;
- mcobj_async->chunk_cache[ mcobj_async->chunk_cache_length ]->next = NULL;
- mcobj_async->chunk_cache[ mcobj_async->chunk_cache_length ]->prev = NULL;
-
- return mcobj_async->chunk_cache[ mcobj_async->chunk_cache_length ];
- }
-
- if(mcobj_async->chunks_length >= mcobj_async->chunks_size)
- {
- if(mcobj_async->chunks_pos_length >= mcobj_async->chunks_pos_size)
- {
- size_t tmp_pos_size = mcobj_async->chunks_pos_size << 1;
- mcobject_async_chunk_t **tmp_pos = myhtml_realloc(mcobj_async->chunks,
- sizeof(mcobject_async_chunk_t*) * tmp_pos_size);
-
- if(tmp_pos)
- {
- memset(&tmp_pos[mcobj_async->chunks_pos_length], 0, (tmp_pos_size - mcobj_async->chunks_pos_length)
- * sizeof(mcobject_async_chunk_t*));
-
- mcobj_async->chunks_pos_size = tmp_pos_size;
- mcobj_async->chunks = tmp_pos;
- }
- else {
- if(status)
- *status = MCOBJECT_ASYNC_STATUS_CHUNK_ERROR_MEMORY_ALLOCATION;
-
- return NULL;
- }
- }
-
- if(mcobject_async_chunk_up(mcobj_async)) {
- if(status)
- *status = MCOBJECT_ASYNC_STATUS_CHUNK_ERROR_MEMORY_ALLOCATION;
-
- return NULL;
- }
-
- mcobj_async->chunks_pos_length++;
- }
-
- mcobject_async_chunk_t* chunk = &mcobj_async->chunks[mcobj_async->chunks_pos_length - 1][mcobj_async->chunks_length];
- mcobj_async->chunks_length++;
-
- chunk->next = NULL;
- chunk->prev = NULL;
-
- if(status)
- *status = mcobject_async_mem_malloc(mcobj_async, chunk, length);
- else
- mcobject_async_mem_malloc(mcobj_async, chunk, length);
-
- return chunk;
-}
-
-mcobject_async_chunk_t * mcobject_async_chunk_malloc(mcobject_async_t *mcobj_async, size_t length, mcobject_async_status_t *status)
-{
- mcsync_lock(mcobj_async->mcsync);
- mcobject_async_chunk_t* chunk = mcobject_async_chunk_malloc_without_lock(mcobj_async, length, status);
- mcsync_unlock(mcobj_async->mcsync);
-
- return chunk;
-}
-
-size_t mcobject_async_node_add(mcobject_async_t *mcobj_async, mcobject_async_status_t *status)
-{
- mcsync_lock(mcobj_async->mcsync);
-
- if(status)
- *status = MCOBJECT_ASYNC_STATUS_OK;
-
- size_t node_idx;
-
- if(mcobj_async->nodes_cache_length) {
- mcobj_async->nodes_cache_length--;
-
- node_idx = mcobj_async->nodes_cache[ mcobj_async->nodes_cache_length ];
- }
- else {
- if(mcobj_async->nodes_length >= mcobj_async->nodes_size) {
- mcsync_unlock(mcobj_async->mcsync);
- return 0;
- }
-
- node_idx = mcobj_async->nodes_length;
- mcobj_async->nodes_length++;
- }
-
- mcobject_async_node_t *node = &mcobj_async->nodes[node_idx];
-
- node->chunk = mcobject_async_chunk_malloc_without_lock(mcobj_async, mcobj_async->origin_size, status);
-
- if(status && *status) {
- mcsync_unlock(mcobj_async->mcsync);
- return 0;
- }
-
- node->chunk->next = NULL;
- node->chunk->prev = NULL;
-
- node->cache_length = 0;
- node->cache_size = mcobj_async->origin_size;
- node->cache = (void**)myhtml_malloc(sizeof(void*) * node->cache_size);
-
- if(node->cache == NULL) {
- if(status)
- *status = MCOBJECT_ASYNC_STATUS_CHUNK_CACHE_ERROR_MEMORY_ALLOCATION;
-
- mcsync_unlock(mcobj_async->mcsync);
- return 0;
- }
-
- mcsync_unlock(mcobj_async->mcsync);
-
- return node_idx;
-}
-
-void mcobject_async_node_clean(mcobject_async_t *mcobj_async, size_t node_idx)
-{
- if(mcobj_async->nodes_length <= node_idx)
- return;
-
- mcobject_async_node_t *node = &mcobj_async->nodes[node_idx];
- node->cache_length = 0;
-
- if(node->chunk == NULL)
- return;
-
- while (node->chunk->prev)
- node->chunk = node->chunk->prev;
-
- node->chunk->length = 0;
- node->cache_length = 0;
-}
-
-void mcobject_async_node_all_clean(mcobject_async_t *mcobj_async)
-{
- for (size_t node_idx = 0; node_idx < mcobj_async->nodes_length; node_idx++) {
- mcobject_async_node_clean(mcobj_async, node_idx);
- }
-}
-
-void mcobject_async_node_delete(mcobject_async_t *mcobj_async, size_t node_idx)
-{
- mcsync_lock(mcobj_async->mcsync);
-
- if(mcobj_async->nodes_length <= node_idx) {
- mcsync_unlock(mcobj_async->mcsync);
- return;
- }
-
- mcobject_async_node_t *node = &mcobj_async->nodes[node_idx];
- mcobject_async_chunk_t *chunk = node->chunk;
-
- while (chunk->next)
- chunk = chunk->next;
-
- while (chunk)
- {
- if(mcobj_async->chunk_cache_length >= mcobj_async->chunk_cache_size) {
- size_t new_size = mcobj_async->chunk_cache_size << 1;
-
- mcobject_async_chunk_t **tmp = (mcobject_async_chunk_t**)myhtml_realloc(mcobj_async->chunk_cache,
- sizeof(mcobject_async_chunk_t*) * new_size);
-
- if(tmp) {
- mcobj_async->chunk_cache_size = new_size;
- mcobj_async->chunk_cache = tmp;
- }
- else {
- // TODO: add return status
- mcsync_unlock(mcobj_async->mcsync);
- return;
- }
- }
-
- mcobj_async->chunk_cache[ mcobj_async->chunk_cache_length ] = chunk;
- mcobj_async->chunk_cache_length++;
-
- chunk = chunk->prev;
- }
-
- if(node->cache)
- myhtml_free(node->cache);
-
- memset(node, 0, sizeof(mcobject_async_node_t));
-
- if(mcobj_async->nodes_cache_length >= mcobj_async->nodes_cache_size) {
- size_t new_size = mcobj_async->nodes_cache_size << 1;
-
- size_t *tmp = (size_t*)myhtml_realloc(mcobj_async->nodes_cache, sizeof(size_t) * mcobj_async->nodes_cache_size);
-
- if(tmp) {
- mcobj_async->nodes_cache = tmp;
- mcobj_async->nodes_cache_size = new_size;
- }
- }
-
- mcobj_async->nodes_cache[ mcobj_async->nodes_cache_length ] = node_idx;
- mcobj_async->nodes_cache_length++;
-
- mcsync_unlock(mcobj_async->mcsync);
-}
-
-void * mcobject_async_malloc(mcobject_async_t *mcobj_async, size_t node_idx, mcobject_async_status_t *status)
-{
- mcobject_async_node_t *node = &mcobj_async->nodes[node_idx];
-
- if(node->cache_length) {
- if(status)
- *status = MCOBJECT_ASYNC_STATUS_OK;
-
- node->cache_length--;
- return node->cache[ node->cache_length ];
- }
-
- if(node->chunk->length >= node->chunk->size)
- {
- if(node->chunk->next) {
- node->chunk = node->chunk->next;
- node->chunk->length = 0;
- }
- else {
- mcobject_async_status_t mystatus;
- mcobject_async_chunk_t *chunk = mcobject_async_chunk_malloc(mcobj_async, mcobj_async->origin_size, &mystatus);
-
- if(mystatus) {
- if(status)
- *status = mystatus;
-
- return NULL;
- }
-
- chunk->prev = node->chunk;
- node->chunk->next = chunk;
-
- node->chunk = chunk;
- }
- }
-
- if(status)
- *status = MCOBJECT_ASYNC_STATUS_OK;
-
- size_t offset = node->chunk->length * mcobj_async->struct_size_sn;
- *((size_t*)(&node->chunk->begin[offset])) = node_idx;
-
- node->chunk->length++;
- return &node->chunk->begin[(offset + sizeof(size_t))];
-}
-
-mcobject_async_status_t mcobject_async_free(mcobject_async_t *mcobj_async, void *entry)
-{
- size_t node_idx = *((size_t*)((unsigned char*)entry - sizeof(size_t)));
-
- if(node_idx >= mcobj_async->nodes_length)
- return MCOBJECT_ASYNC_STATUS_NODES_ERROR_BAD_NODE_ID;
-
- mcobject_async_node_t *node = &mcobj_async->nodes[node_idx];
-
- if(node->cache_length >= node->cache_size) {
- size_t new_size = node->cache_size << 1;
-
- void **tmp = (void**)myhtml_realloc(node->cache, sizeof(void*) * new_size);
-
- if(tmp) {
- node->cache = tmp;
- node->cache_size = new_size;
- }
- else
- return MCOBJECT_ASYNC_STATUS_CACHE_ERROR_MEMORY_REALLOC;
- }
-
- node->cache[ node->cache_length ] = entry;
- node->cache_length++;
-
- return MCOBJECT_ASYNC_STATUS_OK;
-}
-
-
generated by cgit v1.2.3 (git 2.25.1) at 2024-07-16 20:29:19 +0300