Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ReadRange (0.23 sec)

  1. src/internal/race/race.go

    }
    
    func Enable() {
    	runtime.RaceEnable()
    }
    
    func Read(addr unsafe.Pointer) {
    	runtime.RaceRead(addr)
    }
    
    func Write(addr unsafe.Pointer) {
    	runtime.RaceWrite(addr)
    }
    
    func ReadRange(addr unsafe.Pointer, len int) {
    	runtime.RaceReadRange(addr, len)
    }
    
    func WriteRange(addr unsafe.Pointer, len int) {
    	runtime.RaceWriteRange(addr, len)
    }
    
    func Errors() int {
    	return runtime.RaceErrors()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:27 UTC 2023
    - 881 bytes
    - Viewed (0)
  2. src/internal/race/norace.go

    }
    
    func ReleaseMerge(addr unsafe.Pointer) {
    }
    
    func Disable() {
    }
    
    func Enable() {
    }
    
    func Read(addr unsafe.Pointer) {
    }
    
    func Write(addr unsafe.Pointer) {
    }
    
    func ReadRange(addr unsafe.Pointer, len int) {
    }
    
    func WriteRange(addr unsafe.Pointer, len int) {
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:27 UTC 2023
    - 603 bytes
    - Viewed (0)
  3. src/syscall/syscall_unix.go

    	}
    	if faketime && (fd == 1 || fd == 2) {
    		n = faketimeWrite(fd, p)
    		if n < 0 {
    			n, err = 0, errnoErr(Errno(-n))
    		}
    	} else {
    		n, err = write(fd, p)
    	}
    	if race.Enabled && n > 0 {
    		race.ReadRange(unsafe.Pointer(&p[0]), n)
    	}
    	if msan.Enabled && n > 0 {
    		msan.Read(unsafe.Pointer(&p[0]), uintptr(n))
    	}
    	if asan.Enabled && n > 0 {
    		asan.Read(unsafe.Pointer(&p[0]), uintptr(n))
    	}
    	return
    }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 19 16:19:26 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  4. tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.cc

      std::string bucket, object;
      ParseGCSPath(path, false, &bucket, &object, status);
      if (TF_GetCode(status) != TF_OK) return -1;
      auto stream = gcs_file->gcs_client.ReadObject(
          bucket, object, gcs::ReadRange(offset, offset + buffer_size));
      TF_SetStatusFromGCSStatus(stream.status(), status);
      if ((TF_GetCode(status) != TF_OK) &&
          (TF_GetCode(status) != TF_OUT_OF_RANGE)) {
        return -1;
      }
      int64_t read;
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Aug 23 06:55:53 UTC 2023
    - 46.9K bytes
    - Viewed (0)
  5. src/syscall/syscall_windows.go

    	if race.Enabled {
    		race.ReleaseMerge(unsafe.Pointer(&ioSync))
    	}
    	err := writeFile(fd, p, done, overlapped)
    	if race.Enabled && *done > 0 {
    		race.ReadRange(unsafe.Pointer(&p[0]), int(*done))
    	}
    	if msan.Enabled && *done > 0 {
    		msan.Read(unsafe.Pointer(&p[0]), uintptr(*done))
    	}
    	if asan.Enabled && *done > 0 {
    		asan.Read(unsafe.Pointer(&p[0]), uintptr(*done))
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 21 11:49:46 UTC 2024
    - 52.7K bytes
    - Viewed (0)
Back to top