- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 338 for flow (0.04 sec)
-
internal/http/dial_linux.go
// https://blog.cloudflare.com/when-tcp-sockets-refuse-to-die/ // This is a sensitive configuration, it is better to set it to high values, > 60 secs since it can // affect clients reading data with a very slow pace (disappropriate with socket buffer sizes) if opts.UserTimeout > 0 { _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_USER_TIMEOUT, opts.UserTimeout) } if opts.Interface != "" {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 23 10:53:03 UTC 2024 - 5K bytes - Viewed (0) -
docs/en/docs/async.md
So, during that time, the computer can go and do some other work, while "slow-file" 📝 finishes.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Wed Aug 28 23:33:37 UTC 2024 - 23.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ImmutableTableTest.java
assertThat(copy.columnKeySet()).containsExactlyElementsIn(original.columnKeySet()).inOrder(); } @J2ktIncompatible @GwtIncompatible // Mind-bogglingly slow in GWT @AndroidIncompatible // slow public void testOverflowCondition() { // See https://github.com/google/guava/issues/1322 for details. ImmutableTable.Builder<Integer, Integer, String> builder = ImmutableTable.builder();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/idn/Punycode.kt
result += when { c.isSurrogate() -> { val low = (if (i + 1 < limit) this[i + 1] else '\u0000') if (c.isLowSurrogate() || !low.isLowSurrogate()) { '?'.code } else { i++ 0x010000 + (c.code and 0x03ff shl 10 or (low.code and 0x03ff)) } } else -> c.code }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 03 03:04:50 UTC 2024 - 8.5K bytes - Viewed (0) -
android/guava/src/com/google/common/primitives/UnsignedLong.java
* returns the low 64 bits of the result. * * @since 14.0 */ public UnsignedLong plus(UnsignedLong val) { return fromLongBits(this.value + checkNotNull(val).value); } /** * Returns the result of subtracting this and {@code val}. If the result would have more than 64 * bits, returns the low 64 bits of the result. * * @since 14.0 */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Apr 22 13:09:25 UTC 2021 - 8.9K bytes - Viewed (0) -
guava/src/com/google/common/primitives/UnsignedLong.java
* returns the low 64 bits of the result. * * @since 14.0 */ public UnsignedLong plus(UnsignedLong val) { return fromLongBits(this.value + checkNotNull(val).value); } /** * Returns the result of subtracting this and {@code val}. If the result would have more than 64 * bits, returns the low 64 bits of the result. * * @since 14.0 */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Apr 22 13:09:25 UTC 2021 - 8.9K bytes - Viewed (0) -
fess-crawler/src/main/resources/org/codelibs/fess/crawler/mime/tika-mimetypes.xml
</magic> <magic priority="40"> <!-- Higher priority than matlab's priority=20 %% match Low priority match for %PDF-#.# near the start of the file --> <!-- Can trigger false positives, so set the priority rather low here --> <match value="%%" type="string" offset="0:128"> <match value="%PDF-1." type="string" offset="1:512"/> </match>
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Sep 21 06:46:43 UTC 2023 - 298.5K bytes - Viewed (0) -
guava/src/com/google/common/hash/Murmur3_32HashFunction.java
int k1 = mixK1(input); int h1 = mixH1(seed, k1); return fmix(h1, Ints.BYTES); } @Override public HashCode hashLong(long input) { int low = (int) input; int high = (int) (input >>> 32); int k1 = mixK1(low); int h1 = mixH1(seed, k1); k1 = mixK1(high); h1 = mixH1(h1, k1); return fmix(h1, Longs.BYTES); } @Override
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Aug 02 13:50:22 UTC 2024 - 11.8K bytes - Viewed (0) -
internal/pubsub/pubsub.go
numSubscribers int32 maxSubscribers int32 // not atomics: subs []*Sub[T] sync.RWMutex } // Publish message to the subscribers. // Note that publish is always non-blocking send so that we don't block on slow receivers. // Hence receivers should use buffered channel so as not to miss the published events. func (ps *PubSub[T, M]) Publish(item T) { ps.RLock() defer ps.RUnlock() for _, sub := range ps.subs {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Feb 06 16:57:30 UTC 2024 - 5.2K bytes - Viewed (0) -
cmd/os-rename_linux.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "syscall" ) // RenameSys is low level call in case of Linux this uses syscall.Rename() directly. func RenameSys(src, dst string) (err error) { return syscall.Rename(src, dst)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 15 01:09:38 UTC 2024 - 999 bytes - Viewed (0)