Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 640 for defer (0.03 sec)

  1. src/archive/tar/writer.go

    		}
    		h.Name = name
    		if err := tw.WriteHeader(h); err != nil {
    			return err
    		}
    		if d.IsDir() {
    			return nil
    		}
    		f, err := fsys.Open(name)
    		if err != nil {
    			return err
    		}
    		defer f.Close()
    		_, err = io.Copy(tw, f)
    		return err
    	})
    }
    
    // splitUSTARPath splits a path according to USTAR prefix and suffix rules.
    // If the path is not splittable, then it will return ("", "", false).
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 14:22:59 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  2. istioctl/pkg/proxyconfig/proxyconfig.go

    }
    
    func readFile(filename string) ([]byte, error) {
    	file := os.Stdin
    	if filename != "-" {
    		var err error
    		file, err = os.Open(filename)
    		if err != nil {
    			return nil, err
    		}
    	}
    	defer func() {
    		if err := file.Close(); err != nil {
    			log.Errorf("failed to close %s: %s", filename, err)
    		}
    	}()
    	return io.ReadAll(file)
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 15:53:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  3. cmd/bucket-policy-handlers_test.go

    	const n = 100
    	start := make(chan struct{})
    	var ok, errs int
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    	wg.Add(n)
    	for i := 0; i < n; i++ {
    		go func() {
    			defer wg.Done()
    			// Sync start.
    			<-start
    			if err := obj.MakeBucket(GlobalContext, bucketName1, MakeBucketOptions{}); err != nil {
    				if _, ok := err.(BucketExists); !ok {
    					t.Logf("unexpected error: %T: %v", err, err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  4. internal/config/notify/parse.go

    		return err
    	}
    
    	targetList, err := fetchSubSysTargets(ctx, cfg, subSys, transport)
    	if err != nil {
    		return err
    	}
    
    	for _, target := range targetList {
    		defer target.Close()
    	}
    
    	tgts, ok := ctx.Value(config.ContextKeyForTargetFromConfig).(map[string]bool)
    	if !ok {
    		tgts = make(map[string]bool)
    	}
    	for _, target := range targetList {
    		if tgts[target.ID().ID] {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  5. doc/go_spec.html

    </p>
    
    <pre>
    lock(l)
    defer unlock(l)  // unlocking happens before surrounding function returns
    
    // prints 3 2 1 0 before surrounding function returns
    for i := 0; i &lt;= 3; i++ {
    	defer fmt.Print(i)
    }
    
    // f returns 42
    func f() (result int) {
    	defer func() {
    		// result is accessed after it was set to 6 by the return statement
    		result *= 7
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 00:58:01 UTC 2024
    - 282.5K bytes
    - Viewed (0)
  6. docs/debugging/xl-meta/main.go

    			case "-":
    				r = os.Stdin
    			default:
    				f, err := os.Open(file)
    				if err != nil {
    					return err
    				}
    				if st, err := f.Stat(); err == nil {
    					sz = st.Size()
    				}
    				defer f.Close()
    				r = f
    			}
    			if strings.HasSuffix(file, ".zip") {
    				zr, err := zip.NewReader(r.(io.ReaderAt), sz)
    				if err != nil {
    					return err
    				}
    				for _, file := range zr.File {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

      @get:JvmName("dns")
      val dns: Dns = builder.dns
    
      @get:JvmName("proxy")
      val proxy: Proxy? = builder.proxy
    
      @get:JvmName("proxySelector")
      val proxySelector: ProxySelector =
        when {
          // Defer calls to ProxySelector.getDefault() because it can throw a SecurityException.
          builder.proxy != null -> NullProxySelector
          else -> builder.proxySelector ?: ProxySelector.getDefault() ?: NullProxySelector
        }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
  8. docs/changelogs/changelog_3x.md

     *  Fix: The previous release introduced a performance regression on Android,
        caused by looking up CA certificates. This is now fixed.
    
    
    ## Version 3.1.0
    
    _2016-02-06_
    
     *  New: WebSockets now defer some writes. This should improve performance for
        some applications.
     *  New: Override `equals()` and `hashCode()` in our new cookie class. This
        class now defines equality by value rather than by reference.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  9. cmd/xl-storage_test.go

    	tmpDirName := globalTestTmpDir + SlashSeparator + "minio-" + nextSuffix()
    	// Temporary file name.
    	tmpFileName := globalTestTmpDir + SlashSeparator + "minio-" + nextSuffix()
    	f, _ := os.Create(tmpFileName)
    	f.Close()
    	defer os.Remove(tmpFileName)
    
    	// List of all tests for xlStorage initialization.
    	testCases := []struct {
    		name string
    		err  error
    	}{
    		// Validates input argument cannot be empty.
    		{
    			"",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  10. cmd/server_test.go

    	// Run the test with -race flag to utilize this
    	var wg sync.WaitGroup
    	for i := 0; i < testConcurrencyLevel; i++ {
    		wg.Add(1)
    		go func() {
    			defer wg.Done()
    			// HTTP request to create the bucket.
    			request, err := newTestSignedRequest(http.MethodPut, getMakeBucketURL(s.endPoint, bucketName),
    				0, nil, s.accessKey, s.secretKey, s.signer)
    			c.Assert(err, nil)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 116.3K bytes
    - Viewed (0)
Back to top