Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for WriteTo (0.21 sec)

  1. internal/config/config.go

    			b.WriteString(ep.Value)
    			b.WriteString(KvNewline)
    		}
    	}
    }
    
    // WriteTo writes the string representation of the configuration to the given
    // builder. When off is true, adds a comment character before the config system
    // output. It also ignores values when empty and deprecated.
    func (cs *SubsysInfo) WriteTo(b *strings.Builder, off bool) {
    	cs.AddEnvString(b)
    	if off {
    		b.WriteString(KvComment)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 37.3K bytes
    - Viewed (0)
  2. cmd/utils.go

    			runtime.GC()
    			var buf bytes.Buffer
    			err := pprof.Lookup("heap").WriteTo(&buf, 0)
    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerBlock:
    		runtime.SetBlockProfileRate(100)
    		prof.stopFn = func() ([]byte, error) {
    			var buf bytes.Buffer
    			err := pprof.Lookup("block").WriteTo(&buf, 0)
    			runtime.SetBlockProfileRate(0)
    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerMutex:
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 31.3K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    			PutByteBuffer(toSend)
    			err = conn.SetWriteDeadline(time.Now().Add(connWriteTimeout))
    			if err != nil {
    				gridLogIf(ctx, fmt.Errorf("conn.SetWriteDeadline: %w", err))
    				return
    			}
    			_, err = buf.WriteTo(conn)
    			if err != nil {
    				gridLogIf(ctx, fmt.Errorf("ws write: %w", err))
    				return
    			}
    			continue
    		}
    
    		// Merge entries and send
    		queue = append(queue, toSend)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  4. cmd/admin-handlers-config-kv.go

    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	var s strings.Builder
    	for _, subSysConfig := range subSysConfigs {
    		subSysConfig.WriteTo(&s, false)
    	}
    
    	password := cred.SecretKey
    	econfigData, err := madmin.EncryptData(password, []byte(s.String()))
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.7K bytes
    - Viewed (0)
  5. internal/http/server.go

    				return nil
    			}
    
    			// Write all running goroutines.
    			tmp, err := os.CreateTemp("", "minio-goroutines-*.txt")
    			if err == nil {
    				_ = pprof.Lookup("goroutine").WriteTo(tmp, 1)
    				tmp.Close()
    				return errors.New("timed out. some connections are still active. goroutines written to " + tmp.Name())
    			}
    			return errors.New("timed out. some connections are still active")
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  6. cmd/xl-storage_test.go

    	reader := bytes.NewReader(data)
    	for {
    		// Using io.Copy instead of this loop will not work for us as io.Copy
    		// will use bytes.Reader.WriteTo() which will not do shardSize'ed writes
    		// causing error.
    		n, err := reader.Read(shard)
    		w.Write(shard[:n])
    		if err == nil {
    			continue
    		}
    		if err == io.EOF {
    			break
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 66.7K bytes
    - Viewed (0)
Back to top