/* * This file is part of the Distributed Network Block Device 3 * * Copyright(c) 2019 Frederic Robra * Parts copyright 2011-2012 Johann Latocha * * This file may be licensed under the terms of of the * GNU General Public License Version 2 (the ``GPL''). * * Software distributed under the License is distributed * on an ``AS IS'' basis, WITHOUT WARRANTY OF ANY KIND, either * express or implied. See the GPL for the specific language * governing rights and limitations. * * You should have received a copy of the GPL along with this * program. If not, go to http://www.gnu.org/licenses/gpl.html * or write to the Free Software Foundation, Inc., * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. * */ #ifndef DNBD_H_ #define DNBD_H_ #include #include #include #include #define KERNEL_MODULE #include "types.h" #include "serialize.h" #define NUMBER_CONNECTIONS 4 extern struct workqueue_struct *dnbd3_wq; struct dnbd3_server { dnbd3_host_t host; uint64_t rtts[4]; // Last four round trip time measurements in microsecond uint16_t protocol_version; // dnbd3 protocol version of this server uint8_t failures; // How many times the server was unreachable }; struct dnbd3_sock { uint16_t sock_nr; struct socket *sock; struct mutex lock; struct request *pending; struct dnbd3_server *server; uint32_t heartbeat_count; uint32_t cookie; uint8_t panic;//, discover, panic_count; struct dnbd3_device *device; struct work_struct keepalive; struct timer_list keepalive_timer; struct work_struct receive; }; struct dnbd3_device { int minor; struct blk_mq_tag_set tag_set; struct list_head list; // block struct gendisk *disk; // sysfs struct kobject kobj; struct mutex device_lock; // network struct dnbd3_sock socks[NUMBER_CONNECTIONS]; char *imgname; struct dnbd3_server initial_server; struct dnbd3_server 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 update_available; uint8_t use_server_provided_alts; uint16_t rid; uint64_t reported_size; struct work_struct panic_worker; struct work_struct discovery; // if in irq and need to send request struct timer_list discovery_timer; }; struct dnbd3_cmd { struct dnbd3_device *dnbd3; struct mutex lock; // int index; uint32_t cookie; blk_status_t status; unsigned long flags; // uint32_t cmd_cookie; }; #endif /* DNBD_H_ */