Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for processGraphChanges (0.51 sec)

  1. pkg/controller/garbagecollector/graph.go

    		Name:       s.Name,
    		APIVersion: s.APIVersion,
    		UID:        s.UID,
    	}
    }
    
    var _ fmt.Stringer = objectReference{}
    var _ logr.Marshaler = objectReference{}
    
    // The single-threaded GraphBuilder.processGraphChanges() is the sole writer of the
    // nodes. The multi-threaded GarbageCollector.attemptToDeleteItem() reads the nodes.
    // WARNING: node has different locks on different fields. setters and getters
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 13:37:56 UTC 2023
    - 7.1K bytes
    - Viewed (0)
  2. pkg/controller/garbagecollector/graph_builder.go

    	// the in-memory graph according to the changes.
    	graphChanges workqueue.TypedRateLimitingInterface[*event]
    	// uidToNode doesn't require a lock to protect, because only the
    	// single-threaded GraphBuilder.processGraphChanges() reads/writes it.
    	uidToNode *concurrentUIDToNode
    	// GraphBuilder is the producer of attemptToDelete and attemptToOrphan, GC is the consumer.
    	attemptToDelete workqueue.TypedRateLimitingInterface[*node]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  3. pkg/controller/garbagecollector/garbagecollector_test.go

    					ctx.gc.dependencyGraphBuilder.processGraphChanges(ctx.logger)
    				}
    			} else {
    				for i := 0; i < count; i++ {
    					if ctx.gc.dependencyGraphBuilder.graphChanges.Len() == 0 {
    						ctx.t.Errorf("expected at least %d pending changes, got %d", count, i+1)
    						return
    					}
    					ctx.gc.dependencyGraphBuilder.processGraphChanges(ctx.logger)
    				}
    			}
    		},
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.6K bytes
    - Viewed (0)
  4. pkg/controller/garbagecollector/garbagecollector.go

    			return forgetItem
    		}
    	}
    
    	err := gc.attemptToDeleteItem(ctx, n)
    	if err == enqueuedVirtualDeleteEventErr {
    		// a virtual event was produced and will be handled by processGraphChanges, no need to requeue this node
    		return forgetItem
    	} else if err == namespacedOwnerOfClusterScopedObjectErr {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.9K bytes
    - Viewed (0)
Back to top