- Sort Score
- Num 10 results
- Language All
Results 71 - 80 of 674 for chang (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/s3select/simdj/reader.go
) // Reader - JSON record reader for S3Select. type Reader struct { args *json.ReaderArgs input chan simdjson.Stream decoded chan simdjson.Object // err will only be returned after decoded has been closed. err *error readCloser io.ReadCloser onReaderExit func() exitReader chan struct{} readerWg sync.WaitGroup } // Read - reads single record.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Click Count (0) -
internal/lsync/lrwmutex_test.go
if m.GetRLock(ctx, "", "", time.Second) { clocked <- true <-cunlock m.RUnlock() cdone <- true } } // Borrowed from rwmutex_test.go func doTestParallelReaders(numReaders, gomaxprocs int) { runtime.GOMAXPROCS(gomaxprocs) m := NewLRWMutex() clocked := make(chan bool) cunlock := make(chan bool) cdone := make(chan bool)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 7.8K bytes - Click Count (0) -
internal/s3select/json/preader.go
input chan *queueItem // input for workers queue chan *queueItem // output from workers in order err error // global error state, only touched by Reader.Read bufferPool bpool.Pool[[]byte] // pool of []byte objects for input kvDstPool bpool.Pool[[]jstream.KVS] // pool of []jstream.KVS used for output
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 6.5K bytes - Click Count (0) -
internal/once/singleton.go
// Singleton contains a pointer to T that must be set once. // Until the value is set all Get() calls will block. type Singleton[T any] struct { v *T set chan struct{} } // NewSingleton creates a new unset singleton. func NewSingleton[T any]() *Singleton[T] { return &Singleton[T]{set: make(chan struct{}), v: nil} } // Get will return the singleton value. func (s *Singleton[T]) Get() *T { <-s.set return s.v }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 15 12:04:40 GMT 2024 - 952 bytes - Click Count (0) -
CONTRIBUTING.md
This can save everyone a lot of time and frustration. For any non-trivial change, we need to be able to answer these questions: * Why is this change done? What's the use case? * For user-facing features, what will the API look like? * What test cases should it have? What could go wrong?
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Tue Nov 25 06:57:22 GMT 2025 - 19K bytes - Click Count (0) -
src/main/java/jcifs/internal/witness/WitnessAsyncNotifyMessage.java
/** Witness resource change notification type */ public static final int WITNESS_RESOURCE_CHANGE = 1; /** Witness client move notification type */ public static final int WITNESS_CLIENT_MOVE = 2; /** Witness share move notification type */ public static final int WITNESS_SHARE_MOVE = 3; /** Witness IP address change notification type */Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 24 00:12:28 GMT 2025 - 16.4K bytes - Click Count (0) -
internal/grid/connection_test.go
}() cleanReqs := make(chan struct{}) gotCall := make(chan struct{}) defer close(cleanReqs) // 1: Block forever h1 := func(payload []byte) ([]byte, *RemoteErr) { gotCall <- struct{}{} <-cleanReqs return nil, nil } // 2: Also block, but with streaming. h2 := StreamHandler{ Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 5.9K bytes - Click Count (0) -
internal/pubsub/pubsub.go
select { case sub.ch <- item: default: } } } } // Subscribe - Adds a subscriber to pubsub system func (ps *PubSub[T, M]) Subscribe(mask M, subCh chan T, doneCh <-chan struct{}, filter func(entry T) bool) error { totalSubs := atomic.AddInt32(&ps.numSubscribers, 1) if ps.maxSubscribers > 0 && totalSubs > ps.maxSubscribers { atomic.AddInt32(&ps.numSubscribers, -1)Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Click Count (0) -
cmd/metacache-server-pool.go
saver := z.serverPools[o.pool].sets[o.set] // Disconnect from call above, but cancel on exit. listCtx, cancel := context.WithCancel(GlobalContext) saveCh := make(chan metaCacheEntry, metacacheBlockSize) inCh := make(chan metaCacheEntry, metacacheBlockSize) outCh := make(chan metaCacheEntry, o.Limit) filteredResults := o.gatherResults(ctx, outCh) mc := o.newMetacache()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 12.9K bytes - Click Count (0) -
src/test/java/jcifs/smb1/smb1/InfoTest.java
byte[] buffer = new byte[34]; long create = 1600000000000L; long lastAccess = 1600000100000L; long lastWrite = 1600000200000L; long change = 1600000300000L; int attributes = 0x1234; // Convert Unix time to Windows FILETIME (100-nanosecond intervals since 1601) long MILLISECONDS_BETWEEN_1970_AND_1601 = 11644473600000L;
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 4.5K bytes - Click Count (0)