Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 10 for readLong (0.05 seconds)

  1. src/archive/zip/reader_test.go

    	}
    	r, err := NewReader(bytes.NewReader(data), int64(len(data)))
    	if err != ErrInsecurePath {
    		t.Fatalf("Error reading the archive: %v", err)
    	}
    	_, err = r.Open("test.txt")
    	if err != nil {
    		t.Errorf("Error reading file: %v", err)
    	}
    	if len(r.File) != 1 {
    		t.Fatalf("No entries in the file list")
    	}
    	if r.File[0].Name != "../test.txt" {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Oct 17 20:10:27 GMT 2025
    - 56.5K bytes
    - Click Count (0)
  2. cmd/xl-storage.go

    // for io.EOF.
    //
    // If an EOF happens after reading some but not all the bytes,
    // ReadFile returns ErrUnexpectedEOF.
    //
    // If the BitrotVerifier is not nil or not verified ReadFile
    // tries to verify whether the disk has bitrot.
    //
    // Additionally ReadFile also starts reading from an offset. ReadFile
    // semantics are same as io.ReadFull.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  3. src/bufio/bufio_test.go

    		// Put it back and read it again.
    		if err = r.UnreadRune(); err != nil {
    			t.Fatal("unexpected error on UnreadRune:", err)
    		}
    		r2, _, err := r.ReadRune()
    		if err != nil {
    			t.Fatal("unexpected error reading after unreading:", err)
    		}
    		if r1 != r2 {
    			t.Fatalf("incorrect rune after unread: got %c, want %c", r1, r2)
    		}
    	}
    	if got != want {
    		t.Errorf("got %q, want %q", got, want)
    	}
    }
    
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Feb 07 01:08:54 GMT 2025
    - 51.6K bytes
    - Click Count (0)
  4. cmd/test-utils_test.go

    	}
    
    	// httptest Recorder to capture all the response by the http handler.
    	rec := httptest.NewRecorder()
    	// reading the body to preserve it so that it can be used again for second attempt of sending unsigned HTTP request.
    	// If the body is read in the handler the same request cannot be made use of.
    	buf, err := io.ReadAll(anonReq.Body)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (0)
  5. cmd/erasure-object.go

    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, "GetObjectInfo", object, &er)
    	}
    
    	if !opts.NoLock {
    		// Lock the object before reading.
    		lk := er.NewNSLock(bucket, object)
    		lkctx, err := lk.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return ObjectInfo{}, err
    		}
    		ctx = lkctx.Context()
    		defer lk.RUnlock(lkctx)
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  6. cmd/xl-storage_test.go

    		// Buffer size greater than object size. - 6
    		{
    			volume, "myobject", 0, 16,
    			[]byte("hello, world"),
    			io.ErrUnexpectedEOF,
    		},
    		// Reading from an offset success. - 7
    		{
    			volume, "myobject", 7, 5,
    			[]byte("world"), nil,
    		},
    		// Reading from an object but buffer size greater. - 8
    		{
    			volume, "myobject",
    			7, 8,
    			[]byte("world"),
    			io.ErrUnexpectedEOF,
    		},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 66K bytes
    - Click Count (0)
  7. cmd/erasure-server-pool.go

    			return &GetObjectReader{
    				ObjInfo: objInfo,
    			}, toObjectErr(errMethodNotAllowed, bucket, object)
    		}
    		return nil, err
    	}
    
    	// check preconditions before reading the stream.
    	if checkPrecondFn != nil && checkPrecondFn(objInfo) {
    		return nil, PreConditionFailed{}
    	}
    
    	opts.NoLock = true
    	gr, err = z.serverPools[zIdx].GetObjectNInfo(ctx, bucket, object, rs, h, opts)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  8. src/bytes/bytes_test.go

    		result := sliceOfString(slices.Collect(Lines([]byte(s.a))))
    		if !slices.Equal(result, s.b) {
    			t.Errorf(`slices.Collect(Lines(%q)) = %q; want %q`, s.a, result, s.b)
    		}
    	}
    }
    
    // For ease of reading, the test cases use strings that are converted to byte
    // slices before invoking the functions.
    
    var abcd = "abcd"
    var faces = "☺☻☹"
    var commas = "1,2,3,4"
    var dots = "1....2....3....4"
    
    type BinOpTest struct {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Dec 23 23:54:14 GMT 2025
    - 62.9K bytes
    - Click Count (0)
  9. cmd/iam.go

    		}
    	}
    
    	select {
    	case <-sys.configLoaded:
    	default:
    		close(sys.configLoaded)
    	}
    	return nil
    }
    
    // Init - initializes config system by reading entries from config/iam
    func (sys *IAMSys) Init(ctx context.Context, objAPI ObjectLayer, etcdClient *etcd.Client, iamRefreshInterval time.Duration) {
    	bootstrapTraceMsg("IAM initialization started")
    	globalServerConfigMu.RLock()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 76.5K bytes
    - Click Count (0)
  10. cmd/iam-store.go

    	return nil
    }
    
    // IAMStorageAPI defines an interface for the IAM persistence layer
    type IAMStorageAPI interface {
    	// The role of the read-write lock is to prevent go routines from
    	// concurrently reading and writing the IAM storage. The (r)lock()
    	// functions return the iamCache. The cache can be safely written to
    	// only when returned by `lock()`.
    	lock() *iamCache
    	unlock()
    	rlock() *iamCache
    	runlock()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 87.1K bytes
    - Click Count (0)
Back to Top