added mq

1 files changed, 24 insertions, 2 deletions

diff --git a/src/kernel/dnbd3.h b/src/kernel/dnbd3.h
index 2575cd8..b8b0f59 100644
--- a/src/kernel/dnbd3.h
+++ b/src/kernel/dnbd3.h
@@ -57,7 +57,7 @@ typedef struct dnbd3_device_t {
 	char *imgname;
 	struct socket *sock;
 	dnbd3_server_t cur_server, initial_server;
-	unsigned long cur_rtt;
+	uint64_t cur_rtt;
 //	serialized_buffer_t payload_buffer;
 	dnbd3_server_t alt_servers[NUMBER_SERVERS]; // array of alt servers
 	int new_servers_num;	// number of new alt servers that are waiting to be copied to above array
@@ -70,6 +70,18 @@ typedef struct dnbd3_device_t {
 	// server switch
 	struct socket *better_sock;
 
+
+	// process
+//	struct task_struct * thread_send;
+//	struct task_struct * thread_receive;
+//	struct task_struct *thread_discover;
+//	struct timer_list hb_timer;
+//	wait_queue_head_t process_queue_send;
+//	wait_queue_head_t process_queue_receive;
+//	wait_queue_head_t process_queue_discover;
+//	struct list_head request_queue_send;
+//	struct list_head request_queue_receive;
+
 } dnbd3_device_t;
 
 
@@ -80,7 +92,17 @@ typedef struct dnbd3_cmd {
 	int cookie;
 	blk_status_t status;
 	unsigned long flags;
-	u32 cmd_cookie;
+	uint32_t cmd_cookie;
 } dnbd3_cmd;
 
+typedef struct dnbd3_sock {
+	struct socket *sock;
+	struct mutex tx_lock;
+	struct request *pending;
+	int sent;
+	bool dead;
+	int fallback_index;
+	int cookie;
+} dnbd3_sock;
+
 #endif /* DNBD_H_ */