Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for maxMergeMessages (0.26 sec)

  1. internal/grid/grid.go

    	biggerBufMin = 32 << 10
    
    	// This is the maximum size of bigger buffers.
    	biggerBufMax = maxBufferSize
    
    	// If there is a queue, merge up to this many messages.
    	maxMergeMessages = 50
    
    	// clientPingInterval will ping the remote handler every 15 seconds.
    	// Clients disconnect when we exceed 2 intervals.
    	clientPingInterval = 15 * time.Second
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  2. internal/grid/connection.go

    	pingFrame := message{
    		Op:         OpPing,
    		DeadlineMS: uint32(connPingInterval.Milliseconds()),
    		Payload:    make([]byte, pingMsg{}.Msgsize()),
    	}
    
    	defer ping.Stop()
    	queue := make([][]byte, 0, maxMergeMessages)
    	merged := make([]byte, 0, writeBufferSize)
    	var queueSize int
    	var buf bytes.Buffer
    	var wsw wsWriter
    	var lastSetDeadline time.Time
    
    	// Helper to write everything in buf.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
Back to top