summaryrefslogtreecommitdiffstats
path: root/src/kernel/dnbd3.h
diff options
context:
space:
mode:
authorFrederic Robra2019-07-05 15:32:13 +0200
committerFrederic Robra2019-07-05 15:32:13 +0200
commite21031a425e568886b0be8048318ac7ded1616b7 (patch)
tree9f6a0da91c7b81a022048594d63bbbd1b7e5c1d2 /src/kernel/dnbd3.h
parentadded send cmd to read from server (diff)
downloaddnbd3-ng-e21031a425e568886b0be8048318ac7ded1616b7.tar.gz
dnbd3-ng-e21031a425e568886b0be8048318ac7ded1616b7.tar.xz
dnbd3-ng-e21031a425e568886b0be8048318ac7ded1616b7.zip
fixed some errors with multi queue
Diffstat (limited to 'src/kernel/dnbd3.h')
-rw-r--r--src/kernel/dnbd3.h21
1 files changed, 9 insertions, 12 deletions
diff --git a/src/kernel/dnbd3.h b/src/kernel/dnbd3.h
index af9bdff..0a4ef67 100644
--- a/src/kernel/dnbd3.h
+++ b/src/kernel/dnbd3.h
@@ -44,7 +44,7 @@ typedef struct
typedef struct dnbd3_device_t {
int minor;
struct blk_mq_tag_set tag_set;
- struct request_queue queue;
+// struct request_queue queue;
struct mutex config_lock;
refcount_t config_refs;
refcount_t refs;
@@ -67,7 +67,7 @@ typedef struct dnbd3_device_t {
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
dnbd3_server_entry_t new_servers[NUMBER_SERVERS]; // pending new alt servers
- uint8_t discover, panic, disconnecting, update_available, panic_count, request;
+ uint8_t discover, panic, disconnecting, update_available, panic_count;
uint8_t use_server_provided_alts;
uint16_t rid;
uint32_t heartbeat_count;
@@ -99,15 +99,12 @@ typedef struct dnbd3_cmd {
unsigned long flags;
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;
+
+typedef struct dnbd3_sock {
+ struct socket *sock;
+ struct mutex lock;
+ struct request *pending;
+ struct dnbd3_server_t *server;
+} dnbd3_sock;
#endif /* DNBD_H_ */