Package org.apache.pekko.serialization

Class NestedDeserialization

java.lang.Object
org.apache.pekko.serialization.NestedDeserialization
public class NestedDeserialization extends Object
INTERNAL API

Bounds how deeply one deserialization may nest.

Several wire formats carry a nested payload: the enclosed message is an opaque byte array that is deserialized in turn, and that payload may itself enclose another. Each level is parsed on its own, so a protobuf parser's nesting limit does not bound the chain - only the size of the message does. Recursion therefore tracks the nesting rather than the size of the message, and a sufficiently deep chain fails with a StackOverflowError instead of a serialization error.

The depth is per thread because one message is deserialized synchronously on one thread.

  • Constructor Summary

    Constructors
    Constructor
    Description
    NestedDeserialization()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static <T> T
    atNextLevel(int max, scala.Function0<T> body)
    Runs body one level deeper, failing with NotSerializableException - the ordinary way a message that cannot be deserialized is reported - when the nesting exceeds max.
    static int
    currentDepth()
    Current nesting depth, for testing.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • NestedDeserialization

      public NestedDeserialization()

  • Method Details

    • atNextLevel

      public static <T> T atNextLevel(int max, scala.Function0<T> body)
      Runs body one level deeper, failing with NotSerializableException - the ordinary way a message that cannot be deserialized is reported - when the nesting exceeds max.

    • currentDepth

      public static int currentDepth()
      Current nesting depth, for testing.