aboutsummaryrefslogtreecommitdiff
path: root/pkg/driver/server.go
diff options
context:
space:
mode:
Diffstat (limited to 'pkg/driver/server.go')
-rw-r--r--pkg/driver/server.go96
1 files changed, 96 insertions, 0 deletions
diff --git a/pkg/driver/server.go b/pkg/driver/server.go
new file mode 100644
index 0000000..64a9333
--- /dev/null
+++ b/pkg/driver/server.go
@@ -0,0 +1,96 @@
+package driver
+
+import (
+ "net"
+ "os"
+ "sync"
+
+ "github.com/golang/glog"
+ "google.golang.org/grpc"
+
+ "github.com/container-storage-interface/spec/lib/go/csi"
+)
+
+// Defines Non blocking GRPC server interfaces
+type NonBlockingGRPCServer interface {
+ // Start services at the endpoint
+ Start(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer)
+ // Waits for the service to stop
+ Wait()
+ // Stops the service gracefully
+ Stop()
+ // Stops the service forcefully
+ ForceStop()
+}
+
+func NewNonBlockingGRPCServer() NonBlockingGRPCServer {
+ return &nonBlockingGRPCServer{}
+}
+
+// NonBlocking server
+type nonBlockingGRPCServer struct {
+ wg sync.WaitGroup
+ server *grpc.Server
+}
+
+func (s *nonBlockingGRPCServer) Start(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer) {
+
+ s.wg.Add(1)
+
+ go s.serve(endpoint, ids, cs, ns)
+
+ return
+}
+
+func (s *nonBlockingGRPCServer) Wait() {
+ s.wg.Wait()
+}
+
+func (s *nonBlockingGRPCServer) Stop() {
+ s.server.GracefulStop()
+}
+
+func (s *nonBlockingGRPCServer) ForceStop() {
+ s.server.Stop()
+}
+
+func (s *nonBlockingGRPCServer) serve(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer) {
+
+ proto, addr, err := ParseEndpoint(endpoint)
+ if err != nil {
+ glog.Fatal(err.Error())
+ }
+
+ if proto == "unix" {
+ addr = "/" + addr
+ if err := os.Remove(addr); err != nil && !os.IsNotExist(err) {
+ glog.Fatalf("Failed to remove %s, error: %s", addr, err.Error())
+ }
+ }
+
+ listener, err := net.Listen(proto, addr)
+ if err != nil {
+ glog.Fatalf("Failed to listen: %v", err)
+ }
+
+ opts := []grpc.ServerOption{
+ grpc.UnaryInterceptor(logGRPC),
+ }
+ server := grpc.NewServer(opts...)
+ s.server = server
+
+ if ids != nil {
+ csi.RegisterIdentityServer(server, ids)
+ }
+ if cs != nil {
+ csi.RegisterControllerServer(server, cs)
+ }
+ if ns != nil {
+ csi.RegisterNodeServer(server, ns)
+ }
+
+ glog.Infof("Listening for connections on address: %#v", listener.Addr())
+
+ server.Serve(listener)
+
+} \ No newline at end of file