Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 281 - 290 of 846 for handle (0.04 seconds)

  1. src/cmd/asm/internal/asm/operand_test.go

    	"cmd/asm/internal/arch"
    	"cmd/asm/internal/lex"
    	"cmd/internal/obj"
    )
    
    // A simple in-out test: Do we print what we parse?
    
    func setArch(goarch string) (*arch.Arch, *obj.Link) {
    	buildcfg.GOOS = "linux" // obj can handle this OS for all architectures.
    	buildcfg.GOARCH = goarch
    	architecture := arch.Set(goarch, false)
    	if architecture == nil {
    		panic("asm: unrecognized architecture " + goarch)
    	}
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Aug 29 18:31:05 GMT 2023
    - 23.9K bytes
    - Click Count (0)
  2. src/archive/tar/writer.go

    	realName, realSize := hdr.Name, hdr.Size
    
    	// TODO(dsnet): Re-enable this when adding sparse support.
    	// See https://golang.org/issue/22735
    	/*
    		// Handle sparse files.
    		var spd sparseDatas
    		var spb []byte
    		if len(hdr.SparseHoles) > 0 {
    			sph := append([]sparseEntry{}, hdr.SparseHoles...) // Copy sparse map
    			sph = alignSparseEntries(sph, hdr.Size)
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Feb 03 16:38:43 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  3. cmd/object-api-errors.go

    package cmd
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"io"
    )
    
    // Converts underlying storage error. Convenience function written to
    // handle all cases where we have known types of errors returned by
    // underlying storage layer.
    func toObjectErr(oerr error, params ...string) error {
    	if oerr == nil {
    		return nil
    	}
    
    	// Unwarp the error first
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 09 02:05:14 GMT 2024
    - 22.1K bytes
    - Click Count (0)
  4. src/bytes/buffer.go

    // if it becomes too large, WriteRune will panic with [ErrTooLarge].
    func (b *Buffer) WriteRune(r rune) (n int, err error) {
    	// Compare as uint32 to correctly handle negative runes.
    	if uint32(r) < utf8.RuneSelf {
    		b.WriteByte(byte(r))
    		return 1, nil
    	}
    	b.lastRead = opInvalid
    	m, ok := b.tryGrowByReslice(utf8.UTFMax)
    	if !ok {
    		m = b.grow(utf8.UTFMax)
    	}
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Nov 14 19:01:17 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  5. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

      /* use AbstractService for state management */
      private final AbstractService delegate = new ServiceDelegate();
    
      @WeakOuter
      private final class ServiceDelegate extends AbstractService {
    
        // A handle to the running task so that we can stop it when a shutdown has been requested.
        // These two fields are volatile because their values will be accessed from multiple threads.
        private volatile @Nullable Cancellable runningTask;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 27.8K bytes
    - Click Count (0)
  6. cmd/test-utils_test.go

    // Usage hint: Should be used at the end of the API end points tests (ex: check the last few lines of `testAPIListObjectPartsHandler`),
    // need a sample HTTP request to be sent as argument so that the relevant handler is called, the handler registration is expected
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (0)
  7. cmd/utils.go

    		RequestID:    reqID,
    		RemoteHost:   handlers.GetSourceIP(r),
    		Host:         getHostName(r),
    		UserAgent:    r.UserAgent(),
    		API:          api,
    		BucketName:   bucket,
    		ObjectName:   object,
    		VersionID:    strings.TrimSpace(r.Form.Get(xhttp.VersionID)),
    	}
    
    	return logger.SetReqInfo(r.Context(), reqInfo)
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  8. cmd/peer-rest-client.go

    				return nil
    			}
    			gridConn.Store(gc)
    			return gc
    		},
    	}
    }
    
    // Wrapper to restClient.Call to handle network errors, in case of network error the connection is marked disconnected
    // permanently. The only way to restore the connection is at the xl-sets layer by xlsets.monitorAndConnectEndpoints()
    // after verifying format.json
    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. cmd/metacache-entries.go

    		return FileInfo{
    			Volume: bucket,
    			Name:   e.name,
    			Mode:   uint32(os.ModeDir),
    		}, nil
    	}
    	if e.cached != nil {
    		if len(e.cached.versions) == 0 {
    			// This special case is needed to handle xlMeta.versions == 0
    			return FileInfo{
    				Volume:   bucket,
    				Name:     e.name,
    				Deleted:  true,
    				IsLatest: true,
    				ModTime:  timeSentinel1970,
    			}, nil
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 08 15:29:58 GMT 2024
    - 24.1K bytes
    - Click Count (0)
  10. CHANGELOG/CHANGELOG-1.20.md

    ### Uncategorized
    
    - GCE L4 Loadbalancers now handle > 5 ports in service spec correctly. ([#99595](https://github.com/kubernetes/kubernetes/pull/99595), [@prameshj](https://github.com/prameshj)) [SIG Cloud Provider]
    
    ## Dependencies
    
    ### Added
    _Nothing has changed._
    Created: Fri Dec 26 09:05:12 GMT 2025
    - Last Modified: Wed Jan 19 21:05:45 GMT 2022
    - 409K bytes
    - Click Count (0)
Back to Top