anyproto/any-sync
1
0
Fork 0
mirror of https://github.com/anyproto/any-sync.git synced 2025-06-08 05:57:03 +09:00
Code Activity

Change places limiter and metric

Browse source
This commit is contained in:
mcrakhman 2024-04-02 13:49:47 +02:00
parent 39180d9003
commit 4b6c18f77a
No known key found for this signature in database
GPG key ID: DED12CFEF5B8396B
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
net/rpc/server/drpcserver.go
View file

@ -56,12 +56,12 @@ func (s *drpcServer) Init(a *app.App) (err error) {
var handler drpc.Handler
handler = s
if s.metric != nil {
handler = s.metric.WrapDRPCHandler(handler)
}
if s.limiter != nil {
handler = s.limiter.WrapDRPCHandler(handler)
}
if s.metric != nil {
handler = s.metric.WrapDRPCHandler(handler)
}
bufSize := s.config.Stream.MaxMsgSizeMb * (1 << 20)
s.drpcServer = drpcserver.NewWithOptions(handler, drpcserver.Options{Manager: drpcmanager.Options{
Reader: drpcwire.ReaderOptions{MaximumBufferSize: bufSize},