r3/php/r3/r3_persistent.c

54 lines
1.5 KiB
C

#include "php.h"
#include "php_r3.h"
#include "r3_persistent.h"
#include "php_expandable_mux.h"
inline int persistent_store(char *key, int key_len, int list_type, void * val TSRMLS_DC)
{
zend_rsrc_list_entry new_le;
zend_rsrc_list_entry *le;
// store it if it's not in persistent_list
if ( zend_hash_find(&EG(persistent_list), key, key_len + 1, (void**) &le) == SUCCESS ) {
zend_hash_del(&EG(persistent_list), key, key_len + 1);
}
new_le.type = list_type;
new_le.ptr = val;
return zend_hash_update(&EG(persistent_list), key, key_len + 1, (void *) &new_le, sizeof(zend_rsrc_list_entry), NULL);
}
inline void * persistent_fetch(char *key, int key_len TSRMLS_DC)
{
zend_rsrc_list_entry *le;
if ( zend_hash_find(&EG(persistent_list), key, key_len + 1, (void**) &le) == SUCCESS ) {
return le->ptr;
}
return NULL;
}
inline void * r3_persistent_fetch(char *ns, char *key TSRMLS_DC)
{
char *newkey;
int newkey_len;
void *ptr;
newkey_len = spprintf(&newkey, 0, "r3_%s_%s", ns, key);
ptr = persistent_fetch(newkey, newkey_len TSRMLS_CC);
efree(newkey);
return ptr;
}
/*
* Store persistent value with r3 namespace.
*/
inline int r3_persistent_store(char *ns, char *key, int list_type, void * val TSRMLS_DC)
{
char *newkey;
int newkey_len;
int status;
newkey_len = spprintf(&newkey, 0, "r3_%s_%s", ns, key);
status = persistent_store(newkey, newkey_len, list_type, val TSRMLS_CC);
efree(newkey);
return status;
}