Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 81 - 90 of 198 for Channel (0.05 seconds)

  1. cmd/metacache-server-pool.go

    			entries.listID = o.ID
    		}
    	}
    	if !truncated {
    		return entries, io.EOF
    	}
    	return entries, nil
    }
    
    // listMerged will list across all sets and return a merged results stream.
    // The result channel is closed when no more results are expected.
    func (z *erasureServerPools) listMerged(ctx context.Context, o listPathOptions, results chan<- metaCacheEntry) error {
    	var mu sync.Mutex
    	var wg sync.WaitGroup
    	var errs []error
    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)
  2. 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)
  3. 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)
  4. internal/event/target/webhook.go

    	if err := target.init(); 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 would've been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. internal/grid/muxserver.go

    			handlerErr = &err
    		}
    		if debugPrint {
    			fmt.Println("muxServer: Mux", m.ID, "Returned with", handlerErr)
    		}
    	}()
    	// handlerErr is guarded by 'send' channel.
    	handlerErr = handler.Handle(ctx, msg.Payload, handlerIn, send)
    	return handlerErr
    }
    
    // checkRemoteAlive will check if the remote is alive.
    func (m *muxServer) checkRemoteAlive() {
    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)
  10. 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());
            }
    
            @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 15.9K bytes
    - Click Count (0)
Back to Top