Search Options

Results per page
Sort
Preferred Languages
Advance

Results 351 - 360 of 474 for derer (0.04 sec)

  1. cmd/server-main.go

    	}()
    
    	go func() {
    		if globalEnableSyncBoot {
    			defer bootstrapTrace("unfreezeServices", unfreezeServices)
    			t := time.AfterFunc(5*time.Minute, func() {
    				warnings = append(warnings,
    					color.YellowBold("- Initializing the config subsystem is taking longer than 5 minutes. Please remove 'MINIO_SYNC_BOOT=on' to not freeze the APIs"))
    			})
    			defer t.Stop()
    		}
    
    		// Initialize data scanner.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  2. src/bytes/buffer_test.go

    	// Confirm that when Reader panics, the empty buffer remains empty
    	var buf2 Buffer
    	defer func() {
    		recover()
    		check(t, "TestReadFromPanicReader (2)", &buf2, "")
    	}()
    	buf2.ReadFrom(panicReader{panic: true})
    }
    
    func TestReadFromNegativeReader(t *testing.T) {
    	var b Buffer
    	defer func() {
    		switch err := recover().(type) {
    		case nil:
    			t.Fatal("bytes.Buffer.ReadFrom didn't panic")
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Sep 03 20:55:15 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  3. docs/debugging/reorder-disks/main.go

    	XL xl     `json:"xl"`
    }
    
    func getMountMap() (map[string]string, error) {
    	result := make(map[string]string)
    
    	mountInfo, err := os.Open("/proc/self/mountinfo")
    	if err != nil {
    		return nil, err
    	}
    	defer mountInfo.Close()
    
    	scanner := bufio.NewScanner(mountInfo)
    	for scanner.Scan() {
    		s := strings.Split(scanner.Text(), " ")
    		if len(s) != 11 {
    			return nil, errors.New("unsupported /proc/self/mountinfo format")
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  4. internal/s3select/csv/reader_contrib_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	for _, f := range z.File {
    		if f.Name == file {
    			rc, err := f.Open()
    			if err != nil {
    				t.Fatal(err)
    			}
    			defer rc.Close()
    			b, err := io.ReadAll(rc)
    			if err != nil {
    				t.Fatal(err)
    			}
    			return b
    		}
    	}
    	t.Fatal(file, "not found in testdata/testdata.zip")
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 38.5K bytes
    - Viewed (0)
  5. istioctl/pkg/multicluster/remote_secret_test.go

    func (w *fakeOutputWriter) String() string { return w.b.String() }
    
    func TestCreateRemoteSecrets(t *testing.T) {
    	prevOutputWriterStub := makeOutputWriterTestHook
    	defer func() { makeOutputWriterTestHook = prevOutputWriterStub }()
    
    	prevTokenWaitBackoff := tokenWaitBackoff
    	defer func() { tokenWaitBackoff = prevTokenWaitBackoff }()
    
    	sa := makeServiceAccount("saSecret")
    	sa2 := makeServiceAccount("saSecret", "saSecret2")
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  6. cmd/auth-handler.go

    					tc.ResponseRecorder.LogErrBody = true
    				}
    
    				// All our internal APIs are sensitive towards Date
    				// header, for all requests where Date header is not
    				// present we will reject such clients.
    				defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r))
    				writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(errCode), r.URL)
    				atomic.AddUint64(&globalHTTPStats.rejectedRequestsTime, 1)
    				return
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  7. migrator/migrator.go

    				}
    
    				values = append(values, primaryKeys)
    			}
    
    			for _, idx := range stmt.Schema.ParseIndexes() {
    				if m.CreateIndexAfterCreateTable {
    					defer func(value interface{}, name string) {
    						if err == nil {
    							err = tx.Migrator().CreateIndex(value, name)
    						}
    					}(value, idx.Name)
    				} else {
    					if idx.Class != "" {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Apr 26 07:15:49 UTC 2024
    - 29K bytes
    - Viewed (0)
  8. cmd/main.go

    	if debugNoExit {
    		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("")
    				fmt.Println(string(debug.Stack()))
    			}
    			freeze(-1)
    		}()
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 30 22:59:48 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  9. cmd/bitrot-streaming.go

    		closeWithErr: rb.CloseWithError,
    		h:            h,
    		shardSize:    shardSize,
    		canClose:     &sync.WaitGroup{},
    		byteBuf:      buf,
    	}
    	bw.canClose.Add(1)
    	go func() {
    		defer bw.canClose.Done()
    
    		totalFileSize := int64(-1) // For compressed objects length will be unknown (represented by length=-1)
    		if length != -1 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 12:20:54 UTC 2024
    - 6K bytes
    - Viewed (0)
  10. docs/fr/docs/tutorial/query-params.md

    ## Multiples paramètres de chemin et de requête
    
    Vous pouvez déclarer plusieurs paramètres de chemin et paramètres de requête dans la même fonction, **FastAPI** saura comment les gérer.
    
    Et vous n'avez pas besoin de les déclarer dans un ordre spécifique.
    
    Ils seront détectés par leurs noms :
    
    {* ../../docs_src/query_params/tutorial004.py hl[8,10] *}
    
    ## Paramètres de requête requis
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 17:06:01 UTC 2024
    - 5.6K bytes
    - Viewed (0)
Back to top