Skip to content

Commit

Permalink
Merge pull request #1944 from vogel/config-peers-are-outbound
Browse files Browse the repository at this point in the history
set peers from config as OUTBOUND by default

Reviewed-by: MonsieurNicolas
  • Loading branch information
latobarita committed Feb 4, 2019
2 parents 4185e57 + edc8f16 commit d6661f7
Show file tree
Hide file tree
Showing 3 changed files with 13 additions and 19 deletions.
5 changes: 3 additions & 2 deletions src/overlay/OverlayManagerImpl.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -304,8 +304,9 @@ void
OverlayManagerImpl::storePeerList(std::vector<std::string> const& list,
bool setPreferred)
{
auto typeUpgrade = setPreferred ? PeerManager::TypeUpdate::SET_PREFERRED
: PeerManager::TypeUpdate::KEEP;
auto typeUpgrade = setPreferred
? PeerManager::TypeUpdate::SET_PREFERRED
: PeerManager::TypeUpdate::UPDATE_TO_OUTBOUND;

for (auto const& peerStr : list)
{
Expand Down
21 changes: 8 additions & 13 deletions src/overlay/PeerManager.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -278,15 +278,6 @@ PeerManager::update(PeerRecord& peer, TypeUpdate type)
{
switch (type)
{
case TypeUpdate::KEEP:
{
break;
}
case TypeUpdate::SET_INBOUND:
{
peer.mType = static_cast<int>(PeerType::INBOUND);
break;
}
case TypeUpdate::SET_OUTBOUND:
{
peer.mType = static_cast<int>(PeerType::OUTBOUND);
Expand All @@ -305,6 +296,14 @@ PeerManager::update(PeerRecord& peer, TypeUpdate type)
}
break;
}
case TypeUpdate::UPDATE_TO_OUTBOUND:
{
if (peer.mType == static_cast<int>(PeerType::INBOUND))
{
peer.mType = static_cast<int>(PeerType::OUTBOUND);
}
break;
}
default:
{
abort();
Expand Down Expand Up @@ -333,10 +332,6 @@ PeerManager::update(PeerRecord& peer, BackOffUpdate backOff, Application& app)
{
switch (backOff)
{
case BackOffUpdate::KEEP:
{
break;
}
case BackOffUpdate::HARD_RESET:
{
peer.mNumFailures = 0;
Expand Down
6 changes: 2 additions & 4 deletions src/overlay/PeerManager.h
Original file line number Diff line number Diff line change
Expand Up @@ -64,16 +64,14 @@ class PeerManager
public:
enum class TypeUpdate
{
KEEP,
SET_INBOUND,
SET_OUTBOUND,
SET_PREFERRED,
REMOVE_PREFERRED
REMOVE_PREFERRED,
UPDATE_TO_OUTBOUND
};

enum class BackOffUpdate
{
KEEP,
HARD_RESET,
RESET,
INCREASE
Expand Down

0 comments on commit d6661f7

Please sign in to comment.