--- /dev/null
+/*
+ +----------------------------------------------------------------------+
+ | PHP Version 4 |
+ +----------------------------------------------------------------------+
+ | Copyright (c) 1997-2002 The PHP Group |
+ +----------------------------------------------------------------------+
+ | This source file is subject to version 2.02 of the PHP license, |
+ | that is bundled with this package in the file LICENSE, and is |
+ | available at through the world-wide-web at |
+ | http://www.php.net/license/2_02.txt. |
+ | If you did not receive a copy of the PHP license and are unable to |
+ | obtain it through the world-wide-web, please send a note to |
+ | license@php.net so we can mail you a copy immediately. |
+ +----------------------------------------------------------------------+
+ | Author: Sascha Schumann <sascha@schumann.cx> |
+ +----------------------------------------------------------------------+
+
+ $Id$
+*/
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include "php.h"
+#include "php_ini.h"
+#include "ext/standard/info.h"
+#include "php_fam.h"
+
+#include <fam.h>
+
+/* If you declare any globals in php_fam.h uncomment this:
+ZEND_DECLARE_MODULE_GLOBALS(fam)
+*/
+
+/* True global resources - no need for thread safety here */
+static int le_fam, le_fam_r;
+
+/* {{{ fam_functions[]
+ *
+ * Every user visible function must have an entry in fam_functions[].
+ */
+function_entry fam_functions[] = {
+ PHP_FE(fam_open, NULL)
+ PHP_FE(fam_close, NULL)
+ PHP_FE(fam_monitor_directory, NULL)
+ PHP_FE(fam_monitor_file, NULL)
+ PHP_FE(fam_monitor_collection, NULL)
+ PHP_FE(fam_suspend_monitor, NULL)
+ PHP_FE(fam_resume_monitor, NULL)
+ PHP_FE(fam_cancel_monitor, NULL)
+ PHP_FE(fam_pending, NULL)
+ PHP_FE(fam_next_event, NULL)
+ {NULL, NULL, NULL} /* Must be the last line in fam_functions[] */
+};
+/* }}} */
+
+/* {{{ fam_module_entry
+ */
+zend_module_entry fam_module_entry = {
+#if ZEND_MODULE_API_NO >= 20010901
+ STANDARD_MODULE_HEADER,
+#endif
+ "fam",
+ fam_functions,
+ PHP_MINIT(fam),
+ PHP_MSHUTDOWN(fam),
+ PHP_RINIT(fam), /* Replace with NULL if there's nothing to do at request start */
+ PHP_RSHUTDOWN(fam), /* Replace with NULL if there's nothing to do at request end */
+ PHP_MINFO(fam),
+#if ZEND_MODULE_API_NO >= 20010901
+ "0.1", /* Replace with version number for your extension */
+#endif
+ STANDARD_MODULE_PROPERTIES
+};
+/* }}} */
+
+#ifdef COMPILE_DL_FAM
+ZEND_GET_MODULE(fam)
+#endif
+
+/* {{{ PHP_INI
+ */
+/* Remove comments and fill if you need to have entries in php.ini
+PHP_INI_BEGIN()
+ STD_PHP_INI_ENTRY("fam.global_value", "42", PHP_INI_ALL, OnUpdateInt, global_value, zend_fam_globals, fam_globals)
+ STD_PHP_INI_ENTRY("fam.global_string", "foobar", PHP_INI_ALL, OnUpdateString, global_string, zend_fam_globals, fam_globals)
+PHP_INI_END()
+*/
+/* }}} */
+
+/* {{{ php_fam_init_globals
+ */
+/* Uncomment this function if you have INI entries
+static void php_fam_init_globals(zend_fam_globals *fam_globals)
+{
+ fam_globals->global_value = 0;
+ fam_globals->global_string = NULL;
+}
+*/
+/* }}} */
+
+static void rsrc_close_fam(zend_rsrc_list_entry *rsrc TSRMLS_DC)
+{
+ FAMConnection *fc = (FAMConnection *) rsrc->ptr;
+ FAMClose(fc);
+ efree(fc);
+}
+
+static void rsrc_close_fam_r(zend_rsrc_list_entry *rsrc TSRMLS_DC)
+{
+ /* No need to close */
+ efree(rsrc->ptr);
+}
+
+/* {{{ PHP_MINIT_FUNCTION
+ */
+PHP_MINIT_FUNCTION(fam)
+{
+ le_fam = zend_register_list_destructors_ex(rsrc_close_fam, NULL, "fam connections", module_number);
+ le_fam_r = zend_register_list_destructors_ex(rsrc_close_fam_r, NULL, "fam requests", module_number);
+ /* If you have INI entries, uncomment these lines
+ ZEND_INIT_MODULE_GLOBALS(fam, php_fam_init_globals, NULL);
+ REGISTER_INI_ENTRIES();
+ */
+
+
+ REGISTER_LONG_CONSTANT("FAMChanged", FAMChanged, CONST_PERSISTENT);
+ REGISTER_LONG_CONSTANT("FAMDeleted", FAMDeleted, CONST_PERSISTENT);
+ REGISTER_LONG_CONSTANT("FAMStartExecuting", FAMStartExecuting, CONST_PERSISTENT);
+ REGISTER_LONG_CONSTANT("FAMStopExecuting", FAMStopExecuting, CONST_PERSISTENT);
+ REGISTER_LONG_CONSTANT("FAMCreated", FAMCreated, CONST_PERSISTENT);
+ REGISTER_LONG_CONSTANT("FAMMoved", FAMMoved, CONST_PERSISTENT);
+ REGISTER_LONG_CONSTANT("FAMAcknowledge", FAMAcknowledge, CONST_PERSISTENT);
+ REGISTER_LONG_CONSTANT("FAMExists", FAMExists, CONST_PERSISTENT);
+ REGISTER_LONG_CONSTANT("FAMEndExist", FAMEndExist, CONST_PERSISTENT);
+ return SUCCESS;
+}
+/* }}} */
+
+/* {{{ PHP_MSHUTDOWN_FUNCTION
+ */
+PHP_MSHUTDOWN_FUNCTION(fam)
+{
+ /* uncomment this line if you have INI entries
+ UNREGISTER_INI_ENTRIES();
+ */
+ return SUCCESS;
+}
+/* }}} */
+
+/* Remove if there's nothing to do at request start */
+/* {{{ PHP_RINIT_FUNCTION
+ */
+PHP_RINIT_FUNCTION(fam)
+{
+ return SUCCESS;
+}
+/* }}} */
+
+/* Remove if there's nothing to do at request end */
+/* {{{ PHP_RSHUTDOWN_FUNCTION
+ */
+PHP_RSHUTDOWN_FUNCTION(fam)
+{
+ return SUCCESS;
+}
+/* }}} */
+
+/* {{{ PHP_MINFO_FUNCTION
+ */
+PHP_MINFO_FUNCTION(fam)
+{
+ php_info_print_table_start();
+ php_info_print_table_header(2, "fam support", "enabled");
+ php_info_print_table_end();
+
+ /* Remove comments if you have entries in php.ini
+ DISPLAY_INI_ENTRIES();
+ */
+}
+/* }}} */
+
+
+/* {{{ proto int fam_open([string appname])
+ */
+PHP_FUNCTION(fam_open)
+{
+ char *appname = NULL;
+ int argc = ZEND_NUM_ARGS();
+ int appname_len;
+ FAMConnection *fc;
+ int r;
+
+ if (zend_parse_parameters(argc TSRMLS_CC, "|s", &appname, &appname_len) == FAILURE)
+ return;
+
+ fc = emalloc(sizeof *fc);
+ r = FAMOpen2(fc, appname);
+
+ if (r < 0) {
+ efree(fc);
+ RETURN_FALSE;
+ }
+
+ ZEND_REGISTER_RESOURCE(return_value, fc, le_fam);
+}
+/* }}} */
+
+/* {{{ proto boolean fam_close(resource id)
+ */
+PHP_FUNCTION(fam_close)
+{
+ int argc = ZEND_NUM_ARGS();
+ zval *id;
+
+ if (zend_parse_parameters(argc TSRMLS_CC, "r", &id) == FAILURE)
+ return;
+
+ zend_list_delete(Z_RESVAL_P(id));
+}
+/* }}} */
+
+/* {{{ proto int fam_monitor_directory(resource id, string dirname)
+ */
+PHP_FUNCTION(fam_monitor_directory)
+{
+ char *dirname = NULL;
+ int argc = ZEND_NUM_ARGS();
+ int dirname_len;
+ zval *id;
+ FAMRequest *fr;
+ FAMConnection *fc;
+
+ if (zend_parse_parameters(argc TSRMLS_CC, "rs", &id, &dirname, &dirname_len) == FAILURE)
+ return;
+
+ ZEND_FETCH_RESOURCE(fc, FAMConnection *, &id, -1, "fam", le_fam);
+ ZEND_VERIFY_RESOURCE(fc);
+
+ fr = emalloc(sizeof *fr);
+
+ if (FAMMonitorDirectory(fc, dirname, fr, NULL) < 0) {
+ efree(fr);
+ RETURN_FALSE;
+ }
+
+ ZEND_REGISTER_RESOURCE(return_value, fr, le_fam_r);
+}
+/* }}} */
+
+/* {{{ proto int fam_monitor_file(resource id, string filename)
+ */
+PHP_FUNCTION(fam_monitor_file)
+{
+ char *filename = NULL;
+ int argc = ZEND_NUM_ARGS();
+ int filename_len;
+ zval *id;
+ FAMRequest *fr;
+ FAMConnection *fc;
+
+ if (zend_parse_parameters(argc TSRMLS_CC, "rs", &id, &filename, &filename_len) == FAILURE)
+ return;
+
+ ZEND_FETCH_RESOURCE(fc, FAMConnection *, &id, -1, "fam", le_fam);
+ ZEND_VERIFY_RESOURCE(fc);
+
+ fr = emalloc(sizeof *fr);
+
+ if (FAMMonitorFile(fc, filename, fr, NULL) < 0) {
+ efree(fr);
+ RETURN_FALSE;
+ }
+
+ ZEND_REGISTER_RESOURCE(return_value, fr, le_fam_r);
+}
+/* }}} */
+
+/* {{{ proto int fam_monitor_collection(resource id, string dirname, int depth, string mask)
+ */
+PHP_FUNCTION(fam_monitor_collection)
+{
+ char *dirname = NULL;
+ char *mask = NULL;
+ int argc = ZEND_NUM_ARGS();
+ int dirname_len;
+ int mask_len;
+ zval *id;
+ long depth;
+ FAMRequest *fr;
+ FAMConnection *fc;
+
+ if (zend_parse_parameters(argc TSRMLS_CC, "rsls", &id, &dirname, &dirname_len, &depth, &mask, &mask_len) == FAILURE)
+ return;
+
+ ZEND_FETCH_RESOURCE(fc, FAMConnection *, &id, -1, "fam", le_fam);
+ ZEND_VERIFY_RESOURCE(fc);
+
+ fr = emalloc(sizeof *fr);
+
+ if (FAMMonitorCollection(fc, dirname, fr, NULL, depth, mask) < 0) {
+ efree(fr);
+ RETURN_FALSE;
+ }
+
+ ZEND_REGISTER_RESOURCE(return_value, fr, le_fam_r);
+
+}
+/* }}} */
+
+/* {{{ proto boolean fam_suspend_monitor(resource id, resource monitor_id)
+ */
+PHP_FUNCTION(fam_suspend_monitor)
+{
+ int argc = ZEND_NUM_ARGS();
+ zval *id;
+ zval *monitor_id;
+ FAMRequest *fr;
+ FAMConnection *fc;
+
+ if (zend_parse_parameters(argc TSRMLS_CC, "rr", &id, &monitor_id) == FAILURE)
+ return;
+
+ ZEND_FETCH_RESOURCE(fc, FAMConnection *, &id, -1, "fam", le_fam);
+ ZEND_VERIFY_RESOURCE(fc);
+ ZEND_FETCH_RESOURCE(fr, FAMRequest *, &monitor_id, -1, "fam", le_fam_r);
+ ZEND_VERIFY_RESOURCE(fr);
+
+ if (FAMSuspendMonitor(fc, fr) < 0)
+ RETURN_FALSE;
+ RETURN_TRUE;
+}
+/* }}} */
+
+/* {{{ proto boolean fam_resume_monitor(resource id, resource monitor_id)
+ */
+PHP_FUNCTION(fam_resume_monitor)
+{
+ int argc = ZEND_NUM_ARGS();
+ zval *id;
+ zval *monitor_id;
+ FAMRequest *fr;
+ FAMConnection *fc;
+
+ if (zend_parse_parameters(argc TSRMLS_CC, "rr", &id, &monitor_id) == FAILURE)
+ return;
+
+ ZEND_FETCH_RESOURCE(fc, FAMConnection *, &id, -1, "fam", le_fam);
+ ZEND_VERIFY_RESOURCE(fc);
+ ZEND_FETCH_RESOURCE(fr, FAMRequest *, &monitor_id, -1, "fam", le_fam_r);
+ ZEND_VERIFY_RESOURCE(fr);
+
+ if (FAMResumeMonitor(fc, fr) < 0)
+ RETURN_FALSE;
+ RETURN_TRUE;
+
+}
+/* }}} */
+
+/* {{{ proto boolean fam_cancel_monitor(resource id, resource monitor_id)
+ */
+PHP_FUNCTION(fam_cancel_monitor)
+{
+ int argc = ZEND_NUM_ARGS();
+ zval *id;
+ zval *monitor_id;
+ FAMRequest *fr;
+ FAMConnection *fc;
+ int r;
+
+ if (zend_parse_parameters(argc TSRMLS_CC, "rr", &id, &monitor_id) == FAILURE)
+ return;
+
+ ZEND_FETCH_RESOURCE(fc, FAMConnection *, &id, -1, "fam", le_fam);
+ ZEND_VERIFY_RESOURCE(fc);
+ ZEND_FETCH_RESOURCE(fr, FAMRequest *, &monitor_id, -1, "fam", le_fam_r);
+ ZEND_VERIFY_RESOURCE(fr);
+
+ r = FAMCancelMonitor(fc, fr);
+
+ zend_list_delete(Z_RESVAL_P(monitor_id));
+
+ if (r < 0)
+ RETURN_FALSE;
+ RETURN_TRUE;
+}
+/* }}} */
+
+/* {{{ proto int fam_pending(resource id)
+ */
+PHP_FUNCTION(fam_pending)
+{
+ int argc = ZEND_NUM_ARGS();
+ zval *id;
+ FAMConnection *fc;
+
+ if (zend_parse_parameters(argc TSRMLS_CC, "r", &id) == FAILURE)
+ return;
+
+ ZEND_FETCH_RESOURCE(fc, FAMConnection *, &id, -1, "fam", le_fam);
+ ZEND_VERIFY_RESOURCE(fc);
+
+ RETVAL_LONG(FAMPending(fc));
+}
+/* }}} */
+
+/* {{{ proto array fam_next_event(resource id)
+ */
+PHP_FUNCTION(fam_next_event)
+{
+ int argc = ZEND_NUM_ARGS();
+ zval *id;
+ FAMConnection *fc;
+ FAMEvent fe;
+
+ if (zend_parse_parameters(argc TSRMLS_CC, "r", &id) == FAILURE)
+ return;
+
+ ZEND_FETCH_RESOURCE(fc, FAMConnection *, &id, -1, "fam", le_fam);
+ ZEND_VERIFY_RESOURCE(fc);
+
+ if (FAMNextEvent(fc, &fe) < 0)
+ RETURN_FALSE;
+
+ array_init(return_value);
+ if (fe.hostname)
+ add_assoc_string(return_value, "hostname", fe.hostname, 1);
+ add_assoc_string(return_value, "filename", fe.filename, 1);
+ add_assoc_long(return_value, "code", fe.code);
+}
+/* }}} */
+
+
+/*
+ * Local variables:
+ * tab-width: 4
+ * c-basic-offset: 4
+ * End:
+ * vim600: noet sw=4 ts=4 fdm=marker
+ * vim<600: noet sw=4 ts=4
+ */
projects / php / commitdiff