- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 41 for Rd (0.07 sec)
-
cmd/server-main.go
} } func mergeServerCtxtFromConfigFile(configFile string, ctxt *serverCtxt) error { rd, err := xioutil.ReadFile(configFile) if err != nil { return err } cfReader := bytes.NewReader(rd) cv := config.ServerConfigVersion{} if err = yaml.Unmarshal(rd, &cv); err != nil { return err } switch cv.Version { case "v1", "v2": default:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 15:12:57 UTC 2024 - 34.5K bytes - Viewed (0) -
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) -
src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 14.6K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
src/cmd/vendor/github.com/google/pprof/profile/legacy_profile.go
// ParseMemoryMap should be called after setting on a profile to // associate locations to the corresponding mapping based on their // address. func ParseProcMaps(rd io.Reader) ([]*Mapping, error) { s := bufio.NewScanner(rd) return parseProcMapsFromScanner(s) } func parseProcMapsFromScanner(s *bufio.Scanner) ([]*Mapping, error) { var mapping []*Mapping var attrs []string
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 22 18:58:12 UTC 2022 - 32.8K bytes - Viewed (0) -
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) -
src/cmd/internal/obj/loong64/obj.go
p.Spadj = int32(-p.From.Offset) } case obj.AGETCALLERPC: if cursym.Leaf() { // MOV LR, Rd p.As = mov p.From.Type = obj.TYPE_REG p.From.Reg = REGLINK } else { // MOV (RSP), Rd p.As = mov p.From.Type = obj.TYPE_MEM p.From.Reg = REGSP } } if p.To.Type == obj.TYPE_REG && p.To.Reg == REGSP && p.Spadj == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 19:22:18 UTC 2023 - 19.7K bytes - Viewed (0)