- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 1,066 for readOp (0.07 sec)
-
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) -
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) -
.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) -
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) -
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) -
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) -
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) -
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) -
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) -
.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)