[Cogkit-svn] SF.net SVN: cogkit:[2230] trunk/current/src/cog/modules/karajan/src/org/ globus/cog/karajan/workflow/service/channels/ChannelContext.java

[<ha...@us...>]

Revision: 2230
          http://cogkit.svn.sourceforge.net/cogkit/?rev=2230&view=rev
Author:   hategan
Date:     2008-10-10 23:21:43 +0000 (Fri, 10 Oct 2008)

Log Message:
-----------
perhaps safer

Modified Paths:
--------------
    trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/workflow/service/channels/ChannelContext.java

Modified: trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/workflow/service/channels/ChannelContext.java
===================================================================
--- trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/workflow/service/channels/ChannelContext.java	2008-10-10 23:21:02 UTC (rev 2229)
+++ trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/workflow/service/channels/ChannelContext.java	2008-10-10 23:21:43 UTC (rev 2230)
@@ -116,7 +116,7 @@
 		return channelID;
 	}
 	
-	public synchronized int nextCmdSeq() {
+	public int nextCmdSeq() {
 		cmdseq = cmdseq + 1;
 		while (activeSenders.containsKey(cmdseq) || activeReceivers.containsKey(cmdseq)) {
 			cmdseq = cmdseq + 1;
@@ -124,7 +124,7 @@
 		return cmdseq;
 	}
 
-	public void registerCommand(Command cmd) throws ProtocolException {
+	public synchronized void registerCommand(Command cmd) throws ProtocolException {
 		if (cmd.getId() == RequestReply.NOID) {
 			cmd.setId(nextCmdSeq());
 			activeSenders.put(cmd.getId(), cmd);


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.