Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 710 for continue (0.06 sec)

  1. cmd/object-api-putobject_test.go

    			t.Errorf("Test %d: %s: Expected to pass, but failed with: error %s.", i, instanceType, actualErr.Error())
    			continue
    		}
    		if actualErr == nil && testCase.expectedError != nil {
    			t.Errorf("Test %d: %s: Expected to fail with error \"%s\", but passed instead.", i, instanceType, testCase.expectedError.Error())
    			continue
    		}
    		// Failed as expected, but does it fail for the expected reason.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  2. bin/check_samples.sh

    # rely on go build cache
    ISTIOCTL=bin/istioctl
    go build -o $ISTIOCTL ./istioctl/cmd/istioctl
    
    for f in samples/**/*.yaml; do
      if grep -q -e "{{" "$f" ; then
        echo "Skipping check for helm template $f"
        continue
      else
        echo "Validating $f..."
      $ISTIOCTL validate -x \
        -f "$f"
      fi
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Nov 04 01:54:50 UTC 2023
    - 1010 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. android/guava/src/com/google/common/util/concurrent/AtomicLongMap.java

            if (oldValue == 0L) {
              // don't compareAndSet a zero
              if (map.replace(key, atomic, new AtomicLong(delta))) {
                return delta;
              }
              // atomic replaced
              continue outer;
            }
    
            long newValue = oldValue + delta;
            if (atomic.compareAndSet(oldValue, newValue)) {
              return newValue;
            }
            // value changed
          }
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  5. cmd/bucket-metadata-sys.go

    	// instead of serializing the Go routines.
    	sys.Lock()
    	for i, meta := range bucketMetas {
    		if errs[i] != nil {
    			continue
    		}
    		sys.metadataMap[buckets[i]] = meta
    	}
    	sys.Unlock()
    
    	for i, meta := range bucketMetas {
    		if errs[i] != nil {
    			continue
    		}
    		globalEventNotifier.set(buckets[i], meta)   // set notification targets
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  6. cmd/bucket-targets.go

    		if t.Type == tgt.Type {
    			if t.Arn == tgt.Arn {
    				if !update {
    					return BucketRemoteAlreadyExists{Bucket: t.TargetBucket}
    				}
    				newtgts[idx] = *tgt
    				found = true
    				continue
    			}
    			// fail if endpoint is already present in list of targets and not a matching ARN
    			if t.Endpoint == tgt.Endpoint {
    				return BucketRemoteAlreadyExists{Bucket: t.TargetBucket}
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  7. cmd/bootstrap-peer-server.go

    	seenClient := set.NewStringSet()
    	var clnts []*bootstrapRESTClient
    	for _, ep := range endpointServerPools {
    		for _, endpoint := range ep.Endpoints {
    			if endpoint.IsLocal {
    				continue
    			}
    			if seenClient.Contains(endpoint.Host) {
    				continue
    			}
    			seenClient.Add(endpoint.Host)
    			clnts = append(clnts, &bootstrapRESTClient{gm.Connection(endpoint.GridHost())})
    		}
    	}
    	return clnts
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. src/bytes/reader_test.go

    		pos, err := r.Seek(tt.off, tt.seek)
    		if err == nil && tt.seekerr != "" {
    			t.Errorf("%d. want seek error %q", i, tt.seekerr)
    			continue
    		}
    		if err != nil && err.Error() != tt.seekerr {
    			t.Errorf("%d. seek error = %q; want %q", i, err.Error(), tt.seekerr)
    			continue
    		}
    		if tt.wantpos != 0 && tt.wantpos != pos {
    			t.Errorf("%d. pos = %d, want %d", i, pos, tt.wantpos)
    		}
    		buf := make([]byte, tt.n)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Dec 13 18:45:54 UTC 2021
    - 8K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb1/UniAddress.java

                                        "jcifs.smb1.netbios.wins property has not been set" );
                            }
                            continue;
                        }
                        tmp[i++] = RESOLVER_WINS;
                    } else if( s.equalsIgnoreCase( "BCAST" )) {
                        tmp[i++] = RESOLVER_BCAST;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 16.2K bytes
    - Viewed (0)
  10. internal/grid/connection.go

    				atomic.StoreInt64(&c.LastPong, time.Now().UnixNano())
    				continue
    			}
    			toSend, err = pingFrame.MarshalMsg(GetByteBuffer()[:0])
    			if err != nil {
    				gridLogIf(ctx, err) // Fake it... Though this should never fail.
    				atomic.StoreInt64(&c.LastPong, time.Now().UnixNano())
    				continue
    			}
    		case toSend = <-c.outQueue:
    			if len(toSend) == 0 {
    				continue
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
Back to top