Skip to content

Commit c488f2e

Browse files
authored
Increase max size of gRPC messages (#10006)
### Related * #9432 ### What Make sure we apply our increased message sizes in more places. Still waiting for a proper fix (#9432)
1 parent 5423f8c commit c488f2e

File tree

2 files changed

+8
-4
lines changed
  • crates/store

2 files changed

+8
-4
lines changed

crates/store/re_grpc_client/src/message_proxy/write.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -168,7 +168,8 @@ async fn message_proxy_client(
168168
}
169169
}
170170
};
171-
let mut client = MessageProxyServiceClient::new(channel);
171+
let mut client = MessageProxyServiceClient::new(channel)
172+
.max_decoding_message_size(crate::MAX_DECODING_MESSAGE_SIZE);
172173

173174
let stream = async_stream::stream! {
174175
loop {

crates/store/re_grpc_server/src/lib.rs

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -946,9 +946,11 @@ mod tests {
946946
let completion = completion.clone();
947947
async move {
948948
tonic::transport::Server::builder()
949-
.add_service(MessageProxyServiceServer::new(super::MessageProxy::new(
950-
memory_limit,
951-
)))
949+
.add_service(
950+
MessageProxyServiceServer::new(super::MessageProxy::new(memory_limit))
951+
.max_decoding_message_size(MAX_DECODING_MESSAGE_SIZE)
952+
.max_encoding_message_size(MAX_ENCODING_MESSAGE_SIZE),
953+
)
952954
.serve_with_incoming_shutdown(
953955
TcpIncoming::from_listener(tcp_listener, true, None).unwrap(),
954956
completion.wait(),
@@ -969,6 +971,7 @@ mod tests {
969971
.await
970972
.unwrap(),
971973
)
974+
.max_decoding_message_size(crate::MAX_DECODING_MESSAGE_SIZE)
972975
}
973976

974977
async fn read_log_stream(

0 commit comments

Comments
 (0)