Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 166 for IMMEDIATE (0.15 sec)

  1. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandler.java

     *     <li>when the contended action finishes, i.e. the lock has been released, all Lock Requesters will get another message
     *         to trigger an immediate retry</li>
     * </ul>
     * <p>
     * If this is the Lock Requester:
     *    the message is interpreted as confirmation and stored. No further messages are sent to the Lock Owner via
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  2. cmd/storage-rest_test.go

    		{"foo", "yourobject", false},
    	}
    
    	for i, testCase := range testCases {
    		err := storage.Delete(context.Background(), 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  3. 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)
  4. docs/distributed/README.md

    _(existing_servers\*m)+(newly_added_servers\*m)_ drives. New object upload requests automatically start using the least used cluster. This expansion strategy works endlessly, so you can perpetually expand your clusters as needed.  When you restart, it is immediate and non-disruptive to the applications. Each group of servers in the command-line is called a pool. There are 2 server pools in this example. New objects are placed in server pools in proportion to the amount of free space in each pool. Within each...
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  5. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  6. 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 (2)
  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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Mar 19 04:37:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  8. 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: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Feb 21 14:34:57 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

          Platform.get().logCloseableLeak(message, callReference.callStackTrace)
    
          references.removeAt(i)
    
          // If this was the last allocation, the connection is eligible for immediate eviction.
          if (references.isEmpty()) {
            connection.idleAtNs = now - keepAliveDurationNs
            return 0
          }
        }
    
        return references.size
      }
    
      /**
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  10. tensorflow/compiler/jit/compilability_check_util.h

      struct UncompilableNodeInfo {
        std::string name;
        // A list representing a stacktrace from the highest level node in
        // increasing call depth to immediate node that fails the
        // compilability checker.
        std::vector<StackFrame> stack_trace;
        std::string uncompilable_reason;
      };
    
      // Aggregates information about what kinds of ops are allowed.
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Sep 06 19:12:29 UTC 2023
    - 14.9K bytes
    - Viewed (0)
Back to top