Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 208 of 208 for newReader (0.08 sec)

  1. cmd/xl-storage.go

    		// fdatasync() at the end instead of opening the file with O_DSYNC.
    		//
    		// This is an optimization mainly to ensure faster I/O.
    		if len(b) > xioutil.DirectioAlignSize {
    			r := bytes.NewReader(b)
    			return s.writeAllDirect(ctx, filePath, r.Size(), r, flags, skipParent, true)
    		}
    		w, err = s.openFileSync(filePath, flags, skipParent)
    	} else {
    		w, err = s.openFile(filePath, flags, skipParent)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  2. api/go1.txt

    pkg archive/tar, const TypeRegA ideal-char
    pkg archive/tar, const TypeSymlink ideal-char
    pkg archive/tar, const TypeXGlobalHeader ideal-char
    pkg archive/tar, const TypeXHeader ideal-char
    pkg archive/tar, func NewReader(io.Reader) *Reader
    pkg archive/tar, func NewWriter(io.Writer) *Writer
    pkg archive/tar, method (*Reader) Next() (*Header, error)
    pkg archive/tar, method (*Reader) Read([]uint8) (int, error)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
  3. internal/s3select/json/preader_test.go

    		t.Fatal(err)
    	}
    	for _, file := range files {
    		t.Run(file.Name(), func(t *testing.T) {
    			f, err := os.Open(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				t.Fatal(err)
    			}
    			r := NewPReader(f, &ReaderArgs{})
    			var record sql.Record
    			for {
    				record, err = r.Read(record)
    				if err != nil {
    					break
    				}
    			}
    			r.Close()
    			if err != io.EOF {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  4. samples/guide/src/main/java/okhttp3/recipes/CurrentDateHeader.java

        @Override public Response intercept(Chain chain) throws IOException {
          Request request = chain.request();
          Headers newHeaders = request.headers()
              .newBuilder()
              .add("Date", new Date())
              .build();
          Request newRequest = request.newBuilder()
              .headers(newHeaders)
              .build();
          return chain.proceed(newRequest);
        }
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Oct 31 15:32:50 UTC 2018
    - 1.8K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/LinkedHashMultimap.java

          this.nextInValueBucket = nextInValueBucket;
        }
    
        @SuppressWarnings("nullness") // see the comment on the class fields, especially about newHeader
        static <K extends @Nullable Object, V extends @Nullable Object> ValueEntry<K, V> newHeader() {
          return new ValueEntry<>(null, null, 0, null);
        }
    
        boolean matchesValue(@CheckForNull Object v, int smearedVHash) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 21:19:52 UTC 2024
    - 24.3K bytes
    - Viewed (0)
  6. internal/s3select/json/preader.go

    				r.bufferPool.Put(in.input)
    				in.input = nil
    				in.err = d.Err()
    				in.dst <- all
    			}
    		}()
    	}
    }
    
    // NewPReader - creates new parallel JSON reader using readCloser.
    // Should only be used for LINES types.
    func NewPReader(readCloser io.ReadCloser, args *ReaderArgs) *PReader {
    	r := &PReader{
    		args:       args,
    		buf:        bufio.NewReaderSize(readCloser, jsonSplitSize*2),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

      }
    
      public void testDecoupledLoader() {
        FinalizableReferenceQueue.DecoupledLoader decoupledLoader =
            new FinalizableReferenceQueue.DecoupledLoader() {
              @Override
              URLClassLoader newLoader(URL base) {
                return new DecoupledClassLoader(new URL[] {base});
              }
            };
    
        Class<?> finalizerCopy = decoupledLoader.loadFinalizer();
    
        assertNotNull(finalizerCopy);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/base/FinalizableReferenceQueue.java

           * Finalizer.class -> CustomClassLoader -> CustomClassLoader.class -> This class loader
           *
           * System class loader will (and must) be the parent.
           */
          try (URLClassLoader finalizerLoader = newLoader(getBaseUrl())) {
            return finalizerLoader.loadClass(FINALIZER_CLASS_NAME);
          } catch (Exception e) {
            logger.log(Level.WARNING, LOADING_ERROR, e);
            return null;
          }
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Jul 11 20:51:36 UTC 2024
    - 13.1K bytes
    - Viewed (0)
Back to top