- Sort Score
- Result 10 results
- Languages All
Results 351 - 360 of 620 for uint24 (0.07 sec)
-
cmd/erasure-object_test.go
if err != nil { t.Fatal(err) } // Upload a good object _, err = obj.DeleteObject(ctx, bucket, object, ObjectOptions{}) if err != nil { t.Fatal(err) } // Create "obj" under "bucket". _, err = obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader([]byte("abcd")), int64(len("abcd")), "", ""), opts) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 36.8K bytes - Viewed (0) -
cni/pkg/iptables/iptables_e2e_test.go
} } var initialized = &sync.Once{} func setup(t *testing.T) { initialized.Do(func() { // Setup group namespace so iptables --gid-owner will work assert.NoError(t, userns.WriteGroupMap(map[uint32]uint32{userns.OriginalGID(): 0})) // Istio iptables expects to find a non-localhost IP in some interface assert.NoError(t, exec.Command("ip", "addr", "add", "240.240.240.240/32", "dev", "lo").Run())
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Oct 15 15:39:28 UTC 2024 - 2.9K bytes - Viewed (0) -
cmd/batch-handlers_gen.go
o = msgp.Require(b, z.Msgsize()) o = msgp.AppendArrayHeader(o, uint32(len(z))) for zb0003 := range z { o = msgp.AppendString(o, z[zb0003]) } return } // UnmarshalMsg implements msgp.Unmarshaler func (z *BatchJobPrefix) UnmarshalMsg(bts []byte) (o []byte, err error) { var zb0002 uint32 zb0002, bts, err = msgp.ReadArrayHeaderBytes(bts) if err != nil { err = msgp.WrapError(err)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 01 12:53:30 UTC 2024 - 20.4K bytes - Viewed (0) -
cni/pkg/ipset/nldeps_mock.go
args := m.Called(name) return args.Error(0) } func (m *MockedIpsetDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error { args := m.Called(name, ip, ipProto, comment, replace) return args.Error(0) } func (m *MockedIpsetDeps) deleteIP(name string, ip netip.Addr, ipProto uint8) error { args := m.Called(name, ip, ipProto) return args.Error(0) }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Apr 30 22:24:38 UTC 2024 - 1.8K bytes - Viewed (0) -
src/bytes/bytes.go
// we should panic if the repeat will generate an overflow. // See golang.org/issue/16237. if count < 0 { panic("bytes: negative Repeat count") } hi, lo := bits.Mul(uint(len(b)), uint(count)) if hi > 0 || lo > uint(maxInt) { panic("bytes: Repeat output length overflow") } n := int(lo) // lo = len(b) * count if len(b) == 0 { return []byte{} }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Sep 03 20:55:15 UTC 2024 - 35.6K bytes - Viewed (0) -
tests/delete_test.go
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Tue Oct 10 07:03:34 UTC 2023 - 9.4K bytes - Viewed (0) -
internal/s3select/parquet/reader.go
case int32: value = int64(val) if logicalType := se.GetLogicalType(); logicalType != nil { if logicalType.IsSetDATE() { value = sql.FormatSQLTimestamp(time.Unix(60*60*24*int64(val), 0).UTC()) } } else if se.GetConvertedType() == parquettypes.ConvertedType_DATE { value = sql.FormatSQLTimestamp(time.Unix(60*60*24*int64(val), 0).UTC()) } case int64: value = val
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 4.5K bytes - Viewed (0) -
internal/bpool/bpool.go
type BytePoolCap struct { c chan []byte w int wcap int } // NewBytePoolCap creates a new BytePool bounded to the given maxSize, with new // byte arrays sized based on width. func NewBytePoolCap(maxSize uint64, width int, capwidth int) (bp *BytePoolCap) { if capwidth <= 0 { panic("total buffer capacity must be provided") } if capwidth < 64 { panic("buffer capped with smaller than 64 bytes is not supported") }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 3K bytes - Viewed (0) -
internal/grid/stream.go
// If the request context is canceled, the stream will no longer process requests. // Requests sent cannot be used any further by the called. Requests chan<- []byte muxID uint64 ctx context.Context } // Send a payload to the remote server. func (s *Stream) Send(b []byte) error { if s.Requests == nil { return errors.New("stream does not accept requests") } select {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 3.1K bytes - Viewed (0) -
tests/tracer_test.go
package tests_test import ( "context" "time" "gorm.io/gorm/logger" ) type Tracer struct { Logger logger.Interface Test func(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) } func (S Tracer) LogMode(level logger.LogLevel) logger.Interface { return S.Logger.LogMode(level) } func (S Tracer) Info(ctx context.Context, s string, i ...interface{}) {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Tue Oct 18 09:28:06 UTC 2022 - 830 bytes - Viewed (0)