Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for writeMetadata (0.13 sec)

  1. cmd/naughty-disk_test.go

    		}
    		return errs
    	}
    	return d.disk.DeleteVersions(ctx, volume, versions, opts)
    }
    
    func (d *naughtyDisk) WriteMetadata(ctx context.Context, origvolume, volume, path string, fi FileInfo) (err error) {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.WriteMetadata(ctx, origvolume, volume, path, fi)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt

          }
    
        val fileOperator = FileOperator(file!!.channel)
        fileOperator.write(0, header, FILE_HEADER_SIZE)
      }
    
      @Throws(IOException::class)
      private fun writeMetadata(upstreamSize: Long) {
        val metadataBuffer = Buffer()
        metadataBuffer.write(metadata)
    
        val fileOperator = FileOperator(file!!.channel)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  3. cmd/storage-interface.go

    	DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error
    	DeleteBulk(ctx context.Context, volume string, paths ...string) error
    	WriteMetadata(ctx context.Context, origvolume, volume, path string, fi FileInfo) error
    	UpdateMetadata(ctx context.Context, volume, path string, fi FileInfo, opts UpdateMetadataOpts) error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  4. cmd/xl-storage-disk-id-check.go

    }
    
    func (p *xlStorageDiskIDCheck) WriteMetadata(ctx context.Context, origvolume, volume, path string, fi FileInfo) (err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricWriteMetadata, volume, path)
    	if err != nil {
    		return err
    	}
    	defer done(0, &err)
    
    	w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    	return w.Run(func() error { return p.storage.WriteMetadata(ctx, origvolume, volume, path, fi) })
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  5. cmd/storage-rest-client.go

    	defer xhttp.DrainBody(respBody)
    	if err != nil {
    		return err
    	}
    	_, err = waitForHTTPResponse(respBody)
    	return toStorageErr(err)
    }
    
    func (client *storageRESTClient) WriteMetadata(ctx context.Context, origvolume, volume, path string, fi FileInfo) error {
    	ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    	defer cancel()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  6. cmd/erasure-metadata.go

    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    			// Pick one FileInfo for a disk at index.
    			fi := files[index]
    			fi.Erasure.Index = index + 1
    			if fi.IsValid() {
    				return disks[index].WriteMetadata(ctx, origbucket, bucket, prefix, fi)
    			}
    			return errFileCorrupt
    		}, index)
    	}
    
    	// Wait for all the routines.
    	mErrs := g.Wait()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  7. cmd/erasure-healing_test.go

    	// gone down when an object was replaced by a new object.
    	fileInfoOutDated := fileInfoPreHeal
    	fileInfoOutDated.ModTime = time.Now()
    	err = disk.WriteMetadata(context.Background(), "", bucket, object, fileInfoOutDated)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	_, err = er.HealObject(ctx, bucket, object, "", madmin.HealOpts{ScanMode: madmin.HealDeepScan})
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  8. cmd/xl-storage.go

    		return err
    	}
    	defer metaDataPoolPut(wbuf)
    
    	return s.writeAllMeta(ctx, volume, pathJoin(path, xlStorageFormatFile), wbuf, !opts.NoPersistence)
    }
    
    // WriteMetadata - writes FileInfo metadata for path at `xl.meta`
    func (s *xlStorage) WriteMetadata(ctx context.Context, origvolume, volume, path string, fi FileInfo) (err error) {
    	if fi.Fresh {
    		if origvolume != "" {
    			origvolumeDir, err := s.getVolDir(origvolume)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  9. cmd/storage-rest-server.go

    	if !s.checkID(p.DiskID) {
    		return grid.NewNPErr(errDiskNotFound)
    	}
    
    	volume := p.Volume
    	filePath := p.FilePath
    	origvolume := p.OrigVolume
    
    	err := s.getStorage().WriteMetadata(context.Background(), origvolume, volume, filePath, p.FI)
    	return np, grid.NewRemoteErr(err)
    }
    
    // UpdateMetadataHandler update new updated metadata.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  10. cmd/xl-storage_test.go

    				DataBlocks:   4,
    				ParityBlocks: 4,
    				BlockSize:    blockSizeV2,
    				Index:        1,
    				Distribution: []int{0, 1, 2, 3, 4, 5, 6, 7},
    				Checksums:    nil,
    			},
    		}
    		if err := xl.WriteMetadata(ctx, "", volume, object, fi); err != nil {
    			t.Fatalf("Unable to create object, %s", err)
    		}
    	}
    	var deleted [len(versions)]bool
    	checkVerExist := func(t testing.TB) {
    		t.Helper()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
Back to top