diff --git a/client/actors-framework/src/constants.rs b/client/actors-framework/src/constants.rs index 48ac6ed12..394157a77 100644 --- a/client/actors-framework/src/constants.rs +++ b/client/actors-framework/src/constants.rs @@ -1,4 +1,4 @@ -pub const MAX_PENDING_EVENTS: usize = 2000; -pub const MAX_TASKS_SPAWNED_PER_QUEUE: usize = 2000; +pub const MAX_PENDING_EVENTS: usize = 10000; +pub const MAX_TASKS_SPAWNED_PER_QUEUE: usize = 20000; pub const DEFAULT_ACTOR_COMMAND_QUEUE_WARNING_SIZE: usize = 2000; diff --git a/node/src/services/handler.rs b/node/src/services/handler.rs index 9c0380109..18edb7083 100644 --- a/node/src/services/handler.rs +++ b/node/src/services/handler.rs @@ -167,10 +167,14 @@ where let user_sends_file_task = UserSendsFileTask::new(self.clone()); // Subscribing to NewStorageRequest event from the BlockchainService. + // NewStorageRequest event can be used by the user to spam, by spamming the network with new + // storage requests. To prevent this from affecting a BSP node, we make this event NOT + // critical. This means that if used to spam, some of those spam NewStorageRequest events + // will be dropped. let new_storage_request_event_bus_listener: EventBusListener = user_sends_file_task .clone() - .subscribe_to(&self.task_spawner, &self.blockchain, true); + .subscribe_to(&self.task_spawner, &self.blockchain, false); new_storage_request_event_bus_listener.start(); let accepted_bsp_volunteer_event_bus_listener: EventBusListener =