- Sort Score
- Result 10 results
- Languages All
Results 311 - 320 of 590 for scond (0.03 sec)
-
helm-releases/minio-5.0.2.tgz
myminio $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT $ACCESS $SECRET" ; $MC_COMMAND ; STATUS=$? ; until [ $STATUS = 0 ] do ATTEMPTS=`expr $ATTEMPTS + 1` ; echo \"Failed attempts: $ATTEMPTS\" ; if [ $ATTEMPTS -gt $LIMIT ]; then exit 1 ; fi ; sleep 2 ; # 1 second intervals between attempts $MC_COMMAND ; STATUS=$? ; done ; set -e ; # reset `e` as active return 0 } # checkBucketExists ($bucket) # Check if the bucket exists, by using the exit code of `mc ls` checkBucketExists() { BUCKET=$1 CMD=$(${MC} ls myminio/$BUCKET...
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Dec 18 07:57:10 UTC 2022 - 20.4K bytes - Viewed (0) -
cmd/utils.go
CurvePreferences: fips.TLSCurveIDs(), TCPOptions: globalTCPOptions, EnableHTTP2: false, } if clientCert != "" && clientKey != "" { ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel() transport, err := s.NewHTTPTransportWithClientCerts(ctx, clientCert, clientKey) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:22:04 UTC 2024 - 31.9K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer.go
w int // next position to write isFull bool err error block bool mu sync.Mutex wg sync.WaitGroup readCond *sync.Cond // Signaled when data has been read. writeCond *sync.Cond // Signaled when data has been written. } // New returns a new RingBuffer whose buffer has the given size. func New(size int) *RingBuffer { return &RingBuffer{ buf: make([]byte, size),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
// SequentialExecutor by the time the barrier is satisfied barrier.await(1, SECONDS); executor.execute(barrierTask); // timeout means the second task wasn't even tried barrier.await(1, SECONDS); } finally { service.shutdown(); } } public void testRejectedExecutionThrownWithMultipleCalls() throws Exception {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 11.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFileOutputStream.java
* on an SMB server addressed by the <code>SmbFile</code> parameter. See * {@link jcifs.smb.SmbFile} for a detailed description and examples of * the smb URL syntax. If the second argument is <code>true</code>, then * bytes will be written to the end of the file rather than the beginning. * * @param file * An <code>SmbFile</code> representing the file to write to
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sat Nov 13 15:14:04 UTC 2021 - 11.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FastFallbackTest.kt
) serverIpv4.protocols = listOf(Protocol.H2_PRIOR_KNOWLEDGE) serverIpv6.protocols = listOf(Protocol.H2_PRIOR_KNOWLEDGE) // Yield the first IP address so the second IP address completes first. val firstConnectLatch = CountDownLatch(1) val socketFactory = object : DelegatingSocketFactory(SocketFactory.getDefault()) { var first = true
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
// SequentialExecutor by the time the barrier is satisfied barrier.await(1, SECONDS); executor.execute(barrierTask); // timeout means the second task wasn't even tried barrier.await(1, SECONDS); } finally { service.shutdown(); } } public void testRejectedExecutionThrownWithMultipleCalls() throws Exception {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 11.4K bytes - Viewed (0) -
tests/helper_test.go
Company bool Manager bool Team int Languages int Friends int NamedPet bool Tools int } func GetUser(name string, config Config) *User { var ( birthday = time.Now().Round(time.Second) user = User{ Name: name, Age: 18, Birthday: &birthday, } ) if config.Account { user.Account = Account{Number: name + "_account"} }
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Tue Mar 19 03:50:28 UTC 2024 - 8K bytes - Viewed (0) -
docs/lambda/README.md
// Generate presigned GET url with lambda function presignedURL, err := s3Client.PresignedGetObject(context.Background(), "functionbucket", "testobject", time.Duration(1000)*time.Second, reqParams) if err != nil { log.Fatalln(err) } fmt.Println(presignedURL) } ``` Use the Presigned URL via `curl` to receive the transformed object. ``` curl -v $(go run presigned.go)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Apr 04 19:15:28 UTC 2023 - 7.6K bytes - Viewed (0) -
tensorflow/c/c_api_experimental_test.cc
/*input_shapes*/ {make_shape({3, 2}), make_shape({2, 4})}, /*input_tensors*/ {}, /*expected_shape*/ make_shape({3, 4})); // Infer shape when second operand has unknown shape. CheckOutputShapes(matmul_op, /*input_shapes*/ {make_shape({3, 2}), unknown_shape()}, /*input_tensors*/ {},
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Tue Jan 17 22:27:52 UTC 2023 - 13.1K bytes - Viewed (0)