netbird/gvisor
0
0
Fork 0
mirror of https://github.com/netbirdio/gvisor.git synced 2026-05-22 17:12:49 -07:00
Code Issues Packages Projects Releases Wiki Activity

Deflake RecvLessThanBufferWaitAll.

Browse Source 
PiperOrigin-RevId: 229238781
Change-Id: Ib5a1e46293583efcb09e255fcd400c3fcc53ef1b
This commit is contained in:
Ian Gudger
2019-01-14 13:07:29 -08:00
committed by Shentubot
parent 36f5468e7a
commit 003eedea1c
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
test/syscalls/linux/socket_stream_blocking.cc
+8 -1
View File
@@ -98,7 +98,10 @@ TEST_P(BlockingStreamSocketPairTest, RecvLessThanBuffer) {
SyscallSucceedsWithValue(sizeof(sent_data)));
}
TEST_P(BlockingStreamSocketPairTest, RecvLessThanBufferWaitAll) {
// Test that MSG_WAITALL causes recv to block until all requested data is
// received. Random save can interrupt blocking and cause received data to be
// returned, even if the amount received is less than the full requested amount.
TEST_P(BlockingStreamSocketPairTest, RecvLessThanBufferWaitAll_NoRandomSave) {
auto sockets = ASSERT_NO_ERRNO_AND_VALUE(NewSocketPair());
char sent_data[100];
@@ -112,6 +115,10 @@ TEST_P(BlockingStreamSocketPairTest, RecvLessThanBufferWaitAll) {
const ScopedThread t([&]() {
absl::SleepFor(kDuration);
// Don't let saving after the write interrupt the blocking recv.
const DisableSave ds;
ASSERT_THAT(write(sockets->first_fd(), sent_data, sizeof(sent_data)),
SyscallSucceedsWithValue(sizeof(sent_data)));
});