|
|
@@ -375,10 +375,17 @@ class Filter(object): |
|
|
|
insert_ctx.send() |
|
|
|
|
|
|
|
# Save the unprocessed parts |
|
|
|
if processed > 0: |
|
|
|
if processed >= 0: |
|
|
|
old_array = array[processed:] |
|
|
|
else: |
|
|
|
old_array = array |
|
|
|
raise Exception( |
|
|
|
sprintf("%s return value %s must be >= 0", |
|
|
|
str(function), str(processed))) |
|
|
|
|
|
|
|
# Warn if there's too much data remaining |
|
|
|
if old_array.shape[0] > 3 * rows: |
|
|
|
printf("warning: %d unprocessed rows in buffer\n", |
|
|
|
old_array.shape[0]) |
|
|
|
|
|
|
|
# Last call for this contiguous interval |
|
|
|
if old_array.shape[0] != 0: |
|
|
|