golden hour

/opt/alt/php71/usr/include/php/ext/swoole/include

File/Folder	Size	Actions
swoole.h	19.74 KB
swoole_api.h	2.76 KB
swoole_asm_context.h	1.47 KB
swoole_async.h	2.13 KB
swoole_atomic.h	2.24 KB
swoole_base64.h	1.29 KB
swoole_buffer.h	2.02 KB
swoole_c_api.h	1.89 KB
swoole_channel.h	2.36 KB
swoole_client.h	7.85 KB
swoole_config.h	9.26 KB
swoole_coroutine.h	6.25 KB
swoole_coroutine_c_api.h	3.7 KB
swoole_coroutine_channel.h	4.04 KB
swoole_coroutine_context.h	2.39 KB
swoole_coroutine_socket.h	17.16 KB
swoole_coroutine_system.h	3.05 KB
swoole_dtls.h	2.38 KB
swoole_error.h	4.72 KB
swoole_file.h	4.04 KB
swoole_file_hook.h	1.95 KB
swoole_hash.h	9.69 KB
swoole_heap.h	1.79 KB
swoole_http.h	4.63 KB
swoole_http2.h	8 KB
swoole_lock.h	2.62 KB
swoole_log.h	15.53 KB
swoole_lru_cache.h	3.2 KB
swoole_memory.h	2.57 KB
swoole_mime_type.h	1.44 KB
swoole_mqtt.h	2.11 KB
swoole_msg_queue.h	1.84 KB
swoole_pipe.h	2.64 KB
swoole_process_pool.h	5.82 KB
swoole_protocol.h	5 KB
swoole_proxy.h	2.07 KB
swoole_reactor.h	10.47 KB
swoole_redis.h	2.18 KB
swoole_server.h	32.83 KB
swoole_signal.h	1.55 KB
swoole_socket.h	15.48 KB
swoole_socket_hook.h	2.12 KB
swoole_ssl.h	3.58 KB
swoole_static_handler.h	2.8 KB
swoole_string.h	6.87 KB
swoole_table.h	5.74 KB
swoole_timer.h	4.08 KB
swoole_util.h	3.59 KB
swoole_version.h	2.21 KB
swoole_websocket.h	5.07 KB
swoole_wheel_timer.h	2.48 KB

Edit: swoole_table.h

/*
  +----------------------------------------------------------------------+
  | Swoole                                                               |
  +----------------------------------------------------------------------+
  | This source file is subject to version 2.0 of the Apache 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.apache.org/licenses/LICENSE-2.0.html                      |
  | If you did not receive a copy of the Apache2.0 license and are unable|
  | to obtain it through the world-wide-web, please send a note to       |
  | license@swoole.com so we can mail you a copy immediately.            |
  +----------------------------------------------------------------------+
  | Author: Tianfeng Han  <mikan.tenny@gmail.com>                        |
  +----------------------------------------------------------------------+
*/

#pragma once

#include "swoole.h"
#include "swoole_memory.h"
#include "swoole_util.h"
#include "swoole_lock.h"
#include "swoole_hash.h"

#include <signal.h>

#include <vector>
#include <unordered_map>

//#define SW_TABLE_DEBUG   0
#define SW_TABLE_FORCE_UNLOCK_TIME 2000  // milliseconds
#define SW_TABLE_USE_PHP_HASH

