Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 1,066 for readOp (0.08 sec)

  1. cmd/local-locker.go

    		return true, nil
    	}
    	if isWriteLock(lri) {
    		// A write-lock is held, cannot release a read lock
    		return false, fmt.Errorf("RUnlock attempted on a write locked entity: %s", resource)
    	}
    	l.removeEntry(resource, args, &lri)
    	return reply, nil
    }
    
    type lockStats struct {
    	Total  int
    	Writes int
    	Reads  int
    }
    
    func (l *localLocker) stats() lockStats {
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  2. cmd/xl-storage.go

    			return nil, time.Time{}, err
    		}
    		return nil, time.Time{}, errFileNotFound
    	}
    
    	return buf, dmTime, nil
    }
    
    // ReadXL reads from path/xl.meta, does not interpret the data it read. This
    // is a raw call equivalent of ReadVersion().
    func (s *xlStorage) ReadXL(ctx context.Context, volume, path string, readData bool) (RawFileInfo, error) {
    	volumeDir, err := s.getVolDir(volume)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (2)
  3. .github/workflows/sigbuild-docker-presubmit.yml

          - '!tensorflow/tools/tf_sig_build_dockerfiles/README.md'
    
    permissions:
      contents: read
    
    jobs:
      docker:
        if: github.repository == 'tensorflow/tensorflow' # Don't do this in forks
        runs-on: ubuntu-latest
        strategy:
          matrix:
            python-version: [python3.9, python3.10, python3.11, python3.12]
        permissions:
          contents: read
          pull-requests: write
        steps:
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Tue Oct 01 08:13:39 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. internal/deadlineconn/deadlineconn.go

    			c.Conn.SetWriteDeadline(now.Add(c.writeDeadline + updateInterval))
    			c.writeSetAt = now
    		}
    	}
    }
    
    // Read - reads data from the connection using wrapped buffered reader.
    func (c *DeadlineConn) Read(b []byte) (n int, err error) {
    	c.setReadDeadline()
    	n, err = c.Conn.Read(b)
    	return n, err
    }
    
    // Write - writes data to the connection.
    func (c *DeadlineConn) Write(b []byte) (n int, err error) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 26 17:40:11 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/service/CrawlingInfoService.java

                    cf.not(subCf -> subCf.setId_InScope(idList));
                }
            }));
        }
    
        public void importCsv(final Reader reader) {
            @SuppressWarnings("resource")
            final CsvReader csvReader = new CsvReader(reader, new CsvConfig());
            final DateFormat formatter = new SimpleDateFormat(CoreLibConstants.DATE_FORMAT_ISO_8601_EXTEND);
            try {
                List<String> list;
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  6. internal/s3select/csv/args.go

    	CommentCharacter           string `xml:"Comments"`
    	AllowQuotedRecordDelimiter bool   `xml:"AllowQuotedRecordDelimiter"`
    	unmarshaled                bool
    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 20 18:31:45 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  7. cmd/sftp-server-driver.go

    }
    
    func (f *sftpDriver) Fileread(r *sftp.Request) (ra io.ReaderAt, err error) {
    	// This is not timing the actual read operation, but the time it takes to prepare the reader.
    	stopFn := globalSftpMetrics.log(r, f.AccessKey())
    	defer stopFn(0, err)
    
    	flags := r.Pflags()
    	if !flags.Read {
    		// sanity check
    		return nil, os.ErrInvalid
    	}
    
    	bucket, object := path2BucketObject(r.Filepath)
    	if bucket == "" {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  8. internal/bucket/object/lock/lock.go

    // Maximum 4KiB size per object lock config.
    const maxObjectLockConfigSize = 1 << 12
    
    // ParseObjectLockConfig parses ObjectLockConfig from xml
    func ParseObjectLockConfig(reader io.Reader) (*Config, error) {
    	config := Config{}
    	if err := xml.NewDecoder(io.LimitReader(reader, maxObjectLockConfigSize)).Decode(&config); err != nil {
    		return nil, err
    	}
    
    	return &config, nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Jun 29 01:20:27 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  9. common-protos/k8s.io/api/apps/v1beta2/generated.proto

      optional DaemonSetUpdateStrategy updateStrategy = 3;
    
      // The minimum number of seconds for which a newly created DaemonSet pod should
      // be ready without any of its container crashing, for it to be considered
      // available. Defaults to 0 (pod will be considered available as soon as it
      // is ready).
      // +optional
      optional int32 minReadySeconds = 4;
    
      // The number of old history to retain to allow rollback.
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  10. .github/workflows/sigbuild-docker.yml

      push:
        paths:
          - '.github/workflows/sigbuild-docker.yml'
          - 'tensorflow/tools/tf_sig_build_dockerfiles/**'
          - '!tensorflow/tools/tf_sig_build_dockerfiles/README.md'
        branches:
          - master
    
    permissions:
      contents: read
    
    jobs:
      docker:
        if: github.repository == 'tensorflow/tensorflow' # Don't do this in forks
        runs-on: ubuntu-latest
        strategy:
          matrix:
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Tue Oct 01 08:13:39 UTC 2024
    - 4.3K bytes
    - Viewed (0)
Back to top