- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 90 for pvs1 (0.52 sec)
-
pkg/scheduler/framework/plugins/volumebinding/assume_cache_test.go
// List them verifyListPVs(t, cache, pvs1, "class1") verifyListPVs(t, cache, pvs2, "class2") // Delete a PV deletedPV := pvs1["test-pv7"] delete(pvs1, deletedPV.Name) assumecache.DeleteTestObject(cache.AssumeCache, deletedPV) // List them verifyListPVs(t, cache, pvs1, "class1") verifyListPVs(t, cache, pvs2, "class2") } func TestAssumeUpdatePVCache(t *testing.T) { logger, _ := ktesting.NewTestContext(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 12.8K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher_test.go
spec: volume.NewSpecFromPersistentVolume(makeTestPV("pv01", 10, "testdriver-01", "testvol-01"), false), }, { name: "test ok 2", nodeName: "node02", driverName: "driver02", volumeName: "vol02", attachID: getAttachmentName("vol02", "driver02", "node02"), spec: volume.NewSpecFromPersistentVolume(makeTestPV("pv01", 10, "driver02", "vol02"), false), }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/index_test.go
} pv1 := testVolume("pv1", "1Gi") pv5 := testVolume("pv5", "5Gi") pv8 := testVolume("pv8", "8Gi") pvBadSize := testVolume("pvBadSize", "1Mi") pvBadMode := testVolume("pvBadMode", "1Gi") pvBadMode.Spec.AccessModes = []v1.PersistentVolumeAccessMode{v1.ReadOnlyMany} index := newPersistentVolumeOrderedIndex() index.store.Add(pv1) index.store.Add(pv5) index.store.Add(pv8)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 21 13:31:28 UTC 2023 - 44K bytes - Viewed (0) -
pkg/scheduler/util/assumecache/assume_cache_test.go
oldObj: makeObj("pvc1", "5", ""), newObj: makeObj("pvc1", "4", ""), expectErr: cmpopts.AnyError, }, "fail-new-bad-version": { oldObj: makeObj("pvc1", "5", ""), newObj: makeObj("pvc1", "a", ""), expectErr: cmpopts.AnyError, }, "fail-old-bad-version": { oldObj: makeObj("pvc1", "a", ""), newObj: makeObj("pvc1", "5", ""), expectErr: cmpopts.AnyError, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 9.5K bytes - Viewed (0) -
src/internal/poll/sendfile_solaris.go
} dst := dstFD.Sysfd for remain > 0 { n := maxSendfileSize if int64(n) > remain { n = int(remain) } pos1 := pos n, err = syscall.Sendfile(dst, src, &pos1, n) if err == syscall.EAGAIN || err == syscall.EINTR { // partial write may have occurred n = int(pos1 - pos) } if n > 0 { pos += int64(n) written += int64(n) remain -= int64(n) continue
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 1.8K bytes - Viewed (0) -
src/cmd/asm/internal/asm/testdata/ppc64.s
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 21:53:50 UTC 2024 - 50.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
env.reactor.AddVolume(pv) } } func (env *testEnv) updateVolumes(ctx context.Context, pvs []*v1.PersistentVolume) error { for i, pv := range pvs { newPv, err := env.client.CoreV1().PersistentVolumes().Update(ctx, pv, metav1.UpdateOptions{}) if err != nil { return err } pvs[i] = newPv }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/dict/kuromoji/KuromojiFileTest.java
@Override protected void setUp() throws Exception { file1 = File.createTempFile("kuromoji_", ".txt"); FileUtil.write( file1.getAbsolutePath(), "token1,seg1,reading1,pos1\ntoken2,seg2,reading2,pos2\ntoken3,seg3,reading3,pos3" .getBytes(Constants.UTF_8)); } @Override protected void tearDown() throws Exception { file1.delete(); } */
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 7.3K bytes - Viewed (0) -
src/internal/poll/sendfile_bsd.go
return 0, err, false } dst := dstFD.Sysfd for remain > 0 { n := maxSendfileSize if int64(n) > remain { n = int(remain) } pos1 := pos n, err = syscall.Sendfile(dst, src, &pos1, n) if n > 0 { pos += int64(n) written += int64(n) remain -= int64(n) } if err == syscall.EINTR { continue } // This includes syscall.ENOSYS (no kernel
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 1.5K bytes - Viewed (0) -
pkg/proxy/ipvs/util/testing/fake_test.go
// Add a virtual server vs1 := &utilipvs.VirtualServer{ Address: netutils.ParseIPSloppy("1.2.3.4"), Port: uint16(80), Protocol: string("TCP"), Flags: utilipvs.FlagHashed, } err := fake.AddVirtualServer(vs1) if err != nil { t.Errorf("Fail to add virtual server, error: %v", err) } // Get a specific virtual server got1, err := fake.GetVirtualServer(vs1) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 5.6K bytes - Viewed (0)