diff --git a/me/cache/P2PCache.java b/me/cache/P2PCache.java index 8a025176..51c676a3 100644 --- a/me/cache/P2PCache.java +++ b/me/cache/P2PCache.java @@ -125,16 +125,12 @@ public class P2PCache implements IGridCache private void updateTunnel(long freq, boolean updateOutputs) { - if ( updateOutputs ) - { - for (PartP2PTunnel p : outputs.values()) - p.onChange(); - } - else - { - for (PartP2PTunnel p : inputs.values()) - p.onChange(); - } + for (PartP2PTunnel p : outputs.get( freq )) + p.onChange(); + + PartP2PTunnel in = inputs.get( freq ); + if ( in != null ) + in.onChange(); } public TunnelCollection getOutputs(long freq, Class c)