Skip to content

Commit

Permalink
Merge pull request fluent#4117 from daipom/add-test-in_udp-message_le…
Browse files Browse the repository at this point in the history
…ngth_limit

in_udp: add test of message_length_limit
  • Loading branch information
ashie authored Apr 11, 2023
2 parents 9170cda + ea38c8f commit 863ebca
Showing 1 changed file with 28 additions and 0 deletions.
28 changes: 28 additions & 0 deletions test/plugin/test_in_udp.rb
Original file line number Diff line number Diff line change
Expand Up @@ -265,4 +265,32 @@ def create_udp_socket(host, port)
end
end
end

test 'message_length_limit' do
message_length_limit = 32
d = create_driver(base_config + %!
format none
message_length_limit #{message_length_limit}
!)
d.run(expect_records: 3) do
create_udp_socket('127.0.0.1', @port) do |u|
3.times do |i|
u.send("#{i}" * 40 + "\n", 0)
end
end
end

if Fluent.windows?
expected_records = []
else
expected_records = 3.times.collect do |i|
"#{i}" * message_length_limit
end
end
actual_records = d.events.collect do |event|
event[2]["message"]
end

assert_equal expected_records, actual_records
end
end

0 comments on commit 863ebca

Please sign in to comment.