Skip to content
Snippets Groups Projects
Commit a6c1085e authored by Fabian Seidl's avatar Fabian Seidl
Browse files

Only start quantum gRPC server if necessary

See merge request !111
parent 6d64849b
Branches
No related tags found
1 merge request!111Only start quantum gRPC server if necessary
Pipeline #192536 passed
...@@ -258,14 +258,19 @@ func (kms *KMS) startGRPC(interComAddr string, quantumAddress string, tlsData km ...@@ -258,14 +258,19 @@ func (kms *KMS) startGRPC(interComAddr string, quantumAddress string, tlsData km
KMS: kms, KMS: kms,
}) })
quantumLis, err := net.Listen("tcp", quantumAddress) if quantumAddress != "" {
if err != nil { quantumLis, err := net.Listen("tcp", quantumAddress)
log.Fatalf("failed to listen: %v", err) if err != nil {
log.Fatalf("failed to listen: %v", err)
}
quantumServ := grpc.NewServer()
pbQS.RegisterKmsQkdmCommunicationServiceServer(quantumServ, &quipSecServer{
KMS: kms,
})
log.Infof("quantum server listening at %v", quantumLis.Addr())
go quantumServ.Serve(quantumLis) //nolint:errcheck
} }
quantumServ := grpc.NewServer()
pbQS.RegisterKmsQkdmCommunicationServiceServer(quantumServ, &quipSecServer{
KMS: kms,
})
go func() { go func() {
// set status to serving // set status to serving
...@@ -275,9 +280,6 @@ func (kms *KMS) startGRPC(interComAddr string, quantumAddress string, tlsData km ...@@ -275,9 +280,6 @@ func (kms *KMS) startGRPC(interComAddr string, quantumAddress string, tlsData km
// for{} // for{}
}() }()
log.Infof("quantum server listening at %v", quantumLis.Addr())
go quantumServ.Serve(quantumLis) //nolint:errcheck
log.Infof("inter KMS server listening at %v", interKMSLis.Addr()) log.Infof("inter KMS server listening at %v", interKMSLis.Addr())
if err := interKMSServer.Serve(interKMSLis); err != nil { if err := interKMSServer.Serve(interKMSLis); err != nil {
log.Fatalf("failed to serve: %v", err) log.Fatalf("failed to serve: %v", err)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment