225 lines
6.4 KiB
C
225 lines
6.4 KiB
C
/*
|
|
Copyright (C) 2004,2005,2006 (Nuno A. Fonseca) <nuno.fonseca@gmail.com>
|
|
|
|
This program is free software; you can redistribute it and/or
|
|
modify it under the terms of the GNU General Public License
|
|
as published by the Free Software Foundation; either
|
|
version 2 of the License, or (at your option) any later
|
|
version.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
|
|
|
|
|
|
Last rev: $Id: prologterms2c.c,v 1.4 2006-09-28 11:42:51 vsc Exp $
|
|
Comments: This file provides a set of functions to convert a prolog term to a C string and back.
|
|
*/
|
|
#include "config.h"
|
|
#include "prologterms2c.h"
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#if HAVE_STRING_H
|
|
#include <string.h>
|
|
#endif
|
|
#if HAVE_STDARG_H
|
|
#include <stdarg.h>
|
|
#endif
|
|
#if HAVE_MALLOC_H
|
|
#include <malloc.h>
|
|
#endif
|
|
|
|
#if HAVE_MPI_H
|
|
|
|
#ifdef COMPRESS
|
|
#include "minilzo.h"
|
|
#endif
|
|
|
|
#ifndef Quote_illegal_f
|
|
#define Quote_illegal_f 1
|
|
#define Ignore_ops_f 2
|
|
#define Handle_vars_f 4
|
|
#define Use_portray_f 8
|
|
#define To_heap_f 16
|
|
#endif
|
|
|
|
|
|
#ifdef COMPRESS
|
|
|
|
#endif
|
|
|
|
struct buffer_ds buffers[1024];
|
|
|
|
/*********************************************************************************************/
|
|
// prototypes
|
|
void write_msg(const char *fun,const char *file, int line,const char *format, ...);
|
|
|
|
size_t write_term_to_stream(const int fd,const YAP_Term term);
|
|
YAP_Term read_term_from_stream(const int fd);
|
|
/*********************************************************************************************/
|
|
/*
|
|
* Writes a debug message containing the processid, function name, filename, line, and a user message
|
|
*/
|
|
void
|
|
write_msg(const char *fun,const char *file, int line,
|
|
const char *format, ...) {
|
|
va_list ap;
|
|
|
|
va_start(ap, format);
|
|
/* Print the message to stderr */
|
|
fprintf(stderr,
|
|
"[%d:%s in %s at line %d] ", getpid(),fun, file, line);
|
|
vfprintf(stderr, format, ap);
|
|
va_end(ap);
|
|
}
|
|
/*********************************************************************************************
|
|
* Memory handling functions
|
|
*********************************************************************************************/
|
|
/*
|
|
* Adds 'space' to the size of the currently allocated buffer
|
|
*/
|
|
static void
|
|
expand_buffer(const size_t space ) {
|
|
BUFFER_PTR = realloc( BUFFER_PTR, BUFFER_SIZE + space );
|
|
if( BUFFER_PTR == NULL ) {
|
|
YAP_Error(0,0,"Prolog2Term: Out of memory.\n");
|
|
#ifdef MPI
|
|
MPI_Finalize();
|
|
#endif
|
|
YAP_Exit( 1 );
|
|
}
|
|
BUFFER_SIZE+=space;
|
|
}
|
|
/*
|
|
* Changes the size of the buffer to contain at least newsize bytes
|
|
*/
|
|
void change_buffer_size(const size_t newsize) {
|
|
if ( BUFFER_PTR == NULL )
|
|
{
|
|
if ((BUFFER_PTR = malloc( BLOCK_SIZE < newsize ? newsize : BLOCK_SIZE)) == NULL) {
|
|
YAP_Error(0,0,"Prolog2Term: Out of memory.\n");
|
|
#ifdef MPI
|
|
MPI_Finalize();
|
|
#endif
|
|
YAP_Exit( 1 );
|
|
}
|
|
}
|
|
else if ((BUFFER_SIZE>=BLOCK_SIZE &&
|
|
BUFFER_SIZE>=newsize) )
|
|
{
|
|
return;
|
|
}
|
|
else if ((BUFFER_PTR = realloc( BUFFER_PTR, newsize)) == NULL) {
|
|
YAP_Error(0,0,"Prolog2Term: Out of memory.\n");
|
|
#ifdef MPI
|
|
MPI_Finalize();
|
|
#endif
|
|
YAP_Exit( 1 );
|
|
}
|
|
BUFFER_SIZE=newsize;
|
|
}
|
|
/*********************************************************************************************
|
|
* I/O functions
|
|
*********************************************************************************************/
|
|
/*
|
|
* Function used by YAP to write a char to a string
|
|
*/
|
|
static void
|
|
p2c_putt(const YAP_Term t) {
|
|
// if( buffer.size==buffer.len+1 )
|
|
|
|
while ((BUFFER_LEN=YAP_ExportTerm(t, BUFFER_PTR, BUFFER_SIZE)) <= 0) {
|
|
#ifdef DEBUG
|
|
write_msg(__FUNCTION__,__FILE__,__LINE__,"p2c_putc:buffer expanded: size=%u pos=%u len=%u\n",BUFFER_SIZE,BUFFER_POS,BUFFER_LEN);
|
|
#endif
|
|
expand_buffer( BLOCK_SIZE );
|
|
}
|
|
}
|
|
/*
|
|
* Function used by YAP to read a char from a string
|
|
*/
|
|
/*
|
|
* Writes a term to a stream.
|
|
*/
|
|
size_t
|
|
write_term_to_stream(const int fd,const YAP_Term term) {
|
|
|
|
RESET_BUFFER();
|
|
printf("BUFFER_PTR=%p\n", BUFFER_PTR);
|
|
p2c_putt(term);
|
|
if (write(fd,(void*)BUFFER_PTR,BUFFER_LEN) < 0) { // write term
|
|
YAP_Error(0,0,"Prolog2Term: IO error in write.\n");
|
|
return -1;
|
|
}
|
|
return BUFFER_LEN;
|
|
}
|
|
/*
|
|
* Read a prolog term from a stream
|
|
* (the prolog term must have been writen by the write_term_to_stream)
|
|
*/
|
|
YAP_Term
|
|
read_term_from_stream(const int fd) {
|
|
size_t size;
|
|
|
|
RESET_BUFFER();
|
|
if (!read(fd,(void*)&size,sizeof(size_t))) { // read the size of the term
|
|
YAP_Error(0,0,"Prolog2Term: IO error in read.\n");
|
|
}
|
|
#ifdef DEBUG
|
|
write_msg(__FUNCTION__,__FILE__,__LINE__,"read_term_from_stream>>>>size:%d\n",size);
|
|
#endif
|
|
if ( size> BUFFER_SIZE)
|
|
expand_buffer(size-BUFFER_SIZE);
|
|
if (!read(fd,BUFFER_PTR,size)) {
|
|
YAP_Error(0,0,"Prolog2Term: IO error in read.\n");
|
|
}; // read term from stream
|
|
return YAP_ImportTerm( BUFFER_PTR);
|
|
}
|
|
/*********************************************************************************************
|
|
* Conversion: Prolog Term->char[] and char[]->Prolog Term
|
|
*********************************************************************************************/
|
|
/*
|
|
* Converts a term t into a string.
|
|
* The ascii representation of t is
|
|
* copied to ptr if it occupies less than size.
|
|
*/
|
|
char*
|
|
term2string(char *const ptr, size_t *size, const YAP_Term t) {
|
|
char *ret;
|
|
RESET_BUFFER();
|
|
|
|
do {
|
|
if (*size == 0) {
|
|
*size = BUFFER_LEN = YAP_ExportTerm( t, BUFFER_PTR, BUFFER_SIZE );// canonical
|
|
ret=BUFFER_PTR;
|
|
if (BUFFER_LEN == 0) {
|
|
expand_buffer(BLOCK_SIZE);
|
|
}
|
|
} else {
|
|
*size = YAP_ExportTerm( t, ptr, BUFFER_SIZE );// canonical
|
|
ret=ptr;
|
|
}
|
|
} while (*size <= 0);
|
|
return ret;
|
|
}
|
|
/*
|
|
* Converts a string with a ascci representation of a term into a Prolog term.
|
|
*/
|
|
YAP_Term
|
|
string2term(char *const ptr,const size_t *size) {
|
|
YAP_Term t;
|
|
|
|
t = YAP_ImportTerm( ptr );
|
|
if ( t==FALSE ) {
|
|
write_msg(__FUNCTION__,__FILE__,__LINE__,"FAILED string2term>>>>size:%lx %d\n",t,*size);
|
|
exit(1);
|
|
}
|
|
return t;
|
|
}
|
|
#endif /* HAVE_MPI_H */
|