microsoft
/
ctsTraffic
зеркало из https://github.com/microsoft/ctsTraffic.git
1
0
Форкнуть 0
Код Задачи Пакеты Проекты Релизы Вики Активность

Fixed a truncation bug for very large transfers and added a large transfer test.

This commit is contained in:
khorton 2016-08-12 16:19:36 -07:00
Родитель b784f753ad
Коммит f8a8f051ea
3 изменённых файлов: 52 добавлений и 9 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

43
TestScripts/ctsTraffic_acceptance_test.cmd
Просмотреть файл

@ -30,6 +30,7 @@ if /i '%2' == 'debug' (
)
set Role=%1
set VERY_LARGE_TRANSFER=10000000000
set NORMAL_TRANSFER=1000000
set SMALLER_TRANSFER=999999
set VERY_SMALL_TRANSFER=9999
@ -114,6 +115,48 @@ IF ERRORLEVEL 1 (
)
REM **********************************************************************************************
REM Test : verify one extremely long transfer verifying data
REM **********************************************************************************************
Set ERRORLEVEL=
if '%Role%' == 'server' (
cdb -gG -snul -sins -failinc ctsTraffic.exe -listen:* -ServerExitLimit:1 -pattern:%1 -io:%2 -transfer:%VERY_LARGE_TRANSFER%
)
if '%Role%' == 'client' (
REM delay the client
ping localhost -n 5 > nul
cdb -gG -snul -sins -failinc ctsTraffic.exe -target:localhost -connections:1 -iterations:1 -pattern:%1 -io:%2 -transfer:%VERY_LARGE_TRANSFER%
)
IF ERRORLEVEL 1 (
echo TEST FAILED: this test is expected to succeed : %ERRORLEVEL%
PAUSE
) else (
echo PASSED
)
REM **********************************************************************************************
REM Test : verify one extremely long transfer not verifying data
REM **********************************************************************************************
Set ERRORLEVEL=
if '%Role%' == 'server' (
cdb -gG -snul -sins -failinc ctsTraffic.exe -listen:* -ServerExitLimit:1 -pattern:%1 -io:%2 -verify:connection -PrePostRecvs:3 -transfer:%VERY_LARGE_TRANSFER%
)
if '%Role%' == 'client' (
REM delay the client
ping localhost -n 5 > nul
cdb -gG -snul -sins -failinc ctsTraffic.exe -target:localhost -connections:1 -iterations:1 -pattern:%1 -io:%2 -verify:connection -PrePostRecvs:3 -transfer:%VERY_LARGE_TRANSFER%
)
IF ERRORLEVEL 1 (
echo TEST FAILED: this test is expected to succeed : %ERRORLEVEL%
PAUSE
) else (
echo PASSED
)
REM **********************************************************************************************
REM Test : sender sending more bytes than receiver is expecting, slight buffer count delta
REM **********************************************************************************************

Двоичные данные
ctsTraffic/Resource.rc
Просмотреть файл

Двоичный файл не отображается.

18
ctsTraffic/ctsIOPatternState.hpp
Просмотреть файл

@ -118,14 +118,14 @@ namespace ctsTraffic {
L"already_transferred: %llu\n"
L"this->current_transfer: %llu\n"
L"this->inflight_bytes: %llu\n",
static_cast<ULONGLONG>(already_transferred),
static_cast<ULONGLONG>(this->confirmed_bytes),
static_cast<ULONGLONG>(this->inflight_bytes));
static_cast<unsigned long long>(already_transferred),
static_cast<unsigned long long>(this->confirmed_bytes),
static_cast<unsigned long long>(this->inflight_bytes));
ctl::ctFatalCondition(
(already_transferred > this->max_transfer),
L"ctsIOPatternState internal error: bytes already transferred (%llu) is >= the total we're expected to transfer (%llu)\n",
static_cast<ULONGLONG>(already_transferred), static_cast<ULONGLONG>(this->max_transfer));
static_cast<unsigned long long>(already_transferred), static_cast<unsigned long long>(this->max_transfer));
return this->max_transfer - already_transferred;
}
@ -217,7 +217,7 @@ namespace ctsTraffic {
default:
ctl::ctAlwaysFatalCondition(
L"ctsIOPatternState::get_next_task was called in an invalid state (%u): dt %p ctsTraffic!ctsTraffic::ctsIOPatternState",
static_cast<unsigned>(this->internal_state), this);
static_cast<unsigned long>(this->internal_state), this);
return ctsIOPatternProtocolTask::NoIo;
}
}
@ -372,7 +372,7 @@ namespace ctsTraffic {
this->internal_state = InternalPatternState::ErrorIOFailed;
return ctsIOPatternProtocolError::TooManyBytes;
} else {
ctsConfig::PrintDebug(L"\t\tctsIOPatternState::completed_task (RequestFIN) : CompletedTransfer [(already_transferred (%u) == this->max_transfer (%u))]\n", static_cast<unsigned long>(already_transferred), static_cast<unsigned long>(this->max_transfer));
ctsConfig::PrintDebug(L"\t\tctsIOPatternState::completed_task (RequestFIN) : CompletedTransfer\n");
this->internal_state = InternalPatternState::CompletedTransfer;
return ctsIOPatternProtocolError::SuccessfullyCompleted;
}
@ -380,7 +380,7 @@ namespace ctsTraffic {
default:
ctl::ctAlwaysFatalCondition(
L"ctsIOPatternState::completed_task - invalid internal_status (%u): dt %p ctsTraffic!ctsTraffic::ctsIOPatternState",
static_cast<unsigned>(this->internal_state), this);
static_cast<unsigned long>(this->internal_state), this);
}
} else {
// clients will recv the server status, then process their shutdown sequence
@ -425,7 +425,7 @@ namespace ctsTraffic {
return ctsIOPatternProtocolError::TooManyBytes;
}
ctsConfig::PrintDebug(L"\t\tctsIOPatternState::completed_task (RequestFIN) : CompletedTransfer [(already_transferred (%u) == this->max_transfer (%u))]\n", static_cast<unsigned long>(already_transferred), static_cast<unsigned long>(this->max_transfer));
ctsConfig::PrintDebug(L"\t\tctsIOPatternState::completed_task (RequestFIN) : CompletedTransfer\n");
this->internal_state = InternalPatternState::CompletedTransfer;
return ctsIOPatternProtocolError::SuccessfullyCompleted;
@ -437,7 +437,7 @@ namespace ctsTraffic {
default:
ctl::ctAlwaysFatalCondition(
L"ctsIOPatternState::completed_task - invalid internal_status (%u): dt %p ctsTraffic!ctsTraffic::ctsIOPatternState, dt %p ctsTraffic!ctstraffic::ctsIOTask",
static_cast<unsigned>(this->internal_state), this, &_completed_task);
static_cast<unsigned long>(this->internal_state), this, &_completed_task);
}
}