aboutsummaryrefslogtreecommitdiff
path: root/src/freadln.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/freadln.c')
-rw-r--r--src/freadln.c373
1 files changed, 193 insertions, 180 deletions
diff --git a/src/freadln.c b/src/freadln.c
index e8e09bb..42ca868 100644
--- a/src/freadln.c
+++ b/src/freadln.c
@@ -1,4 +1,4 @@
-/*
+/*
* freadln: reads messages continuously from the lines of a file
*
* (c) 1999-2011 IOhannes m zmölnig, forum::für::umläute, institute of electronic music and acoustics (iem)
@@ -8,12 +8,12 @@
* 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, see <http://www.gnu.org/licenses/>.
*/
@@ -37,125 +37,133 @@
#define MIN_FREADLN_LENGTH 10
-/* freadln: reads messages continuously from the lines of
- * a file that doesn't necessarily need to fit
+/* freadln: reads messages continuously from the lines of
+ * a file that doesn't necessarily need to fit
* into the RAM of your system
*/
static t_class *freadln_class;
-typedef struct freadln
-{
- t_object x_ob;
- FILE *x_file;
- char *x_filename;
- char *x_textbuf;
- int x_textbuf_length;
- t_outlet *x_message_outlet;
- t_outlet *x_readybang_outlet;
+typedef struct freadln {
+ t_object x_ob;
+ FILE *x_file;
+ char *x_filename;
+ char *x_textbuf;
+ int x_textbuf_length;
+ t_outlet *x_message_outlet;
+ t_outlet *x_readybang_outlet;
- char linebreak_chr[3];
+ char linebreak_chr[3];
- t_canvas *x_canvas;
+ t_canvas *x_canvas;
} t_freadln;
static void freadln_close (t_freadln *x)
{
- if(x->x_file)
- fclose(x->x_file);
- x->x_file=0;
- if(x->x_filename)
- freebytes(x->x_filename, sizeof(char)*MAXPDSTRING);
- x->x_filename=0;
- if(x->x_textbuf)
- freebytes(x->x_textbuf, sizeof(char)*x->x_textbuf_length);
- x->x_textbuf=0;
- x->x_textbuf_length=0;
+ if(x->x_file) {
+ fclose(x->x_file);
+ }
+ x->x_file=0;
+ if(x->x_filename) {
+ freebytes(x->x_filename, sizeof(char)*MAXPDSTRING);
+ }
+ x->x_filename=0;
+ if(x->x_textbuf) {
+ freebytes(x->x_textbuf, sizeof(char)*x->x_textbuf_length);
+ }
+ x->x_textbuf=0;
+ x->x_textbuf_length=0;
}
static void freadln_open (t_freadln *x, t_symbol *s, t_symbol*type)
{
- char filenamebuf[MAXPDSTRING], *filenamebufptr;
- char*dirname=canvas_getdir(x->x_canvas)->s_name;
- int fd, len;
- post("open: %s", s->s_name);
+ char filenamebuf[MAXPDSTRING], *filenamebufptr;
+ char*dirname=canvas_getdir(x->x_canvas)->s_name;
+ int fd, len;
+ post("open: %s", s->s_name);
- freadln_close(x);
+ freadln_close(x);
-/*
- if(type!=gensym("cr")) {
- pd_error(x, "currently only 'cr' type files are implemented!");
- return;
- }
-*/
- if (type==gensym("cr"))
- strcpy(x->linebreak_chr,"\n");
- else
- strcpy(x->linebreak_chr,";\n");
-
+ /*
+ if(type!=gensym("cr")) {
+ pd_error(x, "currently only 'cr' type files are implemented!");
+ return;
+ }
+ */
+ if (type==gensym("cr")) {
+ strcpy(x->linebreak_chr,"\n");
+ } else {
+ strcpy(x->linebreak_chr,";\n");
+ }
- /* directory, filename, extension, dirresult, nameresult, unsigned int size, int bin */
- if ((fd=open_via_path(
- dirname,
- s->s_name, "",
- filenamebuf,
- &filenamebufptr,
- MAXPDSTRING,
- 0)) < 0 ) {
- pd_error(x, "%s: failed to open %s", s->s_name, filenamebuf);
- return;
- }
- z_close(fd);
- len=strlen(filenamebuf);
- if (!(x->x_filename=(char*)getbytes(sizeof(char)*(len+strlen(s->s_name)+2)))) {
- pd_error(x, "out of memory");
- freadln_close(x);
- return;
- }
- strcpy(x->x_filename,filenamebuf);
- strcpy(x->x_filename+len,"/");
- strcpy(x->x_filename+len+1,filenamebufptr);
- if (!(x->x_file=fopen(x->x_filename, "r"))) {
- pd_error(x, "freadln: failed to fopen %s",x->x_filename);
- return;
- }
- if (!(x->x_textbuf = (char *) getbytes (MIN_FREADLN_LENGTH * sizeof(char)))) {
- pd_error(x, "out of memory!");
- freadln_close(x);
- return;
- }
- x->x_textbuf_length=MIN_FREADLN_LENGTH;
+
+ /* directory, filename, extension, dirresult, nameresult, unsigned int size, int bin */
+ if ((fd=open_via_path(
+ dirname,
+ s->s_name, "",
+ filenamebuf,
+ &filenamebufptr,
+ MAXPDSTRING,
+ 0)) < 0 ) {
+ pd_error(x, "%s: failed to open %s", s->s_name, filenamebuf);
+ return;
+ }
+ z_close(fd);
+ len=strlen(filenamebuf);
+ if (!(x->x_filename=(char*)getbytes(sizeof(char)*(len+strlen(
+ s->s_name)+2)))) {
+ pd_error(x, "out of memory");
+ freadln_close(x);
+ return;
+ }
+ strcpy(x->x_filename,filenamebuf);
+ strcpy(x->x_filename+len,"/");
+ strcpy(x->x_filename+len+1,filenamebufptr);
+ if (!(x->x_file=fopen(x->x_filename, "r"))) {
+ pd_error(x, "freadln: failed to fopen %s",x->x_filename);
+ return;
+ }
+ if (!(x->x_textbuf = (char *) getbytes (MIN_FREADLN_LENGTH * sizeof(
+ char)))) {
+ pd_error(x, "out of memory!");
+ freadln_close(x);
+ return;
+ }
+ x->x_textbuf_length=MIN_FREADLN_LENGTH;
}
-static int enlarge_cstr_if_required(const char **c_str, int *len, const int desired_min_length)
+static int enlarge_cstr_if_required(const char **c_str, int *len,
+ const int desired_min_length)
{
- if ((!(*c_str))||*len==0) {
- *c_str = (char*) calloc (1,sizeof(char));
- return 1;
- }
- if (len[0]<desired_min_length) {
- do {
- len[0]<<=1;
- } while ((len[0]<desired_min_length)&&(len[0]!=0));
- freebytes((char*)*c_str, sizeof(char)*len[0]);
- if (!(*c_str=(char*)calloc(len[0],sizeof(char))))
- len[0]=0;
- }
- return len[0];
+ if ((!(*c_str))||*len==0) {
+ *c_str = (char*) calloc (1,sizeof(char));
+ return 1;
+ }
+ if (len[0]<desired_min_length) {
+ do {
+ len[0]<<=1;
+ } while ((len[0]<desired_min_length)&&(len[0]!=0));
+ freebytes((char*)*c_str, sizeof(char)*len[0]);
+ if (!(*c_str=(char*)calloc(len[0],sizeof(char)))) {
+ len[0]=0;
+ }
+ }
+ return len[0];
}
-static int cstr_char_pos(const char *c_str, const char c)
+static int cstr_char_pos(const char *c_str, const char c)
{
- int cnt=1;
- if (c_str) {
- do {
- if (*c_str==c)
- return cnt;
- cnt++;
- } while (*c_str++!='\0');
- }
- return -1;
+ int cnt=1;
+ if (c_str) {
+ do {
+ if (*c_str==c) {
+ return cnt;
+ }
+ cnt++;
+ } while (*c_str++!='\0');
+ }
+ return -1;
}
static void freadln_done(t_freadln*x)
@@ -165,101 +173,106 @@ static void freadln_done(t_freadln*x)
static void freadln_readline (t_freadln *x)
{
- int min_length=(x->x_textbuf_length < 1)?1:x->x_textbuf_length;
- int linebreak_pos=0;
- int items_read;
- t_binbuf *bbuf;
- t_atom *abuf;
- int abuf_length;
- int rewind_after;
+ int min_length=(x->x_textbuf_length < 1)?1:x->x_textbuf_length;
+ int linebreak_pos=0;
+ int items_read;
+ t_binbuf *bbuf;
+ t_atom *abuf;
+ int abuf_length;
+ int rewind_after;
- if (!x->x_file) {
- pd_error(x, "no file opened for reading");
- freadln_done(x);
- return;
- }
-
- do {
- if (linebreak_pos==-1) {
- min_length<<=1;
- fseek(x->x_file,-(long)(x->x_textbuf_length),SEEK_CUR);
- }
- if (!enlarge_cstr_if_required((const char**) &x->x_textbuf, &x->x_textbuf_length, min_length)) {
- pd_error(x, "out of memory");
- x->x_textbuf_length=0;
- freadln_close(x);
- freadln_done(x);
- return;
- }
- if (!(items_read=fread(x->x_textbuf,sizeof(char),x->x_textbuf_length,x->x_file))) {
- freadln_close(x);
- freadln_done(x);
- return;
- }
- x->x_textbuf[x->x_textbuf_length-1]=0;
- } while (((linebreak_pos=cstr_char_pos(x->x_textbuf,x->linebreak_chr[0]))==-1) &&
- !(items_read < x->x_textbuf_length));
-
- if (linebreak_pos-1 < items_read - strlen(x->linebreak_chr)) {
- rewind_after=items_read-linebreak_pos;
- fseek(x->x_file,-(long)(rewind_after),SEEK_CUR);
- }
- if (linebreak_pos==-1)
- linebreak_pos=items_read;
- x->x_textbuf[linebreak_pos-1]='\0';
- if (!(bbuf=binbuf_new())) {
- pd_error(x, "out of memory");
- freadln_close(x);
- freadln_done(x);
- return;
- }
- binbuf_text(bbuf, x->x_textbuf, linebreak_pos-1);
- abuf = binbuf_getvec(bbuf);
- abuf_length = binbuf_getnatom(bbuf);
- if (abuf_length>0) {
- if (abuf->a_type==A_SYMBOL) {
- outlet_anything(x->x_message_outlet, atom_getsymbol(abuf), abuf_length-1, abuf+1);
- }
- else {
- outlet_list(x->x_message_outlet, gensym("list"), abuf_length, abuf);
- }
- }
- else {
- outlet_list(x->x_message_outlet, atom_getsymbol(abuf), 0, abuf);
- }
- /* NOTE: the following line might be a problem in recursions
- * and could be performed before to outlet_* as well,
- * but(!) atom buffer abuf must be copied if doing so.
- */
- binbuf_free(bbuf);
+ if (!x->x_file) {
+ pd_error(x, "no file opened for reading");
+ freadln_done(x);
+ return;
+ }
+
+ do {
+ if (linebreak_pos==-1) {
+ min_length<<=1;
+ fseek(x->x_file,-(long)(x->x_textbuf_length),SEEK_CUR);
+ }
+ if (!enlarge_cstr_if_required((const char**) &x->x_textbuf,
+ &x->x_textbuf_length, min_length)) {
+ pd_error(x, "out of memory");
+ x->x_textbuf_length=0;
+ freadln_close(x);
+ freadln_done(x);
+ return;
+ }
+ if (!(items_read=fread(x->x_textbuf,sizeof(char),x->x_textbuf_length,
+ x->x_file))) {
+ freadln_close(x);
+ freadln_done(x);
+ return;
+ }
+ x->x_textbuf[x->x_textbuf_length-1]=0;
+ } while (((linebreak_pos=cstr_char_pos(x->x_textbuf,
+ x->linebreak_chr[0]))==-1) &&
+ !(items_read < x->x_textbuf_length));
+
+ if (linebreak_pos-1 < items_read - strlen(x->linebreak_chr)) {
+ rewind_after=items_read-linebreak_pos;
+ fseek(x->x_file,-(long)(rewind_after),SEEK_CUR);
+ }
+ if (linebreak_pos==-1) {
+ linebreak_pos=items_read;
+ }
+ x->x_textbuf[linebreak_pos-1]='\0';
+ if (!(bbuf=binbuf_new())) {
+ pd_error(x, "out of memory");
+ freadln_close(x);
+ freadln_done(x);
+ return;
+ }
+ binbuf_text(bbuf, x->x_textbuf, linebreak_pos-1);
+ abuf = binbuf_getvec(bbuf);
+ abuf_length = binbuf_getnatom(bbuf);
+ if (abuf_length>0) {
+ if (abuf->a_type==A_SYMBOL) {
+ outlet_anything(x->x_message_outlet, atom_getsymbol(abuf), abuf_length-1,
+ abuf+1);
+ } else {
+ outlet_list(x->x_message_outlet, gensym("list"), abuf_length, abuf);
+ }
+ } else {
+ outlet_list(x->x_message_outlet, atom_getsymbol(abuf), 0, abuf);
+ }
+ /* NOTE: the following line might be a problem in recursions
+ * and could be performed before to outlet_* as well,
+ * but(!) atom buffer abuf must be copied if doing so.
+ */
+ binbuf_free(bbuf);
}
static void freadln_free (t_freadln *x)
{
- freadln_close(x);
- outlet_free (x->x_message_outlet);
- outlet_free (x->x_readybang_outlet);
+ freadln_close(x);
+ outlet_free (x->x_message_outlet);
+ outlet_free (x->x_readybang_outlet);
}
static void *freadln_new(void)
{
- t_freadln *x = (t_freadln *)pd_new(freadln_class);
- x->x_message_outlet = outlet_new(&x->x_ob, gensym("list"));
- x->x_readybang_outlet = outlet_new(&x->x_ob, gensym("bang"));
- x->x_filename=0;
- x->x_file=0;
- x->x_textbuf=0;
- x->x_canvas = canvas_getcurrent();
- return (void *)x;
+ t_freadln *x = (t_freadln *)pd_new(freadln_class);
+ x->x_message_outlet = outlet_new(&x->x_ob, gensym("list"));
+ x->x_readybang_outlet = outlet_new(&x->x_ob, gensym("bang"));
+ x->x_filename=0;
+ x->x_file=0;
+ x->x_textbuf=0;
+ x->x_canvas = canvas_getcurrent();
+ return (void *)x;
}
void freadln_setup(void)
{
- freadln_class = class_new(gensym("freadln"), (t_newmethod)freadln_new,
- (t_method) freadln_free, sizeof(t_freadln), 0, 0);
- class_addmethod(freadln_class, (t_method)freadln_open, gensym("open"), A_SYMBOL, A_DEFSYM, 0);
- class_addmethod(freadln_class, (t_method)freadln_close, gensym("close"), A_NULL, 0);
- class_addbang(freadln_class, (t_method)freadln_readline);
+ freadln_class = class_new(gensym("freadln"), (t_newmethod)freadln_new,
+ (t_method) freadln_free, sizeof(t_freadln), 0, 0);
+ class_addmethod(freadln_class, (t_method)freadln_open, gensym("open"),
+ A_SYMBOL, A_DEFSYM, 0);
+ class_addmethod(freadln_class, (t_method)freadln_close, gensym("close"),
+ A_NULL, 0);
+ class_addbang(freadln_class, (t_method)freadln_readline);
- zexy_register("freadln");
+ zexy_register("freadln");
}
generated by cgit v1.2.1 (git 2.18.0) at 2024-11-05 20:44:34 +0000