Microsoft sort une version Linux de l'outil ProcDump de SysInternals

Et annonce l'arrivée de ProcMon pour la même plateforme

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
int WriteCoreDumpInternal(struct CoreDumpWriter *self) 
{ 
    char date[DATE_LENGTH]; 
    char command[BUFFER_LENGTH]; 
    char ** outputBuffer; 
    char lineBuffer[BUFFER_LENGTH]; 
    char coreDumpFileName[BUFFER_LENGTH]; 
    int lineLength; 
    int i; 
    int rc = 0; 
    time_t rawTime; 
  
    pid_t gcorePid; 
    struct tm* timerInfo = NULL; 
    FILE *commandPipe = NULL; 
  
    const char *desc = CoreDumpTypeStrings[self->Type]; 
    char *name = sanitize(self->Config->ProcessName); 
    pid_t pid = self->Config->ProcessId; 
  
    // allocate output buffer 
    outputBuffer = (char**)malloc(sizeof(char*) * MAX_LINES); 
    if(outputBuffer == NULL){ 
        Log(error, INTERNAL_ERROR); 
        Trace("WriteCoreDumpInternal: failed gcore output buffer allocation"); 
        exit(-1); 
    } 
  
    // get time for current dump generated 
    rawTime = time(NULL); 
    if((timerInfo = localtime(&rawTime)) == NULL){ 
        Log(error, INTERNAL_ERROR); 
        Trace("WriteCoreDumpInternal: failed localtime."); 
        exit(-1); 
    } 
    strftime(date, 26, "%Y-%m-%d_%H:%M:%S", timerInfo); 
  
    // assemble the command 
    if(sprintf(command, "gcore -o %s_%s_%s %d 2>&1", name, desc, date, pid) < 0){ 
        Log(error, INTERNAL_ERROR); 
        Trace("WriteCoreDumpInternal: failed sprintf gcore command");  
        exit(-1); 
    } 
  
    // assemble filename 
    if(sprintf(coreDumpFileName, "%s_%s_%s.%d", name, desc, date, pid) < 0){ 
        Log(error, INTERNAL_ERROR); 
        Trace("WriteCoreDumpInternal: failed sprintf core file name");  
        exit(-1); 
    } 
  
    free(name); 
  
    // generate core dump for given process 
    commandPipe = popen2(command, "r", &gcorePid); 
    self->Config->gcorePid = gcorePid; 
  
    if(commandPipe == NULL){ 
        Log(error, "An error occured while generating the core dump"); 
        Trace("WriteCoreDumpInternal: Failed to open pipe to gcore"); 
        exit(1); 
    } 
  
    // read all output from gcore command 
    for(i = 0; i < MAX_LINES && fgets(lineBuffer, sizeof(lineBuffer), commandPipe) != NULL; i++) { 
        lineLength = strlen(lineBuffer); // get # of characters read 
  
        outputBuffer[i] = (char*)malloc(sizeof(char) * lineLength); 
        if(outputBuffer[i] != NULL) { 
            strncpy(outputBuffer[i], lineBuffer, lineLength - 1); // trim newline off 
            outputBuffer[i][lineLength-1] = '\0'; // append null character 
        } 
        else { 
            Log(error, INTERNAL_ERROR); 
            Trace("WriteCoreDumpInternal: failed to allocate gcore error message buffer"); 
            exit(-1); 
        } 
    } 
  
    // close pipe reading from gcore 
    self->Config->gcorePid = NO_PID; // reset gcore pid so that signal handler knows we aren't dumping 
    pclose(commandPipe); 
  
    // check if gcore was able to generate the dump 
    if(strstr(outputBuffer[i-1], "gcore: failed") != NULL){ 
        Log(error, "An error occured while generating the core dump"); 
  
        // log gcore message and free up memory 
        for(int j = 0; j < i; j++){ 
            if(outputBuffer[j] != NULL){ 
                Log(error, "GCORE - %s", outputBuffer[j]); 
                free(outputBuffer[j]); 
            } 
        } 
  
        free(outputBuffer); 
        exit(1); 
    } 
  
    self->Config->NumberOfDumpsCollected++; // safe to increment in crit section 
    if (self->Config->NumberOfDumpsCollected >= self->Config->NumberOfDumpsToCollect) { 
        SetEvent(&self->Config->evtQuit.event); // shut it down, we're done here 
        rc = 1; 
    } 
  
    // validate that core dump file was generated 
    if(access(coreDumpFileName, F_OK) != -1) { 
        if(self->Config->nQuit){ 
            // if we are in a quit state from interrupt delete partially generated core dump file 
            if(sprintf(command, "rm -f %s", coreDumpFileName) < 0){ 
                Trace("WriteCoreDumpInternal: Failed to print rm command"); 
                exit(-1); 
            } 
  
            if(system(command) < 0){ 
                Trace("WriteCoreDumpInternal: Failed to remove partial core dump"); 
                exit(-1); 
            } 
        } 
        else{ 
            // log out sucessful core dump generated 
            Log(info, "Core dump %d generated: %s", self->Config->NumberOfDumpsCollected, coreDumpFileName); 
        } 
    } 
  
    return rc; 
}