The R Project SVN – R-packages – Diff – /trunk/SQLiteDF/src/sqlite_vector.c

  * from sdf_data". */
 static long double g_accumulator = 0.0; /* accumulator var for cumsum, cumprod, etc. */
 static int g_start = 0;            /* flag for start of cummulation */
 static int g_narm = 0;             /* for Summary group */
+void _init_sqlite_function_accumulator() {
+    g_accumulator = 0.0;   /* initialize accumulator */
+    g_start = 1;           /* flag that we are at start of accumulating */
+}
 SEXP sdf_do_variable_math(SEXP func, SEXP vector, SEXP other_args) {
     char *iname, *iname_src, *varname_src, *funcname;
     int namelen, res;
     sqlite3_stmt *stmt;
          * at R */
         iname[namelen] = '.';
         return mkString(iname);
+    }
-    g_accumulator = 0.0;   /* initialize accumulator */
+    _init_sqlite_function_accumulator();
-    g_start = 1;           /* flag that we are at start of accumulating */
     sqlite3_step(stmt);
     sqlite3_finalize(stmt);
     UNUSE_SDF2(iname);
     UNUSE_SDF2(iname_src);
     if (!USE_SDF1(iname_src, TRUE, FALSE)) return R_NilValue;
     g_narm = LOGICAL(na_rm)[0];
     if (strcmp(funcname, "range") == 0) {
         /* special handling for range. use min then max */
-        g_start = 1;
-        g_accumulator = 0.0;
+        _init_sqlite_function_accumulator();
         sprintf(g_sql_buf[0], "select min_df([%s]) from [%s].sdf_data", varname_src, iname_src);
         res = sqlite3_prepare(g_workspace, g_sql_buf[0], -1, &stmt, NULL);
         if (_sqlite_error(res)) return R_NilValue;
         sqlite3_step(stmt); sqlite3_finalize(stmt);
         _ret = g_accumulator;
             PROTECT(ret = NEW_NUMERIC(2));
             REAL(ret)[0] = REAL(ret)[1] = R_NaReal;
             goto __sdf_do_variable_summary_out;
+        }
-        g_start = 1;
-        g_accumulator = 0.0;
+        _init_sqlite_function_accumulator();
         sprintf(g_sql_buf[0], "select max_df([%s]) from [%s].sdf_data", varname_src, iname_src);
         res = sqlite3_prepare(g_workspace, g_sql_buf[0], -1, &stmt, NULL);
         if (_sqlite_error(res)) return R_NilValue;
         sqlite3_step(stmt); sqlite3_finalize(stmt);
         /* if there is NA, then the if above should have caught it already */
         PROTECT(ret = NEW_NUMERIC(2));
         REAL(ret)[0] = _ret;
         REAL(ret)[1] = g_accumulator;
     } else {
-        g_start = 1;  /* we'll use these instead of sqlite3_aggregate_context */
-        g_accumulator = 0.0;
+        _init_sqlite_function_accumulator();
         sprintf(g_sql_buf[0], "select %s_df([%s]) from [%s].sdf_data", funcname, varname_src, iname_src);
         res = sqlite3_prepare(g_workspace, g_sql_buf[0], -1, &stmt, NULL);
         if (_sqlite_error(res)) return R_NilValue;
         res = sqlite3_step(stmt); sqlite3_finalize(stmt);

The R Project SVN R-packages

(root)/trunk/SQLiteDF/src/sqlite_vector.c – Rev 3471 → 3473