// SPDX-License-Identifier: GPL-2.0-or-later /* * Copyright (C) 2016 Namjae Jeon <[email protected]> * Copyright (C) 2018 Samsung Electronics Co., Ltd. */ #include <linux/freezer.h> #include "smb_common.h" #include "server.h" #include "auth.h" #include "connection.h" #include "transport_tcp.h" #define IFACE_STATE_DOWN … #define IFACE_STATE_CONFIGURED … static atomic_t active_num_conn; struct interface { … }; static LIST_HEAD(iface_list); static int bind_additional_ifaces; struct tcp_transport { … }; static const struct ksmbd_transport_ops ksmbd_tcp_transport_ops; static void tcp_stop_kthread(struct task_struct *kthread); static struct interface *alloc_iface(char *ifname); #define KSMBD_TRANS(t) … #define TCP_TRANS(t) … static inline void ksmbd_tcp_nodelay(struct socket *sock) { … } static inline void ksmbd_tcp_reuseaddr(struct socket *sock) { … } static inline void ksmbd_tcp_rcv_timeout(struct socket *sock, s64 secs) { … } static inline void ksmbd_tcp_snd_timeout(struct socket *sock, s64 secs) { … } static struct tcp_transport *alloc_transport(struct socket *client_sk) { … } static void free_transport(struct tcp_transport *t) { … } /** * kvec_array_init() - initialize a IO vector segment * @new: IO vector to be initialized * @iov: base IO vector * @nr_segs: number of segments in base iov * @bytes: total iovec length so far for read * * Return: Number of IO segments */ static unsigned int kvec_array_init(struct kvec *new, struct kvec *iov, unsigned int nr_segs, size_t bytes) { … } /** * get_conn_iovec() - get connection iovec for reading from socket * @t: TCP transport instance * @nr_segs: number of segments in iov * * Return: return existing or newly allocate iovec */ static struct kvec *get_conn_iovec(struct tcp_transport *t, unsigned int nr_segs) { … } static unsigned short ksmbd_tcp_get_port(const struct sockaddr *sa) { … } /** * ksmbd_tcp_new_connection() - create a new tcp session on mount * @client_sk: socket associated with new connection * * whenever a new connection is requested, create a conn thread * (session thread) to handle new incoming smb requests from the connection * * Return: 0 on success, otherwise error */ static int ksmbd_tcp_new_connection(struct socket *client_sk) { … } /** * ksmbd_kthread_fn() - listen to new SMB connections and callback server * @p: arguments to forker thread * * Return: 0 on success, error number otherwise */ static int ksmbd_kthread_fn(void *p) { … } /** * ksmbd_tcp_run_kthread() - start forker thread * @iface: pointer to struct interface * * start forker thread(ksmbd/0) at module init time to listen * on port 445 for new SMB connection requests. It creates per connection * server threads(ksmbd/x) * * Return: 0 on success or error number */ static int ksmbd_tcp_run_kthread(struct interface *iface) { … } /** * ksmbd_tcp_readv() - read data from socket in given iovec * @t: TCP transport instance * @iov_orig: base IO vector * @nr_segs: number of segments in base iov * @to_read: number of bytes to read from socket * @max_retries: maximum retry count * * Return: on success return number of bytes read from socket, * otherwise return error number */ static int ksmbd_tcp_readv(struct tcp_transport *t, struct kvec *iov_orig, unsigned int nr_segs, unsigned int to_read, int max_retries) { … } /** * ksmbd_tcp_read() - read data from socket in given buffer * @t: TCP transport instance * @buf: buffer to store read data from socket * @to_read: number of bytes to read from socket * @max_retries: number of retries if reading from socket fails * * Return: on success return number of bytes read from socket, * otherwise return error number */ static int ksmbd_tcp_read(struct ksmbd_transport *t, char *buf, unsigned int to_read, int max_retries) { … } static int ksmbd_tcp_writev(struct ksmbd_transport *t, struct kvec *iov, int nvecs, int size, bool need_invalidate, unsigned int remote_key) { … } static void ksmbd_tcp_disconnect(struct ksmbd_transport *t) { … } static void tcp_destroy_socket(struct socket *ksmbd_socket) { … } /** * create_socket - create socket for ksmbd/0 * @iface: interface to bind the created socket to * * Return: 0 on success, error number otherwise */ static int create_socket(struct interface *iface) { … } static int ksmbd_netdev_event(struct notifier_block *nb, unsigned long event, void *ptr) { … } static struct notifier_block ksmbd_netdev_notifier = …; int ksmbd_tcp_init(void) { … } static void tcp_stop_kthread(struct task_struct *kthread) { … } void ksmbd_tcp_destroy(void) { … } static struct interface *alloc_iface(char *ifname) { … } int ksmbd_tcp_set_interfaces(char *ifc_list, int ifc_list_sz) { … } static const struct ksmbd_transport_ops ksmbd_tcp_transport_ops = …;
Codebase Browser
linux