#include <vppinfra/time.h>
#include <vppinfra/macros.h>
-int restart_main_fn (unformat_input_t * i)
+int
+restart_main_fn (unformat_input_t * i)
{
int verbose = 0;
int old_pid;
int wait;
- u8 * chroot_path = 0;
- svmdb_client_t * svmdb_client;
+ u8 *chroot_path = 0;
+ svmdb_client_t *svmdb_client;
volatile pid_t *pidp;
struct stat statb;
ino_t old_inode;
int sleeps;
- svmdb_map_args_t _ma, *ma= &_ma;
+ svmdb_map_args_t _ma, *ma = &_ma;
struct timespec _req, *req = &_req;
struct timespec _rem, *rem = &_rem;
- if (geteuid())
+ if (geteuid ())
clib_error ("vpp_restart: must be root...");
while (unformat_check_input (i) != UNFORMAT_END_OF_INPUT)
{
if (unformat (i, "verbose") || unformat (i, "v"))
- verbose = 1;
+ verbose = 1;
else if (unformat (i, "chroot %s", &chroot_path))
- ;
+ ;
else
- {
- clib_error ("unknown input `%U'", format_unformat_error, i);
- return 1;
- }
+ {
+ clib_error ("unknown input `%U'", format_unformat_error, i);
+ return 1;
+ }
}
- /*
- * Step 1: look up the current VPP pid in the shared-memory database
+ /*
+ * Step 1: look up the current VPP pid in the shared-memory database
*/
memset (ma, 0, sizeof (*ma));
- ma->root_path = (char *)chroot_path;
+ ma->root_path = (char *) chroot_path;
svmdb_client = svmdb_map (ma);
pidp = svmdb_local_get_variable_reference (svmdb_client,
- SVMDB_NAMESPACE_VEC,
- "vpp_pid");
+ SVMDB_NAMESPACE_VEC, "vpp_pid");
if (pidp == 0)
{
clib_error ("'vpp_pid' svm variable not found, vpp has never run?");
for (wait = 0; wait < 1000; wait++)
{
req->tv_sec = 0;
- req->tv_nsec = 10000*1000; /* 10 ms */
- while (nanosleep(req, rem) < 0)
- *req = *rem;
-
- if (*pidp)
- goto found2;
+ req->tv_nsec = 10000 * 1000; /* 10 ms */
+ while (nanosleep (req, rem) < 0)
+ *req = *rem;
+
+ if (*pidp)
+ goto found2;
}
clib_error ("VPP not runnning...");
return 3;
-
- found2:
+
+found2:
old_pid = *pidp;
-
+
/*
* Step 2: sanity check the pid we discovered
*/
if (verbose)
- fformat(stdout, "Sanity check current vpp pid %d\n", old_pid);
+ fformat (stdout, "Sanity check current vpp pid %d\n", old_pid);
if (kill (old_pid, 0) < 0)
{
clib_error ("vpp current pid %d not running...", old_pid);
return 2;
}
-
+
if (verbose)
- fformat(stdout, "Sanity check vpp pid %d OK\n", old_pid);
+ fformat (stdout, "Sanity check vpp pid %d OK\n", old_pid);
- /*
- * Step 3: figure out the current vpp <--> client shared-VM file
- * inode number
+ /*
+ * Step 3: figure out the current vpp <--> client shared-VM file
+ * inode number
*/
- if (stat("/dev/shm/vpe-api", &statb) < 0)
+ if (stat ("/dev/shm/vpe-api", &statb) < 0)
{
clib_unix_error ("stat fail");
return 4;
old_inode = statb.st_ino;
if (verbose)
- fformat(stdout, "Old inode %u\n", old_inode);
+ fformat (stdout, "Old inode %u\n", old_inode);
- /* Note: restart wipes out the shared VM database*/
+ /* Note: restart wipes out the shared VM database */
svmdb_unmap (svmdb_client);
/*
sleeps = 0;
- /*
- * Step 5: wait up to 15 seconds for a new incarnation of
+ /*
+ * Step 5: wait up to 15 seconds for a new incarnation of
* the shared-VM API segment to appear.
*/
for (wait = 0; wait < 150; wait++)
{
- if ((stat("/dev/shm/vpe-api", &statb) < 0)
- || statb.st_ino == old_inode)
- {
- req->tv_sec = 0;
- req->tv_nsec = 100000*1000; /* 100 ms */
- while (nanosleep(req, rem) < 0)
- *req = *rem;
- sleeps++;
- }
+ if ((stat ("/dev/shm/vpe-api", &statb) < 0)
+ || statb.st_ino == old_inode)
+ {
+ req->tv_sec = 0;
+ req->tv_nsec = 100000 * 1000; /* 100 ms */
+ while (nanosleep (req, rem) < 0)
+ *req = *rem;
+ sleeps++;
+ }
else
- goto new_inode;
+ goto new_inode;
}
clib_error ("Timeout waiting for new inode to appear...");
return 5;
- new_inode:
+new_inode:
if (verbose && sleeps > 0)
- fformat(stdout, "Inode sleeps %d\n", sleeps);
+ fformat (stdout, "Inode sleeps %d\n", sleeps);
if (verbose)
- fformat(stdout, "New inode %u\n", statb.st_ino);
+ fformat (stdout, "New inode %u\n", statb.st_ino);
- /*
- * Step 6: remap the SVM database
+ /*
+ * Step 6: remap the SVM database
*/
svmdb_client = svmdb_map (ma);
-
+
pidp = svmdb_local_get_variable_reference (svmdb_client,
- SVMDB_NAMESPACE_VEC,
- "vpp_pid");
+ SVMDB_NAMESPACE_VEC, "vpp_pid");
if (pidp == 0)
{
clib_error ("post_restart: 'vpp_pid' svm variable not found,"
- "vpp did not restart?");
+ "vpp did not restart?");
return 2;
}
sleeps = 0;
- /*
+ /*
* Step 7: wait for vpp to publish its new PID
*/
for (wait = 0; wait < 150; wait++)
{
if (*pidp && (*pidp != old_pid))
- goto restarted;
+ goto restarted;
req->tv_sec = 0;
- req->tv_nsec = 100000*1000; /* 100 ms */
- while (nanosleep(req, rem) < 0)
- *req = *rem;
+ req->tv_nsec = 100000 * 1000; /* 100 ms */
+ while (nanosleep (req, rem) < 0)
+ *req = *rem;
sleeps++;
}
-
+
clib_error ("Timeout waiting for vpp to publish pid after restart...");
return 4;
- restarted:
+restarted:
/* Done... */
-
+
if (verbose && sleeps)
- fformat(stdout, "pid sleeps %d\n", sleeps);
+ fformat (stdout, "pid sleeps %d\n", sleeps);
if (verbose)
fformat (stdout, "New PID %d... Restarted...\n", *pidp);
-
+
svmdb_unmap (svmdb_client);
return 0;
}
-int main (int argc, char **argv)
+int
+main (int argc, char **argv)
{
unformat_input_t i;
int ret;
- clib_mem_init (0, 64ULL<<20);
+ clib_mem_init (0, 64ULL << 20);
unformat_init_command_line (&i, argv);
ret = restart_main_fn (&i);
unformat_free (&i);
return ret;
}
+
+/*
+ * fd.io coding-style-patch-verification: ON
+ *
+ * Local Variables:
+ * eval: (c-set-style "gnu")
+ * End:
+ */
Code Review / vpp.git / blobdiff