File tree 1 file changed +25
-0
lines changed
1 file changed +25
-0
lines changed Original file line number Diff line number Diff line change @@ -1160,6 +1160,31 @@ def test_stop_parallel_old_supervisor_after_delay
1160
1160
end
1161
1161
end
1162
1162
1163
+ data ( "Default" , { } )
1164
+ data ( "Small" , { maxstdio : 100 } )
1165
+ data ( "Large" , { maxstdio : 3000 } )
1166
+ def test_maxstdio ( cl_opt )
1167
+ # TODO assert
1168
+
1169
+ omit "maxstdio is only for Windows" unless Fluent . windows?
1170
+
1171
+ supervisor = Fluent ::Supervisor . new ( cl_opt )
1172
+ supervisor . setup_maxstdio
1173
+
1174
+ files = [ ]
1175
+ begin
1176
+ 10000 . times do |i |
1177
+ file = File . open ( File . join ( @tmp_dir , "#{ i } .txt" ) , "w" )
1178
+ files . append ( file )
1179
+ end
1180
+ ensure
1181
+ puts files . length
1182
+ files . each do |file |
1183
+ file . close
1184
+ end
1185
+ end
1186
+ end
1187
+
1163
1188
def create_debug_dummy_logger
1164
1189
dl_opts = { }
1165
1190
dl_opts [ :log_level ] = ServerEngine ::DaemonLogger ::DEBUG
You can’t perform that action at this time.
0 commit comments