You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by ga...@apache.org on 2008/04/30 08:13:53 UTC
svn commit: r652282 - in
/webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory:
InMemoryStorageManager.java InMemoryTransaction.java
Author: gatfora
Date: Tue Apr 29 23:13:53 2008
New Revision: 652282
URL: http://svn.apache.org/viewvc?rev=652282&view=rev
Log:
Only call wakeThread in the cases where we need to wake the Sender as there is work to do
Modified:
webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java
webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryTransaction.java
Modified: webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java?rev=652282&r1=652281&r2=652282&view=diff
==============================================================================
--- webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java (original)
+++ webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java Tue Apr 29 23:13:53 2008
@@ -91,7 +91,7 @@
// do some work that requires a tran without there being a transaction in scope
// then the enlist method will throw an exception.
Thread thread = Thread.currentThread();
- InMemoryTransaction result = new InMemoryTransaction(this, thread);
+ InMemoryTransaction result = new InMemoryTransaction(this, thread, useSerialization);
Transaction oldTran = (Transaction) transactions.putIfAbsent(thread, result);
if(oldTran!=null){
// We don't want to overwrite or return an existing transaction, as someone
@@ -339,4 +339,4 @@
MessageContext msgContext;
SOAPEnvelope envelope;
}
-}
\ No newline at end of file
+}
Modified: webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryTransaction.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryTransaction.java?rev=652282&r1=652281&r2=652282&view=diff
==============================================================================
--- webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryTransaction.java (original)
+++ webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryTransaction.java Tue Apr 29 23:13:53 2008
@@ -47,18 +47,20 @@
private boolean sentMessages = false;
private boolean active = true;
private Thread thread;
+ private boolean useSerialization;
- InMemoryTransaction(InMemoryStorageManager manager, Thread thread) {
+ InMemoryTransaction(InMemoryStorageManager manager, Thread thread, boolean useSerialization) {
if(log.isDebugEnabled()) log.debug("Entry: InMemoryTransaction::<init>");
this.manager = manager;
this.thread = thread;
this.threadName = thread.getName();
+ this.useSerialization = useSerialization;
if(log.isDebugEnabled()) log.debug("Exit: InMemoryTransaction::<init>, " + this);
}
public void commit() {
releaseLocks();
- if(sentMessages) manager.getSender().wakeThread();
+ if(sentMessages && useSerialization) manager.getSender().wakeThread();
active = false;
}
@@ -176,3 +178,4 @@
+
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org