- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 596 for yyerror (0.31 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
final CyclicBarrier barrier = new CyclicBarrier(2); // we need to make sure the error gets thrown on a different thread. ExecutorService service = Executors.newSingleThreadExecutor(); try { final SequentialExecutor executor = new SequentialExecutor(service); Runnable errorTask = new Runnable() { @Override public void run() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 11.4K bytes - Viewed (0) -
cni/pkg/repair/repair_test.go
for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { mt := monitortest.New(t) tt.config.LabelPods = true c, err := NewRepairController(tt.client, tt.config) assert.NoError(t, err) t.Cleanup(func() { assert.NoError(t, c.queue.WaitForClose(time.Second)) }) stop := test.NewStop(t) tt.client.RunAndWait(stop) go c.Run(stop) kube.WaitForCacheSync("test", stop, c.queue.HasSynced)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 24 03:31:28 GMT 2023 - 10.6K bytes - Viewed (0) -
cmd/bucket-replication-handlers.go
arn := r.URL.Query().Get("arn") var err error objectAPI := api.ObjectAPI() if objectAPI == nil { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL) return } if s3Error := checkRequestAuthType(ctx, r, policy.ResetBucketReplicationStateAction, bucket, ""); s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 28 04:08:53 GMT 2023 - 23.2K bytes - Viewed (0) -
cmd/admin-handlers-site-replication.go
data, err := io.ReadAll(body) if err != nil { return SRError{ Cause: err, Code: ErrSiteReplicationInvalidRequest, } } if encryptionKey != "" { data, err = madmin.DecryptData(encryptionKey, bytes.NewReader(data)) if err != nil { return SRError{ Cause: err, Code: ErrSiteReplicationInvalidRequest, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 09:40:39 GMT 2024 - 19.4K bytes - Viewed (0) -
internal/s3select/unused-errors.go
func errExpressionTooLong(err error) *s3Error { return &s3Error{ code: "ExpressionTooLong", message: "The SQL expression is too long: The maximum byte-length for the SQL expression is 256 KB.", statusCode: 400, cause: err, } } func errColumnTooLong(err error) *s3Error { return &s3Error{ code: "ColumnTooLong",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 17.5K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
type esClient interface { isAtleastV7() bool createIndex(ElasticsearchArgs) error ping(context.Context, ElasticsearchArgs) (bool, error) stop() entryExists(context.Context, string, string) (bool, error) removeEntry(context.Context, string, string) error updateEntry(context.Context, string, string, event.Event) error addEntry(context.Context, string, event.Event) error } // ElasticsearchArgs - Elasticsearch target arguments.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
final CyclicBarrier barrier = new CyclicBarrier(2); // we need to make sure the error gets thrown on a different thread. ExecutorService service = Executors.newSingleThreadExecutor(); try { final SequentialExecutor executor = new SequentialExecutor(service); Runnable errorTask = new Runnable() { @Override public void run() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 11.4K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
// no calls to ztunnel if iptables failed assert.Equal(t, ztunnelServer.addedPods.Load(), 0) // error is not partial error if errors.Is(err, ErrPartialAdd) { t.Fatal("expected not a partial error") } } func TestConstructInitialSnap(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() setupLogging()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cmd/auth-handler_test.go
} for i, testCase := range testCases { if _, s3Error := checkAdminRequestAuth(ctx, testCase.Request, policy.AllAdminActions, globalSite.Region); s3Error != testCase.ErrCode { t.Errorf("Test %d: Unexpected s3error returned wanted %d, got %d", i, testCase.ErrCode, s3Error) } } } func TestValidateAdminSignature(t *testing.T) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 15.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeImpl.java
throw new SMBProtocolDowngradeException("Signature error during negotiate validation", e); } catch ( SmbException e ) { if ( log.isDebugEnabled() ) { log.debug(String.format("VALIDATE_NEGOTIATE_INFO response code 0x%x", e.getNtStatus())); } log.trace("VALIDATE_NEGOTIATE_INFO returned error", e);
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Thu Jan 05 13:06:39 GMT 2023 - 29.6K bytes - Viewed (0)