Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 988 for readOp (0.08 sec)

  1. src/main/java/org/codelibs/fess/app/web/api/admin/elevateword/ApiAdminElevatewordAction.java

            validateApi(body, messages -> {});
            CommonPoolUtil.execute(() -> {
                try (Reader reader = new BufferedReader(new InputStreamReader(body.elevateWordFile.getInputStream(), getCsvEncoding()))) {
                    elevateWordService.importCsv(reader);
                    suggestHelper.storeAllElevateWords(false);
                } catch (final Exception e) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. .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)
  6. 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)
  7. 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)
  8. docs/en/docs/tutorial/request-files.md

    * `write(data)`: Writes `data` (`str` or `bytes`) to the file.
    * `read(size)`: Reads `size` (`int`) bytes/characters of the file.
    * `seek(offset)`: Goes to the byte position `offset` (`int`) in the file.
        * E.g., `await myfile.seek(0)` would go to the start of the file.
        * This is especially useful if you run `await myfile.read()` once and then need to read the contents again.
    * `close()`: Closes the file.
    
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  9. src/archive/zip/writer_test.go

    			t.Fatalf("Writer.closed: got %v, want %v", w.closed, test.ok)
    		}
    
    		// skip read test in failure cases
    		if !test.ok {
    			continue
    		}
    
    		// read it back
    		r, err := NewReader(bytes.NewReader(buf.Bytes()), int64(buf.Len()))
    		if err != nil {
    			t.Fatal(err)
    		}
    		if r.Comment != test.comment {
    			t.Fatalf("Reader.Comment: got %v, want %v", r.Comment, test.comment)
    		}
    	}
    }
    
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  10. api/go1.17.txt

    pkg archive/zip, method (*File) OpenRaw() (io.Reader, error)
    pkg archive/zip, method (*Writer) Copy(*File) error
    pkg archive/zip, method (*Writer) CreateRaw(*FileHeader) (io.Writer, error)
    pkg compress/lzw, method (*Reader) Close() error
    pkg compress/lzw, method (*Reader) Read([]uint8) (int, error)
    pkg compress/lzw, method (*Reader) Reset(io.Reader, Order, int)
    pkg compress/lzw, method (*Writer) Close() error
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Fri Feb 17 20:31:46 UTC 2023
    - 18K bytes
    - Viewed (0)
Back to top