- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 449 for reading_ (0.09 sec)
-
guava/src/com/google/common/graph/MapIteratorCache.java
* * Note about volatile: volatile doesn't make it safe to read from a mutable graph in one thread * while writing to it in another. All it does is help with _reading_ from multiple threads * concurrently. For more information, see AbstractNetworkTest.concurrentIteration. */ @CheckForNull private transient volatile Entry<K, V> cacheEntry; MapIteratorCache(Map<K, V> backingMap) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 4.7K bytes - Viewed (0) -
src/main/java/jcifs/netbios/NameQueryResponse.java
return 0; } boolean groupName = ( ( src[ srcIndex ] & 0x80 ) == 0x80 ) ? true : false; int nodeType = ( src[ srcIndex ] & 0x60 ) >> 5; srcIndex += 2; int address = readInt4(src, srcIndex); if ( address != 0 ) { this.addrEntry[ this.addrIndex ] = new NbtAddress(this.recordName, address, groupName, nodeType); } else {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Dec 20 14:09:34 UTC 2020 - 2.2K bytes - Viewed (0) -
android/guava/src/com/google/common/io/LineBuffer.java
import com.google.common.annotations.J2ktIncompatible; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.io.IOException; /** * Package-protected abstract class that implements the line reading algorithm used by {@link * LineReader}. Line separators are per {@link java.io.BufferedReader}: line feed, carriage return, * or carriage return followed immediately by a linefeed. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 3.9K bytes - Viewed (0) -
guava/src/com/google/common/io/LineBuffer.java
import com.google.common.annotations.J2ktIncompatible; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.io.IOException; /** * Package-protected abstract class that implements the line reading algorithm used by {@link * LineReader}. Line separators are per {@link java.io.BufferedReader}: line feed, carriage return, * or carriage return followed immediately by a linefeed. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 3.9K bytes - Viewed (0) -
docs/sts/ldap.go
if f, err := os.Open(sessionPolicyFile); err != nil { log.Fatalf("Unable to open session policy file %s: %v", sessionPolicyFile, err) } else { bs, err := io.ReadAll(f) if err != nil { log.Fatalf("Error reading session policy file: %v", err) } policy = string(bs) } ldapOpts = append(ldapOpts, cr.LDAPIdentityPolicyOpt(policy)) } if expiryDuration != 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 07 12:59:47 UTC 2024 - 4K bytes - Viewed (0) -
docs/sts/assume-role.go
if f, err := os.Open(sessionPolicyFile); err != nil { log.Fatalf("Unable to open session policy file: %v", err) } else { defer f.Close() bs, err := io.ReadAll(f) if err != nil { log.Fatalf("Error reading session policy file: %v", err) } policy = string(bs) } stsOpts.Policy = policy } if expiryDuration != 0 { stsOpts.DurationSeconds = int(expiryDuration.Seconds()) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Aug 17 01:24:54 UTC 2024 - 4.4K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbComSessionSetupAndXResponse.java
int start = bufferIndex; isLoggedInAsGuest = ( buffer[bufferIndex] & 0x01 ) == 0x01 ? true : false; bufferIndex += 2; if (extendedSecurity) { int blobLength = readInt2(buffer, bufferIndex); bufferIndex += 2; blob = new byte[blobLength]; } return bufferIndex - start; } int readBytesWireFormat( byte[] buffer, int bufferIndex ) {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 2.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/trans/nt/NtTransQuerySecurityDescResponse.java
return 0; } @Override protected int readParametersWireFormat ( byte[] buffer, int bufferIndex, int len ) { this.length = SMBUtil.readInt4(buffer, bufferIndex); return 4; } @Override protected int readDataWireFormat ( byte[] buffer, int bufferIndex, int len ) { int start = bufferIndex;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 2.8K bytes - Viewed (0) -
compat/maven-artifact/src/test/java/org/apache/maven/artifact/versioning/ComparableVersionTest.java
checkVersionsOrder(a, c); checkVersionsOrder(c, d); checkVersionsOrder(b, d); checkVersionsOrder(a, d); } /** * Test all versions are equal when starting with many leading zeroes regardless of string length * (related to MNG-6572 optimization) */ @Test void testVersionEqualWithLeadingZeroes() { // versions with string lengths from 1 to 19
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 14K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
throw complete(e) } } fun <E : IOException?> complete(e: E): E { if (completed) return e completed = true // If the body is closed without reading any bytes send a responseBodyStart() now. if (e == null && invokeStartEvent) { invokeStartEvent = false eventListener.responseBodyStart(call) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.2K bytes - Viewed (0)