php-src/ext/fam/fam.c
Sascha Schumann 58b26398de Add FAM support for LGPLed libfam.
FAM, the File Alteration Monitor, provides an API that applications can use to
be notified when specific files or directories are changed.

FAM is being used in Enlightenment, GNOME/Nautilus, and KDE.

# Yes, this will be moved to PECL once that is fully usable. Emails about
# this issue will likely be redirected to /dev/null. :-)
2002-11-18 17:06:05 +00:00

443 lines
11 KiB
C

/*
+----------------------------------------------------------------------+
| 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
*/