Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 311 for opened (0.08 sec)

  1. internal/s3select/select.go

    	if s3Select.progressReader != nil {
    		return s3Select.progressReader.Stats()
    	}
    
    	return -1, -1
    }
    
    // Open - opens S3 object by using callback for SQL selection query.
    // Currently CSV, JSON and Apache Parquet formats are supported.
    func (s3Select *S3Select) Open(rsc io.ReadSeekCloser) error {
    	offset, length, err := s3Select.ScanRange.StartLen()
    	if err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/io/CharSink.java

     *       typically implemented by opening a writer using one of the methods in the first category,
     *       doing something and finally closing the writer that was opened.
     * </ul>
     *
     * <p>Any {@link ByteSink} may be viewed as a {@code CharSink} with a specific {@linkplain Charset
     * character encoding} using {@link ByteSink#asCharSink(Charset)}. Characters written to the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/SmbNamedPipe.java

     * writes to, reads from, and closes the pipe in a single operation.
     * <li><code>TransactNamedPipe</code> A message-type pipe call that
     * writes to and reads from an existing pipe descriptor in one operation.
     * <li><code>CreateFile</code>, <code>ReadFile</code>,
     * <code>WriteFile</code>, and <code>CloseFile</code> A byte-type pipe can
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 6K bytes
    - Viewed (0)
  4. src/main/java/jcifs/internal/smb2/create/Smb2CreateResponse.java

                }
                while ( next > 0 );
                this.createContexts = contexts.toArray(new CreateContextResponse[0]);
            }
    
            if ( log.isDebugEnabled() ) {
                log.debug("Opened " + this.fileName + ": " + Hexdump.toHexString(this.fileId));
            }
    
            return bufferIndex - start;
        }
    
    
        /**
         * @param nameBytes
         * @return
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 8.6K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/smb1/SmbFileInputStream.java

                return 0;
            }
            long start = fp;
    
            if( tmp == null ) {
                throw new IOException( "Bad file descriptor" );
            }
            // ensure file is open
            file.open( openFlags, access, SmbFile.ATTR_NORMAL, 0 );
    
            /*
             * Read AndX Request / Response
             */
    
            if( file.log.level >= 4 )
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 7.9K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/podcgroupns.go

    	for _, entry := range entries {
    		// we can't break here because we need to close all the netns we opened
    		// plus we want to return whatever we can to the user.
    		res, err := p.processEntry(p.proc, netnsObserved, desiredUIDs, entry)
    		if err != nil {
    			log.Debugf("error processing entry: %s %v", entry.Name(), err)
    			continue
    		}
    		if res == nil {
    			continue
    		}
    		pod := pods[res.uid]
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 11K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

          throw IOException("unexpected journal line: $strings")
        }
    
        /**
         * Returns a snapshot of this entry. This opens all streams eagerly to guarantee that we see a
         * single published snapshot. If we opened streams lazily then the streams could come from
         * different edits.
         */
        internal fun snapshot(): Snapshot? {
          ******@****.***ThreadHoldsLock()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  8. src/main/java/jcifs/SmbResource.java

    
        /**
         * Opens an output stream writing to the file (truncating, write only, sharable)
         * 
         * @return output stream, needs to be closed when finished
         * @throws CIFSException
         */
        OutputStream openOutputStream () throws CIFSException;
    
    
        /**
         * Opens an input stream reading the file (read only)
         * 
         * @param flags
         *            open flags
         * @param access
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Dec 20 14:09:34 UTC 2020
    - 26K bytes
    - Viewed (1)
  9. android/guava/src/com/google/common/io/Files.java

          return "Files.asByteSource(" + file + ")";
        }
      }
    
      /**
       * Returns a new {@link ByteSink} for writing bytes to the given file. The given {@code modes}
       * control how the file is opened for writing. When no mode is provided, the file will be
       * truncated before writing. When the {@link FileWriteMode#APPEND APPEND} mode is provided, writes
       * will append to the end of the file without truncating it.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jul 22 19:03:12 UTC 2024
    - 33.1K bytes
    - Viewed (0)
  10. internal/ioutil/ioutil.go

    //
    // This code is similar in spirit to io.Copy but it is only to be
    // used with DIRECT I/O based file descriptor and it is expected that
    // input writer *os.File not a generic io.Writer. Make sure to have
    // the file opened for writes with syscall.O_DIRECT flag.
    func CopyAligned(w io.Writer, r io.Reader, alignedBuf []byte, totalSize int64, file *os.File) (int64, error) {
    	if totalSize == 0 {
    		return 0, nil
    	}
    
    	var written int64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
Back to top