Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 392 for defer (0.05 sec)

  1. cmd/listen-notification-handlers.go

    			return
    		}
    		t := time.NewTicker(time.Duration(pingInterval) * time.Second)
    		defer t.Stop()
    		emptyEventTicker = t.C
    	} else {
    		// Deprecated Apr 2023
    		t := time.NewTicker(500 * time.Millisecond)
    		defer t.Stop()
    		keepAliveTicker = t.C
    	}
    
    	enc := json.NewEncoder(w)
    	for {
    		select {
    		case ev := <-mergeCh:
    			_, err := w.Write(ev)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 6K bytes
    - Viewed (0)
  2. cmd/mrf.go

    func (m *mrfState) addPartialOp(op PartialOperation) {
    	if m == nil {
    		return
    	}
    
    	if atomic.LoadInt32(&m.closed) == 1 {
    		return
    	}
    
    	m.wg.Add(1)
    	defer m.wg.Done()
    
    	if atomic.LoadInt32(&m.closing) == 1 {
    		return
    	}
    
    	select {
    	case m.opCh <- op:
    	default:
    	}
    }
    
    // Do not accept new MRF operations anymore and start to save
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  3. src/cmd/asm/main.go

    	case "all", "ret":
    		ctxt.Retpoline = true
    	}
    
    	ctxt.Bso = bufio.NewWriter(os.Stdout)
    	defer ctxt.Bso.Flush()
    
    	architecture.Init(ctxt)
    
    	// Create object file, write header.
    	buf, err := bio.Create(*flags.OutputFile)
    	if err != nil {
    		log.Fatal(err)
    	}
    	defer buf.Close()
    
    	if !*flags.SymABIs {
    		buf.WriteString(objabi.HeaderString())
    		fmt.Fprintf(buf, "!\n")
    	}
    
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Sun Apr 13 15:09:12 UTC 2025
    - 2.9K bytes
    - Viewed (0)
  4. cmd/common-main.go

    			if err != nil {
    				logger.FatalIf(err, "Unable to get free port for Console UI on the host")
    			}
    			// hold the port
    			l, err := net.Listen("TCP", fmt.Sprintf(":%s", p.String()))
    			if err == nil {
    				defer l.Close()
    			}
    			consoleAddr = net.JoinHostPort("", p.String())
    		}
    
    		if _, _, err := net.SplitHostPort(consoleAddr); err != nil {
    			logger.FatalIf(err, "Unable to start listening on console port")
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.5K bytes
    - Viewed (3)
  5. cmd/object-handlers.go

    // also specify a data serialization format (JSON, CSV) of the object.
    func (api objectAPIHandlers) SelectObjectContentHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "SelectObject")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	// Fetch object stat info.
    	objectAPI := api.ObjectAPI()
    	if objectAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  6. cmd/erasure-decode.go

    	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.
    		readTriggerCh <- true
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  7. cmd/update_test.go

    	httpServer1 := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {}))
    	defer httpServer1.Close()
    	httpServer2 := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		fmt.Fprintln(w, "fbe246edbd382902db9a4035df7dce8cb441357d minio.RELEASE.2016-10-07T01-16-39Z")
    	}))
    	defer httpServer2.Close()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  8. cmd/bucket-lifecycle-handlers.go

    // https://docs.aws.amazon.com/AmazonS3/latest/dev/object-lifecycle-mgmt.html
    func (api objectAPIHandlers) PutBucketLifecycleHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "PutBucketLifecycle")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	objAPI := api.ObjectAPI()
    	if objAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Jan 20 14:49:07 UTC 2025
    - 7K bytes
    - Viewed (0)
  9. cmd/erasure-sets_test.go

    	}
    }
    
    // TestNewErasure - tests initialization of all input disks
    // and constructs a valid `Erasure` object
    func TestNewErasureSets(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    	nDisks := 16 // Maximum disks.
    	var erasureDisks []string
    	for range nDisks {
    		// Do not attempt to create this path, the test validates
    		// so that newErasureSets initializes non existing paths
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 6.8K bytes
    - Viewed (0)
  10. cmd/utils.go

    }
    
    // Returns current profile data, returns error if there is no active
    // profiling in progress. Stops an active profile.
    func getProfileData() (map[string][]byte, error) {
    	globalProfilerMu.Lock()
    	defer globalProfilerMu.Unlock()
    
    	if len(globalProfiler) == 0 {
    		return nil, errors.New("profiler not enabled")
    	}
    
    	dst := make(map[string][]byte, len(globalProfiler))
    	for typ, prof := range globalProfiler {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33K bytes
    - Viewed (0)
Back to top