archive/php-src
1
0
Fork 0
mirror of https://github.com/php/php-src.git synced 2025-08-20 09:24:05 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

For yaz_wait, when event=>TRUE is specified for array options,

Browse source 
yaz_wait returns when one event occurs. This allows us to perform
async operations on many databases. Use OnUpdateInt for PHP4.
This commit is contained in:
Adam Dickmeiss 2003-04-28 19:51:45 +00:00
parent ca47774ede
commit 1329eac05a
1 changed files with 31 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

39
ext/yaz/php_yaz.c
View file

@ -62,6 +62,7 @@ struct Yaz_AssociationInfo {
int persistent; int persistent;
int in_use; int in_use;
int order; int order;
int zval_resource;
}; };
static Yaz_Association yaz_association_mk() static Yaz_Association yaz_association_mk()
@ -205,12 +206,6 @@ static long *array_lookup_bool(HashTable *ht, const char *idx)
return 0; return 0;
} }
#if iliaa_0 /* compile warning fix */
static int send_present(Yaz_Association t);
static int send_sort_present(Yaz_Association t);
static int send_sort(Yaz_Association t);
#endif
static const char *option_get(Yaz_Association as, const char *name) static const char *option_get(Yaz_Association as, const char *name)
{ {
if (!as) { if (!as) {
@ -388,6 +383,7 @@ PHP_FUNCTION(yaz_connect)
#endif #endif
ZEND_REGISTER_RESOURCE(return_value, &shared_associations[i], le_link); ZEND_REGISTER_RESOURCE(return_value, &shared_associations[i], le_link);
as->zval_resource = Z_LVAL_P(return_value);
} }
/* }}} */ /* }}} */
@ -509,13 +505,15 @@ PHP_FUNCTION(yaz_present)
Process events. */ Process events. */
PHP_FUNCTION(yaz_wait) PHP_FUNCTION(yaz_wait)
{ {
pval **pval_options = 0;
int event_mode = 0;
int no = 0; int no = 0;
ZOOM_connection conn_ar[MAX_ASSOC]; ZOOM_connection conn_ar[MAX_ASSOC];
int i, timeout = 15; int i, timeout = 15;
if (ZEND_NUM_ARGS() == 1) { if (ZEND_NUM_ARGS() == 1) {
long *val = 0; long *val = 0;
pval **pval_options = 0; long *event_bool = 0;
HashTable *options_ht = 0; HashTable *options_ht = 0;
if (zend_get_parameters_ex(1, &pval_options) == FAILURE) { if (zend_get_parameters_ex(1, &pval_options) == FAILURE) {
WRONG_PARAM_COUNT; WRONG_PARAM_COUNT;
@ -529,6 +527,9 @@ PHP_FUNCTION(yaz_wait)
if (val) { if (val) {
timeout = *val; timeout = *val;
} }
event_bool = array_lookup_bool(options_ht, "event");
if (event_bool && *event_bool)
event_mode = 1;
} }
#ifdef ZTS #ifdef ZTS
tsrm_mutex_lock(yaz_mutex); tsrm_mutex_lock(yaz_mutex);
@ -546,8 +547,26 @@ PHP_FUNCTION(yaz_wait)
#ifdef ZTS #ifdef ZTS
tsrm_mutex_unlock(yaz_mutex); tsrm_mutex_unlock(yaz_mutex);
#endif #endif
if (event_mode) {
long ev = ZOOM_event(no, conn_ar);
if (ev <= 0) {
RETURN_FALSE;
} else {
Yaz_Association p = shared_associations[ev-1];
int event_code = ZOOM_connection_last_event(p->zoom_conn);
add_assoc_long(*pval_options, "eventcode", event_code);
zend_list_addref(p->zval_resource);
Z_LVAL_P(return_value) = p->zval_resource;
Z_TYPE_P(return_value) = IS_RESOURCE;
return;
}
}
if (no) { if (no) {
while (ZOOM_event (no, conn_ar)); while (ZOOM_event (no, conn_ar))
;
} }
RETURN_TRUE; RETURN_TRUE;
} }
@ -1455,7 +1474,11 @@ static void yaz_close_link (zend_rsrc_list_entry *rsrc TSRMLS_DC)
/* {{{ PHP_INI_BEGIN /* {{{ PHP_INI_BEGIN
*/ */
PHP_INI_BEGIN() PHP_INI_BEGIN()
#if PHP_MAJOR_VERSION >= 5
STD_PHP_INI_ENTRY("yaz.max_links", "100", PHP_INI_ALL, OnUpdateLong, max_links, zend_yaz_globals, yaz_globals) STD_PHP_INI_ENTRY("yaz.max_links", "100", PHP_INI_ALL, OnUpdateLong, max_links, zend_yaz_globals, yaz_globals)
#else
STD_PHP_INI_ENTRY("yaz.max_links", "100", PHP_INI_ALL, OnUpdateInt, max_links, zend_yaz_globals, yaz_globals)
#endif
STD_PHP_INI_ENTRY("yaz.log_file", NULL, PHP_INI_ALL, OnUpdateString, log_file, zend_yaz_globals, yaz_globals) STD_PHP_INI_ENTRY("yaz.log_file", NULL, PHP_INI_ALL, OnUpdateString, log_file, zend_yaz_globals, yaz_globals)
PHP_INI_END() PHP_INI_END()
/* }}} */ /* }}} */