Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 347 for uint16 (0.04 sec)

  1. cmd/update.go

    			Code:       AdminUpdateUnexpectedFailure,
    			Message:    err.Error(),
    			StatusCode: http.StatusInternalServerError,
    		}
    	}
    	return resp.Body, nil
    }
    
    var updateInProgress atomic.Uint32
    
    // Function to get the reader from an architecture
    func downloadBinary(u *url.URL, mode string) (binCompressed []byte, bin []byte, err error) {
    	transport := getUpdateTransport(30 * time.Second)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  2. cmd/xl-storage-format-v2_test.go

    		err = xl.Load(data)
    		if err != nil {
    			t.Fatal(err)
    		}
    		for _, v := range xl.versions {
    			// Signature should match
    			if binary.BigEndian.Uint32(v.header.Signature[:]) != 0x8e5a6406 {
    				t.Log(v.header.String())
    				t.Fatalf("invalid signature 0x%x", binary.BigEndian.Uint32(v.header.Signature[:]))
    			}
    		}
    	})
    }
    
    func Test_xlMetaV2Shallow_LoadTimeStamp(t *testing.T) {
    	// v0 Saved with
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37.8K bytes
    - Viewed (0)
  3. cmd/storage-rest-server.go

    				} else {
    					write([]byte{0})
    				}
    				xioutil.SafeClose(doneCh)
    				return
    			case block := <-blockCh:
    				var tmp [5]byte
    				tmp[0] = 2
    				binary.LittleEndian.PutUint32(tmp[1:], uint32(len(block)))
    				write(tmp[:])
    				write(block)
    				if canWrite {
    					xhttp.Flush(w)
    				}
    			}
    		}
    	}()
    	return &h
    }
    
    var poolBuf8k = bpool.Pool[*[]byte]{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  4. cmd/bucket-replication-utils.go

    	}
    	parts := contentRangeRegexp.FindStringSubmatch(cr)
    	if len(parts) != 4 {
    		return sz, fmt.Errorf("invalid Content-Range header %s", cr)
    	}
    	if parts[3] == "*" {
    		return -1, nil
    	}
    	var usz uint64
    	usz, err = strconv.ParseUint(parts[3], 10, 64)
    	if err != nil {
    		return sz, err
    	}
    	return int64(usz), nil
    }
    
    func extractReplicateDiffOpts(q url.Values) (opts madmin.ReplDiffOpts) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 26.1K bytes
    - Viewed (0)
  5. tests/sql_builder_test.go

    	}
    }
    
    type ageInt int8
    
    func (ageInt) String() string {
    	return "age"
    }
    
    type ageBool bool
    
    func (ageBool) String() string {
    	return "age"
    }
    
    type ageUint64 uint64
    
    func (ageUint64) String() string {
    	return "age"
    }
    
    type ageFloat float64
    
    func (ageFloat) String() string {
    	return "age"
    }
    
    func TestExplainSQL(t *testing.T) {
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Mon Jul 21 02:46:58 UTC 2025
    - 16.7K bytes
    - Viewed (0)
  6. cmd/test-utils_test.go

    // chance the file doesn't exist yet.
    var (
    	randN  uint32
    	randmu sync.Mutex
    )
    
    // Temp files created in default Tmp dir
    var globalTestTmpDir = os.TempDir()
    
    // reseed - returns a new seed every time the function is called.
    func reseed() uint32 {
    	return uint32(time.Now().UnixNano() + int64(os.Getpid()))
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  7. cmd/common-main.go

    			fmt.Scanln()
    			os.Exit(1)
    		}
    	}
    
    	logger.Init(GOPATH, GOROOT)
    	logger.RegisterError(config.FmtError)
    
    	t, _ := minioVersionToReleaseTime(Version)
    	if !t.IsZero() {
    		globalVersionUnix = uint64(t.Unix())
    	}
    
    	globalIsCICD = env.Get("MINIO_CI_CD", "") != "" || env.Get("CI", "") != ""
    
    	console.SetColor("Debug", fcolor.New())
    
    	gob.Register(StorageErr(""))
    	gob.Register(madmin.TimeInfo{})
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.5K bytes
    - Viewed (3)
  8. statement.go

    		default:
    			switch rv := reflect.ValueOf(v); rv.Kind() {
    			case reflect.Slice, reflect.Array:
    				if rv.Len() == 0 {
    					writer.WriteString("(NULL)")
    				} else if rv.Type().Elem() == reflect.TypeOf(uint8(0)) {
    					stmt.Vars = append(stmt.Vars, v)
    					stmt.DB.Dialector.BindVarTo(writer, stmt, v)
    				} else {
    					writer.WriteByte('(')
    					for i := 0; i < rv.Len(); i++ {
    						if i > 0 {
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Fri Sep 12 04:33:27 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  9. src/cmd/asm/internal/asm/asm.go

    	}
    	return addr.Offset
    }
    
    // getRegister checks that addr represents a register and returns its value.
    func (p *Parser) getRegister(prog *obj.Prog, op obj.As, addr *obj.Addr) int16 {
    	if addr.Type != obj.TYPE_REG || addr.Offset != 0 || addr.Name != 0 || addr.Index != 0 {
    		p.errorf("%s: expected register; found %s", op, obj.Dconv(prog, addr))
    	}
    	return addr.Reg
    }
    
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Tue Oct 21 15:13:08 UTC 2025
    - 26.7K bytes
    - Viewed (0)
  10. cmd/admin-router.go

    	if err != nil {
    		// Static params, so this is very unlikely.
    		logger.Fatal(err, "Unable to initialize server")
    	}
    	return gz
    }()
    
    // Set of handler options as bit flags
    type hFlag uint8
    
    const (
    	// this flag disables gzip compression of responses
    	noGZFlag = 1 << iota
    
    	// this flag enables tracing body and headers instead of just headers
    	traceAllFlag
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 10 18:57:03 UTC 2025
    - 26.7K bytes
    - Viewed (0)
Back to top