summaryrefslogtreecommitdiff
path: root/ext/dba/libflatfile/flatfile.c
diff options
context:
space:
mode:
Diffstat (limited to 'ext/dba/libflatfile/flatfile.c')
-rw-r--r--ext/dba/libflatfile/flatfile.c305
1 files changed, 0 insertions, 305 deletions
diff --git a/ext/dba/libflatfile/flatfile.c b/ext/dba/libflatfile/flatfile.c
deleted file mode 100644
index 4cb820875e..0000000000
--- a/ext/dba/libflatfile/flatfile.c
+++ /dev/null
@@ -1,305 +0,0 @@
-/*
- +----------------------------------------------------------------------+
- | 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. |
- +----------------------------------------------------------------------+
- | Authors: Marcus Boerger <helly@php.net> |
- | based on ext/db/db.c by: |
- | Rasmus Lerdorf <rasmus@php.net> |
- | Jim Winstead <jimw@php.net> |
- +----------------------------------------------------------------------+
- */
-
-/* $Id$ */
-
-#ifdef HAVE_CONFIG_H
-#include "config.h"
-#endif
-
-#include "php.h"
-#include "php_globals.h"
-#include "safe_mode.h"
-
-#include <stdlib.h>
-#include <string.h>
-#include <errno.h>
-#if HAVE_UNISTD_H
-#include <unistd.h>
-#endif
-
-#include "flatfile.h"
-
-/*
- * ret = -1 means that database was opened for read-only
- * ret = 0 success
- * ret = 1 key already exists - nothing done
- */
-
-/* {{{ flatfile_store
- */
-int flatfile_store(flatfile *dba, datum key_datum, datum value_datum, int mode TSRMLS_DC) {
- if (mode == FLATFILE_INSERT) {
- if (flatfile_findkey(dba, key_datum TSRMLS_CC)) {
- return 1;
- }
- php_stream_seek(dba->fp, 0L, SEEK_END);
- php_stream_printf(dba->fp TSRMLS_CC, "%d\n", key_datum.dsize);
- php_stream_flush(dba->fp);
- if (php_stream_write(dba->fp, key_datum.dptr, key_datum.dsize) < key_datum.dsize)
- return -1;
- php_stream_printf(dba->fp TSRMLS_CC, "%d\n", value_datum.dsize);
- php_stream_flush(dba->fp);
- if (php_stream_write(dba->fp, value_datum.dptr, value_datum.dsize) < value_datum.dsize)
- return -1;
- } else { /* DBM_REPLACE */
- flatfile_delete(dba, key_datum TSRMLS_CC);
- php_stream_printf(dba->fp TSRMLS_CC, "%d\n", key_datum.dsize);
- php_stream_flush(dba->fp);
- if (php_stream_write(dba->fp, key_datum.dptr, key_datum.dsize) < key_datum.dsize)
- return -1;
- php_stream_printf(dba->fp TSRMLS_CC, "%d\n", value_datum.dsize);
- if (php_stream_write(dba->fp, value_datum.dptr, value_datum.dsize) < value_datum.dsize)
- return -1;
- }
-
- php_stream_flush(dba->fp);
- return 0;
-}
-/* }}} */
-
-/* {{{ flatfile_fetch
- */
-datum flatfile_fetch(flatfile *dba, datum key_datum TSRMLS_DC) {
- datum value_datum = {NULL, 0};
- size_t num=0;
- size_t buf_size = 1024;
- char *buf;
-
- if (flatfile_findkey(dba, key_datum TSRMLS_CC)) {
- buf = emalloc((buf_size+1) * sizeof(char));
- if (php_stream_gets(dba->fp, buf, 15)) {
- num = atoi(buf);
- if (num > buf_size) {
- buf_size+=num;
- buf = erealloc(buf, (buf_size+1)*sizeof(char));
- }
- php_stream_read(dba->fp, buf, num);
- value_datum.dptr = buf;
- value_datum.dsize = num;
- } else {
- value_datum.dptr = NULL;
- value_datum.dsize = 0;
- efree(buf);
- }
- }
- return value_datum;
-}
-/* }}} */
-
-/* {{{ flatfile_delete
- */
-int flatfile_delete(flatfile *dba, datum key_datum TSRMLS_DC) {
- char *key = key_datum.dptr;
- size_t size = key_datum.dsize;
-
- char *buf;
- size_t num;
- size_t buf_size = 1024;
- size_t pos;
-
- php_stream_rewind(dba->fp);
-
- buf = emalloc((buf_size + 1)*sizeof(char));
- while(!php_stream_eof(dba->fp)) {
- /* read in the length of the key name */
- if (!php_stream_gets(dba->fp, buf, 15))
- break;
- num = atoi(buf);
- if (num > buf_size) {
- buf_size += num;
- buf = erealloc(buf, (buf_size+1)*sizeof(char));
- }
- pos = php_stream_tell(dba->fp);
-
- /* read in the key name */
- num = php_stream_read(dba->fp, buf, sizeof(char)*num);
- if (num<0)
- break;
- *(buf+num) = '\0';
-
- if (size == num && !memcmp(buf, key, size)) {
- php_stream_seek(dba->fp, pos, SEEK_SET);
- php_stream_putc(dba->fp, 0);
- php_stream_flush(dba->fp);
- php_stream_seek(dba->fp, 0L, SEEK_END);
- if (buf)
- efree(buf);
- return SUCCESS;
- }
-
- /* read in the length of the value */
- if (!php_stream_gets(dba->fp, buf, 15))
- break;
- num = atoi(buf);
- if (num > buf_size) {
- buf_size+=num;
- buf = erealloc(buf, (buf_size+1)*sizeof(char));
- }
- /* read in the value */
- num = php_stream_read(dba->fp, buf, sizeof(char)*num);
- if (num<0)
- break;
- }
- if (buf)
- efree(buf);
- return FAILURE;
-}
-/* }}} */
-
-/* {{{ flatfile_findkey
- */
-int flatfile_findkey(flatfile *dba, datum key_datum TSRMLS_DC) {
- char *buf = NULL;
- size_t num;
- size_t buf_size = 1024;
- int ret=0;
- void *key = key_datum.dptr;
- size_t size = key_datum.dsize;
-
- php_stream_rewind(dba->fp);
- buf = emalloc((buf_size+1)*sizeof(char));
- while (!php_stream_eof(dba->fp)) {
- if (!php_stream_gets(dba->fp, buf, 15))
- break;
- num = atoi(buf);
- if (num > buf_size) {
- buf_size+=num;
- buf = erealloc(buf, (buf_size+1)*sizeof(char));
- }
- num = php_stream_read(dba->fp, buf, sizeof(char)*num);
- if (num<0) break;
- *(buf+num) = '\0';
- if (size == num) {
- if (!memcmp(buf, key, size)) {
- ret = 1;
- break;
- }
- }
- if (!php_stream_gets(dba->fp, buf, 15))
- break;
- num = atoi(buf);
- if (num > buf_size) {
- buf_size+=num;
- buf = erealloc(buf, (buf_size+1)*sizeof(char));
- }
- num = php_stream_read(dba->fp, buf, sizeof(char)*num);
- if (num<0)
- break;
- *(buf+num) = '\0';
- }
- if (buf)
- efree(buf);
- return(ret);
-}
-/* }}} */
-
-/* {{{ flatfile_firstkey
- */
-datum flatfile_firstkey(flatfile *dba TSRMLS_DC) {
- datum buf;
- size_t num;
- size_t buf_size = 1024;
-
- php_stream_rewind(dba->fp);
- buf.dptr = emalloc((buf_size+1)*sizeof(char));
- while(!php_stream_eof(dba->fp)) {
- if (!php_stream_gets(dba->fp, buf.dptr, 15)) break;
- num = atoi(buf.dptr);
- if (num > buf_size) {
- buf_size+=num;
- buf.dptr = erealloc(buf.dptr, (buf_size+1)*sizeof(char));
- }
- num = php_stream_read(dba->fp, buf.dptr, num);
- if (num<0)
- break;
- buf.dsize = num;
- if (*(buf.dptr)!=0) {
- dba->CurrentFlatFilePos = php_stream_tell(dba->fp);
- return(buf);
- }
- if (!php_stream_gets(dba->fp, buf.dptr, 15)) break;
- num = atoi(buf.dptr);
- if (num > buf_size) {
- buf_size+=num;
- buf.dptr = erealloc(buf.dptr, (buf_size+1)*sizeof(char));
- }
- num = php_stream_read(dba->fp, buf.dptr, num);
- if (num<0)
- break;
- }
- if (buf.dptr)
- efree(buf.dptr);
- buf.dptr = NULL;
- return(buf);
-}
-/* }}} */
-
-/* {{{ flatfile_nextkey
- */
-datum flatfile_nextkey(flatfile *dba TSRMLS_DC) {
- datum buf;
- size_t num;
- size_t buf_size = 1024;
-
- php_stream_seek(dba->fp, dba->CurrentFlatFilePos, SEEK_SET);
- buf.dptr = emalloc((buf_size+1)*sizeof(char));
- while(!php_stream_eof(dba->fp)) {
- if (!php_stream_gets(dba->fp, buf.dptr, 15)) break;
- num = atoi(buf.dptr);
- if (num > buf_size) {
- buf_size+=num;
- buf.dptr = erealloc(buf.dptr, (buf_size+1)*sizeof(char));
- }
- num = php_stream_read(dba->fp, buf.dptr, num);
- if (num<0)
- break;
- if (!php_stream_gets(dba->fp, buf.dptr, 15))
- break;
- num = atoi(buf.dptr);
- if (num > buf_size) {
- buf_size+=num;
- buf.dptr = erealloc(buf.dptr, (buf_size+1)*sizeof(char));
- }
- num = php_stream_read(dba->fp, buf.dptr, num);
- if (num<0)
- break;
- buf.dsize = num;
- if (*(buf.dptr)!=0) {
- dba->CurrentFlatFilePos = php_stream_tell(dba->fp);
- return(buf);
- }
- }
- if (buf.dptr)
- efree(buf.dptr);
- buf.dptr = NULL;
- return(buf);
-}
-/* }}} */
-
-/*
- * Local variables:
- * tab-width: 4
- * c-basic-offset: 4
- * End:
- * vim600: sw=4 ts=4 fdm=marker
- * vim<600: sw=4 ts=4
- */
View Lorry Controller Status