- Sort Score
- Num 10 results
- Language All
Results 641 - 650 of 856 for readOp (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/main/java/jcifs/internal/smb2/Smb2Constants.java
/** * Unspecified session ID value */ public static final long UNSPECIFIED_SESSIONID = 0xFFFFFFFFFFFFFFFFL; /** * SMB2 Channel constant for RDMA V1 * Used in SMB2 READ and WRITE requests to indicate RDMA channel */ public static final int SMB2_CHANNEL_RDMA_V1 = 0x00000001; /** * SMB2 Channel constant for RDMA V1 invalidateCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 4.5K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/nego/Smb2RdmaTransformCapabilitiesContext.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 24 00:12:28 GMT 2025 - 4.4K bytes - Click Count (0) -
compat/maven-settings-builder/src/main/java/org/apache/maven/settings/building/SettingsProblem.java
* track the problem back to its origin. A concrete example for such a source hint can be the file path or URL from * which the settings were read. * * @return The hint about the source of the problem or an empty string if unknown, never {@code null}. */ String getSource(); /**Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 3.5K bytes - Click Count (0) -
helm/minio/templates/_helper_create_bucket.txt
{{- end }} # connectToMinio # Use a check-sleep-check loop to wait for MinIO service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 LIMIT=29 # Allow 30 attempts set -e # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) SECRET=$(cat /config/rootPassword) set +e # The connections to minio are allowed to fail. echo "Connecting to MinIO server: $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT"Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 07 09:47:02 GMT 2025 - 3.5K bytes - Click Count (0) -
src/bytes/boundary_test.go
import ( . "bytes" "syscall" "testing" ) // This file tests the situation where byte operations are checking // data very near to a page boundary. We want to make sure those // operations do not read across the boundary and cause a page // fault where they shouldn't. // These tests run only on linux. The code being tested is // not OS-specific, so it does not need to be tested on all // operating systems.
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Thu Nov 30 20:05:58 GMT 2023 - 2.8K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/rank/fusion/RankFusionProcessorConcurrencyTest.java
final int threadId = i; executor.submit(() -> { try { startLatch.await(); // Wait for all threads to be ready for (int j = 0; j < searchersPerThread; j++) { processor.register(new TestSearcher(10 + threadId * 10 + j));Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 11 08:43:05 GMT 2026 - 13.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/RequestBody.kt
* [RequestBody.writeTo] after that method returns. For duplex requests bodies that condition is * lifted. Such writes occur on an application-provided thread and may occur concurrently with * reads of the [ResponseBody]. For duplex request bodies, [writeTo] should return * quickly, possibly by handing off the provided request body to another thread to perform * writing. *
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 14:16:29 GMT 2025 - 9.3K bytes - Click Count (0) -
src/test/java/jcifs/dcerpc/msrpc/lsarpcIntegrationTest.java
decodedName.decode(decodeBuffer); // Verify the decoded data matches assertEquals(translatedName.sid_type, decodedName.sid_type); // The decode process doesn't preserve the original length, it reads from the buffer assertNotNull(decodedName.name); assertNotNull(decodedName.name.buffer); // Buffer length is based on maximum_length/2 from the encoded data
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 10.8K bytes - Click Count (0) -
internal/event/target/webhook.go
} return fmt.Errorf("%s returned '%s', please check your endpoint configuration", target.args.Endpoint, resp.Status) } // SendFromStore - reads an event from store and sends it to webhook. func (target *WebhookTarget) SendFromStore(key store.Key) error { if err := target.init(); err != nil { return err } eventData, eErr := target.store.Get(key)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 8.8K bytes - Click Count (0) -
cmd/batch-expire.go
r.line, r.col = val.Line, val.Column return nil } // Notify notifies notification endpoint if configured regarding job failure or success. func (r BatchJobExpire) Notify(ctx context.Context, body io.Reader) error { if r.NotificationCfg.Endpoint == "" { return nil } ctx, cancel := context.WithTimeout(ctx, 10*time.Second) defer cancel()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Apr 22 11:16:32 GMT 2025 - 23K bytes - Click Count (0)