X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=src%2Fdata%2Flazy-casereader.c;h=bc68b938d5b0169ad0278a8ca760060c5e2c931a;hb=81579d9e9f994fb2908f50af41c3eb033d216e58;hp=65d10aea2477640a826077a7da01c17f78fbf665;hpb=14aac9fe7a7efbb6c9bded2ed5969a643cb76645;p=pspp-builds.git diff --git a/src/data/lazy-casereader.c b/src/data/lazy-casereader.c index 65d10aea..bc68b938 100644 --- a/src/data/lazy-casereader.c +++ b/src/data/lazy-casereader.c @@ -1,5 +1,5 @@ /* PSPP - a program for statistical analysis. - Copyright (C) 2007, 2009 Free Software Foundation, Inc. + Copyright (C) 2007, 2009, 2011 Free Software Foundation, Inc. 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 @@ -16,16 +16,16 @@ #include -#include +#include "data/lazy-casereader.h" #include -#include -#include -#include -#include +#include "data/case.h" +#include "data/casereader.h" +#include "data/casereader-provider.h" +#include "libpspp/assertion.h" -#include "xalloc.h" +#include "gl/xalloc.h" /* A lazy casereader's auxiliary data. */ struct lazy_casereader @@ -43,8 +43,8 @@ static const struct casereader_class lazy_casereader_class; to a "serial number" that uniquely identifies the new lazy casereader, for use with lazy_casereader_destroy. - VALUE_CNT must be the number of struct values per case read - from the casereader. + PROTO must be the format of the cases to be read from the + casereader. CASE_CNT is an upper limit on the number of cases that casereader_read will return from the casereader in successive @@ -52,7 +52,7 @@ static const struct casereader_class lazy_casereader_class; data source or CASENUMBER_MAX if the number of cases cannot be predicted in advance. */ struct casereader * -lazy_casereader_create (size_t value_cnt, casenumber case_cnt, +lazy_casereader_create (const struct caseproto *proto, casenumber case_cnt, struct casereader *(*callback) (void *aux), void *aux, unsigned long int *serial) { @@ -63,7 +63,7 @@ lazy_casereader_create (size_t value_cnt, casenumber case_cnt, *serial = lc->serial = next_serial++; lc->callback = callback; lc->aux = aux; - return casereader_create_sequential (NULL, value_cnt, case_cnt, + return casereader_create_sequential (NULL, proto, case_cnt, &lazy_casereader_class, lc); }