Search Options

Results per page
Sort
Preferred Languages
Advance

Results 3301 - 3310 of 7,250 for return (0.04 sec)

  1. guava/src/com/google/common/hash/LongAddables.java

                @Override
                public LongAddable get() {
                  return new LongAdder();
                }
              };
        } catch (Throwable t) { // we really want to catch *everything*
          supplier =
              new Supplier<LongAddable>() {
                @Override
                public LongAddable get() {
                  return new PureJavaLongAddable();
                }
              };
        }
        SUPPLIER = supplier;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jan 04 17:27:14 UTC 2022
    - 1.9K bytes
    - Viewed (0)
  2. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/metadata/AbstractArtifactMetadata.java

            this.artifact = artifact;
        }
    
        public boolean storedInGroupDirectory() {
            return false;
        }
    
        public String getGroupId() {
            return artifact.getGroupId();
        }
    
        public String getArtifactId() {
            return artifact.getArtifactId();
        }
    
        public String extendedToString() {
            StringBuilder buffer = new StringBuilder(256);
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  3. internal/http/dial_others.go

    //
    //nolint:unused
    func setTCPParametersFn(opts TCPOptions) func(network, address string, c syscall.RawConn) error {
    	return func(network, address string, c syscall.RawConn) error {
    		return nil
    	}
    }
    
    // DialContext is a function to make custom Dial for internode communications
    type DialContext func(ctx context.Context, network, address string) (net.Conn, error)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 24 04:08:47 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  4. internal/disk/directio_unix.go

    	return directio.OpenFile(filePath, flag, perm)
    }
    
    // DisableDirectIO - disables directio mode.
    func DisableDirectIO(f *os.File) error {
    	fd := f.Fd()
    	flag, err := unix.FcntlInt(fd, unix.F_GETFL, 0)
    	if err != nil {
    		return err
    	}
    	flag &= ^(syscall.O_DIRECT)
    	_, err = unix.FcntlInt(fd, unix.F_SETFL, flag)
    	return err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 17 14:31:36 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  5. istioctl/pkg/util/common.go

    	Err error
    }
    
    func (c CommandParseError) Error() string {
    	return c.Err.Error()
    }
    
    // Confirm waits for a user to confirm with the supplied message.
    func Confirm(msg string, writer io.Writer) bool {
    	for {
    		_, _ = fmt.Fprintf(writer, "%s ", msg)
    		var response string
    		_, err := fmt.Scanln(&response)
    		if err != nil {
    			return false
    		}
    		switch strings.ToUpper(response) {
    		case "Y", "YES":
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  6. internal/rest/rpc-stats.go

    		s.DialAvgDuration = atomic.LoadUint64(&globalStats.tcpDialTotalDur) / v
    		s.TTFBAvgDuration = atomic.LoadUint64(&globalStats.tcpTimeForFirstByteTotalDur) / v
    	}
    	return s
    }
    
    // Return a function which update the global stats related to tcp connections
    func setupReqStatsUpdate(req *http.Request) (*http.Request, func()) {
    	var dialStart, dialEnd int64
    	start := time.Now()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 18:21:34 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/core/beans/util/BeanUtil.java

         * @return コピーされた新しいBean
         */
        public static <T> T copyBeanToNewBean(final Object src, final Class<T> destClass) {
            return copyBeanToNewBean(src, destClass, DEFAULT_OPTIONS);
        }
    
        public static <T> T copyBeanToNewBean(final Object src, final Class<T> destClass, final Consumer<CopyOptions> option) {
            return copyBeanToNewBean(src, destClass, buildCopyOptions(option));
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/http/NetworkExplorer.java

                return f1name.compareToIgnoreCase( f2name );
            }
            return i;
        }
        protected int compareDates( SmbFile f1, String f1name, SmbFile f2 ) throws IOException {
            if( f1.isDirectory() != f2.isDirectory() ) {
                return f1.isDirectory() ? -1 : 1;
            }
            if( f1.isDirectory() ) {
                return f1name.compareToIgnoreCase( f2.getName() );
            }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Wed Jan 22 03:57:31 UTC 2020
    - 19.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/core/jar/JarFileUtil.java

         *
         * @param file
         *            ファイルパス。{@literal null}であってはいけません
         * @return 指定されたJarファイルを読み取るための<code>JarFile</code>
         */
        public static JarFile create(final String file) {
            assertArgumentNotNull("file", file);
    
            try {
                return new JarFile(file);
            } catch (final IOException e) {
                throw new IORuntimeException(e);
            }
        }
    
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

          super(mock);
        }
    
        @Override
        protected <T> Callable<T> wrapTask(Callable<T> callable) {
          return new WrappedCallable<T>(callable);
        }
    
        @Override
        protected Runnable wrapTask(Runnable command) {
          return new WrappedRunnable(command);
        }
      }
    
      private static final class MockExecutor implements ScheduledExecutorService {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.6K bytes
    - Viewed (0)
Back to top