Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 11 for outBlock (0.07 seconds)

  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
    	}
    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)
  2. internal/grid/muxclient.go

    	if !m.checkSeq(seq) {
    		return
    	}
    	if m.acked || m.outBlock == nil {
    		return
    	}
    	available := cap(m.outBlock)
    	for range available {
    		m.outBlock <- struct{}{}
    	}
    	m.acked = true
    }
    
    func (m *muxClient) unblockSend(seq uint32) {
    	if !m.checkSeq(seq) {
    		return
    	}
    	select {
    	case m.outBlock <- struct{}{}:
    	default:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  3. src/main/java/jcifs/util/transport/Transport.java

         * Lock object for synchronizing input operations
         */
        protected final Object inLock = new Object();
        /**
         * Lock object for synchronizing output operations
         */
        protected final Object outLock = new Object();
    
        /**
         * Map for tracking pending responses by their key
         */
        protected final Map<Long, Response> response_map = new ConcurrentHashMap<>(10);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 27.8K bytes
    - Click Count (0)
  4. android/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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Oct 02 01:46:40 GMT 2025
    - 48K bytes
    - Click Count (0)
  5. src/main/java/jcifs/smb/SmbTransportImpl.java

            final byte[] buffer = this.getContext().getBufferCache().getBuffer();
            try {
                // synchronize around encode and write so that the ordering for SMB1 signing can be maintained
                synchronized (this.outLock) {
                    final int n = smb.encode(buffer, 4);
                    Encdec.enc_uint32be(n & 0xFFFF, buffer, 0); /* 4 byte session message header */
                    if (log.isTraceEnabled()) {
                        do {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 69.8K bytes
    - Click Count (0)
  6. api/go1.2.txt

    pkg syscall (freebsd-386-cgo), type Rusage struct, Nswap int32
    pkg syscall (freebsd-386-cgo), type Rusage struct, Nvcsw int32
    pkg syscall (freebsd-386-cgo), type Rusage struct, Oublock int32
    pkg syscall (freebsd-386-cgo), type Rusage struct, Stime Timeval
    pkg syscall (freebsd-386-cgo), type Rusage struct, Utime Timeval
    pkg syscall (freebsd-386-cgo), type SockaddrDatalink struct
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Oct 18 04:36:59 GMT 2013
    - 1.9M bytes
    - Click Count (1)
  7. api/go1.txt

    pkg syscall (darwin-386), type Rusage struct, Nsignals int32
    pkg syscall (darwin-386), type Rusage struct, Nswap int32
    pkg syscall (darwin-386), type Rusage struct, Nvcsw int32
    pkg syscall (darwin-386), type Rusage struct, Oublock int32
    pkg syscall (darwin-386), type Rusage struct, Stime Timeval
    pkg syscall (darwin-386), type Rusage struct, Utime Timeval
    pkg syscall (darwin-386), type SockaddrDatalink struct
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Wed Aug 14 18:58:28 GMT 2013
    - 1.7M bytes
    - Click Count (0)
  8. api/go1.13.txt

    pkg syscall (netbsd-arm64-cgo), type Rusage struct, Nswap int64
    pkg syscall (netbsd-arm64-cgo), type Rusage struct, Nvcsw int64
    pkg syscall (netbsd-arm64-cgo), type Rusage struct, Oublock int64
    pkg syscall (netbsd-arm64-cgo), type Rusage struct, Stime Timeval
    pkg syscall (netbsd-arm64-cgo), type Rusage struct, Utime Timeval
    pkg syscall (netbsd-arm64-cgo), type SockaddrDatalink struct
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Aug 08 18:44:16 GMT 2019
    - 452.6K bytes
    - Click Count (0)
  9. api/go1.14.txt

    pkg syscall (freebsd-arm64), type Rusage struct, Nswap int64
    pkg syscall (freebsd-arm64), type Rusage struct, Nvcsw int64
    pkg syscall (freebsd-arm64), type Rusage struct, Oublock int64
    pkg syscall (freebsd-arm64), type Rusage struct, Stime Timeval
    pkg syscall (freebsd-arm64), type Rusage struct, Utime Timeval
    pkg syscall (freebsd-arm64), type SockaddrDatalink struct
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Feb 17 20:31:46 GMT 2023
    - 508.9K bytes
    - Click Count (0)
  10. api/go1.16.txt

    pkg syscall (darwin-arm64), type Rusage struct, Nsignals int64
    pkg syscall (darwin-arm64), type Rusage struct, Nswap int64
    pkg syscall (darwin-arm64), type Rusage struct, Nvcsw int64
    pkg syscall (darwin-arm64), type Rusage struct, Oublock int64
    pkg syscall (darwin-arm64), type Rusage struct, Stime Timeval
    pkg syscall (darwin-arm64), type Rusage struct, Utime Timeval
    pkg syscall (darwin-arm64), type SockaddrDatalink struct
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Dec 02 16:30:41 GMT 2022
    - 479.2K bytes
    - Click Count (0)
Back to Top