- Sort Score
- Num 10 results
- Language All
Results 771 - 780 of 1,956 for Read (0.02 seconds)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Huffman.kt
val terminalBitCount: Int /** Construct an internal node. */ constructor() { this.children = arrayOfNulls(256) this.symbol = 0 // Not read. this.terminalBitCount = 0 // Not read. } /** Construct a terminal node. */ constructor(symbol: Int, bits: Int) { this.children = null this.symbol = symbol val b = bits and 0x07Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 11K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultWagonManager.java
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Sat Apr 05 11:52:05 GMT 2025 - 29.9K bytes - Click Count (0) -
cmd/generic-handlers.go
func setBrowserRedirectMiddleware(h http.Handler) http.Handler { return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { read := r.Method == http.MethodGet || r.Method == http.MethodHead // Re-direction is handled specifically for browser requests. if !guessIsHealthCheckReq(r) && guessIsBrowserReq(r) && read && globalBrowserRedirect { // Fetch the redirect location if any. if u := getRedirectLocation(r); u != nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 20.7K bytes - Click Count (1) -
docs/SMB3_IMPLEMENTATION_PLAN.md
- [ ] Implement RDMA transport layer - [ ] Add RDMA buffer registration - [ ] Create RDMA read/write operations - [ ] Implement RDMA credits management - [ ] Add fallback to TCP when RDMA unavailable #### 5.3 Integration Points - Create new transport type alongside TCP - Modify negotiation to include RDMA contexts - Update read/write operations for RDMA --- ### Phase 6: Witness Protocol
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 10.7K bytes - Click Count (0) -
src/test/java/jcifs/dcerpc/msrpc/MsrpcShareGetInfoTest.java
// Replace info field Field infoField = msrpcShareGetInfo.getClass().getSuperclass().getDeclaredField("info"); infoField.setAccessible(true); infoField.set(msrpcShareGetInfo, info502); // This should throw an ArrayIndexOutOfBoundsException when trying to read beyond arrayCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 14.3K bytes - Click Count (0) -
cmd/os_unix.go
return nil } return osErrToFileErr(err) } } defer syscall.Close(fd) bufp := direntPool.Get() defer direntPool.Put(bufp) buf := *bufp boff := 0 // starting read position in buf nbuf := 0 // end valid data in buf for { if boff >= nbuf { boff = 0 stop := globalOSMetrics.time(osMetricReadDirent) nbuf, err = syscall.ReadDirent(fd, buf) stop()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 9.3K bytes - Click Count (0) -
cmd/erasure-server-pool.go
derrs := make([]error, len(poolIndices)) dobjects := make([]ObjectInfo, len(poolIndices)) // Delete concurrently in all server pools that reported no error or read quorum error // where the read quorum issue is from metadata inconsistency. var wg sync.WaitGroup for idx, pe := range poolIndices { if v, ok := pe.Err.(InsufficientReadQuorum); ok && v.Type != RQInconsistentMeta {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 89.2K bytes - Click Count (0) -
docs/recipes.md
``` ### Response Caching ([.kt][CacheResponseKotlin], [.java][CacheResponseJava]) To cache responses, you'll need a cache directory that you can read and write to, and a limit on the cache's size. The cache directory should be private, and untrusted applications should not be able to read its contents!
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:01:42 GMT 2026 - 47.8K bytes - Click Count (0) -
src/main/java/jcifs/smb1/netbios/NodeStatusResponse.java
final int namesLength = numberOfNames * 18; final int statsLength = rDataLength - namesLength - 1; numberOfNames = src[srcIndex] & 0xFF; srcIndex++; // gotta read the mac first so we can populate addressArray with it System.arraycopy(src, srcIndex + namesLength, macAddress, 0, 6); srcIndex += readNodeNameArray(src, srcIndex); stats = new byte[statsLength];Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 07:14:38 GMT 2025 - 5.8K bytes - Click Count (0) -
internal/config/policy/opa/config.go
if o.args.AuthToken != "" { req.Header.Set("Authorization", o.args.AuthToken) } resp, err := o.client.Do(req) if err != nil { return false, err } defer o.args.CloseRespFn(resp.Body) // Read the body to be saved later. opaRespBytes, err := io.ReadAll(resp.Body) if err != nil { return false, err } // Handle large OPA responses when OPA URL is ofCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.3K bytes - Click Count (0)