| Giorgi Lekveishvili | b8f089f | 2020-03-18 23:28:12 +0400 | [diff] [blame] | 1 | package main |
| 2 | |
| giolekva | c5126d9 | 2020-03-21 16:39:56 +0400 | [diff] [blame] | 3 | import ( |
| 4 | "flag" |
| 5 | "fmt" |
| 6 | "log" |
| 7 | "net" |
| Giorgi Lekveishvili | b8f089f | 2020-03-18 23:28:12 +0400 | [diff] [blame] | 8 | |
| giolekva | c5126d9 | 2020-03-21 16:39:56 +0400 | [diff] [blame] | 9 | "google.golang.org/grpc" |
| Giorgi Lekveishvili | b8f089f | 2020-03-18 23:28:12 +0400 | [diff] [blame] | 10 | |
| giolekva | c5126d9 | 2020-03-21 16:39:56 +0400 | [diff] [blame] | 11 | "pcloud/api" |
| 12 | "pcloud/master" |
| 13 | ) |
| Giorgi Lekveishvili | b8f089f | 2020-03-18 23:28:12 +0400 | [diff] [blame] | 14 | |
| 15 | var port = flag.Int("port", 123, "Port to listen on.") |
| 16 | |
| 17 | func main() { |
| 18 | flag.Parse() |
| 19 | log.Print("Master server starting") |
| 20 | lis, err := net.Listen("tcp", fmt.Sprintf(":%d", *port)) |
| 21 | if err != nil { |
| 22 | log.Fatalf("Failed to listen on port %d: %v", *port, err) |
| 23 | } |
| 24 | log.Printf("Listening on port: %d", *port) |
| 25 | server := grpc.NewServer() |
| 26 | api.RegisterMetadataStorageServer(server, master.NewMasterServer()) |
| 27 | log.Print("Master serving") |
| 28 | server.Serve(lis) |
| 29 | } |