Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 901 - 910 of 2,827 for than (0.02 seconds)

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

  1. cmd/service.go

    	serviceUnFreeze                           // Un-Freeze previously frozen S3 API calls.
    	// Add new service requests here.
    )
    
    // Global service signal channel.
    var globalServiceSignalCh = make(chan serviceSignal)
    
    // GlobalContext context that is canceled when server is requested to shut down.
    // cancelGlobalContext can be used to indicate server shutdown.
    var GlobalContext, cancelGlobalContext = context.WithCancel(context.Background())
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Feb 28 07:02:14 GMT 2024
    - 3.8K bytes
    - Click Count (0)
  2. .github/stale.yml

    # Limit to only `issues` or `pulls`
    # only: issues
    
    # Optionally, specify configuration settings that are specific to just 'issues' or 'pulls':
    # pulls:
    #   daysUntilStale: 30
    #   markComment: >
    #     This pull request has been automatically marked as stale because it has not had
    #     recent activity. It will be closed if no further activity occurs. Thank you
    #     for your contributions.
    
    # issues:
    #   exemptLabels:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jan 24 04:36:59 GMT 2022
    - 2K bytes
    - Click Count (0)
  3. internal/grid/stream.go

    			if err != nil {
    				s.cancel(err)
    				return err
    			}
    		}
    	}
    }
    
    // Done will return a channel that will be closed when the stream is done.
    // This mirrors context.Done().
    func (s *Stream) Done() <-chan struct{} {
    	return s.ctx.Done()
    }
    
    // Err will return the error that caused the stream to end.
    // This mirrors context.Err().
    func (s *Stream) Err() error {
    	return s.ctx.Err()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jun 07 15:51:52 GMT 2024
    - 3.1K bytes
    - Click Count (0)
  4. cmd/notification.go

    			}
    			consolidatedReport.BucketStats[opts] = d
    		}
    	}
    	return consolidatedReport
    }
    
    func (sys *NotificationSys) collectPeerMetrics(ctx context.Context, peerChannels []<-chan MetricV2, g *errgroup.Group) <-chan MetricV2 {
    	ch := make(chan MetricV2)
    	var wg sync.WaitGroup
    	for index, err := range g.Wait() {
    		if err != nil {
    			if sys.peerClients[index] != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 46K bytes
    - Click Count (0)
  5. cmd/data-scanner_test.go

    		Mode:        objectlock.RetCompliance,
    		Validity:    12 * time.Hour,
    		LockEnabled: true,
    	}
    
    	expiryWorker := func(wg *sync.WaitGroup, readyCh chan<- struct{}, taskCh <-chan expiryOp, gotExpired *[]ObjectToDelete) {
    		defer wg.Done()
    		// signal the calling goroutine that the worker is ready tor receive tasks
    		close(readyCh)
    		var expired []ObjectToDelete
    		for t := range taskCh {
    			switch v := t.(type) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12K bytes
    - Click Count (0)
  6. internal/s3select/message.go

    	getProgressFunc func() (int64, int64)
    	bytesReturned   int64
    
    	payloadBuffer      []byte
    	payloadBufferIndex int
    	payloadCh          chan *bytes.Buffer
    
    	finBytesScanned, finBytesProcessed int64
    
    	errCh  chan []byte
    	doneCh chan struct{}
    }
    
    func (writer *messageWriter) write(data []byte) bool {
    	if _, err := writer.writer.Write(data); err != nil {
    		return false
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  7. internal/dsync/dsync_test.go

    		t.Fatal("GetLock() should be successful")
    	}
    
    	// Add delay to lock server responses to ensure that lock does not timeout
    	for i := range lockServers {
    		lockServers[i].setResponseDelay(5 * testDrwMutexUnlockCallTimeout)
    		defer lockServers[i].setResponseDelay(0)
    	}
    
    	unlockReturned := make(chan struct{}, 1)
    	go func() {
    		ctx, cancel := context.WithTimeout(t.Context(), 500*time.Millisecond)
    		defer cancel()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  8. internal/grid/benchmark_test.go

    		// Register a single handler which echos the payload.
    		errFatal(remote.RegisterStreamingHandler(handlerTest, StreamHandler{
    			// Send 10x response.
    			Handle: func(ctx context.Context, payload []byte, _ <-chan []byte, out chan<- []byte) *RemoteErr {
    				for i := range responses {
    					toSend := GetByteBuffer()[:0]
    					toSend = append(toSend, byte(i))
    					toSend = append(toSend, payload...)
    					select {
    					case <-ctx.Done():
    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)
  9. cmd/erasure.go

    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/pkg/v3/sync/errgroup"
    )
    
    // list all errors that can be ignore in a bucket operation.
    var bucketOpIgnoredErrs = append(baseIgnoredErrs, errDiskAccessDenied, errUnformattedDisk)
    
    // list all errors that can be ignored in a bucket metadata operation.
    var bucketMetadataOpIgnoredErrs = append(bucketOpIgnoredErrs, errVolumeNotFound)
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.1K bytes
    - Click Count (0)
  10. src/main/resources/fess_indices/fess/en-ie/stopwords.txt

    mo
    mé
    na
    nach
    naoi
    naonúr
    ná
    ní
    níor
    nó
    nócha
    ocht
    ochtar
    os
    roimh
    sa
    seacht
    seachtar
    seachtó
    seasca
    seisear
    siad
    sibh
    sinn
    sna
    sé
    sí
    tar
    thar
    thú
    triúr
    trí
    trína
    trínár
    tríocha
    tú
    um
    ár
    é
    éis
    í
    ó
    ón
    óna
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 19 06:31:02 GMT 2018
    - 685 bytes
    - Click Count (0)
Back to Top