- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for Rs (0.05 sec)
-
src/cmd/link/internal/ld/data.go
if weak && !ldr.AttrReachable(rs) { // Redirect it to runtime.unreachableMethod, which will throw if called. rs = syms.unreachableMethod } if target.IsExternal() { nExtReloc++ // set up addend for eventual relocation via outer symbol. rs := rs rs, off := FoldSubSymbolOffset(ldr, rs) xadd := r.Add() + off rst := ldr.SymType(rs)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 12 15:10:50 UTC 2024 - 100.5K bytes - Viewed (1) -
src/database/sql/sql.go
defer rs.closemu.Unlock() if rs.closed { return nil } rs.closed = true if rs.lasterr == nil { rs.lasterr = err } withLock(rs.dc, func() { err = rs.rowsi.Close() }) if fn := rowsCloseHook(); fn != nil { fn(rs, &err) } if rs.cancel != nil { rs.cancel() } if rs.closeStmt != nil { rs.closeStmt.Close() } rs.releaseConn(err)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
cmd/object-handlers.go
return } if rs := r.Header.Get(xhttp.AmzBucketReplicationStatus); rs != "" { srcInfo.UserDefined[ReservedMetadataPrefixLower+ReplicaStatus] = replication.Replica.String() srcInfo.UserDefined[ReservedMetadataPrefixLower+ReplicaTimestamp] = UTCNow().Format(time.RFC3339Nano) srcInfo.UserDefined[xhttp.AmzBucketReplicationStatus] = rs } op := replication.ObjectReplicationType
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 124.2K bytes - Viewed (0) -
cmd/site-replication.go
} } rs.Status = ResyncCanceled rs.LastUpdate = UTCNow() if err := saveSiteResyncMetadata(ctx, rs, objAPI); err != nil { return res, err } select { case globalReplicationPool.resyncer.resyncCancelCh <- struct{}{}: case <-ctx.Done(): } globalSiteResyncMetrics.updateState(rs) res.Status = rs.Status.String() return res, nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
cmd/bucket-replication.go
func newresyncer() *replicationResyncer { rs := replicationResyncer{ statusMap: make(map[string]BucketReplicationResyncStatus), workerSize: resyncWorkerCnt, resyncCancelCh: make(chan struct{}, resyncWorkerCnt), workerCh: make(chan struct{}, resyncWorkerCnt), } for i := 0; i < rs.workerSize; i++ { rs.workerCh <- struct{}{} } return &rs }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
src/cmd/internal/obj/ppc64/asm9.go
opset(ASLDCC, r0) opset(ASRD, r0) opset(ASRDCC, r0) opset(AROTL, r0) case ASRAW: /* sraw Rb,Rs,Ra; srawi sh,Rs,Ra */ opset(ASRAWCC, r0) case AEXTSWSLI: opset(AEXTSWSLICC, r0) case ASRAD: /* sraw Rb,Rs,Ra; srawi sh,Rs,Ra */ opset(ASRADCC, r0) case ASUB: /* SUB Ra,Rb,Rd => subf Rd,ra,rb */ opset(ASUB, r0) opset(ASUBCC, r0) opset(ASUBV, r0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 13:55:28 UTC 2024 - 156.1K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier_test.go
destinations, _ := fp.ipvs.GetRealServers(svc) if len(destinations) != len(vs.RS) { t.Errorf("Expected %d destinations, got %d destinations", len(vs.RS), len(destinations)) } if len(vs.RS) == 1 { if destinations[0].Address.String() != vs.RS[0].IP || destinations[0].Port != vs.RS[0].Port { t.Errorf("Unexpected mismatch destinations") } } } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0) -
src/cmd/internal/obj/arm64/asm7.go
case 106: // CASPx (Rs, Rs+1), (Rb), (Rt, Rt+1) rs := p.From.Reg rt := p.GetTo2().Reg rb := p.To.Reg rs1 := int16(p.From.Offset) rt1 := int16(p.GetTo2().Offset) enc, ok := atomicCASP[p.As] if !ok { c.ctxt.Diag("invalid CASP-like atomic instructions: %v\n", p) } // for CASPx-like instructions, Rs<0> != 1 && Rt<0> != 1 switch { case rs&1 != 0:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 15:44:14 UTC 2024 - 201.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
for _, tc := range testcases { t.Run(tc.name, func(t *testing.T) { rs := &example.ReplicaSet{} rs.DeletionTimestamp = tc.deletionTimestamp if err := markAsDeleting(rs, now); err != nil { t.Error(err) } if reflect.DeepEqual(*rs.DeletionTimestamp, tc.expectDeletionTimestamp) { t.Errorf("expected %v, got %v", tc.expectDeletionTimestamp, *rs.DeletionTimestamp) } }) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
cmd/data-usage-cache_gen.go
} for za0002 := range z.ObjVersions { z.ObjVersions[za0002], err = dc.ReadUint64() if err != nil { err = msgp.WrapError(err, "ObjVersions", za0002) return } } case "rs": if dc.IsNil() { err = dc.ReadNil() if err != nil { err = msgp.WrapError(err, "ReplicationStats") return } z.ReplicationStats = nil } else {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 100.8K bytes - Viewed (0)