Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for mrfCh (0.03 sec)

  1. cmd/notification.go

    			return err
    		}
    		for e := range mCh {
    			select {
    			case <-ctx.Done():
    				return err
    			case mrfCh <- e:
    			}
    		}
    		return nil
    	}(mrfCh)
    	go func(wg *sync.WaitGroup) {
    		wg.Wait()
    		xioutil.SafeClose(mrfCh)
    	}(&wg)
    	return mrfCh, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  2. cmd/admin-bucket-handlers.go

    	keepAliveTicker := time.NewTicker(500 * time.Millisecond)
    	defer keepAliveTicker.Stop()
    
    	mrfCh, err := globalNotificationSys.GetReplicationMRF(ctx, bucket, node)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	enc := json.NewEncoder(w)
    	for {
    		select {
    		case entry, ok := <-mrfCh:
    			if !ok {
    				return
    			}
    			if err := enc.Encode(entry); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
Back to top