Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 91 for traceFn (0.05 seconds)

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

  1. 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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
  2. 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
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 45.5K bytes
    - Click Count (0)
  3. cmd/erasure-object.go

    		if err != nil {
    			return toObjectErr(err, bucket, object)
    		}
    	}
    	traceFn := globalLifecycleSys.trace(fi.ToObjectInfo(bucket, object, opts.Versioned || opts.VersionSuspended))
    
    	destObj, err := genTransitionObjName(bucket)
    	if err != nil {
    		traceFn(ILMTransition, nil, err)
    		return err
    	}
    
    	pr, pw := xioutil.WaitPipe()
    	go func() {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  4. cmd/bucket-replication.go

    			defer wg.Done()
    			for roi := range workers[idx] {
    				select {
    				case <-ctx.Done():
    					return
    				case <-s.resyncCancelCh:
    				default:
    				}
    				traceFn := s.trace(tgt.ResetID, fmt.Sprintf("%s/%s (%s)", opts.bucket, roi.Name, roi.VersionID))
    				if roi.DeleteMarker || !roi.VersionPurgeStatus.Empty() {
    					versionID := ""
    					dmVersionID := ""
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  5. api/maven-api-core/src/main/java/org/apache/maven/api/services/RequestTrace.java

     *   <li>Supports both internal session operations and client-provided trace information</li>
     * </ul>
     *
     * <p>For internal session operations, the trace typically contains {@code *Request} objects
     * that represent the current processing state. Client code can also create traces with
     * application-specific data to provide context when invoking session methods.</p>
     *
     * <p>This trace information is particularly useful for:</p>
     * <ul>
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Oct 16 06:12:36 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  6. 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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  7. fess-crawler/src/test/java/org/codelibs/fess/crawler/exception/CrawlerSystemExceptionTest.java

            assertTrue(causeStackTrace.length > 0);
    
            // Stack traces should be different
            assertNotSame(mainStackTrace, causeStackTrace);
        }
    
        /**
         * Test printStackTrace functionality
         */
        public void test_printStackTrace() {
            CrawlerSystemException exception = new CrawlerSystemException("Print stack trace test");
    
            StringWriter stringWriter = new StringWriter();
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Wed Sep 03 14:42:53 GMT 2025
    - 20K bytes
    - Click Count (0)
  8. 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:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  9. 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
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  10. 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`.
    //
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:19 GMT 2025
    - 23.3K bytes
    - Click Count (0)
Back to Top