diff --git a/artiq/runtime/analyzer.c b/artiq/runtime/analyzer.c
index feeffac2c..84e15b929 100644
--- a/artiq/runtime/analyzer.c
+++ b/artiq/runtime/analyzer.c
@@ -93,8 +93,9 @@ int analyzer_input(void *data, int length)
     return -1;
 }
 
-void analyzer_poll(void **data, int *length)
+void analyzer_poll(void **data, int *length, int *close_flag)
 {
+    *close_flag = 0;
     switch(send_state) {
         case SEND_STATE_HEADER:
             *length = sizeof(struct analyzer_header) - offset_consumed;
diff --git a/artiq/runtime/analyzer.h b/artiq/runtime/analyzer.h
index f1800c643..c94b664b2 100644
--- a/artiq/runtime/analyzer.h
+++ b/artiq/runtime/analyzer.h
@@ -7,7 +7,7 @@ void analyzer_start(void);
 void analyzer_end(void);
 
 int analyzer_input(void *data, int length);
-void analyzer_poll(void **data, int *length);
+void analyzer_poll(void **data, int *length, int *close_flag);
 void analyzer_ack_consumed(int length);
 void analyzer_ack_sent(int length);