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