This is an automated email from the ASF dual-hosted git repository.
bashirbekov pushed a commit to branch feat/add-background-send
in repository https://gitbox.apache.org/repos/asf/iggy.git
The following commit(s) were added to refs/heads/feat/add-background-send by
this push:
new 4f78df71 rm buffer overflow test
4f78df71 is described below
commit 4f78df711d05d77c371844063329624e970fb169
Author: haze518 <[email protected]>
AuthorDate: Mon Jun 9 22:26:28 2025 +0600
rm buffer overflow test
---
core/integration/tests/sdk/producer/background.rs | 42 -----------------------
1 file changed, 42 deletions(-)
diff --git a/core/integration/tests/sdk/producer/background.rs
b/core/integration/tests/sdk/producer/background.rs
index 5e5551d8..0f4de39b 100644
--- a/core/integration/tests/sdk/producer/background.rs
+++ b/core/integration/tests/sdk/producer/background.rs
@@ -94,48 +94,6 @@ async fn background_send_receive_ok() {
cleanup(&client).await;
}
-#[tokio::test]
-async fn background_buffer_overflow_immediate() {
- let mut test_server = TestServer::default();
- test_server.start();
-
- let tcp_client_config = TcpClientConfig {
- server_address: test_server.get_raw_tcp_addr().unwrap(),
- ..TcpClientConfig::default()
- };
- let client =
Box::new(TcpClient::create(Arc::new(tcp_client_config)).unwrap());
- let client = IggyClient::create(client, None, None);
-
- client.connect().await.unwrap();
- assert!(client.ping().await.is_ok(), "Failed to ping server");
-
- login_root(&client).await;
- init_system(&client).await;
-
- client.connect().await.unwrap();
- assert!(client.ping().await.is_ok(), "Failed to ping server");
-
- let cfg = BackgroundConfig::builder()
- .max_buffer_size(IggyByteSize::from(1024))
- .failure_mode(BackpressureMode::FailImmediately)
- .build();
- let producer = client
- .producer(&STREAM_ID.to_string(), &TOPIC_ID.to_string())
- .unwrap()
- .background(cfg)
- .build();
-
- let big = IggyMessage::builder()
- .id(1)
- .payload(Bytes::from(vec![0u8; 2048]))
- .build()
- .unwrap();
- let err = producer.send(vec![big]).await.unwrap_err();
- assert!(matches!(err, IggyError::BackgroundSendBufferOverflow));
-
- cleanup(&client).await;
-}
-
/// Ensures that when backpressure mode is `BlockWithTimeout`, the producer
/// fails with `BackgroundSendTimeout` if buffer is full and the timeout is
exceeded.
///
