cluster.go (etcd-3.5.5) | : | cluster.go (etcd-3.5.6) | ||
---|---|---|---|---|
skipping to change at line 523 | skipping to change at line 523 | |||
} | } | |||
// store TLS assets from agents/servers onto disk | // store TLS assets from agents/servers onto disk | |||
if secure && (op == rpcpb.Operation_INITIAL_START_ETCD || op == rpcpb.Ope ration_RESTART_ETCD) { | if secure && (op == rpcpb.Operation_INITIAL_START_ETCD || op == rpcpb.Ope ration_RESTART_ETCD) { | |||
dirClient := filepath.Join( | dirClient := filepath.Join( | |||
clus.Tester.DataDir, | clus.Tester.DataDir, | |||
clus.Members[idx].Etcd.Name, | clus.Members[idx].Etcd.Name, | |||
"fixtures", | "fixtures", | |||
"client", | "client", | |||
) | ) | |||
if err = fileutil.TouchDirAll(dirClient); err != nil { | if err = fileutil.TouchDirAll(clus.lg, dirClient); err != nil { | |||
return nil, err | return nil, err | |||
} | } | |||
clientCertData := []byte(resp.Member.ClientCertData) | clientCertData := []byte(resp.Member.ClientCertData) | |||
if len(clientCertData) == 0 { | if len(clientCertData) == 0 { | |||
return nil, fmt.Errorf("got empty client cert from %q", m .EtcdClientEndpoint) | return nil, fmt.Errorf("got empty client cert from %q", m .EtcdClientEndpoint) | |||
} | } | |||
clientCertPath := filepath.Join(dirClient, "cert.pem") | clientCertPath := filepath.Join(dirClient, "cert.pem") | |||
if err = ioutil.WriteFile(clientCertPath, clientCertData, 0644); err != nil { // overwrite if exists | if err = ioutil.WriteFile(clientCertPath, clientCertData, 0644); err != nil { // overwrite if exists | |||
return nil, err | return nil, err | |||
End of changes. 1 change blocks. | ||||
1 lines changed or deleted | 1 lines changed or added |