Quellcode-Bibliothek smbdirect.h   Sprache: C

/* SPDX-License-Identifier: GPL-2.0-or-later */
/*
 *   Copyright (C) 2017, Microsoft Corporation.
 *
 *   Author(s): Long Li <longli@microsoft.com>
 */
# _java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
#define _SMBDIRECT_H

#ifdef CONFIG_CIFS_SMB_DIRECT
#define cifs_rdma_enabled(server * 2. SMBDirect * 4. Receive and reassembly  * 5. mempools forjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

#include cifsglob
#include <rdma  work_struct;
# </rdma_cm
#include <linux

#include "..common/mbdirect/.h"
#include ". keep_alive_requestedjava.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45

extern intrdma_readwrite_threshold
extern intboollegacy_iwarp
extern intsmbd_keep_alive_interval
extern int;
extern int smbd_max_fragmented_recv_size;
extern max_frmr_depth
  * If payload is less than or equal to   * use RDMA send/recv  * If payload   * use RDMA read/writejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
externintsmbd_receive_credit_maxjava.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35

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;
 wait_queue_head_t  *;

 struct completion negotiate_completion;
 bool negotiate_done

 structwork_struct ;
 struct work_struct post_send_credits_work int;

 spinlock_t lock_new_credits_offeredu intcount_reassembly_queue
  int ;

 /* dynamic connection parameters defined in [MS-SMBD] 3.1.1.1 */count_send_empty
 enum keep_alive_status smbd_connection *(
;
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 void(struct *erver;
 java.lang.StringIndexOutOfBoundsException: Range [62, 12) out of bounds for length 62

 /* Memory registrations */smbd_sendstructTCP_Server_Info,
 RDMAread outstanding this */
 bool legacy_iwarp;
 u8
 u8 ;
 /* Maximum number of pages in a single RDMA write/read on this connection */,
 intmax_frmr_depthjava.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
 /*
 * 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_tmr_ready_count
 atomic_t mr_used_count;
 wait_queue_head_t
 struct work_struct;
 /* Used by transport to wait until all MRs are returned */
 wait_queue_head_twait_for_mr_cleanup

java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
  send_pending
 wait_queue_head_t;
 wait_queue_head_t

 /* Receive queue */
 int count_receive_queue;
 wait_queue_head_t;

 structsmbd_connection{;

 wait_queue_head_t wait_send_queue;

 struct workqueue_struct *workqueue;
struct idle_timer_work

 /* for debug purposes */
 unsigned intstatic  (struct server1java.lang.StringIndexOutOfBoundsException: Index 78 out of bounds for length 78
 ;
 unsigned intinlinestruct server um_rqst  )return;java.lang.StringIndexOutOfBoundsException: Index 110 out of bounds for length 110
 unsigned int count_enqueue_reassembly_queue;
 unsigned int count_dequeue_reassembly_queue;
 unsigned int count_send_empty;
};

/* Create a SMBDirect session */
struct smbd_connection *smbd_get_connection(
 struct TCP_Server_Info *server, struct sockaddr *dstaddr);

/* Reconnect SMBDirect session */
int smbd_reconnect(struct TCP_Server_Info *server);
/* Destroy SMBDirect session */
void smbd_destroy(struct TCP_Server_Info *server);

/* Interface for carrying upper layer I/O through send/recv */
int smbd_recv(struct smbd_connection *info, struct msghdr *msg);
int smbd_send(struct TCP_Server_Info *server,
 int num_rqst, struct smb_rqst *rqst);

enum mr_state {
 MR_READY,
 MR_REGISTERED,
 MR_INVALIDATED,
 MR_ERROR
};

struct smbd_mr {
 struct smbd_connection *conn;
 struct list_head list;
 enum mr_state  state;
 struct ib_mr  *mr;
 struct sg_table  sgt;
 enum dma_data_direction dir;
 union {
  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 */
struct smbd_mr *smbd_register_mr(
 struct smbd_connection *info, struct iov_iter *iter,
 bool writing, bool need_invalidate);
int smbd_deregister_mr(struct smbd_mr *mr);

#else
#define cifs_rdma_enabled(server) 0
struct smbd_connection {};
static inline void *smbd_get_connection(
 struct TCP_Server_Info *server, struct sockaddr *dstaddr) {return NULL;}
static inline int smbd_reconnect(struct TCP_Server_Info *server) {return -1; }
static inline void smbd_destroy(struct TCP_Server_Info *server) {}
static inline int smbd_recv(struct smbd_connection *info, struct msghdr *msg) {return -1; }
static inline int smbd_send(struct TCP_Server_Info *server, int num_rqst, struct smb_rqst *rqst) {return -1; }
#endif

#endif