@ -514,11 +514,14 @@ public class ArbitraryDataManager extends Thread {
// data cache so that it is rebuilt the next time we serve it
// data cache so that it is rebuilt the next time we serve it
invalidateCache ( arbitraryTransactionData ) ;
invalidateCache ( arbitraryTransactionData ) ;
// We also need to broadcast to the network that we are now hosting files for this transaction
// We may also need to broadcast to the network that we are now hosting files for this transaction,
// but only if these files are in accordance with our storage policy (we may have requested them for viewing only)
if ( ArbitraryDataStorageManager . getInstance ( ) . shouldStoreDataForName ( arbitraryTransactionData . getName ( ) ) ) {
// Use a null peer address to indicate our own
// Use a null peer address to indicate our own
Message newArbitrarySignatureMessage = new ArbitrarySignaturesMessage ( null , Arrays . asList ( signature ) ) ;
Message newArbitrarySignatureMessage = new ArbitrarySignaturesMessage ( null , Arrays . asList ( signature ) ) ;
Network . getInstance ( ) . broadcast ( broadcastPeer - > newArbitrarySignatureMessage ) ;
Network . getInstance ( ) . broadcast ( broadcastPeer - > newArbitrarySignatureMessage ) ;
}
}
}
} catch ( DataException | InterruptedException e ) {
} catch ( DataException | InterruptedException e ) {
LOGGER . error ( String . format ( "Repository issue while finding arbitrary transaction data list for peer %s" , peer ) , e ) ;
LOGGER . error ( String . format ( "Repository issue while finding arbitrary transaction data list for peer %s" , peer ) , e ) ;