Ticket #179: xcache-gets.patch

.c

@@ -1898 +1898 @@
     } LEAVE_LOCK(xce.cache);
 }
 /* }}} */
+/* {{{ proto mixed xcache_gets(array name, [array &failed_items])
+   Get cached data by specified name in an array. 2008.06 fcicq, many code from PECL-APC. */
+PHP_FUNCTION(xcache_gets)
+{
+    xc_entry_t xce, *stored_xce;
+    xc_entry_data_var_t var;
+    HashTable *hash;
+    HashPosition hpos;
+    zval *key;
+    zval *flags = NULL;
+    zval *result;
+    zval **hentry;
+    zval *result_entry;
+    int is_flag_exists;
+
+    if (!xc_var_caches) {
+        VAR_DISABLED_WARNING();
+        RETURN_NULL();
+    }
+    
+    if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "z|z", &key, &flags) == FAILURE) {
+        return;
+    }
+
+    is_flag_exists = 0;
+    if (flags != NULL) {
+        is_flag_exists = 1;
+        if (Z_TYPE_P(flags) != IS_ARRAY) {
+            array_init(flags);
+        }
+    }
+        
+    if (Z_TYPE_P(key) != IS_ARRAY) {
+        php_error_docref(NULL TSRMLS_CC, E_WARNING, "xcache_gets() expects an array of strings.");
+        RETURN_FALSE;
+    } 
+    xce.data.var = &var;
+
+    hash = Z_ARRVAL_P(key);
+    MAKE_STD_ZVAL(result);
+    array_init(result);
+    zend_hash_internal_pointer_reset_ex(hash, &hpos);
+    while(zend_hash_get_current_data_ex(hash, (void**)&hentry, &hpos) == SUCCESS) {
+        if(Z_TYPE_PP(hentry) != IS_STRING) {
+            php_error_docref(NULL TSRMLS_CC, E_WARNING, "xcache_gets() expects an array of strings.");
+            RETURN_FALSE;
+        }
+        xc_entry_init_key_var(&xce, *hentry TSRMLS_CC);
+
+        ENTER_LOCK(xce.cache) {
+            stored_xce = xc_entry_find_dmz(&xce TSRMLS_CC);
+            if (stored_xce) {
+                if (!VAR_ENTRY_EXPIRED(stored_xce)) {
+                    MAKE_STD_ZVAL(result_entry);
+
+                    xc_processor_restore_zval(result_entry, stored_xce->data.var->value, stored_xce->have_references TSRMLS_CC);
+
+                    zend_hash_add(Z_ARRVAL_P(result), Z_STRVAL_PP(hentry), Z_STRLEN_PP(hentry) +1, &result_entry, sizeof(zval*), NULL);
+                    xce.cache->hits ++;
+                } else {
+                    xc_entry_remove_dmz(stored_xce TSRMLS_CC);
+                    if (is_flag_exists) {
+                        add_next_index_stringl(flags,  Z_STRVAL_PP(hentry), Z_STRLEN_PP(hentry) , 1);
+                    }
+                    xce.cache->misses ++;
+                }
+            } else {
+                if (is_flag_exists) {
+                    add_next_index_stringl(flags,  Z_STRVAL_PP(hentry), Z_STRLEN_PP(hentry) , 1);
+                }
+                xce.cache->misses ++;
+            }
+        } LEAVE_LOCK(xce.cache);
+        zend_hash_move_forward_ex(hash, &hpos);
+    }
+    RETVAL_ZVAL(result, 0, 1);
+}
+/* }}} */
 /* {{{ proto bool  xcache_isset(string name)
    Check if an entry exists in cache by specified name */
 PHP_FUNCTION(xcache_isset)
@@ -2300 +2378 @@
     PHP_FE(xcache_inc,               NULL)
     PHP_FE(xcache_dec,               NULL)
     PHP_FE(xcache_get,               NULL)
+    PHP_FE(xcache_gets,               NULL) 
     PHP_FE(xcache_set,               NULL)
     PHP_FE(xcache_isset,             NULL)
     PHP_FE(xcache_unset,             NULL)