lustre/ptlrpc/ptlrpc_internal.h

   1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
   2  * vim:expandtab:shiftwidth=8:tabstop=8:
   3  *
   4  *  Copyright (C) 2003 Cluster File Systems, Inc.
   5  *
   6  *   This file is part of Lustre, http://www.lustre.org.
   7  *
   8  *   Lustre is free software; you can redistribute it and/or
   9  *   modify it under the terms of version 2 of the GNU General Public
  10  *   License as published by the Free Software Foundation.
  11  *
  12  *   Lustre is distributed in the hope that it will be useful,
  13  *   but WITHOUT ANY WARRANTY; without even the implied warranty of
  14  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  15  *   GNU General Public License for more details.
  16  *
  17  *   You should have received a copy of the GNU General Public License
  18  *   along with Lustre; if not, write to the Free Software
  19  *   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  20  *
  21  */
  22
  23 /* Intramodule declarations for ptlrpc. */
  24
  25 #ifndef PTLRPC_INTERNAL_H
  26 #define PTLRPC_INTERNAL_H
  27
  28 #include "../ldlm/ldlm_internal.h"
  29
  30 struct ldlm_namespace;
  31 struct obd_import;
  32 struct ldlm_res_id;
  33 struct ptlrpc_request_set;
  34
  35 void ptlrpc_request_handle_notconn(struct ptlrpc_request *);
  36 void lustre_assert_wire_constants(void);
  37 int ptlrpc_import_in_recovery(struct obd_import *imp);
  38 int ptlrpc_set_import_discon(struct obd_import *imp);
  39 void ptlrpc_handle_failed_import(struct obd_import *imp);
  40 int ptlrpc_replay_next(struct obd_import *imp, int *inflight);
  41 void ptlrpc_initiate_recovery(struct obd_import *imp);
  42
  43
  44 #ifdef __KERNEL__
  45 void ptlrpc_lprocfs_register_service(struct proc_dir_entry *proc_entry,
  46                                      struct ptlrpc_service *svc);
  47 void ptlrpc_lprocfs_unregister_service(struct ptlrpc_service *svc);
  48 void ptlrpc_lprocfs_rpc_sent(struct ptlrpc_request *req);
  49 void ptlrpc_lprocfs_do_request_stat (struct ptlrpc_request *req,
  50                                      long q_usec, long work_usec);
  51 #else
  52 #define ptlrpc_lprocfs_register_service(params...) do{}while(0)
  53 #define ptlrpc_lprocfs_unregister_service(params...) do{}while(0)
  54 #define ptlrpc_lprocfs_rpc_sent(params...) do{}while(0)
  55 #define ptlrpc_lprocfs_do_request_stat(params...) do{}while(0)
  56 #endif /* __KERNEL__ */
  57
  58 /* recovd_thread.c */
  59 int llog_init_commit_master(void);
  60 int llog_cleanup_commit_master(int force);
  61
  62 static inline int opcode_offset(__u32 opc) {
  63         if (opc < OST_LAST_OPC) {
  64                  /* OST opcode */
  65                 return (opc - OST_FIRST_OPC);
  66         } else if (opc < MDS_LAST_OPC) {
  67                 /* MDS opcode */
  68                 return (opc - MDS_FIRST_OPC +
  69                         (OST_LAST_OPC - OST_FIRST_OPC));
  70         } else if (opc < LDLM_LAST_OPC) {
  71                 /* LDLM Opcode */
  72                 return (opc - LDLM_FIRST_OPC +
  73                         (MDS_LAST_OPC - MDS_FIRST_OPC) +
  74                         (OST_LAST_OPC - OST_FIRST_OPC));
  75         } else if (opc < PTLBD_LAST_OPC) {
  76                 /* Portals Block Device */
  77                 return (opc - PTLBD_FIRST_OPC +
  78                         (LDLM_LAST_OPC - LDLM_FIRST_OPC) +
  79                         (MDS_LAST_OPC - MDS_FIRST_OPC) +
  80                         (OST_LAST_OPC - OST_FIRST_OPC));
  81         } else if (opc < OBD_LAST_OPC) {
  82                 /* OBD Ping */
  83                 return (opc - OBD_FIRST_OPC +
  84                         (PTLBD_LAST_OPC - PTLBD_FIRST_OPC) +
  85                         (LDLM_LAST_OPC - LDLM_FIRST_OPC) +
  86                         (MDS_LAST_OPC - MDS_FIRST_OPC) +
  87                         (OST_LAST_OPC - OST_FIRST_OPC));
  88         } else {
  89                 /* Unknown Opcode */
  90                 return -1;
  91         }
  92 }
  93
  94 #define LUSTRE_MAX_OPCODES ((PTLBD_LAST_OPC - PTLBD_FIRST_OPC) + \
  95                             (LDLM_LAST_OPC - LDLM_FIRST_OPC)   + \
  96                             (MDS_LAST_OPC - MDS_FIRST_OPC)     + \
  97                             (OST_LAST_OPC - OST_FIRST_OPC)     + \
  98                             (OBD_LAST_OPC - OBD_FIRST_OPC))
  99
 100 enum {
 101         PTLRPC_REQWAIT_CNTR = 0,
 102         PTLRPC_REQQDEPTH_CNTR,
 103         PTLRPC_REQACTIVE_CNTR,
 104         PTLRPC_REQBUF_AVAIL_CNTR,
 105         PTLRPC_LAST_CNTR
 106 };
 107
 108 int ptlrpc_expire_one_request(struct ptlrpc_request *req);
 109
 110 /* pers.c */
 111 void ptlrpc_fill_bulk_md(ptl_md_t *md, struct ptlrpc_bulk_desc *desc);
 112 void ptlrpc_add_bulk_page(struct ptlrpc_bulk_desc *desc, struct page *page,
 113                           int pageoffset, int len);
 114
 115 /* pinger.c */
 116 int ptlrpc_start_pinger(void);
 117 int ptlrpc_stop_pinger(void);
 118 void ptlrpc_pinger_sending_on_import(struct obd_import *imp);
 119 void ptlrpc_pinger_wake_up(void);
 120
 121 #endif /* PTLRPC_INTERNAL_H */