Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for continue (0.07 sec)

  1. cmd/site-replication.go

    		if dID == globalDeploymentID() {
    			continue
    		}
    		if !uStatus.UserInfoMismatch {
    			continue
    		}
    
    		if isUserInfoEqual(latestUserStat.userInfo.UserInfo, uStatus.userInfo.UserInfo) {
    			continue
    		}
    
    		peerName := info.Sites[dID].Name
    
    		u, ok := globalIAMSys.GetUser(ctx, user)
    		if !ok {
    			continue
    		}
    		creds := u.Credentials
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    		if stringsHasPrefixFold(k, ReservedMetadataPrefixLower) {
    			continue
    		}
    
    		if equals(k, xhttp.AmzBucketReplicationStatus) {
    			continue
    		}
    
    		// https://github.com/google/security-research/security/advisories/GHSA-76wf-9vgp-pj7w
    		if equals(k, xhttp.AmzMetaUnencryptedContentLength, xhttp.AmzMetaUnencryptedContentMD5) {
    			continue
    		}
    		meta[k] = v
    	}
    
    	if oi.ContentEncoding != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    		enc := json.NewEncoder(&buf)
    		for {
    			select {
    			case <-ctx.Done():
    				return
    			case li := <-logCh:
    				if !li.SendLog(node, logKind) {
    					continue
    				}
    				buf.Reset()
    				if err := enc.Encode(li); err != nil {
    					continue
    				}
    				select {
    				case <-ctx.Done():
    					return
    				case encodedCh <- append(grid.GetByteBuffer()[:0], buf.Bytes()...):
    				}
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb1/smb1/SmbFile.java

                    continue;
                if (name.length() > 0) {
                    // if !files we don't need to create SmbFiles here
                    SmbFile f = new SmbFile(this, name, e.getType(),
                                ATTR_READONLY | ATTR_DIRECTORY, 0L, 0L, 0L );
                    if (ff != null && ff.accept(f) == false)
                        continue;
                    if (files) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Mar 13 12:00:57 UTC 2023
    - 107.9K bytes
    - Viewed (0)
  5. tensorflow/c/c_api.cc

        const Tensor& src = outputs[i];
        if (!src.IsInitialized() || src.NumElements() == 0) {
          c_outputs[i] =
              EmptyTensor(static_cast<TF_DataType>(src.dtype()), src.shape());
          continue;
        }
        c_outputs[i] = TF_TensorFromTensor(src, &status->status);
        if (!status->status.ok()) return;
      }
    }
    
    extern "C" {
    
    void TF_Run(TF_DeprecatedSession* s, const TF_Buffer* run_options,
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 102.3K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/CallTest.kt

          MockResponse.Builder()
            .add100Continue()
            .build(),
        )
        val request =
          Request.Builder()
            .url(server.url("/"))
            .header("Expect", "100-continue")
            .post("abc".toRequestBody("text/plain".toMediaType()))
            .build()
        executeSynchronously(request)
          .assertCode(200)
          .assertSuccessful()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
  7. cmd/metrics-v2.go

    	var metrics []MetricV2
    	for promMetric := range ch {
    		dtoMetric := &dto.Metric{}
    		err := promMetric.Write(dtoMetric)
    		if err != nil {
    			// Log error and continue to receive other metric
    			// values
    			bugLogIf(GlobalContext, err)
    			continue
    		}
    
    		h := dtoMetric.GetHistogram()
    		for _, b := range h.Bucket {
    			labels := make(map[string]string)
    			for _, lp := range dtoMetric.GetLabel() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  8. cmd/object-handlers_test.go

    					continue
    				}
    			} else {
    				t.Errorf("Test %d: %s:  Expected the response status to be `%d`, but instead found `%d`", i, instanceType, testCase.expectedRespStatus, rec.Code)
    				continue
    			}
    		}
    		if rec.Code == http.StatusOK {
    			var cpObjResp CopyObjectResponse
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.4.md

    ### kubectl delete: < v1.4.0 client vs >=v1.4.0 cluster
    
    If you use an old version kubectl to delete a replication controller or replicaset, then after the delete command has returned, the replication controller or the replicaset will continue to exist in the key-value store for a short period of time (<1s). You probably will not notice any difference if you use kubectl manually, but you might notice it if you are using kubectl in a script.
    
    ### DELETE operation in REST API
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 133.5K bytes
    - Viewed (0)
  10. guava/src/com/google/common/cache/LocalCache.java

          for (ReferenceEntry<K, V> e = getFirst(hash); e != null; e = e.getNext()) {
            if (e.getHash() != hash) {
              continue;
            }
    
            K entryKey = e.getKey();
            if (entryKey == null) {
              tryDrainReferenceQueues();
              continue;
            }
    
            if (map.keyEquivalence.equivalent(key, entryKey)) {
              return e;
            }
          }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 149.2K bytes
    - Viewed (0)
Back to top