- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,085 for Detached (0.34 sec)
-
pkg/controller/volume/attachdetach/attach_detach_controller.go
continue } attachState := adc.actualStateOfWorld.GetAttachState(volumeName, nodeName) if attachState == cache.AttachStateAttached { logger.V(10).Info("Volume is attached to node. Marking as attached in ActualStateOfWorld", "node", klog.KRef("", string(nodeName)), "volumeName", volumeName) devicePath, err := adc.getNodeVolumeDevicePath(volumeName, nodeName) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes.go
var totalPods, errorPods int for _, uid := range found { if allPods.Has(string(uid)) { continue } totalPods++ // If volumes have not been unmounted/detached, do not delete directory. // Doing so may result in corruption of data. // TODO: getMountedVolumePathListFromDisk() call may be redundant with // kl.getPodVolumePathListFromDisk(). Can this be cleaned up?
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world.go
// If a volume with the name volumeName does not exist in the list of // attached volumes, an error is returned. DeletePodFromVolume(podName volumetypes.UniquePodName, volumeName v1.UniqueVolumeName) error // DeleteVolume removes the given volume from the list of attached volumes // in the cache indicating the volume has been successfully detached from // this node. // If a volume with the name volumeName does not exist in the list of
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 45.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
editor.setString(1, "a") cache.evictAll() // Create a new value in its place. set("k1", "bb", "bb") assertThat(cache.size()).isEqualTo(4) // Committing the detached editor should not change the cache's size. editor.commit() assertThat(cache.size()).isEqualTo(4) assertValue("k1", "bb", "bb") } @ParameterizedTest
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 14:55:09 UTC 2024 - 75.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
internal fun <E : IOException?> messageDone( exchange: Exchange, requestDone: Boolean, responseDone: Boolean, e: E, ): E { if (exchange != this.exchange) return e // This exchange was detached violently! var bothStreamsDone = false var callDone = false this.withLock { if (requestDone && requestBodyOpen || responseDone && responseBodyOpen) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
tests/integration/pilot/testdata/gateway-api-crd.yaml
from the referencing Route, the Route MUST be considered successfully attached. If no Gateway listeners accept attachment from this Route, the Route MUST be considered detached from the Gateway. Support: Extended format: int32 maximum: 65535
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 02:01:51 UTC 2024 - 912.2K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
waitForAttachTimeout = 10 * time.Minute ) // VolumeManager runs a set of asynchronous loops that figure out which volumes // need to be attached/mounted/unmounted/detached based on the pods scheduled on // this node and makes it so. type VolumeManager interface { // Starts the volume manager and all the asynchronous loops that it controls Run(sourcesReady config.SourcesReady, stopCh <-chan struct{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/volume/fc/fc.go
if err = os.RemoveAll(mapPath); err != nil { return fmt.Errorf("fc: failed to delete the directory: %s\nError: %v", mapPath, err) } klog.V(4).Infof("fc: successfully detached disk: %s", mapPath) return nil } func (c *fcDiskUnmapper) UnmapPodDevice() error { return nil } // GetGlobalMapPath returns global map path and error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 17.4K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher.go
if err != nil { attached[spec] = false klog.Error(log("attacher.VolumesAreAttached failed for attach.ID=%v: %v", attachID, err)) continue } klog.V(4).Info(log("attacher.VolumesAreAttached attachment [%v] has status.attached=%t", attachID, attach.Status.Attached)) attached[spec] = attach.Status.Attached } return attached, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 03 07:38:14 UTC 2023 - 25.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
Request.Builder() .url(server.url("/")) .post(AsyncRequestBody()) .build(), ) val response2 = call.execute() // First duplex request is detached with violence. val requestBody1 = (call.request().body as AsyncRequestBody?)!!.takeSink() assertFailsWith<IOException> { requestBody1.writeUtf8("not authenticated\n") requestBody1.flush()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 23.9K bytes - Viewed (0)