ConcurrentStorageTest

2

tests

0

failures

0

ignored

1.070s

duration

100%

successful

Tests

Test Duration Result
shakemapNotificationFirst 0.474s passed
shakemapSocketFirst 0.596s passed

Standard error

###
Thu Mar 20 18:33:21 UTC 2025
INFO	thread=494	[null] sending product to Socket[addr=localhost/127.0.0.1,port=11235,localport=59662]
There are 1 active/queued socket connections
INFO	thread=495	[null] accepted connection Socket[addr=/127.0.0.1,port=59662,localport=11235]
WARNING	thread=157	[null] exception running event archive policy (testPolicy) 
java.lang.NullPointerException: Cannot invoke "java.sql.Connection.prepareStatement(String)" because the return value of "gov.usgs.earthquake.indexer.JDBCProductIndex.getConnection()" is null
	at gov.usgs.earthquake.indexer.JDBCProductIndex.getEvents(JDBCProductIndex.java:232)
	at gov.usgs.earthquake.indexer.Indexer.purgeExpiredProducts(Indexer.java:1838)
	at gov.usgs.earthquake.indexer.Indexer$1.run(Indexer.java:1785)
	at java.base/java.util.TimerThread.mainLoop(Timer.java:566)
	at java.base/java.util.TimerThread.run(Timer.java:516)
INFO	thread=157	[null] purged 0 expired events and 0 expired unassociated products.
Thu Mar 20 18:33:22 UTC 2025
INFO	thread=495	[null] received product 'urn:usgs-product:us:shakemap:usa00040xz:1287260900624'
 from Socket[addr=/127.0.0.1,port=59662,localport=11235]
INFO	thread=495	[null] closed connection Socket[addr=/127.0.0.1,port=59662,localport=11235]
INFO	thread=494	[null] send complete Socket[addr=localhost/127.0.0.1,port=11235,localport=59662] response="[null] received product 'urn:usgs-product:us:shakemap:usa00040xz:1287260900624'
"
java.net.SocketException: Socket closed
	at java.base/sun.nio.ch.NioSocketImpl.endAccept(NioSocketImpl.java:694)
	at java.base/sun.nio.ch.NioSocketImpl.accept(NioSocketImpl.java:767)
	at java.base/java.net.ServerSocket.implAccept(ServerSocket.java:675)
	at java.base/java.net.ServerSocket.platformImplAccept(ServerSocket.java:641)
	at java.base/java.net.ServerSocket.implAccept(ServerSocket.java:617)
	at java.base/java.net.ServerSocket.implAccept(ServerSocket.java:574)
	at java.base/java.net.ServerSocket.accept(ServerSocket.java:532)
	at gov.usgs.earthquake.distribution.ConcurrentStorageTest$ProductWebServer.run(ConcurrentStorageTest.java:301)

###
Thu Mar 20 18:33:22 UTC 2025
WARNING	thread=157	[null] exception running event archive policy (testPolicy) 
java.lang.NullPointerException: Cannot invoke "java.sql.Connection.prepareStatement(String)" because the return value of "gov.usgs.earthquake.indexer.JDBCProductIndex.getConnection()" is null
	at gov.usgs.earthquake.indexer.JDBCProductIndex.getEvents(JDBCProductIndex.java:232)
	at gov.usgs.earthquake.indexer.Indexer.purgeExpiredProducts(Indexer.java:1838)
	at gov.usgs.earthquake.indexer.Indexer$1.run(Indexer.java:1785)
	at java.base/java.util.TimerThread.mainLoop(Timer.java:566)
	at java.base/java.util.TimerThread.run(Timer.java:516)
INFO	thread=157	[null] purged 0 expired events and 0 expired unassociated products.
INFO	thread=609	[null] sending product to Socket[addr=localhost/127.0.0.1,port=11235,localport=59664]
There are 1 active/queued socket connections
INFO	thread=612	[null] accepted connection Socket[addr=/127.0.0.1,port=59664,localport=11235]
WARNING	thread=610	[null] exception while storing product, removing incomplete product
java.net.SocketException: Connection reset
	at java.base/sun.nio.ch.NioSocketImpl.implRead(NioSocketImpl.java:328)
	at java.base/sun.nio.ch.NioSocketImpl.read(NioSocketImpl.java:355)
	at java.base/sun.nio.ch.NioSocketImpl$1.read(NioSocketImpl.java:808)
	at java.base/java.net.Socket$SocketInputStream.read(Socket.java:966)
	at java.base/java.io.BufferedInputStream.read1(BufferedInputStream.java:282)
	at java.base/java.io.BufferedInputStream.read(BufferedInputStream.java:343)
	at java.base/sun.net.www.MeteredStream.read(MeteredStream.java:141)
	at java.base/java.io.FilterInputStream.read(FilterInputStream.java:132)
	at java.base/sun.net.www.protocol.http.HttpURLConnection$HttpInputStream.read(HttpURLConnection.java:3735)
	at gov.usgs.earthquake.util.SizeLimitInputStream.read(SizeLimitInputStream.java:66)
	at java.base/java.io.BufferedInputStream.fill(BufferedInputStream.java:244)
	at java.base/java.io.BufferedInputStream.read1(BufferedInputStream.java:284)
	at java.base/java.io.BufferedInputStream.read(BufferedInputStream.java:343)
	at gov.usgs.earthquake.product.io.BinaryIO.readStream(BinaryIO.java:210)
	at gov.usgs.earthquake.product.io.BinaryProductSource.streamTo(BinaryProductSource.java:85)
	at gov.usgs.earthquake.distribution.FileProductStorage.storeProductSource(FileProductStorage.java:598)
	at gov.usgs.earthquake.distribution.DefaultNotificationReceiver.storeProductSource(DefaultNotificationReceiver.java:401)
	at gov.usgs.earthquake.distribution.DefaultNotificationReceiver.retrieveProduct(DefaultNotificationReceiver.java:325)
	at gov.usgs.earthquake.distribution.NotificationEvent.getProduct(NotificationEvent.java:61)
	at gov.usgs.earthquake.distribution.DefaultNotificationListener.onNotification(DefaultNotificationListener.java:126)
	at gov.usgs.earthquake.distribution.NotificationListenerCallable.call(NotificationListenerCallable.java:30)
	at gov.usgs.earthquake.distribution.NotificationListenerCallable.call(NotificationListenerCallable.java:10)
	at gov.usgs.util.ExecutorTask.run(ExecutorTask.java:180)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:840)
