Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 417 for readlink (0.14 sec)

  1. internal/grid/handlers.go

    }
    
    // Call the remote with the request and return the response.
    // The response should be returned with PutResponse when no error.
    // If no deadline is set, a 1-minute deadline is added.
    func (h *SingleHandler[Req, Resp]) Call(ctx context.Context, c Requester, req Req) (resp Resp, err error) {
    	if c == nil {
    		if h.ignoreNilConn {
    			return resp, nil
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. common-protos/k8s.io/api/apidiscovery/v2beta1/generated.proto

      // singularResource is the singular name of the resource.  This allows clients to handle plural and singular opaquely.
      // For many clients the singular form of the resource will be more understandable to users reading messages and should be used when integrating the name of the resource into a sentence.
      // The command line tool kubectl, for example, allows use of the singular resource name in place of plurals.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  6. 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)
  7. android/guava/src/com/google/common/hash/LongAdder.java

        s.writeLong(sum());
      }
    
      private void readObject(ObjectInputStream s) throws IOException, ClassNotFoundException {
        s.defaultReadObject();
        busy = 0;
        cells = null;
        base = s.readLong();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 20 18:43:59 UTC 2021
    - 5.4K bytes
    - Viewed (0)
  8. guava/src/com/google/common/hash/LongAdder.java

        s.writeLong(sum());
      }
    
      private void readObject(ObjectInputStream s) throws IOException, ClassNotFoundException {
        s.defaultReadObject();
        busy = 0;
        cells = null;
        base = s.readLong();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 20 18:43:59 UTC 2021
    - 5.4K bytes
    - Viewed (0)
  9. common-protos/k8s.io/api/batch/v1beta1/generated.proto

      // reason UnknownTimeZone.
      // More information can be found in https://kubernetes.io/docs/concepts/workloads/controllers/cron-jobs/#time-zones
      // +optional
      optional string timeZone = 8;
    
      // Optional deadline in seconds for starting the job if it misses scheduled
      // time for any reason.  Missed jobs executions will be counted as failed ones.
      // +optional
      optional int64 startingDeadlineSeconds = 2;
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  10. 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)
Back to top