Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 1,087 for contextos (0.06 sec)

  1. android/guava/src/com/google/common/collect/RegularImmutableMultiset.java

      final transient ObjectCountHashMap<E> contents;
      private final transient int size;
    
      @LazyInit @CheckForNull private transient ImmutableSet<E> elementSet;
    
      RegularImmutableMultiset(ObjectCountHashMap<E> contents) {
        this.contents = contents;
        long size = 0;
        for (int i = 0; i < contents.size(); i++) {
          size += contents.getValue(i);
        }
        this.size = Ints.saturatedCast(size);
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Nov 30 21:54:06 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  2. cmd/namespace-lock.go

    type RWLocker interface {
    	GetLock(ctx context.Context, timeout *dynamicTimeout) (lkCtx LockContext, timedOutErr error)
    	Unlock(lkCtx LockContext)
    	GetRLock(ctx context.Context, timeout *dynamicTimeout) (lkCtx LockContext, timedOutErr error)
    	RUnlock(lkCtx LockContext)
    }
    
    // LockContext lock context holds the lock backed context and canceler for the context.
    type LockContext struct {
    	ctx    context.Context
    	cancel context.CancelFunc
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  3. callbacks/create.go

    						if _, isZero := pkField.ValueOf(db.Statement.Context, rv); isZero {
    							db.AddError(pkField.Set(db.Statement.Context, rv, insertID))
    							insertID += pkField.AutoIncrementIncrement
    						}
    					}
    				}
    			case reflect.Struct:
    				_, isZero := pkField.ValueOf(db.Statement.Context, db.Statement.ReflectValue)
    				if isZero {
    					db.AddError(pkField.Set(db.Statement.Context, db.Statement.ReflectValue, insertID))
    				}
    			}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Apr 08 03:29:55 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  4. internal/cachevalue/cache_test.go

    	cache.InitOnce(2*time.Second, Opts{},
    		func(ctx context.Context) (time.Time, error) {
    			return time.Now(), slowCaller(ctx)
    		},
    	)
    
    	ctx, cancel := context.WithCancel(context.Background())
    	cancel() // cancel context to test.
    
    	_, err := cache.GetWithCtx(ctx)
    	if !errors.Is(err, context.Canceled) {
    		t.Fatalf("expected context.Canceled err, got %v", err)
    	}
    
    	ctx, cancel = context.WithCancel(context.Background())
    	defer cancel()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  5. src/archive/tar/example_test.go

    		if err != nil {
    			log.Fatal(err)
    		}
    		fmt.Printf("Contents of %s:\n", hdr.Name)
    		if _, err := io.Copy(os.Stdout, tr); err != nil {
    			log.Fatal(err)
    		}
    		fmt.Println()
    	}
    
    	// Output:
    	// Contents of readme.txt:
    	// This archive contains some text files.
    	// Contents of gopher.txt:
    	// Gopher names:
    	// George
    	// Geoffrey
    	// Gonzo
    	// Contents of todo.txt:
    	// Get animal handling license.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Nov 16 16:54:08 UTC 2017
    - 1.4K bytes
    - Viewed (0)
  6. internal/dsync/locker.go

    	Lock(ctx context.Context, args LockArgs) (bool, error)
    
    	// Do read unlock for given LockArgs. It should return
    	// * a boolean to indicate success/failure of the operation
    	// * an error on failure of unlock request operation.
    	// Canceling the context will abort the remote call.
    	// In that case, the resource may or may not be unlocked.
    	RUnlock(ctx context.Context, args LockArgs) (bool, error)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 18 20:44:38 UTC 2022
    - 2.7K bytes
    - Viewed (0)
  7. internal/kms/stub.go

    func (s StubKMS) Version(ctx context.Context) (string, error) {
    	return "stub", nil
    }
    
    // APIs returns supported APIs
    func (s StubKMS) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
    	return []madmin.KMSAPI{
    		{Method: http.MethodGet, Path: "stub/path"},
    	}, nil
    }
    
    // Status returns a set of endpoints and their KMS status.
    func (s StubKMS) Status(context.Context) (map[string]madmin.ItemState, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  8. cmd/storage-interface.go

    	DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error
    	DeleteBulk(ctx context.Context, volume string, paths ...string) error
    	WriteMetadata(ctx context.Context, origvolume, volume, path string, fi FileInfo) error
    	UpdateMetadata(ctx context.Context, volume, path string, fi FileInfo, opts UpdateMetadataOpts) error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/fess/query/QueryProcessorTest.java

                protected FilterChain createDefaultFilterChain() {
                    return (context, query, boost) -> {
                        called.set(true);
                        return QueryBuilders.boolQuery();
                    };
                }
            };
            queryProcessor.init();
    
            QueryContext context = new QueryContext(null, false);
            MatchAllDocsQuery query = new MatchAllDocsQuery();
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  10. internal/kms/secret-key_test.go

    package kms
    
    import (
    	"bytes"
    	"context"
    	"encoding/base64"
    	"testing"
    )
    
    func TestSingleKeyRoundtrip(t *testing.T) {
    	KMS, err := ParseSecretKey("my-key:eEm+JI9/q4JhH8QwKvf3LKo4DEBl6QbfvAl1CAbMIv8=")
    	if err != nil {
    		t.Fatalf("Failed to initialize KMS: %v", err)
    	}
    
    	key, err := KMS.GenerateKey(context.Background(), &GenerateKeyRequest{Name: "my-key"})
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top