Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 32 for Rd (0.03 sec)

  1. src/syscall/syscall_linux_test.go

    		// This will return when the write side is closed.
    		n, err := syscall.Read(int(rd.Fd()), data)
    		if !(n == 0 && err == nil) {
    			t.Errorf("expected read to return 0, got %d, %s", n, err)
    		}
    
    		// Clean up rd and also ensure rd stays reachable so
    		// it doesn't get closed by GC.
    		rd.Close()
    		wg.Done()
    	}()
    	<-ready
    
    	// Loop here to give the goroutine more time to block in read.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 23K bytes
    - Viewed (0)
  2. src/cmd/internal/obj/arm64/asm7.go

    	}
    	switch o.type_ {
    	default:
    		c.ctxt.Diag("%v: unknown asm %d", p, o.type_)
    
    	case 0: /* pseudo ops */
    		break
    
    	case 1: /* op Rm,[Rn],Rd; default Rn=Rd -> op Rm<<0,[Rn,]Rd (shifted register) */
    		o1 = c.oprrr(p, p.As)
    
    		rf := int(p.From.Reg)
    		rt := int(p.To.Reg)
    		r := int(p.Reg)
    		if p.To.Type == obj.TYPE_NONE {
    			rt = REGZERO
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 15:44:14 UTC 2024
    - 201.1K bytes
    - Viewed (0)
  3. pkg/xds/server.go

    	Subscribed sets.String
    	// Unsubscribed indicates the client no longer requires these resources
    	Unsubscribed sets.String
    }
    
    var emptyResourceDelta = ResourceDelta{}
    
    func (rd ResourceDelta) IsEmpty() bool {
    	return len(rd.Subscribed) == 0 && len(rd.Unsubscribed) == 0
    }
    
    type Resources = []*discovery.Resource
    
    func ResourcesToAny(r Resources) []*anypb.Any {
    	a := make([]*anypb.Any, 0, len(r))
    	for _, rr := range r {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 20:55:20 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/tracing.go

    		}
    	}
    
    	// Add configured resource detectors
    	if otelProvider.ResourceDetectors != nil {
    		res := []*core.TypedExtensionConfig{}
    		rd := otelProvider.ResourceDetectors
    
    		if rd.Environment != nil {
    			res = append(res, xdsfilters.EnvironmentResourceDetector)
    		}
    		if rd.Dynatrace != nil {
    			res = append(res, xdsfilters.DynatraceResourceDetector)
    		}
    		oc.ResourceDetectors = res
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 17:05:28 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  5. src/vendor/golang.org/x/net/nettest/conntest.go

    func testBasicIO(t *testing.T, c1, c2 net.Conn) {
    	want := make([]byte, 1<<20)
    	rand.New(rand.NewSource(0)).Read(want)
    
    	dataCh := make(chan []byte)
    	go func() {
    		rd := bytes.NewReader(want)
    		if err := chunkedCopy(c1, rd); err != nil {
    			t.Errorf("unexpected c1.Write error: %v", err)
    		}
    		if err := c1.Close(); err != nil {
    			t.Errorf("unexpected c1.Close error: %v", err)
    		}
    	}()
    
    	go func() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  6. cmd/admin-handlers-config-kv.go

    	}
    
    	vars := mux.Vars(r)
    
    	subSys := vars["subSys"]
    	key := vars["key"]
    
    	_, envOnly := r.Form["env"]
    
    	rd, err := GetHelp(subSys, key, envOnly)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	json.NewEncoder(w).Encode(rd)
    }
    
    // SetConfigHandler - PUT /minio/admin/v3/config
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  7. cmd/storage-rest-client.go

    	}
    	defer xhttp.DrainBody(respBody)
    	respReader, err := waitForHTTPResponse(respBody)
    	if err != nil {
    		return stat, toStorageErr(err)
    	}
    	rd := msgpNewReader(respReader)
    	defer readMsgpReaderPoolPut(rd)
    
    	for {
    		var st StatInfo
    		err = st.DecodeMsg(rd)
    		if err != nil {
    			if errors.Is(err, io.EOF) {
    				err = nil
    			}
    			break
    		}
    
    		stat = append(stat, st)
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 27.4K bytes
    - Viewed (0)
  8. cmd/admin-handlers-users.go

    	}
    
    	acctInfo := madmin.AccountInfo{
    		AccountName: accountName,
    		Server:      objectAPI.BackendInfo(),
    		Policy:      buf,
    	}
    
    	for _, bucket := range buckets {
    		rd, wr := isAllowedAccess(bucket.Name)
    		if rd || wr {
    			// Fetch the data usage of the current bucket
    			var size uint64
    			var objectsCount uint64
    			var objectsHist, versionsHist map[string]uint64
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue May 28 17:19:04 UTC 2024
    - 78.6K bytes
    - Viewed (0)
  9. src/crypto/tls/testdata/Client-TLSv12-ECDHE-RSA-AES

    00000030  22 c0 bb 31 4e 15 03 03  00 30 00 00 00 00 00 00  |"..1N....0......|
    00000040  00 00 00 00 00 00 00 00  00 00 c8 60 b8 c1 66 9b  |...........`..f.|
    00000050  52 44 3c 26 7f ff 96 a6  21 c7 eb 33 71 f8 40 23  |RD<&....!..3q.@#|
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:33:38 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  10. cmd/erasure-healing_test.go

    			Versioned: true,
    			VersionID: objInfo.VersionID,
    		}); err != nil {
    			t.Fatal(err)
    		}
    	}
    
    	setDisks(nil, nil, nil, nil)
    
    	rd := mustGetPutObjReader(t, bytes.NewReader(data), int64(len(data)), "", "")
    	_, err = objLayer.PutObject(ctx, bucket, object, rd, ObjectOptions{
    		Versioned: true,
    	})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	setDisks(orgDisks[:4]...)
    	disk := getDisk(0)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
Back to top