Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for initPipe (0.16 sec)

  1. testing/internal-testing/src/main/groovy/org/gradle/integtests/fixtures/RedirectStdinExtension.groovy

                def oldStdin = System.in
                initPipe()
                System.setIn(emulatedSystemIn)
                try {
                    invocation.proceed()
                } finally {
                    System.setIn(oldStdin)
                    closePipe()
                }
            }
    
            private void initPipe() {
                if (stdinPipe == null) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  2. testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/UserInitScriptExecuterFixture.groovy

            def temporaryFolder = executer.gradleUserHomeDir.file("init.d")
            def initFile = temporaryFolder.file(this.getClass().getSimpleName() + "-init.gradle")
            executer.beforeExecute {
                // On test retry the user home dir may be deleted, so verify the init script exists before each invocation
                if (!initFile.file) {
                    initFile.text = initScriptContent()
                }
            }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  3. testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/InitScriptExecuterFixture.groovy

            def temporaryFolder = testDir.testDirectory
            def initFile = temporaryFolder.file(this.getClass().getSimpleName() + "-init.gradle")
            initFile.text = initScriptContent()
            executer.beforeExecute {
                usingInitScript(initFile)
            }
            executer.afterExecute {
                afterBuild()
            }
    
            return base
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  4. src/mime/type.go

    	".png":  "image/png",
    	".svg":  "image/svg+xml",
    	".wasm": "application/wasm",
    	".webp": "image/webp",
    	".xml":  "text/xml; charset=utf-8",
    }
    
    var once sync.Once // guards initMime
    
    var testInitMime, osInitMime func()
    
    func initMime() {
    	if fn := testInitMime; fn != nil {
    		fn()
    	} else {
    		setMimeTypes(builtinTypesLower, builtinTypesLower)
    		osInitMime()
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 5K bytes
    - Viewed (0)
  5. subprojects/core/src/integTest/groovy/org/gradle/configuration/ExecuteUserLifecycleListenerBuildOperationIntegrationTest.groovy

            // verify that we don't get any duplicates in these
            sanityCheckApplicationIds()
    
            if (notEmpty(initFile)) {
                initScriptAppId = findScriptApplicationId(targetsGradle(), scriptFile(initFile))
            }
            if (hasScript(initFile, scriptFile.name)) {
                initOtherScriptAppId = findScriptApplicationId(targetsGradle(), scriptFile(scriptFile))
            }
            if (notEmpty(settingsFile)) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 20 11:16:24 UTC 2024
    - 40.2K bytes
    - Viewed (0)
  6. src/internal/syscall/windows/exec_windows_test.go

    	}
    
    	tml := (*windows.TOKEN_MANDATORY_LABEL)(p)
    
    	sid := (*syscall.SID)(unsafe.Pointer(tml.Label.Sid))
    
    	return sid.String()
    }
    
    func tokenGetInfo(t syscall.Token, class uint32, initSize int) (unsafe.Pointer, error) {
    	n := uint32(initSize)
    	for {
    		b := make([]byte, n)
    		e := syscall.GetTokenInformation(t, class, &b[0], uint32(len(b)), &n)
    		if e == nil {
    			return unsafe.Pointer(&b[0]), nil
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Sep 05 23:35:29 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  7. src/syscall/security_windows.go

    func (t Token) Close() error {
    	return CloseHandle(Handle(t))
    }
    
    // getInfo retrieves a specified type of information about an access token.
    func (t Token) getInfo(class uint32, initSize int) (unsafe.Pointer, error) {
    	n := uint32(initSize)
    	for {
    		b := make([]byte, n)
    		e := GetTokenInformation(t, class, &b[0], uint32(len(b)), &n)
    		if e == nil {
    			return unsafe.Pointer(&b[0]), nil
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Sep 12 16:42:41 UTC 2023
    - 10K bytes
    - Viewed (0)
  8. src/sync/poolqueue.go

    	next, prev atomic.Pointer[poolChainElt]
    }
    
    func (c *poolChain) pushHead(val any) {
    	d := c.head
    	if d == nil {
    		// Initialize the chain.
    		const initSize = 8 // Must be a power of 2
    		d = new(poolChainElt)
    		d.vals = make([]eface, initSize)
    		c.head = d
    		c.tail.Store(d)
    	}
    
    	if d.pushHead(val) {
    		return
    	}
    
    	// The current dequeue is full. Allocate a new one of twice
    	// the size.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 18:12:29 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  9. cmd/bucket-replication-metrics.go

    }
    
    // newRateMeasurement creates a new instance of the measurement with the initial start time.
    func newRateMeasurement(initTime time.Time) *rateMeasurement {
    	return &rateMeasurement{
    		startTime: initTime,
    	}
    }
    
    // incrementBytes add bytes reported for a bucket/target.
    func (m *rateMeasurement) incrementBytes(bytes uint64) {
    	atomic.AddUint64(&m.bytesSinceLastWindow, bytes)
    }
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  10. pkg/wasm/cache_test.go

    			}
    			cache := NewLocalFileCache(tmpDir, options)
    			cache.httpFetcher.initialBackoff = time.Microsecond
    			defer close(cache.stopChan)
    
    			var cacheHitKey *moduleKey
    			initTime := time.Now()
    			cache.mux.Lock()
    			for k, m := range c.initialCachedModules {
    				filePath := generateModulePath(t, tmpDir, k.name, m.modulePath)
    				err := os.WriteFile(filePath, []byte("data/\n"), 0o644)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 33.9K bytes
    - Viewed (0)
Back to top