Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 1,187 for _clone (0.32 sec)

  1. android/guava/src/com/google/common/io/MultiReader.java

        return 0;
      }
    
      @Override
      public boolean ready() throws IOException {
        return (current != null) && current.ready();
      }
    
      @Override
      public void close() throws IOException {
        if (current != null) {
          try {
            current.close();
          } finally {
            current = null;
          }
        }
      }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  2. internal/event/target/mysql.go

    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Close - closes underneath connections to MySQL database.
    func (target *MySQLTarget) Close() error {
    	close(target.quitCh)
    	if target.updateStmt != nil {
    		// FIXME: log returned error. ignore time being.
    		_ = target.updateStmt.Close()
    	}
    
    	if target.deleteStmt != nil {
    		// FIXME: log returned error. ignore time being.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  3. cmd/erasure-sets.go

    			srcInfo.Reader.Close() // We are not interested in the reader stream at this point close it.
    			return srcSet.CopyObject(ctx, srcBucket, srcObject, dstBucket, dstObject, srcInfo, srcOpts, dstOpts)
    		}
    		// Destination is not versioned and source version ID is empty
    		// perform an in-place update.
    		if !dstOpts.Versioned && srcOpts.VersionID == "" {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  4. src/main/java/jcifs/smb/SmbSessionImpl.java

            } finally {
                super.finalize();
            }
        }
    
        /**
         * {@inheritDoc}
         *
         * @see java.lang.AutoCloseable#close()
         */
        @Override
        public void close() {
            release();
        }
    
        /**
         *
         */
        public void release() {
            long usage = this.usageCount.decrementAndGet();
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 68.9K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/io/MultiInputStream.java

        advance();
      }
    
      @Override
      public void close() throws IOException {
        if (in != null) {
          try {
            in.close();
          } finally {
            in = null;
          }
        }
      }
    
      /** Closes the current input stream and opens the next one, if any. */
      private void advance() throws IOException {
        close();
        if (it.hasNext()) {
          in = it.next().openStream();
        }
      }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed May 14 19:40:47 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  6. docs/smb3-features/05-rdma-smb-direct-design.md

            RdmaMemoryRegion region;
            
            while ((region = availableSendRegions.poll()) != null) {
                region.close();
                totalReleased.incrementAndGet();
            }
            
            while ((region = availableReceiveRegions.poll()) != null) {
                region.close();
                totalReleased.incrementAndGet();
            }
        }
        
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  7. src/test/java/jcifs/smb/SmbFileIntegrationTest.java

            SmbFile targetFile = new SmbFile(baseUrl + "shared/" + targetFileName, renameContext);
    
            // Copy content to new file
            srcForCopy.copyTo(targetFile);
            srcForCopy.close();
            targetFile.close();
    
            // Wait before delete
            Thread.sleep(500);
            System.gc();
            Thread.sleep(200);
    
            // Delete original using fresh context
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 56K bytes
    - Viewed (0)
  8. scripts/playwright/separate_openapi_schemas/image03.py

        # Manually add the screenshot
        page.screenshot(
            path="docs/en/docs/img/tutorial/separate-openapi-schemas/image03.png"
        )
    
        # ---------------------
        context.close()
        browser.close()
    
    
    process = subprocess.Popen(
        ["uvicorn", "docs_src.separate_openapi_schemas.tutorial001:app"]
    )
    try:
        with sync_playwright() as playwright:
            run(playwright)
    finally:
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Fri Sep 13 09:14:46 UTC 2024
    - 1K bytes
    - Viewed (0)
  9. src/main/java/jcifs/CloseableIterator.java

     * @author mbechler
     */
    public interface CloseableIterator<T> extends Iterator<T>, AutoCloseable {
    
        /**
         * {@inheritDoc}
         *
         * @see java.lang.AutoCloseable#close()
         */
        @Override
        void close() throws CIFSException;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  10. internal/s3select/csv/reader.go

    	dstRec.nameIndexMap = r.nameIndexMap
    
    	return dstRec, nil
    }
    
    // Close - closes underlying reader.
    func (r *Reader) Close() error {
    	if r.close != nil {
    		close(r.close)
    		r.readerWg.Wait()
    		r.close = nil
    	}
    	r.recordsRead = len(r.current)
    	if r.err == nil {
    		r.err = io.EOF
    	}
    	return r.readCloser.Close()
    }
    
    // nextSplit will attempt to skip a number of bytes and
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 8.8K bytes
    - Viewed (0)
Back to top