Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 702 for Continue (0.19 sec)

  1. internal/logger/config.go

    		for _, target := range loggerTargets {
    			endpoint := getCfgVal(legacyEnvLoggerHTTPEndpoint, target, "")
    			if endpoint == "" {
    				continue
    			}
    			url, err := xnet.ParseHTTPURL(endpoint)
    			if err != nil {
    				LogOnceIf(ctx, "logging", err, "logger-webhook-"+endpoint)
    				continue
    			}
    			cfg.HTTP[target] = http.Config{
    				Enabled:  true,
    				Endpoint: url,
    			}
    		}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  2. cmd/os_other.go

    					// file/directory.
    					if osIsNotExist(err) || isSysErrPathNotFound(err) ||
    						isSysErrTooManySymlinks(err) {
    						continue
    					}
    					return err
    				}
    
    				// Ignore symlinked directories.
    				if fi.IsDir() {
    					continue
    				}
    			}
    			if err = filter(fi.Name(), fi.Mode()); err == errDoneForNow {
    				// filtering requested to return by caller.
    				return nil
    			}
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Sep 13 15:14:36 GMT 2023
    - 4K bytes
    - Viewed (0)
  3. cmd/erasure-metadata-utils.go

    			// Assuming offline drives as inconsistent,
    			// to be safe and fallback to original
    			// distribution order.
    			inconsistent++
    			continue
    		}
    		if !meta.IsValid() {
    			inconsistent++
    			continue
    		}
    		if meta.XLV1 != fi.XLV1 {
    			inconsistent++
    			continue
    		}
    		// check if erasure distribution order matches the index
    		// position if this is not correct we discard the disk
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  4. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/SocketPolicy.kt

      DISCONNECT_DURING_RESPONSE_BODY,
      DO_NOT_READ_REQUEST_BODY,
      FAIL_HANDSHAKE,
      SHUTDOWN_INPUT_AT_END,
      SHUTDOWN_OUTPUT_AT_END,
      STALL_SOCKET_AT_START,
      NO_RESPONSE,
      RESET_STREAM_AT_START,
      EXPECT_CONTINUE,
      CONTINUE_ALWAYS,
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb/ShareEnumIterator.java

                        continue;
                    }
                }
                try ( SmbResource nr = adapt(n) ) {
                    if ( !this.filter.accept(nr) ) {
                        continue;
                    }
                    return nr;
                }
                catch ( CIFSException e ) {
                    log.error("Failed to apply filter", e);
                    continue;
                }
    Java
    - Registered: Sun Apr 28 00:10:09 GMT 2024
    - Last Modified: Sun Jul 01 13:12:10 GMT 2018
    - 3.5K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool.go

    				if disk == OfflineDisk {
    					continue
    				}
    				stats, err := disk.StatInfoFile(ctx, volume, file, true)
    				if err != nil {
    					continue
    				}
    				for _, si := range stats {
    					found++
    					var r io.ReadCloser
    					if !si.Dir {
    						r, err = disk.ReadFileStream(ctx, volume, si.Name, 0, si.Size)
    						if err != nil {
    							continue
    						}
    					} else {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K bytes
    - Viewed (0)
  7. cmd/os_windows.go

    				// file/directory.
    				if osIsNotExist(err) || isSysErrPathNotFound(err) ||
    					isSysErrTooManySymlinks(err) {
    					continue
    				}
    				return err
    			}
    
    			if fi.IsDir() {
    				// Ignore symlinked directories.
    				continue
    			}
    
    			typ = fi.Mode()
    		case data.FileAttributes&syscall.FILE_ATTRIBUTE_DIRECTORY != 0:
    			typ = os.ModeDir
    		}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Oct 18 18:08:15 GMT 2023
    - 5.1K bytes
    - Viewed (0)
  8. cmd/endpoint.go

    		default:
    			for i, resolved := range resolvedList {
    				if resolved {
    					// Continue if host is already resolved.
    					continue
    				}
    
    				if endpoints[i].Host == "" {
    					resolvedList[i] = true
    					endpoints[i].IsLocal = true
    					epsResolved++
    					if !foundLocal {
    						foundLocal = true
    					}
    					continue
    				}
    
    				// Log the message to console about the host resolving
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 34.1K bytes
    - Viewed (0)
  9. cmd/global-heal.go

    				retErr = err
    				healingLogIf(ctx, err)
    				continue
    			}
    			// Check if bucket is object locked.
    			lr, err = globalBucketObjectLockSys.Get(bucket)
    			if err != nil {
    				retErr = err
    				healingLogIf(ctx, err)
    				continue
    			}
    			rcfg, err = getReplicationConfig(ctx, bucket)
    			if err != nil {
    				retErr = err
    				healingLogIf(ctx, err)
    				continue
    			}
    		}
    
    		if serverDebugLog {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  10. cmd/local-locker.go

    		lri, ok := l.lockMap[resource]
    		if ok && !isWriteLock(lri) {
    			// Unless it is a write lock reject it.
    			err = fmt.Errorf("unlock attempted on a read locked entity: %s", resource)
    			continue
    		}
    		if ok {
    			reply = l.removeEntry(resource, args, &lri) || reply
    		}
    	}
    	return
    }
    
    // removeEntry based on the uid of the lock message, removes a single entry from the
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 10.6K bytes
    - Viewed (0)
Back to top