Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 289 for immediate (0.69 sec)

  1. cmd/xl-storage.go

    			err = removeAll(filePath)
    		} else {
    			err = Remove(filePath)
    		}
    		return err // Avoid the immediate purge since not needed
    	}
    
    	if err != nil {
    		return err
    	}
    
    	if !immediatePurge && s.diskAlmostFilled() {
    		immediatePurge = true
    	}
    
    	// immediately purge the target
    	if immediatePurge {
    		for _, target := range []string{
    			targetPath,
    			targetPath2,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  2. cmd/erasure-encode_test.go

    		for i, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    			}
    			disk.Delete(context.Background(), "testbucket", "object", DeleteOptions{
    				Recursive: false,
    				Immediate: false,
    			})
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(size), DefaultBitrotAlgorithm, erasure.ShardSize())
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  3. cmd/storage-rest_test.go

    		{"foo", "yourobject", false},
    	}
    
    	for i, testCase := range testCases {
    		err := storage.Delete(t.Context(), testCase.volumeName, testCase.objectName, DeleteOptions{
    			Recursive: false,
    			Immediate: false,
    		})
    		expectErr := (err != nil)
    
    		if expectErr != testCase.expectErr {
    			t.Fatalf("case %v: error: expected: %v, got: %v", i+1, testCase.expectErr, expectErr)
    		}
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

                                    bulkBuilder.add(c.prepareDelete().setIndex(index).setId(uq.getId()));
                                }
                                return bulkBuilder.setRefreshPolicy(RefreshPolicy.IMMEDIATE).execute();
                            });
                            if (response.hasFailures()) {
                                logger.warn(response.buildFailureMessage());
                            }
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:40:57 UTC 2025
    - 16.9K bytes
    - Viewed (1)
  5. src/cmd/asm/internal/asm/parse.go

    			if prefix != '$' {
    				p.errorf("floating-point constant must be an immediate")
    			}
    			a.Type = obj.TYPE_FCONST
    			a.Val = p.floatExpr()
    			// fmt.Printf("FCONST %s\n", obj.Dconv(&emptyProg, 0, a))
    			p.expectOperandEnd()
    			return
    		}
    		if p.have(scanner.String) {
    			if prefix != '$' {
    				p.errorf("string constant must be an immediate")
    				return
    			}
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Wed Nov 12 03:59:40 UTC 2025
    - 37.3K bytes
    - Viewed (0)
  6. src/test/java/jcifs/netbios/SessionServicePacketTest.java

            // Create a mock stream that returns exactly -1 on first read (special case)
            when(mockInputStream.read(any(byte[].class), anyInt(), anyInt())).thenReturn(-1); // Immediate EOF
    
            byte[] buffer = new byte[10];
    
            // The readn method will return 0 when stream returns -1
            // So this should still throw IOException, not return -1
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  7. internal/config/notify/legacy.go

    		},
    		config.KV{
    			Key:   target.AmqpMandatory,
    			Value: config.FormatBool(cfg.Mandatory),
    		},
    		config.KV{
    			Key:   target.AmqpInternal,
    			Value: config.FormatBool(cfg.Immediate),
    		},
    		config.KV{
    			Key:   target.AmqpDurable,
    			Value: config.FormatBool(cfg.Durable),
    		},
    		config.KV{
    			Key:   target.AmqpNoWait,
    			Value: config.FormatBool(cfg.NoWait),
    		},
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Apr 27 04:30:57 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  8. 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.Endpoint().String() {
    				result.After.Drives[i].State = madmin.DriveStateOk
    			}
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  9. cmd/background-newdisks-heal-ops.go

    func (h *healingTracker) delete(ctx context.Context) error {
    	return h.disk.Delete(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename),
    		DeleteOptions{
    			Recursive: false,
    			Immediate: false,
    		},
    	)
    }
    
    func (h *healingTracker) isHealed(bucket string) bool {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    	return slices.Contains(h.HealedBuckets, bucket)
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  10. CONTRIBUTING.md

    There is a somewhat non-obvious filter present on the page that allows you to control which type of messages are displayed.
    The filter is a dropdown box that appears when you click the `Severity ⬇️ ` label in the black header bar to the immediate right of the Gradle version.
    
    If you have a large number of messages of different types, filtering by severity to see only `Error`s can be helpful when processing the report.
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Tue Nov 25 06:57:22 UTC 2025
    - 19K bytes
    - Viewed (0)
Back to top