Skip to content
Snippets Groups Projects
Commit 290b5392 authored by Marco De Marco's avatar Marco De Marco
Browse files

Process response logic fix

parent 13f5aafd
Branches
Tags
No related merge requests found
...@@ -85,6 +85,8 @@ bool ProtocolManager::hasNextFile() ...@@ -85,6 +85,8 @@ bool ProtocolManager::hasNextFile()
{ {
DEBUG_STREAM << "ProtocolManager::hasNextFile() from failed list" << endl; DEBUG_STREAM << "ProtocolManager::hasNextFile() from failed list" << endl;
//FIXME: inhibition of retry for n seconds
m_recoveryMode = true; m_recoveryMode = true;
return true; return true;
} }
...@@ -171,6 +173,8 @@ FileWrapper::SP ProtocolManager::processResponse(ResponseSP response_sp) ...@@ -171,6 +173,8 @@ FileWrapper::SP ProtocolManager::processResponse(ResponseSP response_sp)
if(!response_sp->IsInitialized()) if(!response_sp->IsInitialized())
throw std::runtime_error("Response not initialized"); throw std::runtime_error("Response not initialized");
if(response_sp->state() == Response::REQUEST_ACCEPTED)
{
std::string filePath = response_sp->file_path(); std::string filePath = response_sp->file_path();
if(filePath.empty()) if(filePath.empty())
...@@ -185,8 +189,6 @@ FileWrapper::SP ProtocolManager::processResponse(ResponseSP response_sp) ...@@ -185,8 +189,6 @@ FileWrapper::SP ProtocolManager::processResponse(ResponseSP response_sp)
boost::uint64_t fileSize = response_sp->file_size(); boost::uint64_t fileSize = response_sp->file_size();
if(response_sp->state() == Response::REQUEST_ACCEPTED)
{
INFO_STREAM << "ProtocolManager::processResponse() transfer file " INFO_STREAM << "ProtocolManager::processResponse() transfer file "
<< fileName << " version " << fileVersion << " size " << fileSize << endl; << fileName << " version " << fileVersion << " size " << fileSize << endl;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment