ConcurrentStorageTest

2

tests

0

failures

0

ignored

0.997s

duration

100%

successful

Tests

Test Duration Result
shakemapNotificationFirst 0.545s passed
shakemapSocketFirst 0.452s passed

Standard error

###
Thu May 01 15:45:01 UTC 2025
INFO	thread=515	[null] sending product to Socket[addr=localhost/127.0.0.1,port=11235,localport=54546]
There are 1 active/queued socket connections
INFO	thread=516	[null] accepted connection Socket[addr=/127.0.0.1,port=54546,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.
INFO	thread=516	[null] received product 'urn:usgs-product:us:shakemap:usa00040xz:1287260900624'
 from Socket[addr=/127.0.0.1,port=54546,localport=11235]
INFO	thread=516	[null] closed connection Socket[addr=/127.0.0.1,port=54546,localport=11235]
INFO	thread=515	[null] send complete Socket[addr=localhost/127.0.0.1,port=11235,localport=54546] 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 May 01 15:45:01 UTC 2025
INFO	thread=630	[null] sending product to Socket[addr=localhost/127.0.0.1,port=11235,localport=54556]
There are 1 active/queued socket connections
INFO	thread=633	[null] accepted connection Socket[addr=/127.0.0.1,port=54556,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.
WARNING	thread=631	[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:635)
	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=631	[null] exception while removing incomplete product
java.lang.IllegalArgumentException: Called getProduct before onEndProduct
	at gov.usgs.earthquake.product.io.ObjectProductHandler.getProduct(ObjectProductHandler.java:50)
	at gov.usgs.earthquake.distribution.FileProductStorage.storeProductSource(FileProductStorage.java:687)
	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=631	[null] exception while retrieving product
WARNING	thread=631	[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=631	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=633	[null] received product 'urn:usgs-product:us:shakemap:usa00040xz:1287260900624'
 from Socket[addr=/127.0.0.1,port=54556,localport=11235]
INFO	thread=633	[null] closed connection Socket[addr=/127.0.0.1,port=54556,localport=11235]
INFO	thread=630	[null] send complete Socket[addr=localhost/127.0.0.1,port=11235,localport=54556] 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)