From: Vitaliy Cherepanov <v.cherepanov@samsung.com>
Date: Thu, 31 Oct 2013 11:46:02 +0000 (+0400)
Subject: [PROTO] relative values for disk read write and net send recv
X-Git-Tag: Tizen_SDK_2.3~136
X-Git-Url: http://review.tizen.org/git/?a=commitdiff_plain;h=26c0efcb4b2f1ada8a7cbcfdbbe1a74ca3b13d00;p=platform%2Fcore%2Fsystem%2Fswap-manager.git

[PROTO] relative values for disk read write and net send recv

Change-Id: I1cae378323d8a7cdf0e0a4086502f96bef123167
Signed-off-by: Vitaliy Cherepanov <v.cherepanov@samsung.com>
---

diff --git a/daemon/da_protocol.c b/daemon/da_protocol.c
index b76fbf0..a3a5623 100644
--- a/daemon/da_protocol.c
+++ b/daemon/da_protocol.c
@@ -1009,13 +1009,13 @@ static int process_msg_start(struct msg_buf_t *msg_control)
 		goto send_ack;
 	}
 
-	if (start_transfer() != 0) {
-		LOGE("Cannot start transfer\n");
+	if (prepare_profiling() != 0) {
+		LOGE("failed to prepare profiling\n");
 		goto send_ack;
 	}
 
-	if (prepare_profiling() != 0) {
-		LOGE("failed to prepare profiling\n");
+	if (start_transfer() != 0) {
+		LOGE("Cannot start transfer\n");
 		goto send_ack;
 	}
 
diff --git a/daemon/daemon.c b/daemon/daemon.c
index 44287c9..f4fce8d 100644
--- a/daemon/daemon.c
+++ b/daemon/daemon.c
@@ -425,7 +425,9 @@ int prepare_profiling()
 		}
 		app_info = app_info_get_next(&app);
 	}
-
+	//init rw for systeminfo
+	//init recv send network systeminfo
+	sys_stat_prepare();
 	return 0;
 
 }
diff --git a/daemon/sys_stat.c b/daemon/sys_stat.c
index 367f7ee..ccf9aea 100644
--- a/daemon/sys_stat.c
+++ b/daemon/sys_stat.c
@@ -2153,7 +2153,7 @@ static void init_network_stat()
 	manager.fd.networkstat = fopen("/proc/net/dev", "r");
 }
 
-static void get_network_stat(uint32_t * recv, uint32_t * send)
+static void get_network_stat(uint32_t *recv, uint32_t *send)
 {
 	FILE *fp = manager.fd.networkstat;
 	uintmax_t irecv, isend;
@@ -2181,6 +2181,23 @@ static void get_network_stat(uint32_t * recv, uint32_t * send)
 			skip_tokens(fp, 16);
 }
 
+static void peek_network_stat_diff(uint32_t *recv, uint32_t *send)
+{
+	static uint32_t irecv_old, isend_old;
+	uint32_t tmp;
+
+	get_network_stat(recv, send);
+
+	tmp = *recv;
+	*recv = tmp - irecv_old;
+	irecv_old = tmp;
+
+	tmp = *send;
+	*send = tmp - isend_old;
+	isend_old = tmp;
+
+}
+
 static void init_disk_stat(void)
 {
 	manager.fd.diskstats = fopen("/proc/diskstats", "r");
@@ -2215,7 +2232,7 @@ static int get_partition_sector_size(const char * partition_name)
 }
 
 static void get_disk_stat(uint32_t *reads, uint32_t *sec_reads,
-						 uint32_t * writes, uint32_t *sec_writes)
+			  uint32_t *writes, uint32_t *sec_writes)
 {
 	int sec_size = 0;
 	enum { partition_name_maxlength = 128 };
@@ -2276,14 +2293,44 @@ static void get_disk_stat(uint32_t *reads, uint32_t *sec_reads,
 			//*read += pread * sec_size;
 			//*write += pwrite * sec_size;
 
-			*reads += preads;
-			*writes += pwrites;
+			*reads += (uint32_t)preads;
+			*writes += (uint32_t)pwrites;
 
-			*sec_reads += psec_read;
-			*sec_writes += psec_write;
+			*sec_reads += (uint32_t)psec_read;
+			*sec_writes += (uint32_t)psec_write;
 		}
 	}
 
+}
+
+static void peek_disk_stat_diff(uint32_t *reads, uint32_t *sec_reads,
+			        uint32_t *writes, uint32_t *sec_writes)
+{
+	static uint32_t reads_old;
+	static uint32_t sec_reads_old;
+	static uint32_t writes_old;
+	static uint32_t sec_writes_old;
+
+	uint32_t tmp;
+
+	//get cur values
+	get_disk_stat(reads, sec_reads, writes, sec_writes);
+
+	tmp = *reads;
+	*reads = tmp - reads_old;
+	reads_old = tmp;
+
+	tmp = *writes;
+	*writes = tmp - writes_old;
+	writes_old = tmp;
+
+	tmp = *sec_reads;
+	*sec_reads = tmp - sec_reads_old;
+	sec_reads_old = tmp;
+
+	tmp = *sec_writes;
+	*sec_writes = tmp - sec_writes_old;
+	sec_writes_old = tmp;
 
 }
 
@@ -2474,16 +2521,16 @@ int get_system_info(struct system_info_t *sys_info, int* pidarray, int pidcount)
 	// disk
 	if (IS_OPT_SET(FL_DISK)) {
 		sys_info->total_used_drive = get_total_used_drive();
-		get_disk_stat(&sys_info->disk_reads,
-			      &sys_info->disk_sectors_read,
-			      &sys_info->disk_writes,
-			      &sys_info->disk_sectors_write);
+		peek_disk_stat_diff(&sys_info->disk_reads,
+				    &sys_info->disk_sectors_read,
+				    &sys_info->disk_writes,
+				    &sys_info->disk_sectors_write);
 	}
 
 	// network
 	if (IS_OPT_SET(FL_NETWORK))
-		get_network_stat(&sys_info->network_send_size,
-				 &sys_info->network_receive_size);
+		peek_network_stat_diff(&sys_info->network_send_size,
+				       &sys_info->network_receive_size);
 
 	// device
 	if (IS_OPT_SET(FL_DEVICE)) {
@@ -2709,6 +2756,17 @@ int fill_target_info(struct target_info_t *target_info)
 	return 0;
 }
 
+int sys_stat_prepare(void)
+{
+	uint32_t reads, writes, sec_reads, sec_writes;
+	uint32_t recv, send;
+
+	peek_disk_stat_diff(&reads, &writes, &sec_reads, &sec_writes);
+	peek_network_stat_diff(&recv, &send);
+
+	return 0;
+}
+
 struct msg_data_t *pack_system_info(struct system_info_t *sys_info)
 {
 	struct msg_data_t *msg = NULL;
diff --git a/daemon/sys_stat.h b/daemon/sys_stat.h
index 8d55f2c..2c55eae 100644
--- a/daemon/sys_stat.h
+++ b/daemon/sys_stat.h
@@ -163,7 +163,7 @@ int fill_target_info(struct target_info_t *target_info);
 
 int init_system_file_descriptors();
 void close_system_file_descriptors();
-
+int sys_stat_prepare(void);
 #ifdef __cplusplus
 }
 #endif