- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 211 for msg2 (0.1 seconds)
-
src/main/java/jcifs/smb/NtlmContext.java
} } this.ntlmsspFlags &= msg2.getFlags(); final Type3Message msg3 = createType3Message(msg2); msg3.setupMIC(this.type1Bytes, token); final byte[] out = msg3.toByteArray(); if (log.isTraceEnabled()) { log.trace(msg3.toString()); log.trace(Hexdump.toHexString(token)); }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 17.3K bytes - Click Count (1) -
cmd/data-usage-cache.go
type dataUsageEntry struct { Children dataUsageHashMap `msg:"ch"` // These fields do no include any children. Size int64 `msg:"sz"` Objects uint64 `msg:"os"` Versions uint64 `msg:"vs"` // Versions that are not delete markers. DeleteMarkers uint64 `msg:"dms"` ObjSizes sizeHistogram `msg:"szs"` ObjVersions versionsHistogram `msg:"vh"`Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.7K bytes - Click Count (0) -
internal/grid/handlers.go
return h.subSingle[id] != nil || h.subStateless[id] != nil || h.subStreams[id] != nil } // RoundTripper provides an interface for type roundtrip serialization. type RoundTripper interface { msgp.Unmarshaler msgp.Marshaler msgp.Sizer comparable } // SingleHandler is a type safe handler for single roundtrip requests. type SingleHandler[Req, Resp RoundTripper] struct { id HandlerID
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 27.7K bytes - Click Count (0) -
internal/grid/connection.go
msg.Flags.Clear(FlagSubroute) if payload != nil { if sz := payload.Msgsize(); cap(msg.Payload) < sz { PutByteBuffer(msg.Payload) msg.Payload = GetByteBufferCap(sz) } var err error msg.Payload, err = payload.MarshalMsg(msg.Payload[:0]) msg.Op = payload.Op() if err != nil { return err } } defer PutByteBuffer(msg.Payload) dst := GetByteBufferCap(msg.Msgsize())
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 46.9K bytes - Click Count (0) -
cmd/bucket-replication-metrics.go
PutTagTotal uint64 `json:"putTaggingProxyTotal" msg:"ptc"` GetTagTotal uint64 `json:"getTaggingProxyTotal" msg:"gtc"` RmvTagTotal uint64 `json:"removeTaggingProxyTotal" msg:"rtc"` GetTotal uint64 `json:"getProxyTotal" msg:"gc"` HeadTotal uint64 `json:"headProxyTotal" msg:"hc"` PutTagFailedTotal uint64 `json:"putTaggingProxyFailed" msg:"ptf"`
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 15 12:04:40 GMT 2024 - 14.2K bytes - Click Count (0) -
cmd/storage-datatypes.go
DiskID string `msg:"id"` Volume string `msg:"v"` FilePath string `msg:"fp"` FI FileInfo `msg:"fi"` } // DeleteFileHandlerParams are parameters for DeleteFileHandler type DeleteFileHandlerParams struct { DiskID string `msg:"id"` Volume string `msg:"v"` FilePath string `msg:"fp"` Opts DeleteOptions `msg:"do"` }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 17.4K bytes - Click Count (0) -
cmd/endpoint-ellipses.go
for _, totalSize := range totalSizes { // Check if totalSize has minimum range upto setSize if totalSize < setSizes[0] || totalSize < setDriveCount { msg := fmt.Sprintf("Incorrect number of endpoints provided %s", args) return nil, config.ErrInvalidNumberOfErasureEndpoints(nil).Msg(msg) } } commonSize := getDivisibleSize(totalSizes) possibleSetCounts := func(setSize uint64) (ss []uint64) { for _, s := range setSizes {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 14.7K bytes - Click Count (0) -
cmd/bucket-replication-utils.go
// Total number of failed operations FailedCount int64 `json:"failedReplicationCount" msg:"frc"` // Completed size in bytes ReplicatedSize int64 `json:"completedReplicationSize" msg:"rs"` // Total number of failed operations ReplicatedCount int64 `json:"replicationCount" msg:"rrc"` // Last bucket/object replicated. Bucket string `json:"-" msg:"bkt"` Object string `json:"-" msg:"obj"`
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 26.1K bytes - Click Count (0) -
cmd/tier.go
// TierConfigMgr holds the collection of remote tiers configured in this deployment. type TierConfigMgr struct { sync.RWMutex `msg:"-"` drivercache map[string]WarmBackend `msg:"-"` Tiers map[string]madmin.TierConfig `json:"tiers"` lastRefreshedAt time.Time `msg:"-"` } type tierMetrics struct { sync.RWMutex // protects requestsCount only requestsCount map[string]struct { success int64Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.6K bytes - Click Count (0) -
cmd/batch-handlers_gen.go
func (z *batchJobInfo) Msgsize() (s int) { s = 3 + 2 + msgp.IntSize + 4 + msgp.StringPrefixSize + len(z.JobID) + 3 + msgp.StringPrefixSize + len(z.JobType) + 3 + msgp.TimeSize + 3 + msgp.TimeSize + 3 + msgp.IntSize + 3 + msgp.IntSize + 4 + msgp.BoolSize + 4 + msgp.BoolSize + 5 + msgp.StringPrefixSize + len(z.Bucket) + 5 + msgp.StringPrefixSize + len(z.Object) + 3 + msgp.Int64Size + 3 + msgp.Int64Size + 4 + msgp.Int64Size + 4 + msgp.Int64Size + 3 + msgp.Int64Size + 3 + msgp.Int64Size
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 20.4K bytes - Click Count (0)