/*
  +----------------------------------------------------------------------+
  | PHP Version 5                                                        |
  +----------------------------------------------------------------------+
  | Copyright (c) 1997-2007 The PHP Group                                |
  +----------------------------------------------------------------------+
  | This source file is subject to version 3.01 of the PHP license,      |
  | that is bundled with this package in the file LICENSE, and is        |
  | available through the world-wide-web at the following url:           |
  | http://www.php.net/license/3_01.txt                                  |
  | If you did not receive a copy of the PHP license and are unable to   |
  | obtain it through the world-wide-web, please send a note to          |
  | license@php.net so we can mail you a copy immediately.               |
  +----------------------------------------------------------------------+
  | Author: Liexusong <280259971@qq.com>                                 |
  +----------------------------------------------------------------------+
*/

#include <stdlib.h>
#include <sys/types.h>
#ifndef PHP_WIN32
#include <sys/mman.h>
#endif

#include "beast_mm.h"
#include "spinlock.h"
#include "php.h"
#include "cache.h"
#include "beast_log.h"
#include "shm.h"

#define BUCKETS_DEFAULT_SIZE 8191

static int beast_cache_initialization = 0;
static cache_item_t **beast_cache_buckets = NULL;
static beast_atomic_t *cache_lock;
extern int beast_pid;

void beast_cache_lock()
{
    beast_spinlock(cache_lock, beast_pid);
}

void beast_cache_unlock()
{
    beast_spinunlock(cache_lock, beast_pid);
}

static inline unsigned int
beast_cache_hash(cache_key_t *key)
{
    unsigned int retval;

    retval = (unsigned int)key->device * 3
           + (unsigned int)key->inode * 7;

    return retval;
}


int beast_cache_init(int size)
{
    int index, bucket_size;

    if (beast_cache_initialization) {
        return 0;
    }

    if (beast_mm_init(size) == -1) {
        return -1;
    }

    /* init cache lock */
    cache_lock = (int *)beast_shm_alloc(sizeof(int));
    if (!cache_lock) {
        beast_write_log(beast_log_error,
                        "Unable alloc share memory for cache lock");
        beast_mm_destroy();
        return -1;
    }

    *cache_lock = 0;

    /* init cache buckets's memory */
    bucket_size = sizeof(cache_item_t *) * BUCKETS_DEFAULT_SIZE;

    beast_cache_buckets = (cache_item_t **)beast_shm_alloc(bucket_size);

    if (!beast_cache_buckets) {
        beast_write_log(beast_log_error,
                        "Unable alloc share memory for cache buckets");
        beast_shm_free((void *)cache_lock, sizeof(int));
        beast_mm_destroy();
        return -1;
    }

    for (index = 0; index < BUCKETS_DEFAULT_SIZE; index++) {
        beast_cache_buckets[index] = NULL;
    }

    beast_cache_initialization = 1;

    return 0;
}


cache_item_t *beast_cache_find(cache_key_t *key)
{
    unsigned int hashval = beast_cache_hash(key);
    unsigned int index = hashval % BUCKETS_DEFAULT_SIZE;
    cache_item_t *item, *temp;

    beast_cache_lock();

    item = beast_cache_buckets[index];
    while (item) {
        if (item->key.device == key->device &&
             item->key.inode == key->inode)
        {
            break;
        }
        item = item->next;
    }

    if (item && item->key.mtime < key->mtime) /* cache exprie */
    {
        temp = beast_cache_buckets[index];
        if (temp == item) { /* the header node */
            beast_cache_buckets[index] = item->next;
        } else {
            while (temp->next != item) { /* find prev node */
                temp = temp->next;
            }
            temp->next = item->next;
        }

        beast_mm_free(item);

        item = NULL;
    }

    beast_cache_unlock();

    return item;
}


cache_item_t *beast_cache_create(cache_key_t *key)
{
    cache_item_t *item;
    int msize, bsize;

    msize = sizeof(*item) + key->fsize;
    bsize = sizeof(cache_item_t *) * BUCKETS_DEFAULT_SIZE;

    if ((msize + bsize) > beast_mm_realspace()) {
        beast_write_log(beast_log_error,
                        "Cache item size too big");
        return NULL;
    }

    item = beast_mm_malloc(msize);

    if (!item) {
        beast_write_log(beast_log_notice,
                        "Not enough memory for alloc cache");
        return NULL;
    }

    item->key.device = key->device;
    item->key.inode = key->inode;
    item->key.fsize = key->fsize;
    item->key.mtime = key->mtime;

    item->next = NULL;

    return item;
}


/*
 * Push cache item into cache manager,
 * this function return a cache item,
 * may be return value not equals push item,
 * so we must use return value.
 */
cache_item_t *beast_cache_push(cache_item_t *item)
{
    unsigned int hashval = beast_cache_hash(&item->key);
    unsigned int index = hashval % BUCKETS_DEFAULT_SIZE;

    beast_cache_lock();

    item->next = beast_cache_buckets[index];
    beast_cache_buckets[index] = item;

    beast_cache_unlock();

    return item;
}


int beast_cache_destroy()
{
    if (!beast_cache_initialization) {
        return 0;
    }

    beast_mm_destroy(); /* Destroy memory manager */

    /* Free cache buckets's mmap memory */
    beast_shm_free((void *)beast_cache_buckets,
            sizeof(cache_item_t *) * BUCKETS_DEFAULT_SIZE);
    beast_shm_free((void *)cache_lock, sizeof(int));
    beast_cache_initialization = 0;

    return 0;
}


void beast_cache_info(zval *retval)
{
    char key[128];
    int i;
    cache_item_t *item;

    beast_cache_lock();

    for (i = 0; i < BUCKETS_DEFAULT_SIZE; i++) {
        item = beast_cache_buckets[i];
        while (item) {
            sprintf(key, "{device(%d)#inode(%d)}",
                  item->key.device, item->key.inode);
            add_assoc_long(retval, key, item->key.fsize);
            item = item->next;
        }
    }

    beast_cache_unlock();
}

void beast_cache_flush()
{
    int index;

    beast_cache_lock();

    /* Flush hash buckets */
    for (index = 0; index < BUCKETS_DEFAULT_SIZE; index++) {
        beast_cache_buckets[index] = NULL;
    }

    /* Flush share memory */
    beast_mm_flush();

    beast_cache_unlock();
}