hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CP] fix file read error

Browse Source
This commit is contained in:
zhjc1124
2023-10-19 07:39:28 +00:00
committed by ob-robot
parent 763d2240d5
commit ee920752cb
1 changed files with 16 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
src/observer/main.cpp
View File

@ -408,22 +408,23 @@ static void print_all_thread(const char* desc)
struct dirent *entry;
while ((entry = readdir(dir)) != NULL) {
char *tid = entry->d_name;
if (tid[0] == '.')
continue; // pass . and ..
char path[256];
sprintf(path, "/proc/self/task/%s/comm", tid);
FILE *file = fopen(path, "r");
if (file == NULL) {
MPRINT("fail to print thread tid: %s", tid);
if (tid[0] != '.') { // pass . and ..
char path[256];
sprintf(path, "/proc/self/task/%s/comm", tid);
FILE *file = fopen(path, "r");
if (file == NULL) {
MPRINT("fail to print thread tid: %s", tid);
} else {
char name[256];
fgets(name, 256, file);
size_t len = strlen(name);
if (len > 0 && name[len - 1] == '\n') {
name[len - 1] = '\0';
}
MPRINT("[%s] detect unstopped thread, tid: %s, name: %s", desc, tid, name);
fclose(file);
}
}
char name[256];
fgets(name, 256, file);
size_t len = strlen(name);
if (len > 0 && name[len - 1] == '\n') {
name[len - 1] = '\0';
}
MPRINT("[%s] detect unstopped thread, tid: %s, name: %s", desc, tid, name);
fclose(file);
}
}
closedir(dir);