Commit f993926f authored by Rodrigo Bruno's avatar Rodrigo Bruno Committed by Pavel Emelyanov

Rename cr_opts.ps_port into port

Signed-off-by: Rodrigo Bruno <rbruno at gsd.inesc-id.pt>
Signed-off-by: 's avatarPavel Emelyanov <xemul@parallels.com>
parent 91b689a3
...@@ -351,7 +351,7 @@ static int setup_opts_from_req(int sk, CriuOpts *req) ...@@ -351,7 +351,7 @@ static int setup_opts_from_req(int sk, CriuOpts *req)
if (req->ps) { if (req->ps) {
opts.use_page_server = true; opts.use_page_server = true;
opts.addr = req->ps->address; opts.addr = req->ps->address;
opts.ps_port = htons((short)req->ps->port); opts.port = htons((short)req->ps->port);
if (req->ps->has_fd) { if (req->ps->has_fd) {
if (!opts.swrk_restore) if (!opts.swrk_restore)
...@@ -660,7 +660,7 @@ static int start_page_server_req(int sk, CriuOpts *req) ...@@ -660,7 +660,7 @@ static int start_page_server_req(int sk, CriuOpts *req)
if (setup_opts_from_req(sk, req)) if (setup_opts_from_req(sk, req))
goto out_ch; goto out_ch;
setproctitle("page-server --rpc --address %s --port %hu", opts.addr, opts.ps_port); setproctitle("page-server --rpc --address %s --port %hu", opts.addr, opts.port);
pr_debug("Starting page server\n"); pr_debug("Starting page server\n");
...@@ -669,7 +669,7 @@ static int start_page_server_req(int sk, CriuOpts *req) ...@@ -669,7 +669,7 @@ static int start_page_server_req(int sk, CriuOpts *req)
goto out_ch; goto out_ch;
info.pid = pid; info.pid = pid;
info.port = opts.ps_port; info.port = opts.port;
count = write(start_pipe[1], &info, sizeof(info)); count = write(start_pipe[1], &info, sizeof(info));
if (count != sizeof(info)) if (count != sizeof(info))
......
...@@ -411,8 +411,8 @@ int main(int argc, char *argv[], char *envp[]) ...@@ -411,8 +411,8 @@ int main(int argc, char *argv[], char *envp[])
opts.addr = optarg; opts.addr = optarg;
break; break;
case 1052: case 1052:
opts.ps_port = htons(atoi(optarg)); opts.port = htons(atoi(optarg));
if (!opts.ps_port) if (!opts.port)
goto bad_arg; goto bad_arg;
break; break;
case 'j': case 'j':
......
...@@ -76,7 +76,7 @@ struct cr_options { ...@@ -76,7 +76,7 @@ struct cr_options {
struct list_head inherit_fds; struct list_head inherit_fds;
char *libdir; char *libdir;
bool use_page_server; bool use_page_server;
unsigned short ps_port; unsigned short port;
char *addr; char *addr;
int ps_socket; int ps_socket;
bool track_mem; bool track_mem;
......
...@@ -297,7 +297,7 @@ static int get_sockaddr_in(struct sockaddr_in *addr) ...@@ -297,7 +297,7 @@ static int get_sockaddr_in(struct sockaddr_in *addr)
return -1; return -1;
} }
addr->sin_port = opts.ps_port; addr->sin_port = opts.port;
return 0; return 0;
} }
...@@ -317,7 +317,7 @@ int cr_page_server(bool daemon_mode, int cfd) ...@@ -317,7 +317,7 @@ int cr_page_server(bool daemon_mode, int cfd)
goto no_server; goto no_server;
} }
pr_info("Starting page server on port %u\n", (int)ntohs(opts.ps_port)); pr_info("Starting page server on port %u\n", (int)ntohs(opts.port));
sk = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP); sk = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
if (sk < 0) { if (sk < 0) {
...@@ -339,14 +339,14 @@ int cr_page_server(bool daemon_mode, int cfd) ...@@ -339,14 +339,14 @@ int cr_page_server(bool daemon_mode, int cfd)
} }
/* Get socket port in case of autobind */ /* Get socket port in case of autobind */
if (opts.ps_port == 0) { if (opts.port == 0) {
if (getsockname(sk, (struct sockaddr *)&saddr, &slen)) { if (getsockname(sk, (struct sockaddr *)&saddr, &slen)) {
pr_perror("Can't get page server name"); pr_perror("Can't get page server name");
goto out; goto out;
} }
opts.ps_port = ntohs(saddr.sin_port); opts.port = ntohs(saddr.sin_port);
pr_info("Using %u port\n", opts.ps_port); pr_info("Using %u port\n", opts.port);
} }
no_server: no_server:
...@@ -411,7 +411,7 @@ int connect_to_page_server(void) ...@@ -411,7 +411,7 @@ int connect_to_page_server(void)
} }
pr_info("Connecting to server %s:%u\n", pr_info("Connecting to server %s:%u\n",
opts.addr, (int)ntohs(opts.ps_port)); opts.addr, (int)ntohs(opts.port));
page_server_sk = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP); page_server_sk = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
if (page_server_sk < 0) { if (page_server_sk < 0) {
...@@ -450,7 +450,7 @@ int disconnect_from_page_server(void) ...@@ -450,7 +450,7 @@ int disconnect_from_page_server(void)
return 0; return 0;
pr_info("Disconnect from the page server %s:%u\n", pr_info("Disconnect from the page server %s:%u\n",
opts.addr, (int)ntohs(opts.ps_port)); opts.addr, (int)ntohs(opts.port));
if (opts.ps_socket != -1) if (opts.ps_socket != -1)
/* /*
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment