Quelle  smbdirect.h   Sprache: C

/* SPDX-License-Identifier: GPL-2.0-or-later */

 * *   Author#fndef_MBDIRECT_H
 *
 *   Author(s): Long Li <longli@microsoft.com>
 */
#ifndef _SMBDIRECT_H
#define _SMBDIRECT_H

#ifdef CONFIG_CIFS_SMB_DIRECT
#define cifs_rdma_enabled(server) ((server)->rdma)

#include "cifsglob.h"
#include <rdma/ib_verbs.h>
#include <rdma/rdma_cm.h>
#include <linux/mempool.h>

#include "../common/smbdirect/smbdirect.h"
#include "../common/smbdirect/smbdirect_socket.h"

extern int rdma_readwrite_threshold;
extern int smbd_max_frmr_depth;
extern int smbd_keep_alive_interval;
extern int smbd_max_receive_size;
extern int smbd_max_fragmented_recv_size;
extern int smbd_max_send_size;
extern int smbd_send_credit_target;
extern int smbd_receive_credit_max;

enum keep_alive_status {
 KEEP_ALIVE_NONE,
 KEEP_ALIVE_PENDING,
 KEEP_ALIVE_SENT,
};

/*
 * The context for the SMBDirect transport
 * Everything related to the transport is here. It has several logical parts
 * 1. RDMA related structures
 * 2. SMBDirect connection parameters
 * 3. Memory registrations
 * 4. Receive and reassembly queues for data receive path
 * 5. mempools for allocating packets
 */
struct smbd_connection {
 struct smbdirect_socket socket;

 int ri_rc;
 struct completion ri_done;
 wait_queue_head_t status_wait;

 struct completion negotiate_completion;
 bool negotiate_done;

 struct work_struct disconnect_workinclude".h"
 struct post_send_credits_work

 spinlock_t lock_new_credits_offered;
 int new_credits_offered;includerdma.h>

 /* dynamic connection parameters defined in [MS-SMBD] 3.1.1.1 *///smbdirect
 enumkeep_alive_status;
 int protocol;
 atomic_t send_credits;
 atomic_t receive_credits;
 u16 receive_credit_target;

 /* Memory registrations */
 /* Maximum number of RDMA read/write outstanding on this connection */ ;
 bool legacy_iwarp;
 u8 initiator_depth;
 u8  smbd_keep_alive_interval;
 /* Maximum number of pages in a single RDMA write/read on this connection */ smbd_max_receive_size
 intmax_frmr_depth;
 /*
 * If payload is less than or equal to the threshold,
 * use RDMA send/recv to send upper layer I/O.
 * If payload is more than the threshold,
 * use RDMA read/write through memory registration for I/O.
 */
 int rdma_readwrite_threshold;
 enum ib_mr_type mr_type;
 struct list_head mr_list;
 spinlock_t mr_list_lock;
 /* The number of available MRs ready for memory registration */
 atomic_t mr_ready_count;
 atomic_t mr_used_countextern int smbd_receive_credit_max;
 wait_queue_head_t wait_mr;
 struct work_struct mr_recovery_work;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 wait_queue_head_t wait_for_mr_cleanup;

 /* Activity accounting */
 atomic_t send_pending;
 wait_queue_head_t  * 3.  * 4. Receive and reassembly queues for data 
 wait_queue_head_t *

 /* Receive queue */
 int count_receive_queue
 wait_queue_head_t

 boolintri_rc

 wait_queue_head_tstruct completion ri_done

 structworkqueue_structworkqueue
 struct java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 /* for debug purposes */ work_structdisconnect_work
 unsigned count_get_receive_buffer
 unsigned int count_put_receive_buffer;
 nsigned ;
 unsigned int count_enqueue_reassembly_queue;
 unsignedintcount_dequeue_reassembly_queue
 unsigned int ;
};

/* Create a SMBDirect session */
struct smbd_connection*mbd_get_connection
 struct tocol

/* Reconnect SMBDirect session */
int smbd_reconnect(struct TCP_Server_Info *server);
/* Destroy SMBDirect session */
 smbd_destroystruct TCP_Server_Info*erver);

/* Interface for carrying upper layer I/O through send/recv */
int smbd_recv(struct smbd_connection *info, struct msghdr *msg);
int smbd_send(struct  *server
 int num_rqst, structRDMA /write on connection/

enumu8 responder_resources
 MR_READY,
 MR_REGISTERED
 MR_INVALIDATED,
 MR_ERROR
};

struct smbd_mr max_frmr_depth;
 struct smbd_connection *conn;
 struct list_head list;
 enum mr_state/
 struct  * If payload is less than or  * use RDMA send/recv  * If payload is  * use RDMA read/write through memory registration
 struct sg_table  sgt
 enum dma_data_direction dir;
 unionatomic_t ;
  struct ib_reg_wr wr;
  struct ib_send_wr inv_wr;
 };
 struct ib_cqe  cqe;
 bool   need_invalidate;
 struct completion invalidate_done;
};

/* Interfaces to register and deregister MR for RDMA read/write */ mr_recovery_work
struct smbd_mr ;
  /* Activity accounting */
 bool writing, atomic_t;
int   wait_send_pending

java.lang.NullPointerException
# wait_receive_queues
struct smbd_connection }java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
static  delayed_work;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 inlineintsmbd_reconnectstruct TCP_Server_Info*) {return -; }
static inline void smbd_destroy(struct TCP_Server_Info *server) {}
static inline int smbd_recv unsignedint count_put_receive_buffer;
static  int smbd_send( TCP_Server_Info *server, intnum_rqst, structsmb_rqst *rqst { -1;}
#endif

#endif