root/tags/1.1-rc1/processor/head.m4

dnl {{{ === program start ========================================
divert(0)
#include <string.h>
#include <stdio.h>

#include "php.h"
#include "zend_compile.h"
#include "zend_API.h"
#include "zend_ini.h"

#include "xcache.h"
#include "align.h"
#include "const_string.h"
#include "processor.h"
#include "stack.h"
#include "xcache_globals.h"

#if defined(HARDENING_PATCH_HASH_PROTECT) && HARDENING_PATCH_HASH_PROTECT
extern unsigned int zend_hash_canary;
#endif

define(`SIZEOF_zend_uint', `sizeof(zend_uint)')
define(`COUNTOF_zend_uint', `1')
define(`SIZEOF_int', `sizeof(int)')
define(`COUNTOF_int', `1')
define(`SIZEOF_zend_function', `sizeof(zend_function)')
define(`COUNTOF_zend_function', `1')
define(`SIZEOF_zval_ptr', `sizeof(zval_ptr)')
define(`COUNTOF_zval_ptr', `1')
define(`SIZEOF_xc_entry_name_t', `sizeof(xc_entry_name_t)')
define(`COUNTOF_xc_entry_name_t', `1')

ifdef(`XCACHE_ENABLE_TEST', `
#undef NDEBUG
#include <assert.h>
m4_errprint(`AUTOCHECK INFO: runtime autocheck Enabled (debug build)')
', `
m4_errprint(`AUTOCHECK INFO: runtime autocheck Disabled (optimized build)')
')
sinclude(builddir`/structinfo.m4')

#ifndef NDEBUG
#   undef inline
#define inline
#endif

typedef zval *zval_ptr;
typedef zend_uchar zval_data_type;
#ifdef IS_UNICODE
typedef UChar zstr_uchar;
#endif
typedef char  zstr_char;

#define MAX_DUP_STR_LEN 256
dnl }}}
/* export: typedef struct _processor_t processor_t; :export {{{ */
struct _processor_t {
    char *p;
    zend_uint size;
    HashTable strings;
    HashTable zvalptrs;
    zend_bool reference; /* enable if to deal with reference */
    const xc_entry_t *xce_src;
    const xc_entry_t *xce_dst;
    const zend_class_entry *cache_ce;
    zend_uint cache_class_num;

    const zend_op          *active_opcodes_src;
    zend_op                *active_opcodes_dst;
    const zend_class_entry *active_class_entry_src;
    zend_class_entry       *active_class_entry_dst;
    zend_uint               active_class_num;

    zend_bool readonly_protection; /* wheather it's present */
IFASSERT(xc_stack_t allocsizes;)
};
/* }}} */
#ifdef XCACHE_HAVE_DPRINT
static void xc_dprint_indent(int indent) /* {{{ */
{
    int i;
    for (i = 0; i < indent; i ++) {
        fprintf(stderr, "  ");
    }
}
#endif
/* }}} */
/* {{{ xc_zstrlen_char */
static inline int xc_zstrlen_char(zstr s)
{
    return strlen(ZSTR_S(s));
}
/* }}} */
#ifdef IS_UNICODE
/* {{{ xc_zstrlen_uchar */
static inline int xc_zstrlen_uchar(zstr s)
{
    int i;
    UChar *p = ZSTR_U(s);
    for (i = 0; *p; i ++, p++) {
        /* empty */
    }
    return i;
}
/* }}} */
/* {{{ xc_zstrlen */
static inline int xc_zstrlen(int type, zstr s)
{
    return type == IS_UNICODE ? xc_zstrlen_uchar(s) : xc_zstrlen_char(s);
}
/* }}} */
#else
/* {{{ xc_zstrlen */
#define xc_zstrlen(dummy, s) xc_zstrlen_char(s)
/* }}} */
#endif
/* {{{ xc_calc_string_n */
REDEF(`KIND', `calc')
static inline void xc_calc_string_n(processor_t *processor, zend_uchar type, zstr str, long size IFASSERT(`, int relayline')) {
    pushdef(`__LINE__', `relayline')
    int realsize = UNISW(size, (type == IS_UNICODE) ? UBYTES(size) : size);
    long dummy = 1;

    if (realsize > MAX_DUP_STR_LEN) {
        ALLOC(, char, realsize)
    }
    else if (zend_u_hash_add(&processor->strings, type, str, size, (void *) &dummy, sizeof(dummy), NULL) == SUCCESS) {
        /* new string */
        ALLOC(, char, realsize)
    } 
    IFASSERT(`
        else {
            dnl fprintf(stderr, "dupstr %s\n", ZSTR_S(str));
        }
    ')
    popdef(`__LINE__')
}
/* }}} */
/* {{{ xc_store_string_n */
REDEF(`KIND', `store')
static inline zstr xc_store_string_n(processor_t *processor, zend_uchar type, zstr str, long size IFASSERT(`, int relayline')) {
    pushdef(`__LINE__', `relayline')
    int realsize = UNISW(size, (type == IS_UNICODE) ? UBYTES(size) : size);
    zstr ret, *pret;

    if (realsize > MAX_DUP_STR_LEN) {
        ALLOC(ZSTR_V(ret), char, realsize)
        memcpy(ZSTR_V(ret), ZSTR_V(str), realsize);
        return ret;
    }

    if (zend_u_hash_find(&processor->strings, type, str, size, (void **) &pret) == SUCCESS) {
        return *pret;
    }

    /* new string */
    ALLOC(ZSTR_V(ret), char, realsize)
    memcpy(ZSTR_V(ret), ZSTR_V(str), realsize);
    zend_u_hash_add(&processor->strings, type, str, size, (void *) &ret, sizeof(zstr), NULL);
    return ret;

    popdef(`__LINE__')
}
/* }}} */
/* {{{ xc_get_class_num
 * return class_index + 1
 */
static zend_ulong xc_get_class_num(processor_t *processor, zend_class_entry *ce) {
    zend_ulong i;
    const xc_entry_t *xce = processor->xce_src;
    zend_class_entry *ceptr;

    if (processor->cache_ce == ce) {
        return processor->cache_class_num;
    }
    for (i = 0; i < xce->data.php->classinfo_cnt; i ++) {
        ceptr = CestToCePtr(xce->data.php->classinfos[i].cest);
        if (ZCEP_REFCOUNT_PTR(ceptr) == ZCEP_REFCOUNT_PTR(ce)) {
            processor->cache_ce = ceptr;
            processor->cache_class_num = i + 1;
            return i + 1;
        }
    }
    assert(0);
    return (zend_ulong) -1;
}
/* }}} */
/* {{{ xc_get_class */
#ifdef ZEND_ENGINE_2
static zend_class_entry *xc_get_class(processor_t *processor, zend_ulong class_num) {
    /* must be parent or currrent class */
    assert(class_num <= processor->active_class_num);
    return CestToCePtr(processor->xce_dst->data.php->classinfos[class_num - 1].cest);
}
#endif
/* }}} */
#ifdef ZEND_ENGINE_2
/* fix method on store */
static void xc_fix_method(processor_t *processor, zend_op_array *dst) /* {{{ */
{
    zend_function *zf = (zend_function *) dst;
    zend_class_entry *ce = processor->active_class_entry_dst;

    /* Fixing up the default functions for objects here since
     * we need to compare with the newly allocated functions
     *
     * caveat: a sub-class method can have the same name as the
     * parent~s constructor and create problems.
     */

    if (zf->common.fn_flags & ZEND_ACC_CTOR) {
        if (!ce->constructor) {
            ce->constructor = zf;
        }
    }
    else if (zf->common.fn_flags & ZEND_ACC_DTOR) {
        ce->destructor = zf;
    }
    else if (zf->common.fn_flags & ZEND_ACC_CLONE) {
        ce->clone = zf;
    }
    else {
dnl FIXME: handle common.function_name here
#define SET_IF_SAME_NAME(member) \
        do { \
            if (!strcasecmp(ZSTR_S(zf->common.function_name), #member)) { \
                ce->member = zf; \
            } \
        } \
        while(0)
        /* if(ce->member && !strcmp(zf->common.function_name, ce->member->common.function_name)) { \ */

        SET_IF_SAME_NAME(__get);
        SET_IF_SAME_NAME(__set);
#ifdef ZEND_ENGINE_2_1
        SET_IF_SAME_NAME(__unset);
        SET_IF_SAME_NAME(__isset);
#endif
        SET_IF_SAME_NAME(__call);
#if defined(ZEND_ENGINE_2_2) || PHP_MAJOR_VERSION >= 6
        SET_IF_SAME_NAME(__tostring);
#endif

#undef SET_IF_SAME_NAME
    }
}
/* }}} */
#endif
dnl ================ export API
/* export: xc_entry_t *xc_processor_store_xc_entry_t(xc_entry_t *src TSRMLS_DC); :export {{{ */
xc_entry_t *xc_processor_store_xc_entry_t(xc_entry_t *src TSRMLS_DC) {
    xc_entry_t *dst;
    processor_t processor;

    memset(&processor, 0, sizeof(processor));
    if (src->type == XC_TYPE_VAR) {
        processor.reference = 1;
    }

    IFASSERT(`xc_stack_init(&processor.allocsizes);')

    /* calc size */ {
        zend_hash_init(&processor.strings, 0, NULL, NULL, 0);
        if (processor.reference) {
            zend_hash_init(&processor.zvalptrs, 0, NULL, NULL, 0);
        }

        processor.size = 0;
        /* allocate */
        processor.size = ALIGN(processor.size + sizeof(src[0]));

        xc_calc_xc_entry_t(&processor, src TSRMLS_CC);
        if (processor.reference) {
            zend_hash_destroy(&processor.zvalptrs);
        }
        zend_hash_destroy(&processor.strings);
    }
    src->size = processor.size;

    IFASSERT(`xc_stack_reverse(&processor.allocsizes);')
    /* store {{{ */
    {
        IFASSERT(`char *oldp;')
        zend_hash_init(&processor.strings, 0, NULL, NULL, 0);
        if (processor.reference) {
            zend_hash_init(&processor.zvalptrs, 0, NULL, NULL, 0);
        }

        /* mem :) */
        processor.p = (char *) src->cache->mem->handlers->malloc(src->cache->mem, processor.size);
        if (processor.p == NULL) {
            dst = NULL;
            goto err_alloc;
        }
        IFASSERT(`oldp = processor.p;')
        assert(processor.p == (char *) ALIGN(processor.p));

        /* allocate */
        dst = (xc_entry_t *) processor.p;
        processor.p = (char *) ALIGN(processor.p + sizeof(dst[0]));

        xc_store_xc_entry_t(&processor, dst, src TSRMLS_CC);
        IFASSERT(` {
            int real = processor.p - oldp;
            int should = processor.size;
            if (real != processor.size) {
                fprintf(stderr, "real %d - should %d = %d\n", real, should, real - should);
                abort();
            }
        }')
err_alloc:
        if (processor.reference) {
            zend_hash_destroy(&processor.zvalptrs);
        }
        zend_hash_destroy(&processor.strings);
    }
    /* }}} */

    IFASSERT(`xc_stack_destroy(&processor.allocsizes);')

    return dst;
}
/* }}} */
/* export: xc_entry_t *xc_processor_restore_xc_entry_t(xc_entry_t *dst, const xc_entry_t *src, zend_bool readonly_protection TSRMLS_DC); :export {{{ */
xc_entry_t *xc_processor_restore_xc_entry_t(xc_entry_t *dst, const xc_entry_t *src, zend_bool readonly_protection TSRMLS_DC) {
    processor_t processor;

    memset(&processor, 0, sizeof(processor));
    processor.readonly_protection = readonly_protection;

    xc_restore_xc_entry_t(&processor, dst, src TSRMLS_CC);
    return dst;
}
/* }}} */
/* export: zval *xc_processor_restore_zval(zval *dst, const zval *src TSRMLS_DC); :export {{{ */
zval *xc_processor_restore_zval(zval *dst, const zval *src TSRMLS_DC) {
    processor_t processor;

    memset(&processor, 0, sizeof(processor));
    processor.reference = 1;

    zend_hash_init(&processor.zvalptrs, 0, NULL, NULL, 0);
    dnl fprintf(stderr, "mark[%p] = %p\n", src, dst);
    zend_hash_add(&processor.zvalptrs, (char *)src, sizeof(src), (void*)&dst, sizeof(dst), NULL);
    xc_restore_zval(&processor, dst, src TSRMLS_CC);
    zend_hash_destroy(&processor.zvalptrs);

    return dst;
}
/* }}} */
/* export: void xc_dprint(xc_entry_t *src, int indent TSRMLS_DC); :export {{{ */
#ifdef XCACHE_HAVE_DPRINT
void xc_dprint(xc_entry_t *src, int indent TSRMLS_DC) {
    IFDPRINT(`INDENT()`'fprintf(stderr, "xc_entry_t:src");')
    xc_dprint_xc_entry_t(src, indent TSRMLS_CC);
}
#endif
/* }}} */