diff options
author | kaguilar | 2012-03-08 23:11:44 +0000 |
---|---|---|
committer | Ryan D. Brooks | 2012-03-08 23:11:44 +0000 |
commit | 494b93a674355cde7314e9428426d4c268a968f0 (patch) | |
tree | 566085859718e052c2c1ff53098dae7664ba802c /plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse | |
parent | c5a6e2627aa30768621c2bb4eb7cbd61a3e40b53 (diff) | |
download | org.eclipse.osee-494b93a674355cde7314e9428426d4c268a968f0.tar.gz org.eclipse.osee-494b93a674355cde7314e9428426d4c268a968f0.tar.xz org.eclipse.osee-494b93a674355cde7314e9428426d4c268a968f0.zip |
bug: Fix port util and service tracker issues for Message Services
Diffstat (limited to 'plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse')
2 files changed, 3 insertions, 4 deletions
diff --git a/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/MessageSubscriptionService.java b/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/MessageSubscriptionService.java index 25e334cdb20..f99b81fdfac 100644 --- a/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/MessageSubscriptionService.java +++ b/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/MessageSubscriptionService.java @@ -190,13 +190,11 @@ public class MessageSubscriptionService implements IOteMessageService, IMessageD private void createProccessors() throws IOException { Set<? extends DataType> availableTypes = service.getAvailablePhysicalTypes(); - int port = PortUtil.getInstance().getConsecutiveValidPorts(availableTypes.size()); for (DataType type : availableTypes) { final ChannelProcessor handler = new ChannelProcessor(1, type.getToolingBufferSize(), threadPool, msgDatabase, type); - dispatcher.addChannel(localAddress, port, type, handler); - port++; + dispatcher.addChannel(localAddress, 0, type, handler); } } diff --git a/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/UpdateDispatcher.java b/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/UpdateDispatcher.java index 0e127895b46..e283339dfcc 100644 --- a/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/UpdateDispatcher.java +++ b/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/UpdateDispatcher.java @@ -21,6 +21,7 @@ import java.util.Iterator; import java.util.Map; import java.util.Set; import java.util.logging.Level; + import org.eclipse.osee.framework.logging.OseeLog; import org.eclipse.osee.ote.message.enums.DataType; @@ -31,7 +32,7 @@ import org.eclipse.osee.ote.message.enums.DataType; * @author Ken J. Aguilar */ public final class UpdateDispatcher { - private static final int RECEIVE_BUFFER_SIZE = 1024 * 256; + private static final int RECEIVE_BUFFER_SIZE = 1024 * 512; /** * Class Instance Fields ** */ private final Map<DataType, DatagramChannel> channelMap = new HashMap<DataType, DatagramChannel>(); |