Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 417 for readlink (0.11 sec)

  1. src/archive/tar/writer.go

    		if err != nil {
    			return err
    		}
    		if name == "." {
    			return nil
    		}
    		info, err := d.Info()
    		if err != nil {
    			return err
    		}
    		// TODO(#49580): Handle symlinks when fs.ReadLinkFS is available.
    		if !d.IsDir() && !info.Mode().IsRegular() {
    			return errors.New("tar: cannot add non-regular file")
    		}
    		h, err := FileInfoHeader(info, "")
    		if err != nil {
    			return err
    		}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 14:22:59 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  2. cmd/erasure-object_test.go

    	if err != nil {
    		t.Fatalf("Expected GetObject reading data to succeed, but failed with %v", err)
    	}
    	gr.Close()
    
    	const expectedHash = "fffb6377948ebea75ad2b8058e849ef5"
    	foundHash := fmt.Sprintf("%x", h.Sum(nil))
    	if foundHash != expectedHash {
    		t.Fatalf("Expected data to have md5sum = `%s`, found `%s`", expectedHash, foundHash)
    	}
    }
    
    // Test reading an object with some outdated data in some disks
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  3. internal/s3select/jstream/decoder.go

    			i, err = d.object()
    		}
    		return i, Object, err
    	default:
    		return nil, Unknown, d.mkError(ErrSyntax, "looking for beginning of value")
    	}
    }
    
    // string called by `any` or `object`(for map keys) after reading `"`
    func (d *Decoder) string() (string, error) {
    	d.scratch.reset()
    	c := d.next()
    
    scan:
    	for {
    		switch {
    		case c == '"':
    			return string(d.scratch.bytes()), nil
    		case c == '\\':
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  4. internal/s3select/simdj/reader.go

    		dstRec = &Record{}
    	}
    	dstRec.object = v
    	return dstRec, nil
    }
    
    // Close - closes underlying reader.
    func (r *Reader) Close() error {
    	// Close the input.
    	// Potentially racy if the stream decoder is still reading.
    	if r.readCloser != nil {
    		r.readCloser.Close()
    	}
    	if r.exitReader != nil {
    		close(r.exitReader)
    		r.readerWg.Wait()
    		r.exitReader = nil
    		r.input = nil
    	}
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  5. internal/etag/reader.go

    			return n, VerifyError{
    				Expected: r.checksum,
    				Computed: etag,
    			}
    		}
    	}
    	return n, err
    }
    
    // ETag returns the ETag of all the content read
    // so far. Reading more content changes the MD5
    // checksum. Therefore, calling ETag multiple
    // times may return different results.
    func (r *Reader) ETag() ETag {
    	sum := r.md5.Sum(nil)
    	return ETag(sum)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/LinkedListMultimap.java

        stream.defaultReadObject();
        keyToKeyList = Maps.newLinkedHashMap();
        int size = stream.readInt();
        for (int i = 0; i < size; i++) {
          @SuppressWarnings("unchecked") // reading data stored by writeObject
          K key = (K) stream.readObject();
          @SuppressWarnings("unchecked") // reading data stored by writeObject
          V value = (V) stream.readObject();
          put(key, value);
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 13 14:11:58 UTC 2023
    - 27.5K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/io/CharSink.java

       * Does not close {@code readable} if it is {@code Closeable}.
       *
       * @return the number of characters written
       * @throws IOException if an I/O error occurs while reading from {@code readable} or writing to
       *     this sink
       */
      @CanIgnoreReturnValue
      public long writeFrom(Readable readable) throws IOException {
        checkNotNull(readable);
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  8. internal/logger/target/http/http.go

    	// Worker control
    	workers    atomic.Int64
    	maxWorkers int64
    
    	// workerStartMu sync.Mutex
    	lastStarted time.Time
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    	// Reading logCh must hold read lock on logChMu (to avoid read race)
    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    	logCh   chan interface{}
    	logChMu sync.RWMutex
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  9. internal/ringbuffer/ring_buffer.go

    // When Read encounters an error or end-of-file condition after successfully reading n > 0 bytes, it returns the number of bytes read.
    // It may return the (non-nil) error from the same call or return the error (and n == 0) from a subsequent call.
    // Callers should always process the n > 0 bytes returned before considering the error err.
    // Doing so correctly handles I/O errors that happen after reading some bytes and also both of the allowed EOF behaviors.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. src/main/java/jcifs/ACE.java

     * of the access check algorithm used by Windows is required. The following
     * is a basic description of the algorithm. For a more complete description
     * we recommend reading the section on Access Control in Keith Brown's
     * "The .NET Developer's Guide to Windows Security" (which is also
     * available online).
     * <p>
     * Direct ACEs are evaluated first in order. The SID of the user performing
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 6.5K bytes
    - Viewed (0)
Back to top