fmt.Sprintf("%s%x", e.keyPrefix, s.Lease()) txn := client.Txn(ctx).If(v3.Compare(v3.CreateRevision(k), "=", 0)) txn = txn.Then(v3.OpPut(k, val, v3.WithLease(s.Lease()))) txn = txn.Else(v3.OpGet(k)) // leaderKey // 1. CampaginRevisionkeyetcdRevisionkeykey // , etcd leader fail, keyetcdelection timeout // leaderleaseleaderMDSleader // keyleaderRevisionkeyCampagin // 2. ObserveObserveleaderleaderMDSwatchPrefix Value, goLeaderName) return C.ObserverLeaderChange // observetimeoutcontext, observe timeout // get // keycontextetcd // grpcetcd case <-ticker.C: // mds

fstat + timeout设置 • OPEN 打开 inode返回ok • GETATTR 返回fstat • READ inode 读取的内容不等从16KB到128KB • 关闭⽂件时会发送FLUSH请求和RELEASE请求 • 场景2 解压压缩包场景 • LOOKUP inode 没有该inode • CREATE创建⽂件句柄并返回fstat + timeout设置 RTO是⼀个常数1s • 应⽤类型BPF_PROG_TYPE_SOCK_OPS • HOOK BPF_SOCK_OPS_TIMEOUT_INIT • 内核中调⽤栈 • tcp_timeout_init • tcp_call_bpf(BPF_SOCK_OPS_TIMEOUT_INI T) • bpf_cgrougp_run_sock_ops • … • set_initial_rtoCurve的Cache模块