Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 205 for completed (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/bucket-replication_test.go

    			expectedSync: true,
    		},
    		{ // 4. replication status Complete
    			name: "existing object replication on object in Completed replication status",
    			info: ObjectInfo{
    				Size:                      100,
    				ReplicationStatusInternal: "arn1:COMPLETED",
    				ReplicationStatus:         replication.Completed,
    				VersionID:                 "a3348c34-c352-4498-82f0-1098e8b34df9",
    			},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/Exchange.kt

          }
          try {
            super.close()
            complete(null)
          } catch (e: IOException) {
            throw complete(e)!!
          }
        }
    
        /** If [e] is non-null, this will return a non-null value. */
        private fun complete(e: IOException?): IOException? {
          if (completed) return e
          completed = true
          return bodyComplete(
            bytesRead = bytesReceived,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 10.5K bytes
    - Click Count (0)
  3. src/main/java/jcifs/smb/SpnegoContext.java

            if (!this.completed) {
                throw new CIFSException("Context is not established");
            }
            this.mechContext.verifyMIC(data, mic);
        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.smb.SSPContext#isMICAvailable()
         */
        @Override
        public boolean isMICAvailable() {
            if (!this.completed) {
                return false;
            }
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 14.5K bytes
    - Click Count (0)
  4. tests/test_dependency_contextmanager.py

        state["/async"] = "asyncgen started"
        yield state["/async"]
        state["/async"] = "asyncgen completed"
    
    
    def generator_state(state: dict[str, str] = Depends(get_state)):
        state["/sync"] = "generator started"
        yield state["/sync"]
        state["/sync"] = "generator completed"
    
    
    async def asyncgen_state_try(state: dict[str, str] = Depends(get_state)):
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  5. cmd/bucket-stats.go

    }
    
    // BucketReplicationStats represents inline replication statistics
    // such as pending, failed and completed bytes in total for a bucket
    type BucketReplicationStats struct {
    	Stats map[string]*BucketReplicationStat `json:",omitempty"`
    	// Completed size in bytes
    	ReplicatedSize int64 `json:"completedReplicationSize"`
    	// Total Replica size in bytes
    	ReplicaSize int64 `json:"replicaSize"`
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb/NtStatus.java

         * block is automatically generated from the ntstatus package.
         */
    
        /** The operation completed successfully */
        int NT_STATUS_SUCCESS = 0x00000000;
        /** The request is pending */
        int NT_STATUS_PENDING = 0x00000103;
        /** A notify change request is being completed and information is being returned */
        int NT_STATUS_NOTIFY_ENUM_DIR = 0x0000010C;
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 14.9K bytes
    - Click Count (0)
  7. guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *       be "done" as soon as <i>that</i> {@code Future} completes in any way. Notably, a {@code
     *       Future} is "completed" even if it is cancelled while its underlying work continues on a
     *       thread, an RPC, etc. The {@code Future} is also "completed" if it fails "early" -- for
     *       example, if the deadline expires on a {@code Future} returned from {@link
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 01:35:55 GMT 2025
    - 22.1K bytes
    - Click Count (0)
  8. docs/bucket/replication/DESIGN.md

    The replication design for multiple sites works in a similar manner as described above for two site scenario. However there are some
    important exceptions.
    
    Replication status on the source cluster will be marked as `COMPLETED` only after replication is completed on all targets. If one or more targets failed replication, the replication status is reflected as `PENDING`.
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  9. cmd/bucket-replication-stats.go

    	rs.Endpoint = endpoint
    	rs.Secure = secure
    	rs.TransferSize = n
    	rs.Arn = arn
    	rs.TransferDuration = duration
    	rs.opType = opType
    	switch status {
    	case replication.Completed:
    		rs.Completed = true
    	case replication.Pending:
    		rs.Pending = true
    	case replication.Failed:
    		rs.Failed = true
    		rs.Err = err
    	}
    }
    
    // GetAll returns replication metrics for all buckets at once.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 13.6K bytes
    - Click Count (0)
  10. src/main/java/jcifs/internal/smb2/rdma/disni/DisniRdmaConnection.java

                // sgeList.add(sge);
                //
                // sendWR.setSg_list(sgeList);
                // endpoint.postSend(Arrays.asList(sendWR)).execute().free();
    
                log.debug("DiSNI RDMA send completed, {} bytes", data.remaining());
    
            } catch (Exception e) {
                state = RdmaConnectionState.ERROR;
                throw new IOException("DiSNI RDMA send failed", e);
            }
        }
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 10.2K bytes
    - Click Count (0)
Back to Top