ivampiresp/Spdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

event/app: use PID for trace ID if shm_id is unset

Browse Source 
Change-Id: If79a09e109a3885e1282f3e834b531c250e59512
Signed-off-by: Daniel Verkamp <daniel.verkamp@intel.com>
This commit is contained in:
Daniel Verkamp 2017-03-08 16:23:18 -07:00 committed by Jim Harris
parent ac9b92c853
commit 60fc74584a
2 changed files with 20 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
app/trace/trace.cpp
View File

@ -94,7 +94,6 @@ struct object_stats g_stats[SPDK_TRACE_MAX_OBJECT];
static char *exe_name;
static int verbose = 1;
static int g_shm_id = 0;
static int g_fudge_factor = 20;
static uint64_t tsc_rate;
@ -306,7 +305,9 @@ static void usage(void)
fprintf(stderr, " '-c' to display single lcore history\n");
fprintf(stderr, " '-f' to specify number of events to ignore at\n");
fprintf(stderr, " beginning and end of trace (default: 20)\n");
fprintf(stderr, " '-i' to specify the shared memory ID, (required)\n");
fprintf(stderr, " '-i' to specify the shared memory ID\n");
fprintf(stderr, " '-p' to specify the trace PID\n");
fprintf(stderr, " (One of -i or -p must be specified)\n");
}
int main(int argc, char **argv)
@ -319,9 +320,10 @@ int main(int argc, char **argv)
const char *app_name = "ids";
int op;
char shm_name[64];
int shm_id = -1, shm_pid = -1;
exe_name = argv[0];
while ((op = getopt(argc, argv, "c:f:i:qs:")) != -1) {
while ((op = getopt(argc, argv, "c:f:i:p:qs:")) != -1) {
switch (op) {
case 'c':
lcore = atoi(optarg);
@ -336,7 +338,10 @@ int main(int argc, char **argv)
g_fudge_factor = atoi(optarg);
break;
case 'i':
g_shm_id = atoi(optarg);
shm_id = atoi(optarg);
break;
case 'p':
shm_pid = atoi(optarg);
break;
case 'q':
verbose = 0;
@ -350,7 +355,11 @@ int main(int argc, char **argv)
}
}
snprintf(shm_name, sizeof(shm_name), "/%s_trace.%d", app_name, g_shm_id);
if (shm_id >= 0) {
snprintf(shm_name, sizeof(shm_name), "/%s_trace.%d", app_name, shm_id);
} else {
snprintf(shm_name, sizeof(shm_name), "/%s_trace.pid%d", app_name, shm_pid);
}
fd = shm_open(shm_name, O_RDONLY, 0600);
if (fd < 0) {
fprintf(stderr, "Could not open shm %s.\n", shm_name);

5
lib/event/app.c
View File

@ -387,7 +387,12 @@ spdk_app_init(struct spdk_app_opts *opts)
sigaddset(&signew, SIGHUP);
pthread_sigmask(SIG_SETMASK, &signew, NULL);
if (opts->shm_id >= 0) {
snprintf(shm_name, sizeof(shm_name), "/%s_trace.%d", opts->name, opts->shm_id);
} else {
snprintf(shm_name, sizeof(shm_name), "/%s_trace.pid%d", opts->name, (int)getpid());
}
spdk_trace_init(shm_name);
if (opts->tpoint_group_mask == NULL) {