Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,030 for doPing (0.1 sec)

  1. internal/grid/muxclient.go

    				// Next loop will catch it.
    			case <-pingTimer:
    				if !m.doPing(respHandler) {
    					return
    				}
    				goto sendResp
    			}
    		case <-pingTimer:
    			if !m.doPing(respHandler) {
    				return
    			}
    		}
    	}
    }
    
    // doPing checks last ping time and sends another ping.
    func (m *muxClient) doPing(respHandler chan<- Response) (ok bool) {
    	m.respMu.Lock()
    	if m.closed {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  2. src/go/build/deps_test.go

    	NET, log
    	< net/mail;
    
    	NONE < crypto/internal/boring/sig, crypto/internal/boring/syso;
    	sync/atomic < crypto/internal/boring/bcache, crypto/internal/boring/fipstls;
    	crypto/internal/boring/sig, crypto/internal/boring/fipstls < crypto/tls/fipsonly;
    
    	# CRYPTO is core crypto algorithms - no cgo, fmt, net.
    	crypto/internal/boring/sig,
    	crypto/internal/boring/syso,
    	golang.org/x/sys/cpu,
    	hash, embed
    	< crypto
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 16:41:13 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  3. README.md

    require distributed deploying MinIO with Erasure Coding. For extended development and production, deploy MinIO with Erasure Coding enabled - specifically,
    with a *minimum* of 4 drives per MinIO server. See [MinIO Erasure Code Overview](https://min.io/docs/minio/linux/operations/concepts/erasure-coding.html)
    for more complete documentation.
    
    ### Stable
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 10 00:22:36 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java

      }
    
      /*
       * TODO(cpovirk): It would be great to run all these tests (including class unloading) in an
       * environment that forces Futures.getChecked to its fallback WeakSetValidator. One awful way of
       * doing so would be to derive a separate test library by using remove_from_jar to strip out
       * ClassValueValidator.
       *
       * Fortunately, we get pretty good coverage "by accident": We run all these tests against the
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 16.4K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java

      }
    
      /*
       * TODO(cpovirk): It would be great to run all these tests (including class unloading) in an
       * environment that forces Futures.getChecked to its fallback WeakSetValidator. One awful way of
       * doing so would be to derive a separate test library by using remove_from_jar to strip out
       * ClassValueValidator.
       *
       * Fortunately, we get pretty good coverage "by accident": We run all these tests against the
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 16.4K bytes
    - Viewed (0)
  6. docs/en/docs/async.md

    But as you go away from the counter and sit at the table with a number for your turn, you can switch 🔀 your attention to your crush, and "work" ⏯ 🤓 on that. Then you are again doing something very "productive" as is flirting with your crush 😍.
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Mon May 20 00:24:48 UTC 2024
    - 23K bytes
    - Viewed (0)
  7. src/cmd/compile/internal/types2/subst.go

    		if base != t.base {
    			return &Pointer{base: base}
    		}
    
    	case *Tuple:
    		return subst.tuple(t)
    
    	case *Signature:
    		// Preserve the receiver: it is handled during *Interface and *Named type
    		// substitution.
    		//
    		// Naively doing the substitution here can lead to an infinite recursion in
    		// the case where the receiver is an interface. For example, consider the
    		// following declaration:
    		//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:04:07 UTC 2024
    - 11K bytes
    - Viewed (0)
  8. src/crypto/rsa/pkcs1v15.go

    		return nil, err
    	}
    	k := pub.Size()
    	if len(msg) > k-11 {
    		return nil, ErrMessageTooLong
    	}
    
    	if boring.Enabled && random == boring.RandReader {
    		bkey, err := boringPublicKey(pub)
    		if err != nil {
    			return nil, err
    		}
    		return boring.EncryptRSAPKCS1(bkey, msg)
    	}
    	boring.UnreachableExceptTests()
    
    	// EM = 0x00 || 0x02 || PS || 0x00 || M
    	em := make([]byte, k)
    	em[1] = 2
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 00:11:21 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  9. CONTRIBUTING.md

    #### C++ coding style
    
    Changes to TensorFlow C++ code should conform to
    [Google C++ Style Guide](https://google.github.io/styleguide/cppguide.html).
    
    Use `clang-tidy` to check your C/C++ changes. To install `clang-tidy` on ubuntu:16.04, do:
    
    ```bash
    apt-get install -y clang-tidy
    ```
    
    You can check a C/C++ file by doing:
    
    
    ```bash
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Mar 21 11:45:51 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  10. src/crypto/rsa/rsa.go

    	k := pub.Size()
    	if len(msg) > k-2*hash.Size()-2 {
    		return nil, ErrMessageTooLong
    	}
    
    	if boring.Enabled && random == boring.RandReader {
    		bkey, err := boringPublicKey(pub)
    		if err != nil {
    			return nil, err
    		}
    		return boring.EncryptRSAOAEP(hash, hash, bkey, msg, label)
    	}
    	boring.UnreachableExceptTests()
    
    	hash.Write(label)
    	lHash := hash.Sum(nil)
    	hash.Reset()
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 00:11:18 UTC 2024
    - 23.4K bytes
    - Viewed (0)
Back to top