- Sort Score
- Num 10 results
- Language All
Results 1051 - 1060 of 1,508 for Pread (0.06 seconds)
-
helm-releases/minio-4.0.12.tgz
actions: # - "s3:CreateBucket" # - "s3:DeleteBucket" # - "s3:GetBucketLocation" # - "s3:ListBucket" # - "s3:ListBucketMultipartU" ## readonlyexamplepolic policy grants access to buckets with name starting with example. ## In addition, grants objects read permissions on buckets starting with example. # - name: readonlyexamplepolic # statements: # - resources: # - 'arn:aws:s3:::example*/*' # actions: # - "s3:GetObject" # - resources: # - 'arn:aws:s3:::example*' # actions: # - "s3:GetBucketLocation" #...
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Aug 14 05:50:43 GMT 2022 - 19.4K bytes - Click Count (0) -
docs/smb3-features/03-multi-channel-design.md
return transport; } catch (IOException e) { throw new RuntimeException("Failed to create transport", e); } }); } ``` ### 5.3 Read/Write Operations with Multi-Channel ```java // In SmbFile.java public void optimizedLargeRead(byte[] buffer, long offset, int length) throws IOException {Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 39.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
// A happens-before edge between the writes of these fields and their reads exists, because // in order to read these fields, the corresponding write to incompleteOutputCount must have // been read. private boolean wasCancelled = false; private boolean shouldInterrupt = true; private final AtomicInteger incompleteOutputCount;Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 64.3K bytes - Click Count (0) -
internal/rest/client.go
} return req, nil } type respBodyMonitor struct { io.ReadCloser expectTimeouts bool errorStatusOnce sync.Once } func (r *respBodyMonitor) Read(p []byte) (n int, err error) { n, err = r.ReadCloser.Read(p) r.errorStatus(err) return n, err } func (r *respBodyMonitor) Close() (err error) { err = r.ReadCloser.Close() r.errorStatus(err) return err }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 14.7K bytes - Click Count (0) -
internal/bucket/lifecycle/filter.go
} return e.EncodeToken(xml.EndElement{Name: start.Name}) } // UnmarshalXML - decodes XML data. func (f *Filter) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) { f.set = true for { // Read tokens from the XML document in a stream. t, err := d.Token() if err != nil { if err == io.EOF { break } return err } if se, ok := t.(xml.StartElement); ok {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Sep 04 17:01:26 GMT 2024 - 6.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/AbstractTableReadTest.java
import java.util.Objects; import junit.framework.TestCase; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; /** * Test cases for {@link Table} read operations. * * @author Jared Levy */ @GwtCompatible @NullMarked public abstract class AbstractTableReadTest<C extends @Nullable Character> extends TestCase { protected Table<String, Integer, C> table;Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 16:03:47 GMT 2025 - 6.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/service/CrawlingInfoService.java
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 19.9K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/storage/StorageClient.java
* <li>connectTimeout - Connection timeout in milliseconds (default: 10000)</li> * <li>writeTimeout - Write timeout in milliseconds (default: 10000)</li> * <li>readTimeout - Read timeout in milliseconds (default: 10000)</li> * </ul> * * <p>The client supports URLs in the format: {@code storage://bucket-name/object-path} * * <p>Features: * <ul>
Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Mon Nov 24 03:59:47 GMT 2025 - 20K bytes - Click Count (2) -
src/test/java/jcifs/internal/smb2/lease/LeaseManagerTest.java
assertTrue(fullEntry.hasReadCache()); assertTrue(fullEntry.hasWriteCache()); assertTrue(fullEntry.hasHandleCache()); // Test read-only lease Smb2LeaseKey readKey = leaseManager.requestLease(path + "2", Smb2LeaseState.SMB2_LEASE_READ_CACHING); leaseManager.updateLease(readKey, Smb2LeaseState.SMB2_LEASE_READ_CACHING);Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 21 00:16:17 GMT 2025 - 13.2K bytes - Click Count (0) -
docs/pt/docs/advanced/events.md
Um **gerenciador de contexto** em Python é algo que você pode usar em uma declaração `with`, por exemplo, `open()` pode ser usado como um gerenciador de contexto: ```Python with open("file.txt") as file: file.read() ``` Em versões mais recentes do Python, há também um **gerenciador de contexto assíncrono**. Você o usaria com `async with`: ```Python async with lifespan(app): await do_stuff() ```
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 8.8K bytes - Click Count (0)