Skip to content

Commit 204e328

Browse files
authored
DPL: allow for larger state information to be sent around (#15378)
1 parent a5278aa commit 204e328

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

Framework/Core/src/DataProcessingStates.cxx

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -111,9 +111,9 @@ void DataProcessingStates::updateState(CommandSpec cmd)
111111
// Add a static mutex to protect the queue
112112
// Get the next available operation in an atomic way.
113113
int size = sizeof(CommandHeader) + cmd.size;
114-
if (size > 16384) {
115-
throw runtime_error_f("State size is %d for state %s. States larger than 16384 bytes not supported for now.",
116-
size, stateSpecs[cmd.id].name.c_str());
114+
if (size > STATES_BUFFER_SIZE / 8) {
115+
throw runtime_error_f("State size is %d (data: %d bytes, header: %zu bytes) for state %s. States larger than %d bytes (1/8 of the states buffer) not supported. State data preview: %.100s",
116+
size, cmd.size, sizeof(CommandHeader), stateSpecs[cmd.id].name.c_str(), STATES_BUFFER_SIZE / 8, cmd.data ? cmd.data : "(null)");
117117
}
118118
int idx = nextState.fetch_sub(size, std::memory_order_relaxed);
119119
if (idx - size < 0) {

0 commit comments

Comments
 (0)