Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for hashString (0.36 sec)

  1. cmd/xl-storage-format-utils.go

    	for k, v := range m {
    		// Separate key and value with an individual xor with a random number.
    		// Add values of each, so they cannot be trivially collided.
    		crc ^= (xxh3.HashString(k) ^ 0x4ee3bbaf7ab2506b) + (xxh3.HashString(v) ^ 0x8da4c8da66194257)
    	}
    	return crc
    }
    
    // hashDeterministicBytes will return a deterministic (weak) hash for the map values.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. internal/logger/logger.go

    			Source:    trace,
    			Variables: tags,
    		}
    	} else {
    		entry.Message = message
    	}
    
    	if anonFlag {
    		entry.API.Args.Bucket = HashString(entry.API.Args.Bucket)
    		entry.API.Args.Object = HashString(entry.API.Args.Object)
    		entry.RemoteHost = HashString(entry.RemoteHost)
    		if entry.Trace != nil {
    			entry.Trace.Variables = make(map[string]interface{})
    		}
    	}
    
    	return entry
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 22 09:43:48 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  3. cmd/bucket-lifecycle.go

    	return xxh3.HashString(f.TransitionedObject.Tier + f.TransitionedObject.Name)
    }
    
    func (n newerNoncurrentTask) OpHash() uint64 {
    	return xxh3.HashString(n.bucket + n.versions[0].ObjectV.ObjectName)
    }
    
    func (j jentry) OpHash() uint64 {
    	return xxh3.HashString(j.TierName + j.ObjName)
    }
    
    func (e expiryTask) OpHash() uint64 {
    	return xxh3.HashString(e.objInfo.Bucket + e.objInfo.Name)
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  4. cmd/bootstrap-peer-server.go

    		// differently on each nodes, update skipEnvs()
    		// map if there are such environment values
    		if _, ok := skipEnvs[envK]; ok {
    			continue
    		}
    		envValues[envK] = logger.HashString(env.Get(envK, ""))
    	}
    	scfg := &ServerSystemConfig{NEndpoints: globalEndpoints.NEndpoints(), MinioEnv: envValues, Checksum: binaryChecksum}
    	var cmdLines []string
    	for _, ep := range globalEndpoints {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. cmd/admin-handlers.go

    			// We XOR, so order doesn't matter.
    			for _, v := range c.DNSNames {
    				check ^= xxh3.HashString(v)
    			}
    			for _, v := range c.EmailAddresses {
    				check ^= xxh3.HashString(v)
    			}
    			for _, v := range c.IPAddresses {
    				check ^= xxh3.HashString(v.String())
    			}
    			for _, v := range c.URIs {
    				check ^= xxh3.HashString(v.String())
    			}
    			tlsInfo.Certs = append(tlsInfo.Certs, madmin.TLSCert{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  6. internal/grid/connection.go

    // It should be 50% chance of any host initiating the connection.
    func (c *Connection) shouldConnect() bool {
    	// The remote should have the opposite result.
    	h0 := xxh3.HashString(c.Local + c.Remote)
    	h1 := xxh3.HashString(c.Remote + c.Local)
    	if h0 == h1 {
    		return c.Local < c.Remote
    	}
    	return h0 < h1
    }
    
    func (c *Connection) send(ctx context.Context, msg []byte) error {
    	select {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  7. cmd/bucket-replication.go

    // Must be able to grab read lock from p.
    
    func (p *ReplicationPool) getWorkerCh(bucket, object string, sz int64) chan<- ReplicationWorkerOperation {
    	h := xxh3.HashString(bucket + object)
    	p.mu.RLock()
    	defer p.mu.RUnlock()
    	if len(p.workers) == 0 {
    		return nil
    	}
    	return p.workers[h%uint64(len(p.workers))]
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
Back to top