Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 436 for readlink (0.07 sec)

  1. docs/sts/ldap.go

    		if f, err := os.Open(sessionPolicyFile); err != nil {
    			log.Fatalf("Unable to open session policy file %s: %v", sessionPolicyFile, err)
    		} else {
    			bs, err := io.ReadAll(f)
    			if err != nil {
    				log.Fatalf("Error reading session policy file: %v", err)
    			}
    			policy = string(bs)
    		}
    		ldapOpts = append(ldapOpts, cr.LDAPIdentityPolicyOpt(policy))
    	}
    	if expiryDuration != 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 07 12:59:47 UTC 2024
    - 4K bytes
    - Viewed (0)
  2. src/archive/zip/register.go

    // simultaneously, but each returned writer will be used only by
    // one goroutine at a time.
    type Compressor func(w io.Writer) (io.WriteCloser, error)
    
    // A Decompressor returns a new decompressing reader, reading from r.
    // The [io.ReadCloser]'s Close method must be used to release associated resources.
    // The Decompressor itself must be safe to invoke from multiple goroutines
    // simultaneously, but each returned reader will be used only by
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Oct 13 18:36:46 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  3. src/main/java/jcifs/pac/ASN1Util.java

            length = 0;
            do
            {
                int octet = s.read();
                if (octet < 0)
                {
                    throw new EOFException("EOF found reading length");
                }
    
                if ((length >>> 23) != 0)
                {
                    throw new IOException("long form definite-length more than 31 bits");
                }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Oct 02 12:02:06 UTC 2023
    - 6.5K bytes
    - Viewed (0)
  4. src/test/java/jcifs/tests/RandomAccessFileTest.java

            byte[] offBuf = new byte[cnt];
            int pos = 0;
            while ( pos < cnt ) {
                int r = is.read(offBuf, pos, offBuf.length - pos);
                if ( r < 0 ) {
                    fail("EOF while reading");
                }
                pos += r;
            }
    
            for ( int i = 0; i < offBuf.length; i++ ) {
                if ( offBuf[ i ] != 0 ) {
                    fail("Not zero @ " + i);
                }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 11.4K bytes
    - Viewed (0)
  5. cmd/bitrot.go

    	if algo != HighwayHash256S {
    		h := algo.New()
    		if n, err := io.Copy(h, r); err != nil || n != wantSize {
    			// Premature failure in reading the object, file is corrupt.
    			return errFileCorrupt
    		}
    		if !bytes.Equal(h.Sum(nil), want) {
    			return errFileCorrupt
    		}
    		return nil
    	}
    
    	h := algo.New()
    	hashBuf := make([]byte, h.Size())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  6. cmd/tier.go

    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	randInterval := func() time.Duration {
    		return time.Duration(r.Float64() * 5 * float64(time.Second))
    	}
    
    	// To avoid all MinIO nodes reading the tier config object at the same
    	// time.
    	t := time.NewTimer(tierCfgRefresh + randInterval())
    	defer t.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-t.C:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  7. internal/s3select/parquet/reader.go

    	jsonfmt "github.com/minio/minio/internal/s3select/json"
    	"github.com/minio/minio/internal/s3select/jstream"
    	"github.com/minio/minio/internal/s3select/sql"
    )
    
    // Reader implements reading records from parquet input.
    type Reader struct {
    	io.Closer
    	r *parquetgo.FileReader
    }
    
    // NewParquetReader creates a Reader2 from a io.ReadSeekCloser.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  8. misc/linkcheck/linkcheck.go

    		crawl(newURL.String(), url)
    		return nil
    	}
    	if res.StatusCode != 200 {
    		return errors.New(res.Status)
    	}
    	slurp, err := io.ReadAll(res.Body)
    	res.Body.Close()
    	if err != nil {
    		log.Fatalf("Error reading %s body: %v", url, err)
    	}
    	if *verbose {
    		log.Printf("Len of %s: %d", url, len(slurp))
    	}
    	body := string(slurp)
    	for _, ref := range localLinks(body) {
    		if *verbose {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 06 15:53:04 UTC 2021
    - 3.9K bytes
    - Viewed (0)
  9. cmd/batch-expire_gen.go

    				if err != nil {
    					err = msgp.WrapError(err, "Purge")
    					return
    				}
    				switch msgp.UnsafeString(field) {
    				case "RetainVersions":
    					z.Purge.RetainVersions, err = dc.ReadInt()
    					if err != nil {
    						err = msgp.WrapError(err, "Purge", "RetainVersions")
    						return
    					}
    				default:
    					err = dc.Skip()
    					if err != nil {
    						err = msgp.WrapError(err, "Purge")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  10. internal/hash/reader.go

    				ExpectedMD5:   v.Expected.String(),
    				CalculatedMD5: v.Computed.String(),
    			}
    		}
    	}
    	return n, err
    }
    
    // Size returns the absolute number of bytes the Reader
    // will return during reading. It returns -1 for unlimited
    // data.
    func (r *Reader) Size() int64 { return r.size }
    
    // ActualSize returns the pre-modified size of the object.
    // DecompressedSize - For compressed objects.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 10.9K bytes
    - Viewed (0)
Back to top