- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 189 for newobj (0.12 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
t.Fatalf("unexpected error: %v", err) } transformer := func(ctx context.Context, newObj runtime.Object, oldObj runtime.Object) (transformedNewObj runtime.Object, err error) { <-ready pod, ok := newObj.(*example.Pod) if !ok { t.Fatalf("unexpected object %v", newObj) } pod.Labels = map[string]string{ "modified": "true", } return pod, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java
if (keyObj instanceof final UrlQueue<?> urlQueue) { return OptionalThing.of(urlQueue.getId().toString()); } if (keyObj instanceof final StatsKeyObject statsKey) { return OptionalThing.of(statsKey.getId()); } if (keyObj instanceof final String key) { return OptionalThing.of(key); } if (keyObj instanceof final Number key) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.9K bytes - Viewed (0) -
src/internal/coverage/slicewriter/slicewriter.go
return offset, nil case io.SeekCurrent: newoff := sws.off + offset if newoff != sws.off && (newoff < 0 || newoff > int64(len(sws.payload))) { return 0, fmt.Errorf("invalid seek: new offset %d (out of range [0 %d]", newoff, len(sws.payload)) } sws.off += offset return sws.off, nil case io.SeekEnd: newoff := int64(len(sws.payload)) + offset if newoff != sws.off && (newoff < 0 || newoff > int64(len(sws.payload))) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 26 12:44:26 UTC 2023 - 2.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java
final CrawlerStatsHelper crawlerStatsHelper = ComponentUtil.getCrawlerStatsHelper(); final StatsKeyObject keyObj = paramMap.get(Constants.CRAWLER_STATS_KEY) instanceof final StatsKeyObject sko ? sko : null; if (keyObj != null) { crawlerStatsHelper.runOnThread(keyObj); } final DataStoreParams localParams = paramMap.newInstance(); executor.execute(() -> { try {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 16.8K bytes - Viewed (0) -
pkg/registry/batch/job/strategy.go
isJobFailureTargetChanged := batchvalidation.IsConditionTrue(oldJob.Status.Conditions, batch.JobFailureTarget) != batchvalidation.IsConditionTrue(newJob.Status.Conditions, batch.JobFailureTarget) isCompletedIndexesChanged := oldJob.Status.CompletedIndexes != newJob.Status.CompletedIndexes isFailedIndexesChanged := !ptr.Equal(oldJob.Status.FailedIndexes, newJob.Status.FailedIndexes) isActiveChanged := oldJob.Status.Active != newJob.Status.Active
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 16:43:24 UTC 2024 - 18.4K bytes - Viewed (0) -
src/internal/coverage/slicereader/slicereader.go
} r.off = offset return offset, nil case io.SeekCurrent: newoff := r.off + offset if newoff < 0 || newoff > int64(len(r.b)) { return 0, fmt.Errorf("invalid seek: new offset %d (out of range [0 %d]", newoff, len(r.b)) } r.off = newoff return r.off, nil case io.SeekEnd: newoff := int64(len(r.b)) + offset if newoff < 0 || newoff > int64(len(r.b)) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 23 11:36:28 UTC 2023 - 2.5K bytes - Viewed (0) -
pkg/registry/batch/job/strategy_test.go
featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.JobBackoffLimitPerIndex, tc.enableJobBackoffLimitPerIndex) newJob := tc.job.DeepCopy() tc.update(newJob) errs := Strategy.ValidateUpdate(ctx, newJob, tc.job) if diff := cmp.Diff(tc.wantErrs, errs, ignoreErrValueDetail); diff != "" { t.Errorf("Unexpected errors (-want,+got):\n%s", diff) } }) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 101.5K bytes - Viewed (0) -
src/crypto/cipher/ofb.go
cipher []byte out []byte outUsed int } // NewOFB returns a [Stream] that encrypts or decrypts using the block cipher b // in output feedback mode. The initialization vector iv's length must be equal // to b's block size. func NewOFB(b Block, iv []byte) Stream { blockSize := b.BlockSize() if len(iv) != blockSize { panic("cipher.NewOFB: IV length must equal block size") } bufSize := streamBufferSize
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 17:09:47 UTC 2023 - 1.6K bytes - Viewed (0) -
src/vendor/golang.org/x/net/dns/dnsmessage/message.go
} func (h *header) unpack(msg []byte, off int) (int, error) { newOff := off var err error if h.id, newOff, err = unpackUint16(msg, newOff); err != nil { return off, &nestedError{"id", err} } if h.bits, newOff, err = unpackUint16(msg, newOff); err != nil { return off, &nestedError{"bits", err} } if h.questions, newOff, err = unpackUint16(msg, newOff); err != nil { return off, &nestedError{"questions", err} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Mar 09 00:09:40 UTC 2024 - 69K bytes - Viewed (0) -
src/crypto/cipher/cbc.go
package cipher import ( "bytes" "crypto/internal/alias" "crypto/subtle" ) type cbc struct { b Block blockSize int iv []byte tmp []byte } func newCBC(b Block, iv []byte) *cbc { return &cbc{ b: b, blockSize: b.BlockSize(), iv: bytes.Clone(iv), tmp: make([]byte, b.BlockSize()), } } type cbcEncrypter cbc
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 28 03:55:33 UTC 2022 - 5.4K bytes - Viewed (0)