Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for outBlock (0.04 sec)

  1. internal/grid/muxserver.go

    func (m *muxServer) close() {
    	m.cancel()
    	m.recvMu.Lock()
    	defer m.recvMu.Unlock()
    
    	if m.inbound != nil {
    		xioutil.SafeClose(m.inbound)
    		m.inbound = nil
    	}
    
    	if m.outBlock != nil {
    		xioutil.SafeClose(m.outBlock)
    		m.outBlock = nil
    
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  2. internal/grid/muxclient.go

    	if !m.checkSeq(seq) {
    		return
    	}
    	if m.acked || m.outBlock == nil {
    		return
    	}
    	available := cap(m.outBlock)
    	for i := 0; i < available; i++ {
    		m.outBlock <- struct{}{}
    	}
    	m.acked = true
    }
    
    func (m *muxClient) unblockSend(seq uint32) {
    	if !m.checkSeq(seq) {
    		return
    	}
    	select {
    	case m.outBlock <- struct{}{}:
    	default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  3. guava/src/com/google/common/net/MediaType.java

      /**
       * <a href="https://www.loc.gov/preservation/digital/formats/fdd/fdd000379.shtml">Microsoft
       * Outlook</a> items.
       *
       * @since 27.1
       */
      public static final MediaType MICROSOFT_OUTLOOK =
          createConstant(APPLICATION_TYPE, "vnd.ms-outlook");
    
      /**
       * <a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Sep 26 19:15:09 UTC 2024
    - 47.5K bytes
    - Viewed (0)
Back to top