Skip to content

Commit

Permalink
ns
Browse files Browse the repository at this point in the history
  • Loading branch information
belaban committed Jul 19, 2023
1 parent aa39012 commit 2f1fbcd
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/org/jgroups/protocols/relay/RELAY2.java
Original file line number Diff line number Diff line change
Expand Up @@ -790,15 +790,15 @@ protected void sendSiteUnreachableTo(Address src, String target_site) {
}
// send message back to the src node.
Message msg=new EmptyMessage(src).setFlag(Flag.OOB)
.putHeader(id, new Relay2Header(SITE_UNREACHABLE).setSites(target_site));
.putHeader(id, new Relay2Header(SITE_UNREACHABLE).addToSites(target_site));
down(msg);
}

protected void sitesChange(boolean down, String ... sites) {
if(!broadcast_route_notifications || sites == null || sites.length == 0)
protected void sitesChange(boolean down, Set<String> sites) {
if(!broadcast_route_notifications || sites == null || sites.isEmpty())
return;
Relay2Header hdr=new Relay2Header(down? SITES_DOWN : SITES_UP, null, null)
.setSites(sites);
.addToSites(sites);
down_prot.down(new EmptyMessage(null).putHeader(id, hdr));
}

Expand Down

0 comments on commit 2f1fbcd

Please sign in to comment.