Skip to main content
summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorkaguilar2012-03-08 23:11:44 +0000
committerRyan D. Brooks2012-03-08 23:11:44 +0000
commit494b93a674355cde7314e9428426d4c268a968f0 (patch)
tree566085859718e052c2c1ff53098dae7664ba802c /plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse
parentc5a6e2627aa30768621c2bb4eb7cbd61a3e40b53 (diff)
downloadorg.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')
-rw-r--r--plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/MessageSubscriptionService.java4
-rw-r--r--plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/UpdateDispatcher.java3
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>();

Back to the top