- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 172 for kevent (0.2 sec)
-
pkg/scheduler/internal/queue/events.go
) const ( // PodAdd is the event when a new pod is added to API server. PodAdd = "PodAdd" // ScheduleAttemptFailure is the event when a schedule attempt fails. ScheduleAttemptFailure = "ScheduleAttemptFailure" // BackoffComplete is the event when a pod finishes backoff. BackoffComplete = "BackoffComplete" // ForceActivate is the event when a pod is moved from unschedulablePods/backoffQ
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 6.4K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor_internal.h
int plugin_id_value_; stream_executor::ExecutorCache executor_cache_; }; class CEvent : public Event { public: CEvent(SP_Device* device, SP_StreamExecutor* stream_executor) : device_(device), stream_executor_(stream_executor), event_handle_(nullptr) {} ~CEvent() override { Destroy(); } Event::Status PollForStatus() override { SE_EventStatus event_status =
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jun 14 07:39:19 UTC 2024 - 8K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor.cc
// DeviceDescription. return builder.Build(); } absl::StatusOr<std::unique_ptr<Event>> CreateEvent() override { auto c_event = std::make_unique<CEvent>(&device_, stream_executor_); TF_RETURN_IF_ERROR(c_event->Create()); return std::move(c_event); } absl::StatusOr<std::unique_ptr<Stream>> CreateStream( std::optional<std::variant<StreamPriority, int>> priority =
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jun 14 07:39:19 UTC 2024 - 27.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
defer f.Unlock() f.stopped = false f.result = make(chan Event) } func (f *FakeWatcher) ResultChan() <-chan Event { return f.result } // Add sends an add event. func (f *FakeWatcher) Add(obj runtime.Object) { f.result <- Event{Added, obj} } // Modify sends a modify event. func (f *FakeWatcher) Modify(obj runtime.Object) { f.result <- Event{Modified, obj} } // Delete sends a delete event.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
maven-core/src/main/java/org/apache/maven/internal/aether/LoggingRepositoryListener.java
public void artifactInstalling(RepositoryEvent event) { logger.info("Installing {} to {}", event.getArtifact().getFile(), event.getFile()); } @Override public void metadataInstalling(RepositoryEvent event) { logger.debug("Installing {} to {}", event.getMetadata(), event.getFile()); } @Override public void metadataResolved(RepositoryEvent event) { Exception e = event.getException();
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Jun 06 19:10:58 UTC 2024 - 3.4K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
ongoing.remove(new TransferResourceIdentifier(event.getResource())); put(event, ongoing.isEmpty()); } private static class Exchange { private final TransferEvent event; private Exchange(TransferEvent event) { this.event = event; } public void process(Consumer<TransferEvent> consumer) { consumer.accept(event); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 20:50:56 UTC 2024 - 8.4K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/transfer/AbstractMavenTransferListener.java
} @Override public void transferSucceeded(TransferEvent event) { String action = (event.getRequestType() == TransferEvent.RequestType.PUT ? "Uploaded" : "Downloaded"); String direction = event.getRequestType() == TransferEvent.RequestType.PUT ? "to" : "from"; TransferResource resource = event.getResource(); long contentLength = event.getTransferredBytes(); FileSizeFormat format = new FileSizeFormat();
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 21:48:41 UTC 2024 - 4.1K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListener.java
} @Override public void transferInitiated(TransferEvent event) { overridePreviousTransfer(event); super.transferInitiated(event); } @Override public void transferCorrupted(TransferEvent event) throws TransferCancelledException { overridePreviousTransfer(event); super.transferCorrupted(event); } @Override
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 21:48:41 UTC 2024 - 5.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval_test.go
t.Fatal("expected non-empty interval buffer") } event, err := wci.Next() if err != nil { t.Fatalf("unexpected error: %v", err) } if event == nil { t.Error("unexpected nil event") break } expectedEvent, ok := events[event.Key] if !ok { t.Fatalf("event with key %s not found", event.Key) } if !reflect.DeepEqual(event, expectedEvent) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 11.6K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
event := input.(controllers.Event) switch event.Latest().(type) { case *corev1.Namespace: return s.reconcileNamespace(input) case *corev1.Pod: return s.reconcilePod(input) default: return fmt.Errorf("unexpected event type: %+v", input) } } func (s *InformerHandlers) reconcileNamespace(input any) error { event := input.(controllers.Event) ns := event.Latest().(*corev1.Namespace)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0)