Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 1,174 for readN (0.89 sec)

  1. src/main/java/jcifs/internal/smb2/lease/LeaseManager.java

                    try {
                        // Invalidate any cached read data
                        // This would typically clear file's internal read buffers
                        // For now, we log the action as the actual implementation
                        // depends on SmbFile's internal caching mechanism
                        log.info("Invalidated read cache for: {}", path);
                    } catch (Exception e) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  2. src/test/java/jcifs/smb1/smb1/NetShareEnumResponseTest.java

                    0x05, 0x00 // totalAvailableEntries = 5
            };
    
            int bytesRead = response.readParametersWireFormat(buffer, 0, buffer.length);
    
            assertEquals(8, bytesRead, "Should read 8 bytes for parameters.");
            assertEquals(0, response.status, "Status should be 0.");
            assertEquals(2, response.numEntries, "Number of entries should be 2.");
        }
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    	}
    
    	// We can safely allow RenameFile errors up to len(er.getDisks()) - writeQuorum
    	// otherwise return failure. Cleanup successful renames.
    	return evalDisks(disks, errs), err
    }
    
    // PutObjectPart - reads incoming stream and internally erasure codes
    // them. This call is similar to single put operation but it is part
    // of the multipart transaction.
    //
    // Implements S3 compatible Upload Part API.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  4. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

              openClientSockets.remove(raw)
              return false
            }
    
            if (!dispatcher.peek().inTunnel) return true // No more tunnel requests.
          }
        }
    
        /**
         * Reads a request and writes its response. Returns true if further calls should be attempted
         * on the socket.
         */
        @Throws(IOException::class, InterruptedException::class)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 20:36:00 UTC 2025
    - 40.3K bytes
    - Viewed (0)
  5. src/main/java/jcifs/ACE.java

        /**
         * Permission to read file attributes
         */
        int FILE_READ_ATTRIBUTES = 0x00000080; // 8
        /**
         * Permission to write file attributes
         */
        int FILE_WRITE_ATTRIBUTES = 0x00000100; // 9
        /**
         * Standard delete permission
         */
        int DELETE = 0x00010000; // 16
        /**
         * Permission to read the security descriptor
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-HostnamesCommon.kt

      var b = addressOffset
    
      var i = pos
      while (i < limit) {
        if (b == address.size) return false // Too many groups.
    
        // Read a delimiter.
        if (b != addressOffset) {
          if (input[i] != '.') return false // Wrong delimiter.
          i++
        }
    
        // Read 1 or more decimal digits for a value in 0..255.
        var value = 0
        val groupOffset = i
        while (i < limit) {
          val c = input[i]
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 11.2K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Request.kt

          }
    
        /**
         * Attaches [tag] to the request using [T] as a key. Tags can be read from a request using
         * [Request.tag]. Use null to remove any existing tag assigned for [T].
         *
         * Use this API to attach timing, debugging, or other application data to a request so that
         * you may read it in interceptors, event listeners, or callbacks.
         */
        @JvmName("reifiedTag")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 13.1K bytes
    - Viewed (1)
  8. src/main/java/jcifs/internal/smb2/rdma/RdmaTransport.java

            }
        }
    
        /**
         * Performs RDMA read operation.
         *
         * @param buffer the buffer to read into
         * @param remoteAddress remote memory address
         * @param remoteKey remote access key
         * @param length number of bytes to read
         * @return number of bytes read
         * @throws IOException if operation fails
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  9. src/test/java/jcifs/smb1/smb1/Trans2SetFileInformationResponseTest.java

        /**
         * Test for the readSetupWireFormat method.
         * It should always return 0.
         */
        @Test
        void testReadSetupWireFormat() {
            byte[] buffer = new byte[10];
            // The method should not read anything and return 0
            assertEquals(0, response.readSetupWireFormat(buffer, 0, 10), "readSetupWireFormat should return 0.");
        }
    
        /**
         * Test for the readParametersWireFormat method.
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  10. android/guava-testlib/src/com/google/common/testing/FakeTicker.java

    import org.jspecify.annotations.NullMarked;
    
    /**
     * A Ticker whose value can be advanced programmatically in test.
     *
     * <p>The ticker can be configured so that the time is incremented whenever {@link #read} is called:
     * see {@link #setAutoIncrementStep}.
     *
     * <p>This class is thread-safe.
     *
     * @author Jige Yu
     * @since 10.0
     */
    @NullMarked
    @GwtCompatible
    public class FakeTicker extends Ticker {
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Apr 14 15:16:19 UTC 2025
    - 4.1K bytes
    - Viewed (0)
Back to top