File tree Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -192,11 +192,11 @@ def congestion_check(key)
192
192
end
193
193
194
194
# called from Stud::Buffer#buffer_flush when there are events to flush
195
- def flush ( events , key , teardown = false )
195
+ def flush ( events , key , close = false )
196
196
@redis ||= connect
197
- # we should not block due to congestion on teardown
197
+ # we should not block due to congestion on close
198
198
# to support this Stud::Buffer#buffer_flush should pass here the :final boolean value.
199
- congestion_check ( key ) unless teardown
199
+ congestion_check ( key ) unless close
200
200
@redis . rpush ( key , events )
201
201
end
202
202
# called from Stud::Buffer#buffer_flush when an error occurs
@@ -209,7 +209,7 @@ def on_flush_error(e)
209
209
@redis = connect
210
210
end
211
211
212
- def teardown
212
+ def close
213
213
if @batch
214
214
buffer_flush ( :final => true )
215
215
end
Original file line number Diff line number Diff line change 72
72
CONFIG
73
73
74
74
agent do
75
- # we have to wait for teardown to execute & flush the last batch.
75
+ # we have to wait for close to execute & flush the last batch.
76
76
# otherwise we might start doing assertions before everything has been
77
77
# sent out to redis.
78
78
sleep 2
You can’t perform that action at this time.
0 commit comments