Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 4 of 4 for PutResponse (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/grid/handlers.go

    	if _, ok := any(newReq()).(Recycler); ok {
    		s.callReuseReq = true
    	}
    	return &s
    }
    
    // PutResponse will accept a response for reuse.
    // This can be used by a caller to recycle a response after receiving it from a Call.
    func (h *SingleHandler[Req, Resp]) PutResponse(r Resp) {
    	h.recycleResp(r)
    }
    
    // AllowCallRequestPool indicates it is safe to reuse the request
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  2. cmd/bootstrap-peer-server.go

    	}
    
    	recvCfg, err := serverVerifyHandler.Call(ctx, client.gridConn, grid.NewMSS())
    	if err != nil {
    		return err
    	}
    	// We do not need the response after returning.
    	defer serverVerifyHandler.PutResponse(recvCfg)
    
    	return srcCfg.Diff(recvCfg)
    }
    
    // Stringer provides a canonicalized representation of node.
    func (client *bootstrapRESTClient) String() string {
    	return client.gridConn.String()
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Oct 01 22:13:18 GMT 2024
    - 8.4K bytes
    - Click Count (0)
  3. internal/grid/benchmark_test.go

    						latency += time.Since(t).Nanoseconds()
    						if err != nil {
    							if debugReqs {
    								fmt.Println(err.Error())
    							}
    							b.Fatal(err.Error())
    						}
    						rpc.PutResponse(resp)
    						n++
    					}
    					atomic.AddInt64(&ops, int64(n))
    					atomic.AddInt64(&lat, latency)
    				})
    				spent := time.Since(t)
    				if spent > 0 && n > 0 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.5K bytes
    - Click Count (0)
  4. cmd/peer-rest-client.go

    		peerRESTLogMask: strconv.Itoa(int(kind)),
    	}))
    	if err != nil {
    		return
    	}
    	st.Results(func(b *grid.Bytes) error {
    		select {
    		case logCh <- *b:
    		default:
    			consoleLogRPC.PutResponse(b)
    			// Do not block on slow receivers.
    		}
    		return nil
    	})
    }
    
    // ConsoleLog - sends request to peer nodes to get console logs
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
Back to Top