Function VerifyMaxMessageSizeInheritance

be/src/rpc/thrift-util.cc:348–356

}

void VerifyMaxMessageSizeInheritance(TTransport* source, TTransport* dest) {
  // Verify that the source has the max message size set to either the internal
  // limit or the external limit
  int64_t source_max_message_size = source->getConfiguration()->getMaxMessageSize();
  DCHECK(source_max_message_size == ThriftInternalRpcMaxMessageSize() ||
      source_max_message_size == ThriftExternalRpcMaxMessageSize());
  // Verify that the destination transport has the same limit as the source
  DCHECK_EQ(source_max_message_size, dest->getConfiguration()->getMaxMessageSize());
}
}