Patches item #664469, was opened at 2003-01-08 11:36 You can respond by visiting: https://sourceforge.net/tracker/?func=detail&atid=376687&aid=664469&group_id=22866
Category: JBossMQ Group: v3.0 Rabbit Hole Status: Open Resolution: None Priority: 5 Submitted By: Ryan Harris (rpharris) Assigned to: Nobody/Anonymous (nobody) Summary: JMS Message lost due to synchronization in MessageReference Initial Comment: References Bug#664459 Bug and fix submitted by Ryan Harris of Sterling Commerce, Inc. http://www.sterlingcommerce.com Due to a synchronization error in a MessageReference object, the file reference to a Message object is deleted while no hard reference exists. However, the system is not finished processing the Message and when it attempts to retrieve its hard reference from the file reference on the disk, it fails with a FileNotFound exception. A fix is included and a is attached. It will be submitted in the patch section as well. The problem occurs when a series of the following three events occurs in a MessageReference object. This scenario only occurs when the heap size has passed the HighMemoryMark of the Cachemanager AND the garbage collector happens to run just after the validateSoftReferenceDepth step below. Original MessageReference.invalidate: public void invalidate() throws JMSException { clear(); // Clear out the disk copy } This is the original course of events that occurs: ************************************** validateSoftRefernceDepth (deleting our hard reference and creating a soft reference) **context switch** GC Runs and collects our hard reference. **context switch** invalidate and clear are called (we have no hard reference at this point, deleting our disk reference) **context switch** makeHard is called (we have no hard reference nor a file on the disk) Explosion. ************************************ In order to fix this error, it is required that we check within the invalidate method if we actually have a hard reference to the object, before we blow away the file reference on the disk. Modified MessageReference.invalidate: public void invalidate() throws JMSException { synchronized(messageCache) { if(hardReference != null) clear(); // Clear out the disk copy } } This forces the events into the following pattern: *************************************** validateSoftRefernceDepth (deleting our hard reference) **context switch** GC Runs and collects our hard reference. **context switch** invalidate (fails to delete disk reference because we have no hard reference) **context switch** makeHard is called (we have no hard reference but thefile is still on the disk) Everything is happy. **************************************** Operating Systems: Linux, Windows2k, HPUX, Solaris, AIX, Others most likely JDK: 1.3.1 Stack Trace: [WARN,SpyConnectionConsumer] Connection consumer closing due to error in listening thread. org.jboss.mq.SpyJMSException: Could not load message from secondary storage: ; - nested throwable: (java.io.FileNotFoundException: C:\si_1230 \SterlingIntegrator\jboss\jboss\tmp\jbossmq\Message -5437 (The system cannot find the file specified)) at org.jboss.mq.pm.file.CacheStore.loadFromStorage (CacheStore.java:61) at org.jboss.mq.server.MessageCache.loadFromStorage (MessageCache.java:246) at org.jboss.mq.server.MessageReference.makeHard (MessageReference.java:207) at org.jboss.mq.server.MessageReference.getMessage (MessageReference.java:93 ) at org.jboss.mq.server.BasicQueue.setupMessageAckn owledgement(BasicQueue.ja va:380) at org.jboss.mq.server.BasicQueue.receive (BasicQueue.java:238) at org.jboss.mq.server.JMSQueue.receive (JMSQueue.java:122) at org.jboss.mq.server.ClientConsumer.receive (ClientConsumer.java:225) at org.jboss.mq.server.JMSDestinationManager.receive (JMSDestinationManager. java:669) at org.jboss.mq.server.TracingInterceptor.receive (TracingInterceptor.java:4 33) at org.jboss.mq.server.JMSServerInvoker.receive (JMSServerInvoker.java:227) at org.jboss.mq.il.jvm.JVMServerIL.receive (JVMServerIL.java:245) at org.jboss.mq.Connection.receive (Connection.java:1046) at org.jboss.mq.SpyConnectionConsumer.run (SpyConnectionConsumer.java:183) at java.lang.Thread.run(Thread.java:479) java.io.FileNotFoundException: C:\si_1230 \SterlingIntegrator\jboss\jboss\tmp\jbossmq\Message -5437 (The system cannot find the file specified) at java.io.FileInputStream.open(Native Method) at java.io.FileInputStream.<init> (FileInputStream.java:59) at java.io.FileInputStream.<init> (FileInputStream.java:90) at org.jboss.mq.pm.file.CacheStore.loadFromStorage (CacheStore.java:54) at org.jboss.mq.server.MessageCache.loadFromStorage (MessageCache.java:246) at org.jboss.mq.server.MessageReference.makeHard (MessageReference.java:207) at org.jboss.mq.server.MessageReference.getMessage (MessageReference.java:93 ) at org.jboss.mq.server.BasicQueue.setupMessageAckn owledgement(BasicQueue.ja va:380) at org.jboss.mq.server.BasicQueue.receive (BasicQueue.java:238) at org.jboss.mq.server.JMSQueue.receive (JMSQueue.java:122) at org.jboss.mq.server.ClientConsumer.receive (ClientConsumer.java:225) at org.jboss.mq.server.JMSDestinationManager.receive (JMSDestinationManager. java:669) at org.jboss.mq.server.TracingInterceptor.receive (TracingInterceptor.java:4 33) at org.jboss.mq.server.JMSServerInvoker.receive (JMSServerInvoker.java:227) at org.jboss.mq.il.jvm.JVMServerIL.receive (JVMServerIL.java:245) at org.jboss.mq.Connection.receive (Connection.java:1046) at org.jboss.mq.SpyConnectionConsumer.run SpyConnectionConsumer.java:183) at java.lang.Thread.run(Thread.java:479) [INFO,Default] Mon Dec 30 17:56:49 EST 2002 - >connect() ---------------------------------------------------------------------- You can respond by visiting: https://sourceforge.net/tracker/?func=detail&atid=376687&aid=664469&group_id=22866 ------------------------------------------------------- This SF.NET email is sponsored by: SourceForge Enterprise Edition + IBM + LinuxWorld = Something 2 See! http://www.vasoftware.com _______________________________________________ Jboss-development mailing list [EMAIL PROTECTED] https://lists.sourceforge.net/lists/listinfo/jboss-development
