- Sort Score
- Num 10 results
- Language All
Results 81 - 90 of 954 for channel (0.06 seconds)
-
cmd/metacache-server-pool.go
// 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 Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 12.9K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocket.kt
@Throws(IOException::class) override fun sendUrgentData(value: Int) { delegate!!.sendUrgentData(value) } override fun getChannel(): SocketChannel = delegate!!.channel override fun getHandshakeSession(): SSLSession = delegate!!.handshakeSession override fun getApplicationProtocol(): String = delegate!!.applicationProtocol
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 7.4K bytes - Click Count (0) -
cmd/listen-notification-handlers.go
setEventStreamHeaders(w) // Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers. // Use buffered channel to take care of burst sends or slow w.Write() mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames())) localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 6K bytes - Click Count (0) -
internal/event/target/webhook.go
ctx, cancel := context.WithCancel(ctx) var queueStore store.Store[event.Event] if args.QueueDir != "" { queueDir := filepath.Join(args.QueueDir, storePrefix+"-webhook-"+id) queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil { cancel()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 8.8K bytes - Click Count (0) -
cmd/admin-heal-ops.go
h.mutex.Lock() h.endTime = UTCNow() h.currentStatus.Summary = healFinishedStatus h.mutex.Unlock() // drain traverse channel so the traversal // go-routine does not leak. go func() { // Eventually the traversal go-routine closes // the channel and returns, so this go-routine // itself will not leak. <-h.traverseAndHealDoneCh }() } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 25.4K bytes - Click Count (0) -
internal/event/target/mqtt.go
_, err := target.isActive() if err != nil { return err } eventData, err := target.store.Get(key) if err != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(err) { return nil } return err }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 8.2K bytes - Click Count (0) -
src/main/java/jcifs/config/PropertyConfiguration.java
String maxVersion = props.getProperty("jcifs.smb.client.maxVersion"); if (minVersion != null || maxVersion != null) { initProtocolVersions(minVersion, maxVersion); } // Multi-Channel Configuration value = props.getProperty("jcifs.smb.client.useMultiChannel"); if (value != null) { this.useMultiChannelExplicitlySet = true;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 24 00:49:49 GMT 2025 - 13.3K bytes - Click Count (0) -
internal/event/target/nsq.go
} _, err := target.isActive() if err != nil { return err } eventData, eErr := target.store.Get(key) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7.1K bytes - Click Count (0) -
internal/grid/muxserver.go
if msg.DeadlineMS > 0 { ctx, cancel = context.WithTimeout(ctx, time.Duration(msg.DeadlineMS)*time.Millisecond) } else { ctx, cancel = context.WithCancel(ctx) } m := muxServer{ ID: msg.MuxID, RecvSeq: msg.Seq + 1, SendSeq: msg.Seq, ctx: ctx, cancel: cancel, parent: c, LastPing: time.Now().Unix(), BaseFlags: c.baseFlags, } go func() { // TODO: Handle }()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 9.7K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/io/Smb2WriteResponseTest.java
int bytesRead = response.readBytesWireFormat(buffer, 0); assertEquals(16, bytesRead); // Structure size + reserved (4) + count (4) + remaining (4) + channel info (4) assertEquals(1024, response.getCount()); assertEquals(512, response.getRemaining()); } @TestCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 15.9K bytes - Click Count (0)