Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for Initializers (0.09 sec)

  1. guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java

        assertEquals(Double.doubleToRawLongBits(x), Double.doubleToRawLongBits(y));
      }
    
      /** constructor initializes to given value */
      public void testConstructor() {
        for (double x : VALUES) {
          AtomicDouble a = new AtomicDouble(x);
          assertBitEquals(x, a.get());
        }
      }
    
      /** default constructed initializes to zero */
      public void testConstructor2() {
        AtomicDouble a = new AtomicDouble();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  2. internal/logger/target/kafka/kafka.go

    	}
    
    	sconfig.Net.KeepAlive = 60 * time.Second
    	sconfig.Net.SASL.User = h.kconfig.SASL.User
    	sconfig.Net.SASL.Password = h.kconfig.SASL.Password
    	initScramClient(h.kconfig, sconfig) // initializes configured scram client.
    	sconfig.Net.SASL.Enable = h.kconfig.SASL.Enable
    
    	tlsConfig, err := saramatls.NewConfig(h.kconfig.TLS.ClientTLSCert, h.kconfig.TLS.ClientTLSKey)
    	if err != nil {
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  3. internal/jwt/parser.go

    // If nil an empty string will be returned.
    func (c *MapClaims) GetAccessKey() string {
    	if c == nil {
    		return ""
    	}
    	return c.AccessKey
    }
    
    // NewStandardClaims - initializes standard claims
    func NewStandardClaims() *StandardClaims {
    	return &StandardClaims{}
    }
    
    // SetIssuer sets issuer for these claims
    func (c *StandardClaims) SetIssuer(issuer string) {
    	c.Issuer = issuer
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  4. guava/src/com/google/common/hash/LittleEndianByteArray.java

      }
    
      /**
       * The only reference to Unsafe is in this nested class. We set things up so that if
       * Unsafe.theUnsafe is inaccessible, the attempt to load the nested class fails, and the outer
       * class's static initializer can fall back on a non-Unsafe version.
       */
      @SuppressWarnings({"SunApi", "removal"}) // b/345822163
      private enum UnsafeByteArray implements LittleEndianBytes {
        // Do *not* change the order of these constants!
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  5. guava/src/com/google/common/reflect/Invokable.java

          } else {
            // Strictly, this doesn't necessarily indicate a hidden 'this' in the case of
            // static initializer. But there seems no way to tell in that case. :(
            // This may cause issues when an anonymous class is created inside a static initializer,
            // and the class's constructor's first parameter happens to be the enclosing class.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 19.6K bytes
    - Viewed (0)
  6. internal/event/target/kafka.go

    		}
    		config.Version = kafkaVersion
    	}
    
    	config.Net.KeepAlive = 60 * time.Second
    	config.Net.SASL.User = args.SASL.User
    	config.Net.SASL.Password = args.SASL.Password
    	initScramClient(args, config) // initializes configured scram client.
    	config.Net.SASL.Enable = args.SASL.Enable
    
    	tlsConfig, err := saramatls.NewConfig(args.TLS.ClientTLSCert, args.TLS.ClientTLSKey)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  7. internal/dsync/dsync_test.go

    	testDrwMutexUnlockCallTimeout      = 250 * time.Millisecond
    	testDrwMutexForceUnlockCallTimeout = 250 * time.Millisecond
    	testDrwMutexRefreshInterval        = 100 * time.Millisecond
    )
    
    // TestMain initializes the testing framework
    func TestMain(m *testing.M) {
    	startLockServers()
    
    	// Initialize locker clients for dsync.
    	var clnts []NetLocker
    	for i := 0; i < len(nodes); i++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  8. src/bytes/buffer.go

    // in delim.
    func (b *Buffer) ReadString(delim byte) (line string, err error) {
    	slice, err := b.readSlice(delim)
    	return string(slice), err
    }
    
    // NewBuffer creates and initializes a new [Buffer] using buf as its
    // initial contents. The new [Buffer] takes ownership of buf, and the
    // caller should not use buf after this call. NewBuffer is intended to
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Oct 29 16:47:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  9. api/go1.5.txt

    pkg go/types, type Info struct, InitOrder []*Initializer
    pkg go/types, type Info struct, Scopes map[ast.Node]*Scope
    pkg go/types, type Info struct, Selections map[*ast.SelectorExpr]*Selection
    pkg go/types, type Info struct, Types map[ast.Expr]TypeAndValue
    pkg go/types, type Info struct, Uses map[*ast.Ident]Object
    pkg go/types, type Initializer struct
    pkg go/types, type Initializer struct, Lhs []*Var
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 30 21:14:09 UTC 2015
    - 46.6K bytes
    - Viewed (0)
  10. cmd/sftp-server-driver.go

    	startTime := time.Now()
    	source := getSource(2)
    	return func(sz int64, err error) {
    		globalTrace.Publish(sftpTrace(s, startTime, source, user, err, sz))
    	}
    }
    
    // NewSFTPDriver initializes sftp.Handlers implementation of following interfaces
    //
    // - sftp.Fileread
    // - sftp.Filewrite
    // - sftp.Filelist
    // - sftp.Filecmd
    func NewSFTPDriver(perms *ssh.Permissions) sftp.Handlers {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
Back to top