Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 3,411 for cyan (0.22 sec)

  1. internal/grid/handlers.go

    // An optional subroute can be given. Multiple entries are joined with '/'.
    func (h *StreamTypeHandler[Payload, Req, Resp]) RegisterNoPayload(m *Manager, handle func(ctx context.Context, in <-chan Req, out chan<- Resp) *RemoteErr, subroute ...string) error {
    	h.WithPayload = false
    	return h.register(m, func(ctx context.Context, p Payload, in <-chan Req, out chan<- Resp) *RemoteErr {
    		return handle(ctx, in, out)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  2. internal/grid/muxserver.go

    	// Data inbound to the handler
    	var handlerIn chan []byte
    	if inboundCap > 0 {
    		m.inbound = make(chan []byte, inboundCap)
    		handlerIn = make(chan []byte, 1)
    		go func(inbound chan []byte) {
    			wg.Wait()
    			defer xioutil.SafeClose(handlerIn)
    			m.handleInbound(c, inbound, handlerIn)
    		}(m.inbound)
    	}
    	// Fill outbound block.
    	// Each token represents a message that can be sent to the client without blocking.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  3. cmd/service.go

    	globalServiceFreezeMu.Lock()
    	// Close when we reach 0
    	globalServiceFreezeCnt--
    	if globalServiceFreezeCnt <= 0 {
    		// Set to a nil channel.
    		var _ch chan struct{}
    		if val := globalServiceFreeze.Swap(_ch); val != nil {
    			if ch, ok := val.(chan struct{}); ok && ch != nil {
    				// Close previous non-nil channel.
    				xioutil.SafeClose(ch)
    			}
    		}
    		globalServiceFreezeCnt = 0 // Don't risk going negative.
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Feb 28 07:02:14 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  4. misc/cgo/gmp/fib.go

    // license that can be found in the LICENSE file.
    
    //go:build ignore
    
    // Compute Fibonacci numbers with two goroutines
    // that pass integers back and forth.  No actual
    // concurrency, just threads and synchronization
    // and foreign code on multiple pthreads.
    
    package main
    
    import (
    	big "."
    	"runtime"
    )
    
    func fibber(c chan *big.Int, out chan string, n int64) {
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Mon Apr 10 22:32:35 UTC 2023
    - 919 bytes
    - Viewed (0)
  5. cmd/shared-lock.go

    )
    
    var sharedLockTimeout = newDynamicTimeoutWithOpts(dynamicTimeoutOpts{
    	timeout:       30 * time.Second,
    	minimum:       10 * time.Second,
    	retryInterval: time.Minute,
    })
    
    type sharedLock struct {
    	lockContext chan LockContext
    }
    
    func (ld sharedLock) backgroundRoutine(ctx context.Context, objAPI ObjectLayer, lockName string) {
    	for {
    		locker := objAPI.NewNSLock(minioMetaBucket, lockName)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Feb 13 09:26:38 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  6. internal/grid/README.md

    The handler function has this signature.
    
    Sample handler:
    ```go
        handler :=  func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr {
            fmt.Println("Got request with initial payload", p, "from", GetCaller(ctx context.Context))
            fmt.Println("Subroute:", GetSubroute(ctx))
            for {
                select {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 10 18:57:03 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  7. internal/store/store.go

    	}
    	return key
    }
    
    // replayItems - Reads the items from the store and replays.
    func replayItems[I any](store Store[I], doneCh <-chan struct{}, log logger, id string) <-chan Key {
    	keyCh := make(chan Key)
    
    	go func() {
    		defer xioutil.SafeClose(keyCh)
    
    		retryTicker := time.NewTicker(retryInterval)
    		defer retryTicker.Stop()
    
    		for {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  8. internal/grid/muxclient.go

    		responseCh <- resp
    	}
    }
    
    func (m *muxClient) handleTwowayRequests(errResp chan<- Response, requests <-chan []byte) {
    	var errState bool
    	if debugPrint {
    		start := time.Now()
    		defer func() {
    			fmt.Println("Mux", m.MuxID, "Request took", time.Since(start).Round(time.Millisecond))
    		}()
    	}
    
    	var pingTimer <-chan time.Time
    	if m.deadline == 0 || m.deadline > m.clientPingInterval {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  9. internal/grid/connection.go

    	if handler == nil {
    		return nil, ErrUnknownHandler
    	}
    
    	var requests chan []byte
    	var responses chan Response
    	if handler.InCapacity > 0 {
    		requests = make(chan []byte, handler.InCapacity)
    	}
    	if handler.OutCapacity > 0 {
    		responses = make(chan Response, handler.OutCapacity)
    	} else {
    		responses = make(chan Response, 1)
    	}
    
    	cl, err := c.newMuxClient(ctx)
    	if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 46.9K bytes
    - Viewed (0)
  10. internal/grid/connection_test.go

    	}()
    
    	cleanReqs := make(chan struct{})
    	gotCall := make(chan struct{})
    	defer close(cleanReqs)
    	// 1: Block forever
    	h1 := func(payload []byte) ([]byte, *RemoteErr) {
    		gotCall <- struct{}{}
    		<-cleanReqs
    		return nil, nil
    	}
    	// 2: Also block, but with streaming.
    	h2 := StreamHandler{
    		Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 5.9K bytes
    - Viewed (0)
Back to top