Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 193 for channel (0.27 sec)

  1. internal/bpool/bpool.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package bpool
    
    import "github.com/klauspost/reedsolomon"
    
    // BytePoolCap implements a leaky pool of []byte in the form of a bounded channel.
    type BytePoolCap struct {
    	c    chan []byte
    	w    int
    	wcap int
    }
    
    // NewBytePoolCap creates a new BytePool bounded to the given maxSize, with new
    // byte arrays sized based on width.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 2.6K bytes
    - Viewed (0)
  2. internal/logger/target/kafka/kafka.go

    	if err != nil {
    		atomic.AddInt64(&h.failedMessages, 1)
    		return
    	}
    	// Delete the event from store.
    	return h.store.Del(key.Name)
    }
    
    // Cancel - cancels the target
    func (h *Target) Cancel() {
    	// If queuestore is configured, cancel it's context to
    	// stop the replay go-routine.
    	if h.store != nil {
    		h.storeCtxCancel()
    	}
    
    	// Set logch to nil and close it.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.1K bytes
    - Viewed (1)
  3. cmd/admin-heal-ops.go

    		h.mutex.Lock()
    		h.endTime = UTCNow()
    		h.currentStatus.Summary = healFinishedStatus
    		h.mutex.Unlock()
    
    		// drain traverse channel so the traversal
    		// go-routine does not leak.
    		go func() {
    			// Eventually the traversal go-routine closes
    			// the channel and returns, so this go-routine
    			// itself will not leak.
    			<-h.traverseAndHealDoneCh
    		}()
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  4. cmd/grid.go

    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/rest"
    )
    
    // globalGrid is the global grid manager.
    var globalGrid atomic.Pointer[grid.Manager]
    
    // globalGridStart is a channel that will block startup of grid connections until closed.
    var globalGridStart = make(chan struct{})
    
    func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error {
    	hosts, local := eps.GridHosts()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 26 15:00:38 GMT 2024
    - 2K bytes
    - Viewed (0)
  5. cmd/service.go

    	// 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.
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 28 07:02:14 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  6. internal/bpool/bpool_test.go

    		t.Fatalf("bytepool length invalid: got %v want %v", len(b), width)
    	}
    	if cap(b) != capWidth {
    		t.Fatalf("bytepool length invalid: got %v want %v", cap(b), capWidth)
    	}
    
    	bufPool.Put(b)
    
    	// Close the channel so we can iterate over it.
    	close(bufPool.c)
    
    	// Check the size of the pool.
    	if uint64(len(bufPool.c)) != size {
    		t.Fatalf("bytepool size invalid: got %v want %v", len(bufPool.c), size)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 19:13:27 GMT 2024
    - 2.6K bytes
    - Viewed (0)
  7. internal/event/target/nsq.go

    	}
    
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    
    	eventData, eErr := target.store.Get(key.Name)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 7.1K bytes
    - Viewed (0)
  8. cmd/metacache-server-pool.go

    	// Disconnect from call above, but cancel on exit.
    	listCtx, cancel := context.WithCancel(GlobalContext)
    	saveCh := make(chan metaCacheEntry, metacacheBlockSize)
    	inCh := make(chan metaCacheEntry, metacacheBlockSize)
    	outCh := make(chan metaCacheEntry, o.Limit)
    
    	filteredResults := o.gatherResults(ctx, outCh)
    
    	mc := o.newMetacache()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  9. cmd/metacache-entries.go

    			m.o[i].metadata = nil
    		}
    	}
    	m.o = m.o[idx:]
    }
    
    // mergeEntryChannels will merge entries from in and return them sorted on out.
    // To signify no more results are on an input channel, close it.
    // The output channel will be closed when all inputs are emptied.
    // If file names are equal, compareMeta is called to select which one to choose.
    // The entry not chosen will be discarded.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  10. cmd/data-usage.go

    	backgroundHealInfoPath = bucketMetaPrefix + SlashSeparator + ".background-heal.json"
    
    	dataUsageCacheName = ".usage-cache.bin"
    )
    
    // storeDataUsageInBackend will store all objects sent on the dui channel until closed.
    func storeDataUsageInBackend(ctx context.Context, objAPI ObjectLayer, dui <-chan DataUsageInfo) {
    	attempts := 1
    	for dataUsageInfo := range dui {
    		json := jsoniter.ConfigCompatibleWithStandardLibrary
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.6K bytes
    - Viewed (0)
Back to top