summaryrefslogtreecommitdiff
path: root/ext/dba/dba_flatfile.c
diff options
context:
space:
mode:
authorLorry Tar Creator <lorry-tar-importer@baserock.org>2013-03-14 05:42:27 +0000
committer <>2013-04-03 16:25:08 +0000
commitc4dd7a1a684490673e25aaf4fabec5df138854c4 (patch)
tree4d57c44caae4480efff02b90b9be86f44bf25409 /ext/dba/dba_flatfile.c
downloadphp2-master.tar.gz
Imported from /home/lorry/working-area/delta_php2/php-5.4.13.tar.bz2.HEADphp-5.4.13master
Diffstat (limited to 'ext/dba/dba_flatfile.c')
-rw-r--r--ext/dba/dba_flatfile.c188
1 files changed, 188 insertions, 0 deletions
diff --git a/ext/dba/dba_flatfile.c b/ext/dba/dba_flatfile.c
new file mode 100644
index 0000000..082aa5c
--- /dev/null
+++ b/ext/dba/dba_flatfile.c
@@ -0,0 +1,188 @@
+/*
+ +----------------------------------------------------------------------+
+ | PHP Version 5 |
+ +----------------------------------------------------------------------+
+ | Copyright (c) 1997-2013 The PHP Group |
+ +----------------------------------------------------------------------+
+ | This source file is subject to version 3.01 of the PHP license, |
+ | that is bundled with this package in the file LICENSE, and is |
+ | available through the world-wide-web at the following url: |
+ | http://www.php.net/license/3_01.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: Marcus Boerger <helly@php.net> |
+ +----------------------------------------------------------------------+
+ */
+
+/* $Id$ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include "php.h"
+
+#if DBA_FLATFILE
+#include "php_flatfile.h"
+
+#include "libflatfile/flatfile.h"
+
+#ifdef HAVE_UNISTD_H
+#include <unistd.h>
+#endif
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+
+#define FLATFILE_DATA flatfile *dba = info->dbf
+#define FLATFILE_GKEY datum gkey; gkey.dptr = (char *) key; gkey.dsize = keylen
+
+DBA_OPEN_FUNC(flatfile)
+{
+ info->dbf = pemalloc(sizeof(flatfile), info->flags&DBA_PERSISTENT);
+ memset(info->dbf, 0, sizeof(flatfile));
+
+ ((flatfile*)info->dbf)->fp = info->fp;
+
+ return SUCCESS;
+}
+
+DBA_CLOSE_FUNC(flatfile)
+{
+ FLATFILE_DATA;
+
+ if (dba->nextkey.dptr) {
+ efree(dba->nextkey.dptr);
+ }
+ pefree(dba, info->flags&DBA_PERSISTENT);
+}
+
+DBA_FETCH_FUNC(flatfile)
+{
+ datum gval;
+ char *new = NULL;
+
+ FLATFILE_DATA;
+ FLATFILE_GKEY;
+
+ gval = flatfile_fetch(dba, gkey TSRMLS_CC);
+ if (gval.dptr) {
+ if (newlen) {
+ *newlen = gval.dsize;
+ }
+ new = estrndup(gval.dptr, gval.dsize);
+ efree(gval.dptr);
+ }
+ return new;
+}
+
+DBA_UPDATE_FUNC(flatfile)
+{
+ datum gval;
+
+ FLATFILE_DATA;
+ FLATFILE_GKEY;
+ gval.dptr = (char *) val;
+ gval.dsize = vallen;
+
+ switch(flatfile_store(dba, gkey, gval, mode==1 ? FLATFILE_INSERT : FLATFILE_REPLACE TSRMLS_CC)) {
+ case -1:
+ php_error_docref1(NULL TSRMLS_CC, key, E_WARNING, "Operation not possible");
+ return FAILURE;
+ default:
+ case 0:
+ return SUCCESS;
+ case 1:
+ php_error_docref1(NULL TSRMLS_CC, key, E_WARNING, "Key already exists");
+ return FAILURE;
+ }
+}
+
+DBA_EXISTS_FUNC(flatfile)
+{
+ datum gval;
+ FLATFILE_DATA;
+ FLATFILE_GKEY;
+
+ gval = flatfile_fetch(dba, gkey TSRMLS_CC);
+ if (gval.dptr) {
+ efree(gval.dptr);
+ return SUCCESS;
+ }
+ return FAILURE;
+}
+
+DBA_DELETE_FUNC(flatfile)
+{
+ FLATFILE_DATA;
+ FLATFILE_GKEY;
+ return(flatfile_delete(dba, gkey TSRMLS_CC) == -1 ? FAILURE : SUCCESS);
+}
+
+DBA_FIRSTKEY_FUNC(flatfile)
+{
+ FLATFILE_DATA;
+
+ if (dba->nextkey.dptr) {
+ efree(dba->nextkey.dptr);
+ }
+ dba->nextkey = flatfile_firstkey(dba TSRMLS_CC);
+ if (dba->nextkey.dptr) {
+ if (newlen) {
+ *newlen = dba->nextkey.dsize;
+ }
+ return estrndup(dba->nextkey.dptr, dba->nextkey.dsize);
+ }
+ return NULL;
+}
+
+DBA_NEXTKEY_FUNC(flatfile)
+{
+ FLATFILE_DATA;
+
+ if (!dba->nextkey.dptr) {
+ return NULL;
+ }
+
+ if (dba->nextkey.dptr) {
+ efree(dba->nextkey.dptr);
+ }
+ dba->nextkey = flatfile_nextkey(dba TSRMLS_CC);
+ if (dba->nextkey.dptr) {
+ if (newlen) {
+ *newlen = dba->nextkey.dsize;
+ }
+ return estrndup(dba->nextkey.dptr, dba->nextkey.dsize);
+ }
+ return NULL;
+}
+
+DBA_OPTIMIZE_FUNC(flatfile)
+{
+ /* dummy */
+ return SUCCESS;
+}
+
+DBA_SYNC_FUNC(flatfile)
+{
+ /* dummy */
+ return SUCCESS;
+}
+
+DBA_INFO_FUNC(flatfile)
+{
+ return estrdup(flatfile_version());
+}
+
+#endif
+
+/*
+ * Local variables:
+ * tab-width: 4
+ * c-basic-offset: 4
+ * End:
+ * vim600: sw=4 ts=4 fdm=marker
+ * vim<600: sw=4 ts=4
+ */