namespace swoole {

typedef uint32_t TableStringLength;
typedef uint64_t (*HashFunc)(const char *key, size_t len);

struct TableColumn;

struct TableRow {
    sw_atomic_t lock_;
    pid_t lock_pid;
    /**
     * 1:used, 0:empty
     */
    uint8_t active;
    uint8_t key_len;
    /**
     * next slot
     */
    TableRow *next;
    /**
     * Hash Key
     */
    char key[SW_TABLE_KEY_SIZE];
    char data[0];

void lock();

void unlock() {
        sw_spinlock_release(&lock_);
    }

void clear() {
        sw_memset_zero((char *) &lock_pid, sizeof(TableRow) - offsetof(TableRow, lock_pid));
    }

void set_value(TableColumn *col, void *value, size_t vlen);
    void get_value(TableColumn *col, double *dval);
    void get_value(TableColumn *col, long *lval);
    void get_value(TableColumn *col, char **strval, TableStringLength *strlen);
};

struct TableIterator {
    uint32_t absolute_index;
    uint32_t collision_index;
    TableRow *row;
};

enum TableFlag {
    SW_TABLE_FLAG_NEW_ROW = 1,
    SW_TABLE_FLAG_CONFLICT = 1u << 1,
};

struct TableColumn {
    enum Type {
        TYPE_INT = 1,
        TYPE_FLOAT,
        TYPE_STRING,
    };

enum Type type;
    uint32_t size;
    std::string name;
    size_t index;

TableColumn(const std::string &_name, enum Type _type, size_t _size) {
        index = 0;
        name = _name;
        type = _type;
        switch (_type) {
        case TYPE_INT:
            size = sizeof(long);
            break;
        case TYPE_FLOAT:
            size = sizeof(double);
            break;
        case TYPE_STRING:
            size = _size + sizeof(TableStringLength);
            break;
        default:
            abort();
            break;
        }
    }

void clear(TableRow *row);
};

class Table {
  private:
    Table() = delete;
    ~Table() = delete;

std::unordered_map<std::string, TableColumn *> *column_map;
    Mutex *mutex;
    size_t size;
    size_t mask;
    size_t item_size;
    size_t memory_size;
    float conflict_proportion;

/**
     * total rows that in active state(shm)
     */
    sw_atomic_t row_num;

TableRow **rows;
    FixedPool *pool;

TableIterator *iterator;
    HashFunc hash_func;
    bool created;

void *memory;

#ifdef SW_TABLE_DEBUG
    int conflict_count;
    int insert_count;
    int conflict_max_level;
#endif

public:
    std::vector<TableColumn *> *column_list;

static Table *make(uint32_t rows_size, float conflict_proportion);
    size_t get_memory_size();
    bool create();
    bool add_column(const std::string &name, enum TableColumn::Type type, size_t size);
    TableRow *set(const char *key, uint16_t keylen, TableRow **rowlock, int *out_flags);
    TableRow *get(const char *key, uint16_t keylen, TableRow **rowlock);
    bool del(const char *key, uint16_t keylen);
    void forward();
    void destroy();

bool is_created() {
        return created;
    }

bool ready() {
        return memory != nullptr;
    }

void set_hash_func(HashFunc _fn) {
        hash_func = _fn;
    }

size_t get_size() {
        return size;
    }

TableRow *get_by_index(uint32_t index) {
        TableRow *row = rows[index];
        return row->active ? row : nullptr;
    }

TableColumn *get_column(const std::string &key) {
        auto i = column_map->find(key);
        if (i == column_map->end()) {
            return nullptr;
        } else {
            return i->second;
        }
    }

size_t count() {
        return row_num;
    }

TableRow *current() {
        return iterator->row;
    }

void rewind() {
        sw_memset_zero(iterator, sizeof(*iterator));
    }

TableRow *hash(const char *key, int keylen) {
        uint64_t hashv = hash_func(key, keylen);
        uint64_t index = hashv & mask;
        assert(index < size);
        return rows[index];
    }

void check_key_length(uint16_t *keylen) {
        if (*keylen >= SW_TABLE_KEY_SIZE) {
            *keylen = SW_TABLE_KEY_SIZE - 1;
        }
    }

void clear_row(TableRow *row) {
        for (auto i = column_list->begin(); i != column_list->end(); i++) {
            (*i)->clear(row);
        }
    }

void init_row(TableRow *new_row, const char *key, int keylen) {
        sw_memset_zero(new_row, sizeof(TableRow));
        memcpy(new_row->key, key, keylen);
        new_row->key[keylen] = '\0';
        new_row->key_len = keylen;
        new_row->active = 1;
        sw_atomic_fetch_add(&(row_num), 1);
#ifdef SW_TABLE_DEBUG
        insert_count++;
#endif
    }
};
}  // namespace swoole