- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 186 for ending2 (0.22 sec)
-
android/guava/src/com/google/common/graph/Graphs.java
NodeVisitState state = visitedNodes.get(node); if (state == NodeVisitState.COMPLETE) { return false; } if (state == NodeVisitState.PENDING) { return true; } visitedNodes.put(node, NodeVisitState.PENDING); for (N nextNode : graph.successors(node)) { if (canTraverseWithoutReusingEdge(graph, nextNode, previousNode)
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 21.2K bytes - Viewed (0) -
internal/grid/muxclient.go
select { case <-m.ctx.Done(): if debugPrint { fmt.Println("Client sending disconnect to mux", m.MuxID) } m.addErrorNonBlockingClose(internalResp, context.Cause(m.ctx)) errState = true continue case req, ok := <-requests: if !ok { // Done send EOF if debugPrint { fmt.Println("Client done, sending EOF to mux", m.MuxID) } msg := message{ Op: OpMuxClientMsg,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/bucket/replication/datatypes.go
//go:generate msgp -file=$GOFILE // StatusType of Replication for x-amz-replication-status header type StatusType string // Type - replication type enum type Type int const ( // Pending - replication is pending. Pending StatusType = "PENDING" // Completed - replication completed ok. Completed StatusType = "COMPLETED" // CompletedLegacy was called "COMPLETE" incorrectly. CompletedLegacy StatusType = "COMPLETE"
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 1.5K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
} // VersionPurgeStatusType represents status of a versioned delete or permanent delete w.r.t bucket replication type VersionPurgeStatusType string const ( // Pending - versioned delete replication is pending. Pending VersionPurgeStatusType = "PENDING" // Complete - versioned delete replication is now complete, erase version on disk. Complete VersionPurgeStatusType = "COMPLETE"
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 26.2K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultProfileInjector.java
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 9.5K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jan 22 19:37:41 GMT 2024 - 12.3K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
object FailHandshake : SocketPolicy /** * Shutdown the socket input after sending the response. For testing bad behavior. * * See [SocketPolicy] for reasons why this can cause test flakiness and how to avoid it. */ object ShutdownInputAtEnd : SocketPolicy /** * Shutdown the socket output after sending the response. For testing bad behavior. *
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/bucket-stats.go
// in Queue stats for bucket - from qCache QStat InQueueMetric `json:"queued"` // Deprecated fields // Pending size in bytes PendingSize int64 `json:"pendingReplicationSize"` // Failed size in bytes FailedSize int64 `json:"failedReplicationSize"` // Total number of pending operations including metadata updates PendingCount int64 `json:"pendingReplicationCount"`
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 13.1K bytes - Viewed (0) -
cmd/tier-journal.go
VersionID string `msg:"vid"` TierName string `msg:"tier"` } const ( tierJournalVersion = 1 tierJournalHdrLen = 2 // 2 bytes ) var errUnsupportedJournalVersion = errors.New("unsupported pending deletes journal version") func newTierDiskJournal() *tierDiskJournal { return &tierDiskJournal{} } // NewTierJournal initializes tier deletion journal func NewTierJournal() *TierJournal { j := &TierJournal{
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/entity/PingResponse.java
private static final String NUMBER_OF_NODES = "number_of_nodes"; private static final String NUMBER_OF_DATA_NODES = "number_of_data_nodes"; private static final String NUMBER_OF_PENDING_TASKS = "number_of_pending_tasks"; private static final String NUMBER_OF_IN_FLIGHT_FETCH = "number_of_in_flight_fetch"; private static final String DELAYED_UNASSIGNED_SHARDS = "delayed_unassigned_shards";
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.9K bytes - Viewed (0)