- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 75 for Initiated (0.55 sec)
-
maven-embedder/src/test/java/org/apache/maven/cli/transfer/SimplexTransferListenerTest.java
// for technical reasons we cannot throw here, even if delegate does cancel transfer listener.transferInitiated(event(session, resource, TransferEvent.EventType.INITIATED)); Thread.sleep(500); // to make sure queue is processed, cancellation applied // subsequent call will cancel assertThrows( TransferCancelledException.class,
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 20:50:56 UTC 2024 - 4.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
* `promisedStreamId` to which response frames will be delivered. Push promise frames are sent as * a part of the response to `streamId`. The `promisedStreamId` has a priority of one greater than * `streamId`. * * @param streamId client-initiated stream ID. Must be an odd number. * @param promisedStreamId server-initiated stream ID. Must be an even number.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
// blocking I/O) and this (to create streams). Such operations must synchronize on 'this' last. // This ensures that we never wait for a blocking operation while holding 'this'. /** True if this peer initiated the connection. */ internal val client: Boolean = builder.client /** User code to run in response to incoming streams or settings. */ internal val listener: Listener = builder.listener
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/resourceversion.go
) // ResourceVersionController adds the resource version obtained from a randomly nonexistent namespace // to the SVM status before the migration is initiated. This resource version is utilized for checking // freshness of GC cache before the migration is initiated. type ResourceVersionController struct { discoveryClient *discovery.DiscoveryClient metadataClient metadata.Interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
internal var errorException: IOException? = null init { if (headers != null) { check(!isLocallyInitiated) { "locally-initiated streams shouldn't have headers yet" } headersQueue += headers } else { check(isLocallyInitiated) { "remotely-initiated streams should have headers" } } } /** * Returns true if this stream is open. A stream is open until either: *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
exchange.process(transferEvent -> { TransferEvent.EventType type = transferEvent.getType(); try { switch (type) { case INITIATED: delegate.transferInitiated(transferEvent); break; case STARTED: delegate.transferStarted(transferEvent);
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 20:50:56 UTC 2024 - 8.4K bytes - Viewed (0) -
cmd/object-api-datatypes.go
// Name of the object. Object string // Upload ID identifying the multipart upload whose parts are being listed. UploadID string // Date and time at which the multipart upload was initiated. Initiated time.Time // Any metadata set during InitMultipartUpload, including encryption headers. UserDefined map[string]string } // ListPartsInfo - represents list of all parts. type ListPartsInfo struct {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 20.9K bytes - Viewed (0) -
cmd/erasure-multipart.go
Object: object, UploadID: base64.RawURLEncoding.EncodeToString([]byte(fmt.Sprintf("%s.%s", globalDeploymentID(), uploadID))), Initiated: startTime, }) populatedUploadIDs.Add(uploadID) } sort.Slice(uploads, func(i int, j int) bool { return uploads[i].Initiated.Before(uploads[j].Initiated) }) uploadIndex := 0 if uploadIDMarker != "" { for uploadIndex < len(uploads) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0) -
cmd/api-response.go
for index, upload := range multipartsInfo.Uploads { newUpload := Upload{} newUpload.UploadID = upload.UploadID newUpload.Key = s3EncodeName(upload.Object, encodingType) newUpload.Initiated = amztime.ISO8601Format(upload.Initiated.UTC()) listMultipartUploadsResponse.Uploads[index] = newUpload } return listMultipartUploadsResponse } // generate multi objects delete response.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 33.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheStrategy.kt
* set, the max age is preferred. */ private var expires: Date? = null /** * Extension header set by OkHttp specifying the timestamp when the cached HTTP request was * first initiated. */ private var sentRequestMillis = 0L /** * Extension header set by OkHttp specifying the timestamp when the cached HTTP response was * first received. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 13:24:48 UTC 2024 - 12K bytes - Viewed (0)