Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 33 for IMMEDIATE (0.15 sec)

  1. cmd/erasure-healing_test.go

    		}
    
    		for i := 0; i < nfi.Erasure.ParityBlocks; i++ {
    			erasureDisks[i].Delete(context.Background(), bucket, pathJoin(object, xlStorageFormatFile), DeleteOptions{
    				Recursive: false,
    				Immediate: false,
    			})
    		}
    
    		// Try healing now, it should heal the content properly.
    		_, err = objLayer.HealObject(ctx, bucket, object, "", hopts)
    		if err != nil {
    			t.Fatal(err)
    		}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  2. doc/next/5-toolchain.md

    this check, for debugging and experimenting purposes.
    
    <!-- CL 473495 -->
    When building a dynamically linked ELF binary (including PIE binary), the
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 17:18:10 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  3. platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/Codec.kt

        val sharedIdentities: ReadIdentities
    
        override val isolate: ReadIsolate
    
        val classLoader: ClassLoader
    
        fun beanStateReaderFor(beanType: Class<*>): BeanStateReader
    
        /**
         * When in immediate mode, [read] calls are NOT suspending.
         * Useful for bridging with non-suspending serialization protocols such as [java.io.Serializable].
         */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 23:09:56 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  4. src/time/tick_test.go

    		tim.Reset(1)
    		assertTick()
    		Sleep(sched)
    		tim.Reset(10000 * Second)
    		drainAsync()
    		noTick()
    
    		// Test that len sees an immediate tick arrive
    		// for Reset of timer in heap.
    		tim.Reset(1)
    		assertLen()
    		assertTick()
    
    		// Test that len sees an immediate tick arrive
    		// for Reset of timer NOT in heap.
    		tim.Stop()
    		drainAsync()
    		tim.Reset(1)
    		assertLen()
    		assertTick()
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 17:10:37 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  5. cmd/erasure-multipart.go

    			_ = storageDisks[index].Delete(context.TODO(), minioMetaMultipartBucket, curpartPath, DeleteOptions{
    				Recursive: false,
    				Immediate: false,
    			})
    			_ = storageDisks[index].Delete(context.TODO(), minioMetaMultipartBucket, curpartPath+".meta", DeleteOptions{
    				Recursive: false,
    				Immediate: false,
    			})
    
    			return nil
    		}, index)
    	}
    	g.Wait()
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  6. cmd/erasure-healing-common_test.go

    					// appears in outDatedDisks.
    					tamperedIndex = index
    					dErr := erasureDisks[index].Delete(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1"), DeleteOptions{
    						Recursive: false,
    						Immediate: false,
    					})
    					if dErr != nil {
    						t.Fatalf("Failed to delete %s - %v", filepath.Join(object, "part.1"), dErr)
    					}
    					break
    				}
    			case corruptPart:
    				for index, err := range test.errs {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 23K bytes
    - Viewed (0)
  7. cmd/storage-rest-client.go

    }
    
    // DeleteFile - deletes a file.
    func (client *storageRESTClient) Delete(ctx context.Context, volume string, path string, deleteOpts DeleteOptions) error {
    	if !deleteOpts.Immediate {
    		// add deadlines for all non-immediate purges
    		var cancel context.CancelFunc
    		ctx, cancel = context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    		defer cancel()
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 27.4K bytes
    - Viewed (0)
  8. cmd/xl-storage.go

    	} else {
    		err = Rename(filePath, targetPath)
    	}
    
    	var targetPath2 string
    	if immediatePurge && HasSuffix(filePath, SlashSeparator) {
    		// With immediate purge also attempt deleting for `__XL_DIR__` folder/directory objects.
    		targetPath2 = pathutil.Join(s.drivePath, minioMetaTmpDeletedBucket, mustGetUUID())
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
  9. cmd/storage-datatypes.go

    )
    
    //go:generate msgp -file=$GOFILE
    
    // DeleteOptions represents the disk level delete options available for the APIs
    type DeleteOptions struct {
    	BaseOptions
    	Recursive bool `msg:"r"`
    	Immediate bool `msg:"i"`
    	UndoWrite bool `msg:"u"`
    	// OldDataDir of the previous object
    	OldDataDir string `msg:"o,omitempty"` // old data dir used only when to revert a rename()
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  10. cmd/erasure-healing.go

    		if partsMetadata[i].IsRemote() {
    			rmDataDir := partsMetadata[i].DataDir
    			disk.Delete(ctx, bucket, pathJoin(encodeDirObject(object), rmDataDir), DeleteOptions{
    				Immediate: true,
    				Recursive: true,
    			})
    		}
    
    		for i, v := range result.Before.Drives {
    			if v.Endpoint == disk.String() {
    				result.After.Drives[i].State = madmin.DriveStateOk
    			}
    		}
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 33.8K bytes
    - Viewed (0)
Back to top