* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
- * You should have received a copy of the GNU General Public License
- * along with this program; if not, write to the Free Software
- * Foundation, Inc., 59 Temple Place - Suite 330, Boston,
- * MA 02111-1307, USA.
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
*/
#include <stdlib.h>
void add_file(struct processtop *proc, struct files *file, int fd)
{
- if (proc->process_files_table->len <= fd) {
+ struct files *tmp_file;
+ int size;
+
+ size = proc->process_files_table->len;
+
+ if (size <= fd) {
g_ptr_array_set_size(proc->process_files_table, fd);
g_ptr_array_add(proc->process_files_table, file);
} else {
- g_ptr_array_index(proc->process_files_table, fd) = file;
+ tmp_file = g_ptr_array_index(proc->process_files_table, fd);
+ if (tmp_file == NULL)
+ g_ptr_array_index(proc->process_files_table, fd) = file;
+ else {
+ if (strcmp(tmp_file->name, file->name) != 0) {
+ size = proc->process_files_table->len;
+ g_ptr_array_set_size(proc->process_files_table,
+ size+1);
+ g_ptr_array_index(proc->process_files_table,
+ size) = tmp_file;
+ g_ptr_array_index(proc->process_files_table,
+ fd) = file;
+ } else
+ tmp_file->flag = __NR_open;
+ }
}
file->fd = fd;
+ file->flag = __NR_open;
+ lttngtop.nbfiles++;
+ lttngtop.nbnewfiles++;
}
+/* TODO */
+/* To be done */
+void edit_file(struct processtop *proc, struct files *file, int fd)
+{
+ int size = proc->process_files_table->len;
+ struct files *tmpfile;
+
+ if (size <= fd)
+ return;
+ else {
+ tmpfile = g_ptr_array_index(proc->process_files_table, fd);
+ tmpfile->name = strdup(file->name);
+ free(file);
+ }
+}
void insert_file(struct processtop *proc, int fd)
{
if (fd >= proc->process_files_table->len) {
tmp = g_new0(struct files, 1);
tmp->name = "Unknown";
+ tmp->read = 0;
+ tmp->write = 0;
+ tmp->fd = fd;
add_file(proc, tmp, fd);
} else {
-
tmp = g_ptr_array_index(proc->process_files_table, fd);
if (tmp == NULL) {
tmp = g_new0(struct files, 1);
}
void close_file(struct processtop *proc, int fd)
+{
+ struct files *file;
+
+ file = get_file(proc, fd);
+ if (file != NULL) {
+ file->flag = __NR_close;
+ lttngtop.nbfiles--;
+ }
+ lttngtop.nbclosedfiles++;
+}
+
+struct files *get_file(struct processtop *proc, int fd)
{
int len;
+ struct files *tmp = NULL;
len = proc->process_files_table->len;
* and its fd could be greater than all of the others fd
* used by the process
*/
- if (fd < len) {
- g_ptr_array_remove_index_fast(proc->process_files_table, fd);
- g_ptr_array_set_size(proc->process_files_table, len + 1);
- }
-}
+ if (fd < len && fd >= 0)
+ tmp = g_ptr_array_index(proc->process_files_table, fd);
-struct files *get_file(struct processtop *proc, int fd)
-{
- struct files *tmp;
- tmp = g_ptr_array_index(proc->process_files_table, fd);
return tmp;
}
fprintf(stderr, "]\n\n");
}
+void show_history(struct file_history *history)
+{
+ struct file_history *tmp = history;
+
+ while (tmp != NULL) {
+ fprintf(stderr, "fd = %d, name = %s\n", tmp->file->fd,
+ tmp->file->name);
+ tmp = tmp->next;
+ }
+
+}
+
int update_iostream_ret(struct lttngtop *ctx, int tid, char *comm,
unsigned long timestamp, uint64_t cpu_id, int ret)
{
tmpfile->write += ret;
} else if (tmp->syscall_info->type == __NR_open
&& ret > 0) {
- add_file(tmp, tmp->files_history->file, ret);
+ tmpfile = tmp->files_history->file;
+ add_file(tmp, tmpfile, ret);
+ tmpfile->fd = ret;
} else {
err = -1;
}
enum bt_cb_ret handle_exit_syscall(struct bt_ctf_event *call_data,
void *private_data)
{
- struct definition *scope;
+ const struct definition *scope;
unsigned long timestamp;
char *comm;
uint64_t ret, tid;
enum bt_cb_ret handle_sys_write(struct bt_ctf_event *call_data,
void *private_data)
{
- struct definition *scope;
+ const struct definition *scope;
struct processtop *tmp;
unsigned long timestamp;
uint64_t cpu_id;
void *private_data)
{
struct processtop *tmp;
- struct definition *scope;
+ const struct definition *scope;
unsigned long timestamp;
uint64_t cpu_id;
char *comm;
{
struct processtop *tmp;
- struct definition *scope;
+ const struct definition *scope;
unsigned long timestamp;
uint64_t cpu_id;
char *comm;
file = bt_ctf_get_string(bt_ctf_get_field(call_data,
scope, "_filename"));
if (bt_ctf_field_get_error()) {
- fprintf(stderr, "Missing fd context info\n");
+ fprintf(stderr, "Missing file name context info\n");
goto error;
}
enum bt_cb_ret handle_sys_close(struct bt_ctf_event *call_data,
void *private_data)
{
- struct definition *scope;
+ const struct definition *scope;
unsigned long timestamp;
int64_t tid;
struct processtop *tmp;
}
tmp = get_proc(<tngtop, tid, comm, timestamp);
+
close_file(tmp, fd);
return BT_CB_OK;
error:
return BT_CB_ERROR_STOP;
}
+/*
+enum bt_cb_ret handle_statedump_file_descriptor(struct bt_ctf_event *call_data,
+ void *private_data)
+{
+ struct definition *scope;
+ struct files *file;
+ unsigned long timestamp;
+ int64_t tid;
+ struct processtop *tmp;
+ char *comm, *file_name;
+ int fd;
+
+ timestamp = bt_ctf_get_timestamp(call_data);
+ if (timestamp == -1ULL)
+ goto error;
+
+ comm = get_context_comm(call_data);
+
+ scope = bt_ctf_get_top_level_scope(call_data,
+ BT_EVENT_FIELDS);
+ tid = bt_ctf_get_uint64(bt_ctf_get_field(call_data,
+ scope, "_tid"));
+ if (bt_ctf_field_get_error()) {
+ fprintf(stderr, "Missing tid context info\n");
+ goto error;
+ }
+
+ scope = bt_ctf_get_top_level_scope(call_data,
+ BT_EVENT_FIELDS);
+ fd = bt_ctf_get_uint64(bt_ctf_get_field(call_data,
+ scope, "_fd"));
+ if (bt_ctf_field_get_error()) {
+ fprintf(stderr, "Missing fd context info\n");
+ goto error;
+ }
+
+ scope = bt_ctf_get_top_level_scope(call_data,
+ BT_EVENT_FIELDS);
+ file_name = bt_ctf_get_string(bt_ctf_get_field(call_data,
+ scope, "_filename"));
+ if (bt_ctf_field_get_error()) {
+ fprintf(stderr, "Missing file name context info\n");
+ goto error;
+ }
+
+ file = g_new0(struct files, 1);
+ file->name = strdup(file_name);
+ file->fd = fd;
+ tmp = find_process_tid(<tngtop, tid, comm);
+ edit_file(tmp, file, fd);
+
+ fprintf(stderr, "%lu %s\n", tmp->tid, file_name);
+
+ return BT_CB_OK;
+
+error:
+ return BT_CB_ERROR_STOP;
+}
+*/
projects / lttngtop.git / blobdiff