ConcurrentStorageTest

2

tests

0

failures

0

ignored

0.961s

duration

100%

successful

Tests

Test Duration Result
shakemapNotificationFirst 0.503s passed
shakemapSocketFirst 0.458s passed

Standard error

###
Fri Jun 27 16:16:02 UTC 2025
INFO	thread=527	[null] sending product to Socket[addr=localhost/127.0.0.1,port=11235,localport=33166]
There are 1 active/queued socket connections
INFO	thread=528	[null] accepted connection Socket[addr=/127.0.0.1,port=33166,localport=11235]
WARNING	thread=164	[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=164	[null] purged 0 expired events and 0 expired unassociated products.
INFO	thread=528	[null] received product 'urn:usgs-product:us:shakemap:usa00040xz:1287260900624'
 from Socket[addr=/127.0.0.1,port=33166,localport=11235]
INFO	thread=527	[null] send complete Socket[addr=localhost/127.0.0.1,port=11235,localport=33166] response="[null] received product 'urn:usgs-product:us:shakemap:usa00040xz:1287260900624'
"
INFO	thread=528	[null] closed connection Socket[addr=/127.0.0.1,port=33166,localport=11235]
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)

###
Fri Jun 27 16:16:03 UTC 2025
INFO	thread=642	[null] sending product to Socket[addr=localhost/127.0.0.1,port=11235,localport=33178]
There are 1 active/queued socket connections
INFO	thread=643	[null] accepted connection Socket[addr=/127.0.0.1,port=33178,localport=11235]
WARNING	thread=164	[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=164	[null] purged 0 expired events and 0 expired unassociated products.
WARNING	thread=641	[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:84)
	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.ExecutorListenerNotifier.queueNotification(ExecutorListenerNotifier.java:168)
	at gov.usgs.earthquake.distribution.ExecutorListenerNotifier.notifyListeners(ExecutorListenerNotifier.java:142)
	at gov.usgs.earthquake.distribution.ExecutorListenerNotifier.notifyListeners(ExecutorListenerNotifier.java:125)
	at gov.usgs.earthquake.distribution.DefaultNotificationReceiver.notifyListeners(DefaultNotificationReceiver.java:209)
	at gov.usgs.earthquake.distribution.DefaultNotificationReceiver.receiveNotification(DefaultNotificationReceiver.java:187)
	at gov.usgs.earthquake.distribution.ConcurrentStorageTest$SendViaNotification.run(ConcurrentStorageTest.java:207)
WARNING	thread=641	[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.ExecutorListenerNotifier.queueNotification(ExecutorListenerNotifier.java:168)
	at gov.usgs.earthquake.distribution.ExecutorListenerNotifier.notifyListeners(ExecutorListenerNotifier.java:142)
	at gov.usgs.earthquake.distribution.ExecutorListenerNotifier.notifyListeners(ExecutorListenerNotifier.java:125)
	at gov.usgs.earthquake.distribution.DefaultNotificationReceiver.notifyListeners(DefaultNotificationReceiver.java:209)
	at gov.usgs.earthquake.distribution.DefaultNotificationReceiver.receiveNotification(DefaultNotificationReceiver.java:187)
	at gov.usgs.earthquake.distribution.ConcurrentStorageTest$SendViaNotification.run(ConcurrentStorageTest.java:207)
WARNING	thread=641	[null] exception while retrieving product
INFO	thread=643	[null] received product 'urn:usgs-product:us:shakemap:usa00040xz:1287260900624'
 from Socket[addr=/127.0.0.1,port=33178,localport=11235]
INFO	thread=642	[null] send complete Socket[addr=localhost/127.0.0.1,port=11235,localport=33178] response="[null] received product 'urn:usgs-product:us:shakemap:usa00040xz:1287260900624'
"
INFO	thread=643	[null] closed connection Socket[addr=/127.0.0.1,port=33178,localport=11235]
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)