@@ -195,7 +195,7 @@ def wait_flush(target_file)
195195 chunk_id = nil
196196 @i . configure ( config_element ( 'ROOT' , '' , { '@id' => id } , [ config_element ( 'buffer' , 'tag' , hash ) ] ) )
197197 @i . register ( :write ) { |chunk |
198- chunk_id = chunk . unique_id ;
198+ chunk_id = chunk . unique_id
199199 raise error_class , "yay, your #write must fail"
200200 }
201201
@@ -220,7 +220,7 @@ def wait_flush(target_file)
220220 secconf = config_element ( 'secondary' , '' , { '@type' => 'backup_output' } )
221221 @i . configure ( config_element ( 'ROOT' , '' , { '@id' => id } , [ config_element ( 'buffer' , 'tag' , hash ) , secconf ] ) )
222222 @i . register ( :write ) { |chunk |
223- chunk_id = chunk . unique_id ;
223+ chunk_id = chunk . unique_id
224224 raise Fluent ::UnrecoverableError , "yay, your #write must fail"
225225 }
226226
@@ -242,7 +242,7 @@ def wait_flush(target_file)
242242 secconf = config_element ( 'secondary' , '' , { '@type' => 'backup_output' } )
243243 @i . configure ( config_element ( 'ROOT' , '' , { '@id' => id } , [ config_element ( 'buffer' , 'tag' , hash ) , secconf ] ) )
244244 @i . register ( :write ) { |chunk |
245- chunk_id = chunk . unique_id ;
245+ chunk_id = chunk . unique_id
246246 raise Fluent ::UnrecoverableError , "yay, your #write must fail"
247247 }
248248
@@ -267,7 +267,7 @@ def wait_flush(target_file)
267267 secconf = config_element ( 'secondary' , '' , { '@type' => 'backup_output' } )
268268 @i . configure ( config_element ( 'ROOT' , '' , { '@id' => id } , [ config_element ( 'buffer' , 'tag' , hash ) , secconf ] ) )
269269 @i . register ( :write ) { |chunk |
270- chunk_id = chunk . unique_id ;
270+ chunk_id = chunk . unique_id
271271 raise Fluent ::UnrecoverableError , "yay, your #write must fail"
272272 }
273273
@@ -293,7 +293,7 @@ def wait_flush(target_file)
293293 secconf = config_element ( 'secondary' , '' , { '@type' => 'backup_output2' } )
294294 @i . configure ( config_element ( 'ROOT' , '' , { '@id' => id } , [ config_element ( 'buffer' , 'tag' , hash ) , secconf ] ) )
295295 @i . register ( :write ) { |chunk |
296- chunk_id = chunk . unique_id ;
296+ chunk_id = chunk . unique_id
297297 raise Fluent ::UnrecoverableError , "yay, your #write must fail"
298298 }
299299 @i . secondary . register ( :write ) { |chunk |
@@ -322,7 +322,7 @@ def wait_flush(target_file)
322322 secconf = config_element ( 'secondary' , '' , { '@type' => 'backup_async_output' } )
323323 @i . configure ( config_element ( 'ROOT' , '' , { '@id' => id } , [ config_element ( 'buffer' , 'tag' , hash ) , secconf ] ) )
324324 @i . register ( :write ) { |chunk |
325- chunk_id = chunk . unique_id ;
325+ chunk_id = chunk . unique_id
326326 raise Fluent ::UnrecoverableError , "yay, your #write must fail"
327327 }
328328
@@ -347,7 +347,7 @@ def wait_flush(target_file)
347347 chunk_id = nil
348348 @i . configure ( config_element ( 'ROOT' , '' , { '@id' => id } , [ config_element ( 'buffer' , 'tag' , hash ) ] ) )
349349 @i . register ( :write ) { |chunk |
350- chunk_id = chunk . unique_id ;
350+ chunk_id = chunk . unique_id
351351 raise Fluent ::UnrecoverableError , "yay, your #write must fail"
352352 }
353353
0 commit comments