Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 449 for reading_ (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top