Commit ef6f7573 authored by Xiaofei Du's avatar Xiaofei Du Committed by Facebook GitHub Bot

Conserve resource for IoUringBackendTest to avoid rlimit issue

Summary:
This is best effort. We cannot control how many tests are running
at the same time. And if the user is running other tests that consumes resource

Differential Revision: D24289056

fbshipit-source-id: 0810ba0989e84a5bce6d695dd6df0dfe2618fbf7
parent bf475c74
...@@ -250,8 +250,8 @@ std::unique_ptr<folly::EventBase> getEventBase( ...@@ -250,8 +250,8 @@ std::unique_ptr<folly::EventBase> getEventBase(
} }
void testEventFD(bool overflow, bool persist, bool asyncRead) { void testEventFD(bool overflow, bool persist, bool asyncRead) {
static constexpr size_t kBackendCapacity = 64; static constexpr size_t kBackendCapacity = 16;
static constexpr size_t kBackendMaxSubmit = 32; static constexpr size_t kBackendMaxSubmit = 8;
// for overflow == true we use a greater than kBackendCapacity number of // for overflow == true we use a greater than kBackendCapacity number of
// EventFD instances and lower when overflow == false // EventFD instances and lower when overflow == false
size_t kNumEventFds = overflow ? 2048 : 32; size_t kNumEventFds = overflow ? 2048 : 32;
...@@ -284,8 +284,8 @@ void testEventFD(bool overflow, bool persist, bool asyncRead) { ...@@ -284,8 +284,8 @@ void testEventFD(bool overflow, bool persist, bool asyncRead) {
} }
void testInvalidFd(size_t numTotal, size_t numValid, size_t numInvalid) { void testInvalidFd(size_t numTotal, size_t numValid, size_t numInvalid) {
static constexpr size_t kBackendCapacity = 128; static constexpr size_t kBackendCapacity = 32;
static constexpr size_t kBackendMaxSubmit = 64; static constexpr size_t kBackendMaxSubmit = 16;
auto total = numTotal; auto total = numTotal;
...@@ -422,10 +422,10 @@ class EventRecvmsgCallback : public folly::EventRecvmsgCallback { ...@@ -422,10 +422,10 @@ class EventRecvmsgCallback : public folly::EventRecvmsgCallback {
}; };
void testAsyncUDPRecvmsg(bool useRegisteredFds) { void testAsyncUDPRecvmsg(bool useRegisteredFds) {
static constexpr size_t kBackendCapacity = 64; static constexpr size_t kBackendCapacity = 16;
static constexpr size_t kBackendMaxSubmit = 32; static constexpr size_t kBackendMaxSubmit = 8;
static constexpr size_t kBackendMaxGet = 32; static constexpr size_t kBackendMaxGet = 8;
static constexpr size_t kNumSockets = 32; static constexpr size_t kNumSockets = 8;
static constexpr size_t kNumBytes = 16; static constexpr size_t kNumBytes = 16;
static constexpr size_t kNumPackets = 32; static constexpr size_t kNumPackets = 32;
auto total = kNumPackets * kNumSockets; auto total = kNumPackets * kNumSockets;
...@@ -535,9 +535,9 @@ TEST(IoUringBackend, Invalid_fd_5_5) { ...@@ -535,9 +535,9 @@ TEST(IoUringBackend, Invalid_fd_5_5) {
} }
TEST(IoUringBackend, RegisteredFds) { TEST(IoUringBackend, RegisteredFds) {
static constexpr size_t kBackendCapacity = 64; static constexpr size_t kBackendCapacity = 16;
static constexpr size_t kBackendMaxSubmit = 32; static constexpr size_t kBackendMaxSubmit = 8;
static constexpr size_t kBackendMaxGet = 32; static constexpr size_t kBackendMaxGet = 8;
std::unique_ptr<folly::IoUringBackend> backendReg; std::unique_ptr<folly::IoUringBackend> backendReg;
std::unique_ptr<folly::IoUringBackend> backendNoReg; std::unique_ptr<folly::IoUringBackend> backendNoReg;
...@@ -593,9 +593,9 @@ TEST(IoUringBackend, RegisteredFds) { ...@@ -593,9 +593,9 @@ TEST(IoUringBackend, RegisteredFds) {
} }
TEST(IoUringBackend, FileReadWrite) { TEST(IoUringBackend, FileReadWrite) {
static constexpr size_t kBackendCapacity = 2048; static constexpr size_t kBackendCapacity = 512;
static constexpr size_t kBackendMaxSubmit = 32; static constexpr size_t kBackendMaxSubmit = 8;
static constexpr size_t kBackendMaxGet = 32; static constexpr size_t kBackendMaxGet = 8;
folly::PollIoBackend::Options options; folly::PollIoBackend::Options options;
options.setCapacity(kBackendCapacity) options.setCapacity(kBackendCapacity)
...@@ -658,9 +658,9 @@ TEST(IoUringBackend, FileReadWrite) { ...@@ -658,9 +658,9 @@ TEST(IoUringBackend, FileReadWrite) {
} }
TEST(IoUringBackend, FileReadvWritev) { TEST(IoUringBackend, FileReadvWritev) {
static constexpr size_t kBackendCapacity = 2048; static constexpr size_t kBackendCapacity = 512;
static constexpr size_t kBackendMaxSubmit = 32; static constexpr size_t kBackendMaxSubmit = 8;
static constexpr size_t kBackendMaxGet = 32; static constexpr size_t kBackendMaxGet = 8;
folly::PollIoBackend::Options options; folly::PollIoBackend::Options options;
options.setCapacity(kBackendCapacity) options.setCapacity(kBackendCapacity)
...@@ -753,9 +753,9 @@ TEST(IoUringBackend, FileReadvWritev) { ...@@ -753,9 +753,9 @@ TEST(IoUringBackend, FileReadvWritev) {
} }
TEST(IoUringBackend, FileReadMany) { TEST(IoUringBackend, FileReadMany) {
static constexpr size_t kBackendCapacity = 1024; static constexpr size_t kBackendCapacity = 256;
static constexpr size_t kBackendMaxSubmit = 128; static constexpr size_t kBackendMaxSubmit = 32;
static constexpr size_t kBackendMaxGet = 128; static constexpr size_t kBackendMaxGet = 32;
folly::PollIoBackend::Options options; folly::PollIoBackend::Options options;
options.setCapacity(kBackendCapacity) options.setCapacity(kBackendCapacity)
...@@ -814,9 +814,9 @@ TEST(IoUringBackend, FileReadMany) { ...@@ -814,9 +814,9 @@ TEST(IoUringBackend, FileReadMany) {
} }
TEST(IoUringBackend, FileWriteMany) { TEST(IoUringBackend, FileWriteMany) {
static constexpr size_t kBackendCapacity = 1024; static constexpr size_t kBackendCapacity = 256;
static constexpr size_t kBackendMaxSubmit = 128; static constexpr size_t kBackendMaxSubmit = 32;
static constexpr size_t kBackendMaxGet = 128; static constexpr size_t kBackendMaxGet = 32;
folly::PollIoBackend::Options options; folly::PollIoBackend::Options options;
options.setCapacity(kBackendCapacity) options.setCapacity(kBackendCapacity)
...@@ -899,8 +899,8 @@ TEST(IoUringBackend, FileWriteMany) { ...@@ -899,8 +899,8 @@ TEST(IoUringBackend, FileWriteMany) {
namespace folly { namespace folly {
namespace test { namespace test {
static constexpr size_t kCapacity = 16 * 1024; static constexpr size_t kCapacity = 4 * 1024;
static constexpr size_t kMaxSubmit = 128; static constexpr size_t kMaxSubmit = 32;
static constexpr size_t kMaxGet = static_cast<size_t>(-1); static constexpr size_t kMaxGet = static_cast<size_t>(-1);
struct IoUringBackendProvider { struct IoUringBackendProvider {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment