Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 74 for implement (0.19 sec)

  1. src/archive/tar/stat_unix.go

    			major := uint32((dev & 0x0000ff00) >> 8)
    			minor := uint32((dev & 0x000000ff) >> 0)
    			minor |= uint32((dev & 0xffff0000) >> 8)
    			h.Devmajor, h.Devminor = int64(major), int64(minor)
    		default:
    			// TODO: Implement solaris (see https://golang.org/issue/8106)
    		}
    	}
    	return nil
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Mar 15 16:01:50 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  2. cmd/batch-expire.go

    	results := make(chan ObjectInfo, workerSize)
    	if err := api.Walk(ctx, r.Bucket, r.Prefix, results, WalkOptions{
    		Marker:       lastObject,
    		LatestOnly:   false, // we need to visit all versions of the object to implement purge: retainVersions
    		VersionsSort: WalkVersionsSortDesc,
    	}); err != nil {
    		// Do not need to retry if we can't list objects on source.
    		return err
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 21K bytes
    - Viewed (1)
  3. internal/http/dial_others.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package http
    
    import (
    	"context"
    	"net"
    	"syscall"
    	"time"
    )
    
    // TODO: if possible implement for non-linux platforms, not a priority at the moment
    //
    //nolint:unused
    func setTCPParametersFn(opts TCPOptions) func(network, address string, c syscall.RawConn) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 1.6K bytes
    - Viewed (0)
  4. cni/cmd/istio-cni/main.go

    		// this may fail, but it should be safe to ignore according
    		// to https://github.com/uber-go/zap/issues/328
    		_ = log.Sync()
    	}()
    
    	// TODO: implement plugin version
    	funcs := skel.CNIFuncs{
    		Add:   plugin.CmdAdd,
    		Del:   plugin.CmdDelete,
    		Check: plugin.CmdCheck,
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 13:56:46 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  5. cmd/api-errors.go

    		Description:    "Invalid Request",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrHealNotImplemented: {
    		Code:           "XMinioHealNotImplemented",
    		Description:    "This server does not implement heal functionality.",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrHealNoSuchProcess: {
    		Code:           "XMinioHealNoSuchProcess",
    		Description:    "No such heal process is running on the server",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  6. internal/bucket/bandwidth/monitor_gen.go

    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z BucketBandwidthReport) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 0
    	_ = z
    	err = en.Append(0x80)
    	if err != nil {
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z BucketBandwidthReport) MarshalMsg(b []byte) (o []byte, err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  7. cmd/storage-datatypes_gen.go

    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z BaseOptions) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 0
    	_ = z
    	err = en.Append(0x80)
    	if err != nil {
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z BaseOptions) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 127.5K bytes
    - Viewed (0)
  8. cmd/local-locker_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *localLockMap) DecodeMsg(dc *msgp.Reader) (err error) {
    	var zb0004 uint32
    	zb0004, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	if (*z) == nil {
    		(*z) = make(localLockMap, zb0004)
    	} else if len((*z)) > 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  9. cmd/tier-last-day-stats_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *DailyAllTierStats) DecodeMsg(dc *msgp.Reader) (err error) {
    	var zb0004 uint32
    	zb0004, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	if (*z) == nil {
    		(*z) = make(DailyAllTierStats, zb0004)
    	} else if len((*z)) > 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  10. internal/bpool/bpool.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package bpool
    
    import "github.com/klauspost/reedsolomon"
    
    // BytePoolCap implements a leaky pool of []byte in the form of a bounded channel.
    type BytePoolCap struct {
    	c    chan []byte
    	w    int
    	wcap int
    }
    
    // NewBytePoolCap creates a new BytePool bounded to the given maxSize, with new
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 2.6K bytes
    - Viewed (0)
Back to top