MCPcopy Create free account
hub / github.com/apache/impala / SetMaxMessageSize

Function SetMaxMessageSize

be/src/rpc/thrift-util.cc:341–346  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

339}
340
341void SetMaxMessageSize(TTransport* transport, int64_t max_message_size) {
342 // TODO: Find way to assign TConfiguration through TTransportFactory instead.
343 transport->getConfiguration()->setMaxMessageSize(max_message_size);
344 transport->updateKnownMessageSize(-1);
345 EXPECT_NO_THROW(transport->checkReadBytesAvailable(max_message_size));
346}
347
348void VerifyMaxMessageSizeInheritance(TTransport* source, TTransport* dest) {
349 // Verify that the source has the max message size set to either the internal

Callers 2

SetupConnectionMethod · 0.85
CreateSocketMethod · 0.85

Calls 4

setMaxMessageSizeMethod · 0.45
getConfigurationMethod · 0.45

Tested by

no test coverage detected