Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 348 for readArg (0.25 sec)

  1. internal/ioutil/ioutil.go

    	return s.Reader.Read(p)
    }
    
    // NewSkipReader - creates a SkipReader
    func NewSkipReader(r io.Reader, n int64) io.Reader {
    	return &SkipReader{r, n}
    }
    
    var copyBufPool = sync.Pool{
    	New: func() interface{} {
    		b := make([]byte, 32*1024)
    		return &b
    	},
    }
    
    // Copy is exactly like io.Copy but with reusable buffers.
    func Copy(dst io.Writer, src io.Reader) (written int64, err error) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  2. src/os/readfrom_linux_test.go

    	})
    }
    
    func testSpliceFile(t *testing.T, proto string, size, limit int64) {
    	dst, src, data, hook, cleanup := newSpliceFileTest(t, proto, size)
    	defer cleanup()
    
    	// If we have a limit, wrap the reader.
    	var (
    		r  io.Reader
    		lr *io.LimitedReader
    	)
    	if limit >= 0 {
    		lr = &io.LimitedReader{N: limit, R: src}
    		r = lr
    		if limit < int64(len(data)) {
    			data = data[:limit]
    		}
    	} else {
    		r = src
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 21:49:26 UTC 2024
    - 20.3K bytes
    - Viewed (0)
  3. src/net/http/fs.go

    		list, err = d.ReadDir(-1)
    		dirs = list
    	} else {
    		var list fileInfoDirs
    		list, err = f.Readdir(-1)
    		dirs = list
    	}
    
    	if err != nil {
    		logf(r, "http: error reading directory: %v", err)
    		Error(w, "Error reading directory", StatusInternalServerError)
    		return
    	}
    	sort.Slice(dirs, func(i, j int) bool { return dirs.name(i) < dirs.name(j) })
    
    	w.Header().Set("Content-Type", "text/html; charset=utf-8")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 09 17:06:47 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  4. src/os/file.go

    	}
    	if log := testlog.Logger(); log != nil {
    		wd, err := Getwd()
    		if err == nil {
    			log.Chdir(wd)
    		}
    	}
    	return nil
    }
    
    // Open opens the named file for reading. If successful, methods on
    // the returned file can be used for reading; the associated file
    // descriptor has mode O_RDONLY.
    // If there is an error, it will be of type *PathError.
    func Open(name string) (*File, error) {
    	return OpenFile(name, O_RDONLY, 0)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 23:07:37 UTC 2024
    - 25.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/io/BaseEncoding.java

      }
    
      /**
       * Returns an {@code InputStream} that decodes base-encoded input from the specified {@code
       * Reader}. The returned stream throws a {@link DecodingException} upon decoding-specific errors.
       */
      @J2ktIncompatible
      @GwtIncompatible // Reader,InputStream
      public abstract InputStream decodingStream(Reader reader);
    
      /**
       * Returns a {@code ByteSource} that reads base-encoded bytes from the specified {@code
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Mar 15 16:33:32 UTC 2024
    - 41.7K bytes
    - Viewed (0)
  6. src/net/net.go

    	return err == context.DeadlineExceeded
    }
    
    // DNSConfigError represents an error reading the machine's DNS configuration.
    // (No longer used; kept for compatibility.)
    type DNSConfigError struct {
    	Err error
    }
    
    func (e *DNSConfigError) Unwrap() error   { return e.Err }
    func (e *DNSConfigError) Error() string   { return "error reading DNS config: " + e.Err.Error() }
    func (e *DNSConfigError) Timeout() bool   { return false }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/web/admin/dict/kuromoji/AdminDictKuromojiAction.java

                }, this::asEditHtml);
            }
            if (form.segmentation != null && form.reading != null && form.segmentation.split(" ").length != form.reading.split(" ").length) {
                throwValidationError(messages -> {
                    messages.addErrorsInvalidKuromojiSegmentation("segmentation", form.segmentation, form.reading);
                }, this::asEditHtml);
            }
        }
    
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 18.8K bytes
    - Viewed (0)
  8. cmd/xl-storage-disk-id-check.go

    func (p *xlStorageDiskIDCheck) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) (err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricCreateFile, volume, path)
    	if err != nil {
    		return err
    	}
    	defer done(size, &err)
    
    	return p.storage.CreateFile(ctx, origvolume, volume, path, size, io.NopCloser(reader))
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  9. testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/configurationcache/ConfigurationCacheProblemsFixture.groovy

            new JsonSlurper().parseText(jsonText) as Map<String, Object>
        }
    
        private static String linesBetween(File file, String beginLine, String endLine) {
            return file.withReader('utf-8') { reader ->
                reader.lines().iterator()
                    .dropWhile { it != beginLine }
                    .drop(1)
                    .takeWhile { it != endLine }
                    .collect()
                    .join('\n')
            }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 22.8K bytes
    - Viewed (0)
  10. guava/src/com/google/common/io/BaseEncoding.java

      }
    
      /**
       * Returns an {@code InputStream} that decodes base-encoded input from the specified {@code
       * Reader}. The returned stream throws a {@link DecodingException} upon decoding-specific errors.
       */
      @J2ktIncompatible
      @GwtIncompatible // Reader,InputStream
      public abstract InputStream decodingStream(Reader reader);
    
      /**
       * Returns a {@code ByteSource} that reads base-encoded bytes from the specified {@code
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Mar 15 16:33:32 UTC 2024
    - 41.7K bytes
    - Viewed (0)
Back to top