Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for newUploader (0.98 sec)

  1. src/cmd/vendor/golang.org/x/telemetry/internal/upload/run.go

    	uploadServerURL string
    	startTime       time.Time
    
    	cache parsedCache
    
    	logFile *os.File
    	logger  *log.Logger
    }
    
    // newUploader creates a new uploader to use for running the upload for the
    // given config.
    //
    // Uploaders should only be used for one call to [uploader.Run].
    func newUploader(rcfg RunConfig) (*uploader, error) {
    	// Determine the upload directory.
    	var dir telemetry.Dir
    	if rcfg.TelemetryDir != "" {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 21:12:15 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. pkg/kubelet/kubeletconfig/configfiles/configfiles.go

    	kubeletCodecs *serializer.CodecFactory
    	// kubeletFile is an absolute path to the file containing a serialized KubeletConfiguration
    	kubeletFile string
    }
    
    // NewFsLoader returns a Loader that loads a KubeletConfiguration from the `kubeletFile`
    func NewFsLoader(fs utilfs.Filesystem, kubeletFile string) (Loader, error) {
    	_, kubeletCodecs, err := kubeletscheme.NewSchemeAndCodecs(serializer.EnableStrict)
    	if err != nil {
    		return nil, err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 10 17:13:59 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  3. subprojects/core/src/main/java/org/gradle/api/internal/initialization/loadercache/DefaultClassLoaderCache.java

                    CachedClassLoader newLoader = getAndRetainLoader(spec, id, factoryFunction);
                    byId.put(id, newLoader);
    
                    if (cachedLoader != null) {
                        LOGGER.debug("Releasing previous classloader for {}", id);
                        cachedLoader.release(id);
                    }
                    return newLoader.classLoader;
                } else {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Dec 11 13:37:56 UTC 2023
    - 10.4K bytes
    - Viewed (0)
  4. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/classloader/TransformReplacer.java

        }
    
        private Loader storeIfAbsent(ProtectionDomain domain, Loader newLoader) {
            Loader oldLoader = loaders.putIfAbsent(domain, newLoader);
            if (oldLoader != null) {
                // Discard the new loader, someone beat us with storing it.
                IoActions.closeQuietly(newLoader);
                return oldLoader;
            }
            return newLoader;
        }
    
        @Override
        public void close() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

      }
    
      public void testDecoupledLoader() {
        FinalizableReferenceQueue.DecoupledLoader decoupledLoader =
            new FinalizableReferenceQueue.DecoupledLoader() {
              @Override
              URLClassLoader newLoader(URL base) {
                return new DecoupledClassLoader(new URL[] {base});
              }
            };
    
        Class<?> finalizerCopy = decoupledLoader.loadFinalizer();
    
        assertNotNull(finalizerCopy);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 10 19:21:11 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  6. src/cmd/link/internal/loader/loader_test.go

    	idx := uint32(len(ldr.objSyms))
    	st := loadState{l: ldr}
    	return st.addSym(name, 0, or, idx, nonPkgDef, &goobj.Sym{})
    }
    
    func mkLoader() *Loader {
    	er := ErrorReporter{}
    	ldr := NewLoader(0, &er)
    	er.ldr = ldr
    	return ldr
    }
    
    func TestAddMaterializedSymbol(t *testing.T) {
    	ldr := mkLoader()
    	dummyOreader := oReader{version: -1, syms: make([]Sym, 100)}
    	or := &dummyOreader
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 07 19:08:09 UTC 2024
    - 12K bytes
    - Viewed (0)
  7. cmd/kubelet/app/server.go

    	// compute absolute path based on current working dir
    	kubeletConfigFile, err := filepath.Abs(name)
    	if err != nil {
    		return nil, fmt.Errorf(errFmt, name, err)
    	}
    	loader, err := configfiles.NewFsLoader(&utilfs.DefaultFs{}, kubeletConfigFile)
    	if err != nil {
    		return nil, fmt.Errorf(errFmt, name, err)
    	}
    	kc, err := loader.Load()
    	if err != nil {
    		return nil, fmt.Errorf(errFmt, name, err)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:34 UTC 2024
    - 53.9K bytes
    - Viewed (0)
  8. src/cmd/link/internal/ld/lib.go

    	switch *FlagStrictDups {
    	case 0:
    		// nothing to do
    	case 1, 2:
    		flags |= loader.FlagStrictDups
    	default:
    		log.Fatalf("invalid -strictdups flag value %d", *FlagStrictDups)
    	}
    	ctxt.loader = loader.NewLoader(flags, &ctxt.ErrorReporter.ErrorReporter)
    	ctxt.ErrorReporter.SymName = func(s loader.Sym) string {
    		return ctxt.loader.SymName(s)
    	}
    
    	// ctxt.Library grows during the loop, so not a range loop.
    	i := 0
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 21 18:45:27 UTC 2024
    - 88.6K bytes
    - Viewed (0)
  9. src/cmd/link/internal/loader/loader.go

    	relocs []goobj.Reloc
    	data   []byte
    	auxs   []goobj.Aux
    }
    
    const (
    	// Loader.flags
    	FlagStrictDups = 1 << iota
    	FlagCheckLinkname
    )
    
    func NewLoader(flags uint32, reporter *ErrorReporter) *Loader {
    	nbuiltin := goobj.NBuiltin()
    	extReader := &oReader{objidx: extObj}
    	ldr := &Loader{
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 20:26:10 UTC 2024
    - 81.5K bytes
    - Viewed (0)
Back to top