- Sort Score
- Result 10 results
- Languages All
Results 3301 - 3310 of 7,250 for return (0.09 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)