Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 94 for traceFn (0.05 sec)

  1. cmd/object-handlers-common.go

    				VersionID: dobj.VersionID,
    			}
    			traceFn := globalLifecycleSys.trace(oi)
    			// Note: NewerNoncurrentVersions action is performed only scanner today
    			tags := newLifecycleAuditEvent(lcEventSrc_Scanner, lcEvent).Tags()
    
    			// Send audit for the lifecycle delete operation
    			auditLogLifecycle(
    				ctx,
    				oi,
    				ILMExpiry, tags, traceFn)
    
    			evArgs := eventArgs{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 06:33:53 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    					transitionLogIf(es.ctx, err)
    					traceFn(ILMFreeVersionDelete, nil, err)
    					continue
    				}
    
    				// Remove this free version
    				_, err = es.objAPI.DeleteObject(es.ctx, oi.Bucket, oi.Name, ObjectOptions{
    					VersionID:        oi.VersionID,
    					InclFreeVersions: true,
    				})
    				if err == nil {
    					auditLogLifecycle(es.ctx, oi, ILMFreeVersionDelete, nil, traceFn)
    				}
    				if ignoreNotFoundErr(err) != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  3. cmd/data-scanner.go

    	if err != nil {
    		if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
    			traceFn(ILMExpiry, nil, nil)
    			return false
    		}
    		// Assume it is still there.
    		err := fmt.Errorf("DeleteObject(%s, %s): %w", obj.Bucket, obj.Name, err)
    		ilmLogOnceIf(ctx, err, "non-transition-expiry"+obj.Name)
    		traceFn(ILMExpiry, nil, err)
    		return false
    	}
    	if dobj.Name == "" {
    		dobj = obj
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  4. internal/logger/logger.go

    		if !strings.HasPrefix(file, "<autogenerated>") &&
    			!strings.HasPrefix(funcName, "runtime.") {
    			// Form and append a line of stack trace into a
    			// collection, 'trace', to build full stack trace
    			trace = append(trace, fmt.Sprintf("%v:%v:%v()", file, lineNumber, funcName))
    
    			// Ignore trace logs beyond the following conditions
    			for _, name := range matchingFuncNames {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 09:43:48 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  5. cmd/peer-rest-client.go

    				time.Sleep(5 * time.Second)
    			}
    		}
    	}()
    }
    
    // Trace - send http trace request to peer nodes
    func (client *peerRESTClient) Trace(ctx context.Context, traceCh chan<- []byte, traceOpts madmin.ServiceTraceOpts) {
    	go func() {
    		for {
    			// Blocks until context is canceled or an error occurs.
    			client.doTrace(ctx, traceCh, traceOpts)
    			select {
    			case <-ctx.Done():
    				return
    			default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

              return Lists.<LockGraphNode>newArrayListWithCapacity(3);
            }
          };
    
      /**
       * A Throwable used to record a stack trace that illustrates an example of a specific lock
       * acquisition ordering. The top of the stack trace is truncated such that it starts with the
       * acquisition of the lock in question, e.g.
       *
       * <pre>
       * com...ExampleStackTrace: LockB -&gt; LockC
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 35.9K bytes
    - Viewed (0)
  7. tensorflow/c/eager/c_api_unified_experimental_test.cc

        ASSERT_EQ(TF_OK, TF_GetCode(s)) << TF_Message(s);
        TF_DeleteAbstractTensor(add_output1);
        TF_DeleteAbstractTensor(add_output2);
        TF_DeleteOutputList(func_outputs);
      }
    
      /**
       * We traced so far this function:
       *
       *   def two_adds(a, b):
       *     my_add1 = a + b
       *     my_add2 = b + b
       *     return my_add1, my_add2
       *
       * Now we will execute this function with an eager context:
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 39.1K bytes
    - Viewed (0)
  8. internal/grid/connection.go

    	connPingInterval   time.Duration
    	blockConnect       chan struct{}
    
    	incomingBytes func(n int64) // Record incoming bytes.
    	outgoingBytes func(n int64) // Record outgoing bytes.
    	trace         *tracer       // tracer for this connection.
    	baseFlags     Flags
    	outBytes      atomic.Int64
    	inBytes       atomic.Int64
    	inMessages    atomic.Int64
    	outMessages   atomic.Int64
    	reconnects    atomic.Int64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  9. cmd/api-router.go

    //
    // The passed in handler function must be a method of `objectAPIHandlers` for
    // the name displayed in logs and trace to be accurate. The name is extracted
    // via reflection.
    //
    // When **no** flags are passed, the behavior is to trace both headers and body,
    // gzip the response and throttle the handler via `maxClients`. Each of these
    // can be disabled via the corresponding `s3HFlag`.
    //
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  10. impl/maven-core/src/main/java/org/apache/maven/internal/aether/ReverseTreeRepositoryListener.java

                if (trace.getData() instanceof CollectStepData) {
                    collectStepTrace = (CollectStepData) trace.getData();
                    break;
                }
                trace = trace.getParent();
            }
            return collectStepTrace;
        }
    
        /**
         * The event "artifact resolved" if fired WHENEVER an artifact is resolved, BUT it happens also when an artifact
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 9.8K bytes
    - Viewed (0)
Back to top