Skip to content

Commit

Permalink
Epankou/bug routes update ewc 374 (#171)
Browse files Browse the repository at this point in the history
* Bug(fix) microservice removal: networking microsrevice isn't removed (EWC-424)

* Bug(fix) microservice removal: removed extra host mapping (EWC-424)

* Bug(fix) microservice removal: simplified getRunningContainers method (EWC-424)

* Bug(fix) route update: added missing method for route update (EWC-374)
  • Loading branch information
epankou authored and mchepelev committed Dec 27, 2018
1 parent 8ef66fa commit 00c4e53
Show file tree
Hide file tree
Showing 4 changed files with 2 additions and 5 deletions.
4 changes: 2 additions & 2 deletions daemon/src/org/eclipse/iofog/field_agent/FieldAgent.java
Original file line number Diff line number Diff line change
Expand Up @@ -294,13 +294,13 @@ private void verificationFailed() {

if (microserviceConfig) {
processMicroserviceConfig(microservices);
LocalApi.getInstance().update();
}

if (routing) {
processRoutes(microservices);
MessageBus.getInstance().update();
}

LocalApi.getInstance().update();
}
if (changes.getBoolean("tunnel") && !initialization) {
sshProxyManager.update(getProxyConfig());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,6 @@ public void handle(ChannelHandlerContext ctx, HttpRequest req) {

WebSocketMap.addWebsocket('C', id, ctx);
StatusReporter.setLocalApiStatus().setOpenConfigSocketsCount(WebSocketMap.controlWebsocketMap.size());

}

/**
Expand Down
Empty file.
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@
import static java.lang.String.format;
import static org.eclipse.iofog.process_manager.ContainerTask.Tasks.*;
import static org.eclipse.iofog.utils.Constants.ControllerStatus.OK;
import static org.eclipse.iofog.utils.Constants.IOFOG_DOCKER_CONTAINER_NAME_PREFIX;
import static org.eclipse.iofog.utils.Constants.PROCESS_MANAGER;

/**
Expand Down Expand Up @@ -209,7 +208,6 @@ private void deleteOldAgentMicroservices() {
*/
private void deleteObsoleteAgentMicroservices(Set<Microservice> allAgentMicroservices) {
docker.getRunningIofogContainers().stream()
.filter(container -> docker.getContainerName(container).startsWith(IOFOG_DOCKER_CONTAINER_NAME_PREFIX))
.map(container -> docker.getContainerMicroserviceUuid(container))
.filter(microserviceUuid -> allAgentMicroservices.stream()
.noneMatch(microservice -> microservice.getMicroserviceUuid().equals(microserviceUuid)))
Expand Down

0 comments on commit 00c4e53

Please sign in to comment.