Search Options

Results per page
Sort
Preferred Languages
Advance

Results 781 - 790 of 963 for nil (0.96 sec)

  1. internal/kms/context.go

    // key-value pairs as canonical JSON object. The sort order
    // is based on the un-escaped keys. It never returns an error.
    func (c Context) MarshalText() ([]byte, error) {
    	if len(c) == 0 {
    		return []byte{'{', '}'}, nil
    	}
    
    	// Pre-allocate a buffer - 128 bytes is an arbitrary
    	// heuristic value that seems like a good starting size.
    	b := bytes.NewBuffer(make([]byte, 0, 128))
    	if len(c) == 1 {
    		for k, v := range c {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 6K bytes
    - Viewed (0)
  2. internal/disk/stat_bsd.go

    	"syscall"
    )
    
    // GetInfo returns total and free bytes available in a directory, e.g. `/`.
    func GetInfo(path string, _ bool) (info Info, err error) {
    	s := syscall.Statfs_t{}
    	err = syscall.Statfs(path, &s)
    	if err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := s.Bfree - s.Bavail
    	info = Info{
    		Total:  uint64(s.Bsize) * (s.Blocks - reservedBlocks),
    		Free:   uint64(s.Bsize) * s.Bavail,
    		Files:  s.Files,
    		Ffree:  s.Ffree,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  3. internal/http/close.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package http
    
    import (
    	"io"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    // DrainBody close non nil response with any response Body.
    // convenient wrapper to drain any remaining data on response body.
    //
    // Subsequently this allows golang http RoundTripper
    // to reuse the same connection for future requests.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  4. internal/config/browser/browser.go

    		HSTSIncludeSubdomains: true,
    		HSTSPreload:           true,
    		ReferrerPolicy:        "strict-origin-when-cross-origin",
    	}
    
    	if err = config.CheckValidKeys(config.BrowserSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	hstsIncludeSubdomains := env.Get(EnvBrowserHSTSIncludeSubdomains, kvs.GetWithDefault(browserHSTSIncludeSubdomains, DefaultKVS)) == config.EnableOn
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jun 21 00:58:58 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/dcerpc/DcerpcConstants.java

         */
        int DCERPC_MAYBE = 0x40; /* `maybe' call semantics requested */
        /**
         * Object UUID flag - if true, a non-nil object UUID is present
         */
        int DCERPC_OBJECT_UUID = 0x80; /* if true, a non-nil object UUID */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  6. cmd/metrics-v3-system-memory.go

    )
    
    // loadMemoryMetrics - `MetricsLoaderFn` for node memory metrics.
    func loadMemoryMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	memMetrics, err := c.memoryMetrics.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    		return err
    	}
    
    	m.Set(memTotal, float64(memMetrics.Total))
    	m.Set(memUsed, float64(memMetrics.Used))
    	usedPerc := float64(memMetrics.Used) * 100 / float64(memMetrics.Total)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 17 05:10:25 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  7. internal/http/request-recorder.go

    // Close is a no operation closer
    func (r *RequestRecorder) Close() error {
    	// no-op
    	return nil
    }
    
    // Read reads from the internal reader and counts/save the body in the memory
    func (r *RequestRecorder) Read(p []byte) (n int, err error) {
    	n, err = r.Reader.Read(p)
    	r.bytesRead += n
    
    	if r.LogBody {
    		r.buf.Write(p[:n])
    	}
    	if err != nil {
    		return n, err
    	}
    	return n, err
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 12 21:37:19 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  8. internal/amztime/iso8601_time.go

    func ISO8601Parse(iso8601 string) (t time.Time, err error) {
    	for _, layout := range []string{
    		iso8601TimeFormat,
    		iso8601TimeFormatLong,
    		time.RFC3339,
    	} {
    		t, err = time.Parse(layout, iso8601)
    		if err == nil {
    			return t, nil
    		}
    	}
    
    	return t, err
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Jan 16 23:38:33 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  9. src/cmd/asm/internal/asm/line_test.go

    	for i, test := range tests {
    		arch, ctxt := setArch(goarch)
    		tokenizer := lex.NewTokenizer("", strings.NewReader(test.input+"\n"), nil)
    		parser := NewParser(ctxt, arch, tokenizer)
    
    		err := tryParse(t, func() {
    			parser.Parse()
    		})
    
    		switch {
    		case err == nil:
    			t.Errorf("#%d: %q: want error %q; have none", i, test.input, test.error)
    		case !strings.Contains(err.Error(), test.error):
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  10. internal/logger/target/kafka/kafka_scram_client_contrib.go

    func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) {
    	x.Client, err = x.NewClient(userName, password, authzID)
    	if err != nil {
    		return err
    	}
    	x.ClientConversation = x.NewConversation()
    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    // very first conversation step) and attempts to move the authentication
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 3.3K bytes
    - Viewed (0)
Back to top