WARNING	thread=610	[null] exception while removing incomplete product
java.lang.IllegalArgumentException: Called getProduct before onEndProduct
	at gov.usgs.earthquake.product.io.ObjectProductHandler.getProduct(ObjectProductHandler.java:51)
	at gov.usgs.earthquake.distribution.FileProductStorage.storeProductSource(FileProductStorage.java:638)
	at gov.usgs.earthquake.distribution.DefaultNotificationReceiver.storeProductSource(DefaultNotificationReceiver.java:401)
	at gov.usgs.earthquake.distribution.DefaultNotificationReceiver.retrieveProduct(DefaultNotificationReceiver.java:325)
	at gov.usgs.earthquake.distribution.NotificationEvent.getProduct(NotificationEvent.java:61)
	at gov.usgs.earthquake.distribution.DefaultNotificationListener.onNotification(DefaultNotificationListener.java:126)
	at gov.usgs.earthquake.distribution.NotificationListenerCallable.call(NotificationListenerCallable.java:30)
	at gov.usgs.earthquake.distribution.NotificationListenerCallable.call(NotificationListenerCallable.java:10)
	at gov.usgs.util.ExecutorTask.run(ExecutorTask.java:180)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:840)
WARNING	thread=610	[null] exception while retrieving product
WARNING	thread=610	[null] listener (null) threw exception, for product id = urn:usgs-product:us:shakemap:usa00040xz:1287260900624
gov.usgs.earthquake.distribution.ContinuableListenerException: retrieved product null, notification id=urn:usgs-product:us:shakemap:usa00040xz:1287260900624
	at gov.usgs.earthquake.distribution.DefaultNotificationListener.onNotification(DefaultNotificationListener.java:135)
	at gov.usgs.earthquake.distribution.NotificationListenerCallable.call(NotificationListenerCallable.java:30)
	at gov.usgs.earthquake.distribution.NotificationListenerCallable.call(NotificationListenerCallable.java:10)
	at gov.usgs.util.ExecutorTask.run(ExecutorTask.java:180)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:840)
INFO	thread=610	Exception executing task
gov.usgs.earthquake.distribution.ContinuableListenerException: retrieved product null, notification id=urn:usgs-product:us:shakemap:usa00040xz:1287260900624
	at gov.usgs.earthquake.distribution.DefaultNotificationListener.onNotification(DefaultNotificationListener.java:135)
	at gov.usgs.earthquake.distribution.NotificationListenerCallable.call(NotificationListenerCallable.java:30)
	at gov.usgs.earthquake.distribution.NotificationListenerCallable.call(NotificationListenerCallable.java:10)
	at gov.usgs.util.ExecutorTask.run(ExecutorTask.java:180)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:840)
INFO	thread=612	[null] received product 'urn:usgs-product:us:shakemap:usa00040xz:1287260900624'
 from Socket[addr=/127.0.0.1,port=59664,localport=11235]
INFO	thread=612	[null] closed connection Socket[addr=/127.0.0.1,port=59664,localport=11235]
INFO	thread=609	[null] send complete Socket[addr=localhost/127.0.0.1,port=11235,localport=59664] response="[null] received product 'urn:usgs-product:us:shakemap:usa00040xz:1287260900624'
"
java.net.SocketException: Socket closed
	at java.base/sun.nio.ch.NioSocketImpl.endAccept(NioSocketImpl.java:694)
	at java.base/sun.nio.ch.NioSocketImpl.accept(NioSocketImpl.java:767)
	at java.base/java.net.ServerSocket.implAccept(ServerSocket.java:675)
	at java.base/java.net.ServerSocket.platformImplAccept(ServerSocket.java:641)
	at java.base/java.net.ServerSocket.implAccept(ServerSocket.java:617)
	at java.base/java.net.ServerSocket.implAccept(ServerSocket.java:574)
	at java.base/java.net.ServerSocket.accept(ServerSocket.java:532)
	at gov.usgs.earthquake.distribution.ConcurrentStorageTest$ProductWebServer.run(ConcurrentStorageTest.java:301)