Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for outBlock (0.1 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)
  4. src/main/java/jcifs/util/transport/Transport.java

        protected String name = "Transport" + id++;
        private volatile Thread thread;
        private volatile TransportException te;
    
        protected final Object inLock = new Object();
        protected final Object outLock = new Object();
    
        protected final Map<Long, Response> response_map = new ConcurrentHashMap<>(10);
        private final AtomicLong usageCount = new AtomicLong(1);
    
    
        /**
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 01 18:12:21 UTC 2020
    - 24.1K bytes
    - Viewed (0)
  5. fess-crawler-lasta/src/main/resources/crawler/extractor.xml

    				"application/vnd.ms-fontobject",
    				"application/vnd.ms-htmlhelp",
    				"application/vnd.ms-ims",
    				"application/vnd.ms-lrm",
    				"application/vnd.ms-outlook",
    				"application/vnd.ms-outlook-pst",
    				"application/vnd.ms-pki.seccat",
    				"application/vnd.ms-pki.stl",
    				"application/vnd.ms-playready.initiator+xml",
    				"application/vnd.ms-powerpoint",
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Aug 01 21:40:30 UTC 2020
    - 49K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbTransportImpl.java

            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 ) {
                    int n = smb.encode(buffer, 4);
                    Encdec.enc_uint32be(n & 0xFFFF, buffer, 0); /* 4 byte session message header */
                    if ( log.isTraceEnabled() ) {
                        do {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Wed Jan 18 23:47:00 UTC 2023
    - 67K bytes
    - Viewed (0)
  7. fess-crawler/src/main/resources/org/codelibs/fess/crawler/mime/tika-mimetypes.xml

        <glob pattern="*.lrm"/>
      </mime-type>
    
      <mime-type type="application/vnd.ms-outlook">
        <_comment>Microsoft Outlook Message</_comment>
        <glob pattern="*.msg" />
        <sub-class-of type="application/x-tika-msoffice"/>
      </mime-type>
    
      <mime-type type="application/vnd.ms-outlook-pst">
        <_comment>Outlook Personal Folders File Format</_comment>
        <magic priority="50">
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Sep 21 06:46:43 UTC 2023
    - 298.5K bytes
    - Viewed (0)
  8. 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
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Oct 18 04:36:59 UTC 2013
    - 1.9M bytes
    - Viewed (0)
  9. 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
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
  10. 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
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Aug 08 18:44:16 UTC 2019
    - 452.6K bytes
    - Viewed (0)
Back to top