Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 92 for Immediate (0.07 sec)

  1. internal/bucket/lifecycle/transition.go

    	if !obj.IsLatest || t.IsNull() {
    		return time.Time{}, false
    	}
    
    	if !t.IsDateNull() {
    		return t.Date.Time, true
    	}
    
    	// Days == 0 indicates immediate tiering, i.e object is eligible for tiering since its creation.
    	if t.Days == 0 {
    		return obj.ModTime, true
    	}
    	return ExpectedExpiryTime(obj.ModTime, int(t.Days)), true
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 10 17:07:49 UTC 2022
    - 5.1K bytes
    - Viewed (0)
  2. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  3. tensorflow/c/eager/abstract_operation.h

    #include "tensorflow/core/platform/status.h"
    
    namespace tensorflow {
    
    // Abstract interface to an operation.
    // This interface allows building and executing an operation in either
    // tracing or immediate execution mode.
    class AbstractOperation {
     protected:
      enum AbstractOperationKind {
        kGraph,
        kMlir,
        kEager,
        kTfrt,
        kTape,
        kOpHandler
      };
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  4. cmd/bitrot-streaming.go

    	// sequent of operations:
    	// 1) pipe.Write()
    	// 2) pipe.Close()
    	// Now pipe.Close() can return before the data is read on the other end of the pipe and written to the disk
    	// Hence an immediate Read() on the file can return incorrect data.
    	if b.canClose != nil {
    		b.canClose.Wait()
    	}
    
    	// Recycle the buffer.
    	if b.byteBuf != nil {
    		globalBytePoolCap.Load().Put(b.byteBuf)
    		b.byteBuf = nil
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 12:20:54 UTC 2024
    - 6K bytes
    - Viewed (0)
  5. CODE_OF_CONDUCT.md

    If the behavior is threatening or harassing, or for other reasons requires immediate escalation, please see below.
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Feb 05 18:43:16 UTC 2021
    - 5.2K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/WebSocket.kt

     *    be transmitted until the web socket is open.
     *
     *  * **Open:** the web socket has been accepted by the remote peer and is fully operational.
     *    Messages in either direction are enqueued for immediate transmission.
     *
     *  * **Closing:** one of the peers on the web socket has initiated a graceful shutdown. The web
     *    socket will continue to transmit already-enqueued messages but will refuse to enqueue new
     *    ones.
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  7. tensorflow/c/eager/gradients.h

      tensorflow::DataType GetDType() const;
    
      AbstractTensorHandle* ZerosLike() const;
    
      AbstractTensorHandle* GetHandle() const;
    
     private:
      AbstractTensorHandle* handle_;
    };
    
    // A tracing/immediate-execution agnostic tape.
    //
    // Gradient functions defined for this tape must support handling null incoming
    // gradients.
    class Tape : protected eager::GradientTape<AbstractTensorHandle,
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  8. cmd/xl-storage_test.go

    			Recursive: false,
    			Immediate: false,
    		}); err != errFileAccessDenied {
    			t.Errorf("expected: %s, got: %s", errFileAccessDenied, err)
    		}
    	}
    
    	// TestXLStorage for delete on an removed disk.
    	// should fail with disk not found.
    	err = xlStorageDeletedStorage.Delete(context.Background(), "del-vol", "my-file", DeleteOptions{
    		Recursive: false,
    		Immediate: false,
    	})
    	if err != errDiskNotFound {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

        if (insertAt == -1) insertAt = futureTasks.size
        futureTasks.add(insertAt, task)
    
        // Impact the coordinator if we inserted at the front.
        return insertAt == 0
      }
    
      /**
       * Schedules immediate execution of [Task.tryCancel] on all currently-enqueued tasks. These calls
       * will not be made until any currently-executing task has completed. Tasks that return true will
       * be removed from the execution schedule.
       */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  10. 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: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
Back to top