Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 233 for Chan (0.38 sec)

  1. cmd/main.go

    func Main(args []string) {
    	// Set the minio app name.
    	appName := filepath.Base(args[0])
    
    	if env.Get("_MINIO_DEBUG_NO_EXIT", "") != "" {
    		freeze := func(_ int) {
    			// Infinite blocking op
    			<-make(chan struct{})
    		}
    
    		// Override the logger os.Exit()
    		logger.ExitFunc = freeze
    
    		defer func() {
    			if err := recover(); err != nil {
    				fmt.Println("panic:", err)
    				fmt.Println("")
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 09 03:07:08 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  2. cmd/data-usage-cache.go

    	lifeCycle *lifecycle.Lifecycle `msg:"-"`
    
    	// optional updates channel.
    	// If set updates will be sent regularly to this channel.
    	// Will not be closed when returned.
    	updates     chan<- dataUsageEntry `msg:"-"`
    	replication replicationConfig     `msg:"-"`
    }
    
    func (e *dataUsageEntry) addSizes(summary sizeSummary) {
    	e.Size += summary.totalSize
    	e.Versions += summary.versions
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  3. cmd/bucket-replication-utils.go

    }
    
    type replicationResyncer struct {
    	// map of bucket to their resync status
    	statusMap      map[string]BucketReplicationResyncStatus
    	workerSize     int
    	resyncCancelCh chan struct{}
    	workerCh       chan struct{}
    	sync.RWMutex
    }
    
    const (
    	replicationDir      = ".replication"
    	resyncFileName      = "resync.bin"
    	resyncMetaFormat    = 1
    	resyncMetaVersionV1 = 1
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 26.2K bytes
    - Viewed (0)
  4. internal/grid/handlers.go

    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)
    	}, subroute...)
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 26.9K bytes
    - Viewed (0)
  5. cmd/erasure-decode.go

    	}
    	var newBufLK sync.RWMutex
    
    	if p.offset+p.shardSize > p.shardFileSize {
    		p.shardSize = p.shardFileSize - p.offset
    	}
    	if p.shardSize == 0 {
    		return newBuf, nil
    	}
    
    	readTriggerCh := make(chan bool, len(p.readers))
    	defer xioutil.SafeClose(readTriggerCh) // close the channel upon return
    
    	for i := 0; i < p.dataBlocks; i++ {
    		// Setup read triggers for p.dataBlocks number of reads so that it reads in parallel.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  6. cmd/peer-rest-client.go

    }
    
    func (client *peerRESTClient) GetResourceMetrics(ctx context.Context) (<-chan MetricV2, error) {
    	resp, err := getResourceMetricsRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	if err != nil {
    		return nil, err
    	}
    	ch := make(chan MetricV2)
    	go func(ch chan<- MetricV2) {
    		defer close(ch)
    		for _, m := range resp.Value() {
    			if m == nil {
    				continue
    			}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  7. internal/s3select/csv/reader.go

    	input        chan *queueItem  // input for workers
    	queue        chan *queueItem  // output from workers in order
    	err          error            // global error state, only touched by Reader.Read
    	bufferPool   sync.Pool        // pool of []byte objects for input
    	csvDstPool   sync.Pool        // pool of [][]string used for output
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  8. cmd/global-heal.go

    				globalExpiryState.enqueueByDays(objInfo, evt, lcEventSrc_Heal)
    				return true
    			default:
    				return false
    			}
    		}
    
    		// Collect updates to tracker from concurrent healEntry calls
    		results := make(chan healEntryResult, 1000)
    		go func() {
    			for res := range results {
    				if res.entryDone {
    					tracker.setObject(res.name)
    					if time.Since(tracker.getLastUpdate()) > time.Minute {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  9. cmd/ftp-server-driver.go

    	defer cancel()
    
    	if prefix == "" {
    		// if all objects are not deleted yet this call may fail.
    		return clnt.RemoveBucket(cctx, bucket)
    	}
    
    	objectsCh := make(chan minio.ObjectInfo)
    
    	// Send object names that are needed to be removed to objectsCh
    	go func() {
    		defer xioutil.SafeClose(objectsCh)
    		opts := minio.ListObjectsOptions{
    			Prefix:    prefix,
    			Recursive: true,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  10. cmd/namespace-lock_test.go

    		// not be required but makes reproduction much easier.
    		nsLk.lockMapMutex.Lock()
    
    		// lk3 blocks.
    		lk3ch := make(chan bool)
    		go func() {
    			lk3ch <- nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 0)
    		}()
    
    		// lk4, blocks.
    		lk4ch := make(chan bool)
    		go func() {
    			lk4ch <- nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 0)
    		}()
    		runtime.Gosched()
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 3.1K bytes
    - Viewed (0)
Back to top