/dports/science/py-ase/ase-3.22.0/ase/test/vibrations/ |
H A D | test_placzek.py | 18 rmc = ResonantRamanCalculator(atoms, H2MorseExcitedStatesCalculator) 19 rmc.run() 34 rmc = ResonantRamanCalculator(atoms, H2MorseExcitedStatesCalculator, 36 rmc.run() 39 assert (Path(rmc.name) / ('ex.eq' + rmc.exext)).is_file() 45 assert key in rmc.cache 46 del rmc.cache[key] # make sure this is not used 67 name=name, txt='-') as rmc: 68 rmc.run() 94 name=name, txt='-') as rmc: [all …]
|
/dports/emulators/qemu/qemu-6.2.0/hw/arm/ |
H A D | raspi.c | 323 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi0_machine_class_init() local 325 rmc->board_rev = 0x920092; /* Revision 1.2 */ in raspi0_machine_class_init() 326 raspi_machine_class_common_init(mc, rmc->board_rev); in raspi0_machine_class_init() 332 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi1ap_machine_class_init() local 334 rmc->board_rev = 0x900021; /* Revision 1.1 */ in raspi1ap_machine_class_init() 341 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi2b_machine_class_init() local 343 rmc->board_rev = 0xa21041; in raspi2b_machine_class_init() 351 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi3ap_machine_class_init() local 353 rmc->board_rev = 0x9020e0; /* Revision 1.0 */ in raspi3ap_machine_class_init() 360 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi3b_machine_class_init() local [all …]
|
/dports/emulators/qemu60/qemu-6.0.0/hw/arm/ |
H A D | raspi.c | 325 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi0_machine_class_init() local 327 rmc->board_rev = 0x920092; /* Revision 1.2 */ in raspi0_machine_class_init() 328 raspi_machine_class_common_init(mc, rmc->board_rev); in raspi0_machine_class_init() 334 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi1ap_machine_class_init() local 336 rmc->board_rev = 0x900021; /* Revision 1.1 */ in raspi1ap_machine_class_init() 343 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi2b_machine_class_init() local 346 rmc->board_rev = 0xa21041; in raspi2b_machine_class_init() 354 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi3ap_machine_class_init() local 356 rmc->board_rev = 0x9020e0; /* Revision 1.0 */ in raspi3ap_machine_class_init() 363 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi3b_machine_class_init() local [all …]
|
/dports/emulators/qemu5/qemu-5.2.0/hw/arm/ |
H A D | raspi.c | 325 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi0_machine_class_init() local 327 rmc->board_rev = 0x920092; /* Revision 1.2 */ in raspi0_machine_class_init() 328 raspi_machine_class_common_init(mc, rmc->board_rev); in raspi0_machine_class_init() 334 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi1ap_machine_class_init() local 336 rmc->board_rev = 0x900021; /* Revision 1.1 */ in raspi1ap_machine_class_init() 343 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi2b_machine_class_init() local 346 rmc->board_rev = 0xa21041; in raspi2b_machine_class_init() 354 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi3ap_machine_class_init() local 356 rmc->board_rev = 0x9020e0; /* Revision 1.0 */ in raspi3ap_machine_class_init() 363 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi3b_machine_class_init() local [all …]
|
/dports/emulators/qemu-devel/qemu-de8ed1055c2ce18c95f597eb10df360dcb534f99/hw/arm/ |
H A D | raspi.c | 323 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi0_machine_class_init() local 325 rmc->board_rev = 0x920092; /* Revision 1.2 */ in raspi0_machine_class_init() 326 raspi_machine_class_common_init(mc, rmc->board_rev); in raspi0_machine_class_init() 332 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi1ap_machine_class_init() local 334 rmc->board_rev = 0x900021; /* Revision 1.1 */ in raspi1ap_machine_class_init() 341 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi2b_machine_class_init() local 343 rmc->board_rev = 0xa21041; in raspi2b_machine_class_init() 351 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi3ap_machine_class_init() local 353 rmc->board_rev = 0x9020e0; /* Revision 1.0 */ in raspi3ap_machine_class_init() 360 RaspiMachineClass *rmc = RASPI_MACHINE_CLASS(oc); in raspi3b_machine_class_init() local [all …]
|
/dports/astro/qmapshack/qmapshack-V_1.16.1/src/qmapshack/realtime/gpstether/ |
H A D | CRtGpsTetherInfo.cpp | 142 if(rmc.isValid) in getPosition() 144 return QPointF(rmc.lon, rmc.lat); in getPosition() 194 rmc.isValid = false; in slotDisconnected() 235 if(rmc.isValid) in slotUpdate() 237 timestamp = rmc.datetime; in slotUpdate() 238 lon = rmc.lon; in slotUpdate() 239 lat = rmc.lat; in slotUpdate() 240 speed = rmc.groundSpeed; in slotUpdate() 343 rmc.isValid = false; in nmeaRMC() 346 rmc.isValid = true; in nmeaRMC() [all …]
|
/dports/converters/p5-URI-UTF8-Punycode/URI-UTF8-Punycode-1.05/bin/ |
H A D | Makefile.PL | 27 my $rmc = $Config{cc} eq 'cl' ? 'del' : 'rm -f'; 46 $mfu .= "\t$rmc $Config{installbin}\\$e$optsf\n"; 47 $mfc .= "\t$rmc$rmo $e$optsf\n"; 59 \t$rmc$rmo *$Config{_o} 60 \t$rmc$rmo *.res 61 \t$rmc$rmo *.pdb 63 \t$rmc Makefile
|
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/clientv3/ |
H A D | retry.go | 197 func (rmc *retryMaintenanceClient) Alarm(ctx context.Context, in *pb.AlarmRequest, opts ...grpc.Cal… 198 return rmc.mc.Alarm(ctx, in, append(opts, withRetryPolicy(repeatable))...) 201 func (rmc *retryMaintenanceClient) Status(ctx context.Context, in *pb.StatusRequest, opts ...grpc.C… 202 return rmc.mc.Status(ctx, in, append(opts, withRetryPolicy(repeatable))...) 205 func (rmc *retryMaintenanceClient) Hash(ctx context.Context, in *pb.HashRequest, opts ...grpc.CallO… 206 return rmc.mc.Hash(ctx, in, append(opts, withRetryPolicy(repeatable))...) 210 return rmc.mc.HashKV(ctx, in, append(opts, withRetryPolicy(repeatable))...) 214 return rmc.mc.Snapshot(ctx, in, append(opts, withRetryPolicy(repeatable))...) 218 return rmc.mc.MoveLeader(ctx, in, append(opts, withRetryPolicy(repeatable))...) 222 return rmc.mc.Defragment(ctx, in, opts...) [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/go.etcd.io/etcd/client/v3/ |
H A D | retry.go | 197 func (rmc *retryMaintenanceClient) Alarm(ctx context.Context, in *pb.AlarmRequest, opts ...grpc.Cal… 198 return rmc.mc.Alarm(ctx, in, append(opts, withRetryPolicy(repeatable))...) 201 func (rmc *retryMaintenanceClient) Status(ctx context.Context, in *pb.StatusRequest, opts ...grpc.C… 202 return rmc.mc.Status(ctx, in, append(opts, withRetryPolicy(repeatable))...) 205 func (rmc *retryMaintenanceClient) Hash(ctx context.Context, in *pb.HashRequest, opts ...grpc.CallO… 206 return rmc.mc.Hash(ctx, in, append(opts, withRetryPolicy(repeatable))...) 210 return rmc.mc.HashKV(ctx, in, append(opts, withRetryPolicy(repeatable))...) 214 return rmc.mc.Snapshot(ctx, in, append(opts, withRetryPolicy(repeatable))...) 218 return rmc.mc.MoveLeader(ctx, in, append(opts, withRetryPolicy(repeatable))...) 222 return rmc.mc.Defragment(ctx, in, opts...) [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/go.etcd.io/etcd/client/v3/ |
H A D | retry.go | 197 func (rmc *retryMaintenanceClient) Alarm(ctx context.Context, in *pb.AlarmRequest, opts ...grpc.Cal… 198 return rmc.mc.Alarm(ctx, in, append(opts, withRetryPolicy(repeatable))...) 201 func (rmc *retryMaintenanceClient) Status(ctx context.Context, in *pb.StatusRequest, opts ...grpc.C… 202 return rmc.mc.Status(ctx, in, append(opts, withRetryPolicy(repeatable))...) 205 func (rmc *retryMaintenanceClient) Hash(ctx context.Context, in *pb.HashRequest, opts ...grpc.CallO… 206 return rmc.mc.Hash(ctx, in, append(opts, withRetryPolicy(repeatable))...) 210 return rmc.mc.HashKV(ctx, in, append(opts, withRetryPolicy(repeatable))...) 214 return rmc.mc.Snapshot(ctx, in, append(opts, withRetryPolicy(repeatable))...) 218 return rmc.mc.MoveLeader(ctx, in, append(opts, withRetryPolicy(repeatable))...) 222 return rmc.mc.Defragment(ctx, in, opts...) [all …]
|
/dports/www/gitea/gitea-1.16.5/vendor/go.etcd.io/etcd/client/v3/ |
H A D | retry.go | 197 func (rmc *retryMaintenanceClient) Alarm(ctx context.Context, in *pb.AlarmRequest, opts ...grpc.Cal… 198 return rmc.mc.Alarm(ctx, in, append(opts, withRetryPolicy(repeatable))...) 201 func (rmc *retryMaintenanceClient) Status(ctx context.Context, in *pb.StatusRequest, opts ...grpc.C… 202 return rmc.mc.Status(ctx, in, append(opts, withRetryPolicy(repeatable))...) 205 func (rmc *retryMaintenanceClient) Hash(ctx context.Context, in *pb.HashRequest, opts ...grpc.CallO… 206 return rmc.mc.Hash(ctx, in, append(opts, withRetryPolicy(repeatable))...) 210 return rmc.mc.HashKV(ctx, in, append(opts, withRetryPolicy(repeatable))...) 214 return rmc.mc.Snapshot(ctx, in, append(opts, withRetryPolicy(repeatable))...) 218 return rmc.mc.MoveLeader(ctx, in, append(opts, withRetryPolicy(repeatable))...) 222 return rmc.mc.Defragment(ctx, in, opts...) [all …]
|
/dports/sysutils/kubectl/kubernetes-1.22.2/vendor/go.etcd.io/etcd/client/v3/ |
H A D | retry.go | 197 func (rmc *retryMaintenanceClient) Alarm(ctx context.Context, in *pb.AlarmRequest, opts ...grpc.Cal… 198 return rmc.mc.Alarm(ctx, in, append(opts, withRetryPolicy(repeatable))...) 201 func (rmc *retryMaintenanceClient) Status(ctx context.Context, in *pb.StatusRequest, opts ...grpc.C… 202 return rmc.mc.Status(ctx, in, append(opts, withRetryPolicy(repeatable))...) 205 func (rmc *retryMaintenanceClient) Hash(ctx context.Context, in *pb.HashRequest, opts ...grpc.CallO… 206 return rmc.mc.Hash(ctx, in, append(opts, withRetryPolicy(repeatable))...) 210 return rmc.mc.HashKV(ctx, in, append(opts, withRetryPolicy(repeatable))...) 214 return rmc.mc.Snapshot(ctx, in, append(opts, withRetryPolicy(repeatable))...) 218 return rmc.mc.MoveLeader(ctx, in, append(opts, withRetryPolicy(repeatable))...) 222 return rmc.mc.Defragment(ctx, in, opts...) [all …]
|
/dports/www/minio-client/etcd-3.5.0/client/v3/ |
H A D | retry.go | 197 func (rmc *retryMaintenanceClient) Alarm(ctx context.Context, in *pb.AlarmRequest, opts ...grpc.Cal… 198 return rmc.mc.Alarm(ctx, in, append(opts, withRetryPolicy(repeatable))...) 201 func (rmc *retryMaintenanceClient) Status(ctx context.Context, in *pb.StatusRequest, opts ...grpc.C… 202 return rmc.mc.Status(ctx, in, append(opts, withRetryPolicy(repeatable))...) 205 func (rmc *retryMaintenanceClient) Hash(ctx context.Context, in *pb.HashRequest, opts ...grpc.CallO… 206 return rmc.mc.Hash(ctx, in, append(opts, withRetryPolicy(repeatable))...) 210 return rmc.mc.HashKV(ctx, in, append(opts, withRetryPolicy(repeatable))...) 214 return rmc.mc.Snapshot(ctx, in, append(opts, withRetryPolicy(repeatable))...) 218 return rmc.mc.MoveLeader(ctx, in, append(opts, withRetryPolicy(repeatable))...) 222 return rmc.mc.Defragment(ctx, in, opts...) [all …]
|
/dports/net/traefik/traefik-2.6.1/vendor/go.etcd.io/etcd/client/v3/ |
H A D | retry.go | 197 func (rmc *retryMaintenanceClient) Alarm(ctx context.Context, in *pb.AlarmRequest, opts ...grpc.Cal… 198 return rmc.mc.Alarm(ctx, in, append(opts, withRetryPolicy(repeatable))...) 201 func (rmc *retryMaintenanceClient) Status(ctx context.Context, in *pb.StatusRequest, opts ...grpc.C… 202 return rmc.mc.Status(ctx, in, append(opts, withRetryPolicy(repeatable))...) 205 func (rmc *retryMaintenanceClient) Hash(ctx context.Context, in *pb.HashRequest, opts ...grpc.CallO… 206 return rmc.mc.Hash(ctx, in, append(opts, withRetryPolicy(repeatable))...) 210 return rmc.mc.HashKV(ctx, in, append(opts, withRetryPolicy(repeatable))...) 214 return rmc.mc.Snapshot(ctx, in, append(opts, withRetryPolicy(repeatable))...) 218 return rmc.mc.MoveLeader(ctx, in, append(opts, withRetryPolicy(repeatable))...) 222 return rmc.mc.Defragment(ctx, in, opts...) [all …]
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/fddi/ |
H A D | defza.c | 449 u32 own, rmc; in fza_do_xmit() local 484 writel_o(rmc, &fp->ring_rmc_tx[i].rmc); in fza_do_xmit() 493 rmc = 0; in fza_do_xmit() 529 writel_o(rmc, &fp->ring_smt_rx[i].rmc); in fza_do_recv_smt() 544 u32 own, rmc; in fza_tx() local 555 rmc = readl_u(&fp->ring_rmc_tx[i].rmc); in fza_tx() 681 u32 own, rmc, buf; in fza_rx() local 691 rmc = readl_u(&fp->ring_hst_rx[i].rmc); in fza_rx() 710 if (fza_rx_err(fp, rmc, fc)) in fza_rx() 741 skb->data, len, rmc, in fza_rx() [all …]
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/fddi/ |
H A D | defza.c | 449 u32 own, rmc; in fza_do_xmit() local 484 writel_o(rmc, &fp->ring_rmc_tx[i].rmc); in fza_do_xmit() 493 rmc = 0; in fza_do_xmit() 529 writel_o(rmc, &fp->ring_smt_rx[i].rmc); in fza_do_recv_smt() 544 u32 own, rmc; in fza_tx() local 555 rmc = readl_u(&fp->ring_rmc_tx[i].rmc); in fza_tx() 681 u32 own, rmc, buf; in fza_rx() local 691 rmc = readl_u(&fp->ring_hst_rx[i].rmc); in fza_rx() 710 if (fza_rx_err(fp, rmc, fc)) in fza_rx() 741 skb->data, len, rmc, in fza_rx() [all …]
|
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/fddi/ |
H A D | defza.c | 449 u32 own, rmc; in fza_do_xmit() local 484 writel_o(rmc, &fp->ring_rmc_tx[i].rmc); in fza_do_xmit() 493 rmc = 0; in fza_do_xmit() 529 writel_o(rmc, &fp->ring_smt_rx[i].rmc); in fza_do_recv_smt() 544 u32 own, rmc; in fza_tx() local 555 rmc = readl_u(&fp->ring_rmc_tx[i].rmc); in fza_tx() 681 u32 own, rmc, buf; in fza_rx() local 691 rmc = readl_u(&fp->ring_hst_rx[i].rmc); in fza_rx() 710 if (fza_rx_err(fp, rmc, fc)) in fza_rx() 741 skb->data, len, rmc, in fza_rx() [all …]
|
/dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/clientv3/ |
H A D | retry.go | 193 func (rmc *retryMaintenanceClient) Alarm(ctx context.Context, in *pb.AlarmRequest, opts ...grpc.Cal… 194 return rmc.mc.Alarm(ctx, in, append(opts, withRetryPolicy(repeatable))...) 197 func (rmc *retryMaintenanceClient) Status(ctx context.Context, in *pb.StatusRequest, opts ...grpc.C… 198 return rmc.mc.Status(ctx, in, append(opts, withRetryPolicy(repeatable))...) 201 func (rmc *retryMaintenanceClient) Hash(ctx context.Context, in *pb.HashRequest, opts ...grpc.CallO… 202 return rmc.mc.Hash(ctx, in, append(opts, withRetryPolicy(repeatable))...) 205 func (rmc *retryMaintenanceClient) HashKV(ctx context.Context, in *pb.HashKVRequest, opts ...grpc.C… 206 return rmc.mc.HashKV(ctx, in, append(opts, withRetryPolicy(repeatable))...) 210 return rmc.mc.Snapshot(ctx, in, append(opts, withRetryPolicy(repeatable))...) 214 return rmc.mc.MoveLeader(ctx, in, append(opts, withRetryPolicy(repeatable))...) [all …]
|
/dports/devel/etcd33/etcd-3.3.23/clientv3/ |
H A D | retry.go | 193 func (rmc *retryMaintenanceClient) Alarm(ctx context.Context, in *pb.AlarmRequest, opts ...grpc.Cal… 194 return rmc.mc.Alarm(ctx, in, append(opts, withRetryPolicy(repeatable))...) 197 func (rmc *retryMaintenanceClient) Status(ctx context.Context, in *pb.StatusRequest, opts ...grpc.C… 198 return rmc.mc.Status(ctx, in, append(opts, withRetryPolicy(repeatable))...) 201 func (rmc *retryMaintenanceClient) Hash(ctx context.Context, in *pb.HashRequest, opts ...grpc.CallO… 202 return rmc.mc.Hash(ctx, in, append(opts, withRetryPolicy(repeatable))...) 205 func (rmc *retryMaintenanceClient) HashKV(ctx context.Context, in *pb.HashKVRequest, opts ...grpc.C… 206 return rmc.mc.HashKV(ctx, in, append(opts, withRetryPolicy(repeatable))...) 210 return rmc.mc.Snapshot(ctx, in, append(opts, withRetryPolicy(repeatable))...) 214 return rmc.mc.MoveLeader(ctx, in, append(opts, withRetryPolicy(repeatable))...) [all …]
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/clientv3/ |
H A D | retry.go | 193 func (rmc *retryMaintenanceClient) Alarm(ctx context.Context, in *pb.AlarmRequest, opts ...grpc.Cal… 194 return rmc.mc.Alarm(ctx, in, append(opts, withRetryPolicy(repeatable))...) 197 func (rmc *retryMaintenanceClient) Status(ctx context.Context, in *pb.StatusRequest, opts ...grpc.C… 198 return rmc.mc.Status(ctx, in, append(opts, withRetryPolicy(repeatable))...) 201 func (rmc *retryMaintenanceClient) Hash(ctx context.Context, in *pb.HashRequest, opts ...grpc.CallO… 202 return rmc.mc.Hash(ctx, in, append(opts, withRetryPolicy(repeatable))...) 205 func (rmc *retryMaintenanceClient) HashKV(ctx context.Context, in *pb.HashKVRequest, opts ...grpc.C… 206 return rmc.mc.HashKV(ctx, in, append(opts, withRetryPolicy(repeatable))...) 210 return rmc.mc.Snapshot(ctx, in, append(opts, withRetryPolicy(repeatable))...) 214 return rmc.mc.MoveLeader(ctx, in, append(opts, withRetryPolicy(repeatable))...) [all …]
|
/dports/net-im/telepathy-salut/telepathy-salut-0.8.1/lib/gibber/tests/ |
H A D | test-r-multicast-transport-io.c | 15 GibberRMulticastCausalTransport *rmc; variable 52 sender = gibber_r_multicast_causal_transport_get_sender_by_name (rmc, name); in fail_node() 197 rmc = gibber_r_multicast_causal_transport_new (GIBBER_TRANSPORT (t), in main() 201 rm = gibber_r_multicast_transport_new (rmc); in main() 203 g_object_unref (rmc); in main() 209 rmc_connected_handler = g_signal_connect (rmc, "connected", in main() 217 g_assert (gibber_r_multicast_causal_transport_connect (rmc, FALSE, NULL)); in main()
|
/dports/emulators/qemu/qemu-6.2.0/target/ppc/translate/ |
H A D | dfp-impl.c.inc | 166 TRANS_DFP_T_B_U32_U32_Rc(DQUAI, te, rmc) 167 TRANS_DFP_T_B_U32_U32_Rc(DQUAIQ, te, rmc) 168 TRANS_DFP_T_A_B_I32_Rc(DQUA, rmc) 169 TRANS_DFP_T_A_B_I32_Rc(DQUAQ, rmc) 170 TRANS_DFP_T_A_B_I32_Rc(DRRND, rmc) 171 TRANS_DFP_T_A_B_I32_Rc(DRRNDQ, rmc) 172 TRANS_DFP_T_B_U32_U32_Rc(DRINTX, r, rmc) 173 TRANS_DFP_T_B_U32_U32_Rc(DRINTXQ, r, rmc) 174 TRANS_DFP_T_B_U32_U32_Rc(DRINTN, r, rmc) 175 TRANS_DFP_T_B_U32_U32_Rc(DRINTNQ, r, rmc)
|
/dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/vendor/github.com/coreos/etcd/clientv3/ |
H A D | retry.go | 302 err = rmc.retryf(ctx, func(rctx context.Context) error { 303 resp, err = rmc.mc.Alarm(rctx, in, opts...) 310 err = rmc.retryf(ctx, func(rctx context.Context) error { 311 resp, err = rmc.mc.Status(rctx, in, opts...) 318 err = rmc.retryf(ctx, func(rctx context.Context) error { 319 resp, err = rmc.mc.Hash(rctx, in, opts...) 326 err = rmc.retryf(ctx, func(rctx context.Context) error { 327 resp, err = rmc.mc.HashKV(rctx, in, opts...) 335 stream, err = rmc.mc.Snapshot(rctx, in, opts...) 343 resp, err = rmc.mc.MoveLeader(rctx, in, opts...) [all …]
|
/dports/sysutils/sensu-go/sensu-go-5.11.1/vendor/github.com/coreos/etcd/clientv3/ |
H A D | retry.go | 302 err = rmc.retryf(ctx, func(rctx context.Context) error { 303 resp, err = rmc.mc.Alarm(rctx, in, opts...) 310 err = rmc.retryf(ctx, func(rctx context.Context) error { 311 resp, err = rmc.mc.Status(rctx, in, opts...) 318 err = rmc.retryf(ctx, func(rctx context.Context) error { 319 resp, err = rmc.mc.Hash(rctx, in, opts...) 326 err = rmc.retryf(ctx, func(rctx context.Context) error { 327 resp, err = rmc.mc.HashKV(rctx, in, opts...) 335 stream, err = rmc.mc.Snapshot(rctx, in, opts...) 343 resp, err = rmc.mc.MoveLeader(rctx, in, opts...) [all …]
|
/dports/sysutils/helmfile/vault-f6547fa8e820/vendor/go.etcd.io/etcd/clientv3/ |
H A D | retry.go | 197 func (rmc *retryMaintenanceClient) Alarm(ctx context.Context, in *pb.AlarmRequest, opts ...grpc.Cal… 198 return rmc.mc.Alarm(ctx, in, append(opts, withRetryPolicy(repeatable))...) 201 func (rmc *retryMaintenanceClient) Status(ctx context.Context, in *pb.StatusRequest, opts ...grpc.C… 202 return rmc.mc.Status(ctx, in, append(opts, withRetryPolicy(repeatable))...) 205 func (rmc *retryMaintenanceClient) Hash(ctx context.Context, in *pb.HashRequest, opts ...grpc.CallO… 206 return rmc.mc.Hash(ctx, in, append(opts, withRetryPolicy(repeatable))...) 209 func (rmc *retryMaintenanceClient) HashKV(ctx context.Context, in *pb.HashKVRequest, opts ...grpc.C… 210 return rmc.mc.HashKV(ctx, in, append(opts, withRetryPolicy(repeatable))...) 214 return rmc.mc.Snapshot(ctx, in, append(opts, withRetryPolicy(repeatable))...) 218 return rmc.mc.MoveLeader(ctx, in, append(opts, withRetryPolicy(repeatable))...) [all …]
|