Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 281 - 290 of 1,423 for closed (0.04 seconds)

  1. internal/lru/lru.go

    		c.removeOldest()
    	}
    	c.size = size
    	return diff
    }
    
    // Close destroys cleanup goroutine. To clean up the cache, run Purge() before Close().
    // func (c *LRU[K, V]) Close() {
    //	c.mu.Lock()
    //	defer c.mu.Unlock()
    //	select {
    //	case <-c.done:
    //		return
    //	default:
    //	}
    //	close(c.done)
    // }
    
    // removeOldest removes the oldest item from the cache. Has to be called with lock!
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 12.6K bytes
    - Click Count (0)
  2. src/main/java/jcifs/internal/smb2/create/Smb2CreateRequest.java

        /**
         * Access to the file is random
         */
        public static final int FILE_RANDOM_ACCESS = 0x800;
        /**
         * Delete the file when the last handle to it is closed
         */
        public static final int FILE_DELETE_ON_CLOSE = 0x1000;
        /**
         * Open file by its file ID
         */
        public static final int FILE_OPEN_BY_FILE_ID = 0x2000;
        /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 02:21:31 GMT 2025
    - 22.9K bytes
    - Click Count (0)
  3. src/main/java/jcifs/dcerpc/msrpc/samr.java

            }
    
            /** The return value of the operation */
            public int retval;
            /** The handle to be closed */
            public rpc.policy_handle handle;
    
            /**
             * Constructs a SamrCloseHandle request.
             *
             * @param handle The policy handle to close
             */
            public SamrCloseHandle(final rpc.policy_handle handle) {
                this.handle = handle;
            }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 23.4K bytes
    - Click Count (0)
  4. src/main/java/jcifs/smb1/dcerpc/msrpc/samr.java

            }
    
            /** The return value of the operation */
            public int retval;
            /** The handle to be closed */
            public rpc.policy_handle handle;
    
            /**
             * Constructs a SamrCloseHandle request.
             *
             * @param handle The policy handle to close
             */
            public SamrCloseHandle(final rpc.policy_handle handle) {
                this.handle = handle;
            }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 23.1K bytes
    - Click Count (0)
  5. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.SmbTransportPool#close()
         */
        @Override
        public boolean close() throws CIFSException {
            boolean inUse = false;
    
            // Cleanup first
            cleanup();
            log.debug("Closing pool");
    
            // Create a snapshot of connections to close
            List<SmbTransportImpl> toClose = new ArrayList<>(this.connections);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 33.4K bytes
    - Click Count (0)
  6. internal/s3select/select.go

    		}
    	}
    	return rsc.reader.Read(p)
    }
    
    // Close call to implement io.Closer. Calling Read/Seek after Close reopens the
    // object for reading and a subsequent Close call is required to ensure
    // resources are freed.
    func (rsc *ObjectReadSeekCloser) Close() error {
    	rsc.closerOnce.Do(func() {
    		if rsc.reader != nil {
    			rsc.closerErr = rsc.reader.Close()
    			rsc.reader = nil
    		}
    	})
    	return rsc.closerErr
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 21.2K bytes
    - Click Count (0)
  7. CHANGELOG.md

        of unacknowledged data per stream and no per-connection limit.
    
     *  Fix: Don't close a `Deflater` while we're still using it to compress a web socket message. We
        had a severe bug where web sockets were closed on the wrong thread, which caused
        `NullPointerException` crashes in `Deflater`.
    
     *  Fix: Don't crash after a web socket fails its connection upgrade. We incorrectly released
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 15 11:57:47 GMT 2026
    - 36.2K bytes
    - Click Count (2)
  8. cmd/object-api-utils.go

    				cleanUpFns: cFns,
    			}
    			return r, nil
    		}
    	}
    	return fn, off, length, nil
    }
    
    // Close - calls the cleanup actions in reverse order
    func (g *GetObjectReader) Close() error {
    	if g == nil {
    		return nil
    	}
    	// sync.Once is used here to ensure that Close() is
    	// idempotent.
    	g.once.Do(func() {
    		for i := len(g.cleanUpFns) - 1; i >= 0; i-- {
    			g.cleanUpFns[i]()
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 37.3K bytes
    - Click Count (0)
  9. src/test/java/jcifs/SmbResourceTest.java

        class ResourceManagementTests {
    
            @Test
            @DisplayName("close operation should work correctly")
            void testClose() {
                // When/Then
                assertDoesNotThrow(() -> mockResource.close(), "Close operation should not throw exception");
                verify(mockResource).close();
            }
    
            @Test
            @DisplayName("resource should be AutoCloseable")
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 35K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt

              windowSizeIncrement = increment,
            ),
          )
        }
        handler.windowUpdate(streamId, increment)
      }
    
      @Throws(IOException::class)
      override fun close() {
        source.close()
      }
    
      /**
       * Decompression of the header block occurs above the framing layer. This class lazily reads
       * continuation frames as they are needed by [Hpack.Reader.readHeaders].
       */
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 19.7K bytes
    - Click Count (0)
Back to Top