--- /dev/null
+---
+ libmultipath/checkers.h | 3 +
+ libmultipath/checkers/Makefile | 4 +
+ libmultipath/checkers/tur.c | 111 +++++++++++++++++++++++++++++++++++++++++
+ multipath.conf.annotated | 5 +
+ 4 files changed, 121 insertions(+), 2 deletions(-)
+
+Index: multipath-tools/libmultipath/checkers.h
+===================================================================
+--- multipath-tools.orig/libmultipath/checkers.h
++++ multipath-tools/libmultipath/checkers.h
+@@ -60,6 +60,7 @@ enum path_check_state {
+
+ #define DIRECTIO "directio"
+ #define TUR "tur"
++#define HP_TUR "hp_tur"
+ #define HP_SW "hp_sw"
+ #define RDAC "rdac"
+ #define EMC_CLARIION "emc_clariion"
+@@ -91,6 +92,7 @@ enum path_check_state {
+ #define CHECKER_MSG_LEN 256
+ #define CHECKER_DEV_LEN 256
+ #define LIB_CHECKER_NAMELEN 256
++#define WWID_SIZE 128
+
+ struct checker {
+ struct list_head node;
+@@ -99,6 +101,7 @@ struct checker {
+ int disable;
+ char name[CHECKER_NAME_LEN];
+ char message[CHECKER_MSG_LEN]; /* comm with callers */
++ char wwid[WWID_SIZE]; /* LUN wwid */
+ void * context; /* store for persistent data */
+ void ** mpcontext; /* store for persistent data shared
+ multipath-wide. Use MALLOC if
+Index: multipath-tools/libmultipath/checkers/Makefile
+===================================================================
+--- multipath-tools.orig/libmultipath/checkers/Makefile
++++ multipath-tools/libmultipath/checkers/Makefile
+@@ -8,6 +8,7 @@ LIBS= \
+ libcheckcciss_tur.so \
+ libcheckreadsector0.so \
+ libchecktur.so \
++ libcheckhp_tur.so \
+ libcheckdirectio.so \
+ libcheckemc_clariion.so \
+ libcheckhp_sw.so \
+@@ -23,6 +24,9 @@ libcheckdirectio.so: libsg.o directio.o
+ libcheck%.so: libsg.o %.o
+ $(CC) $(SHARED_FLAGS) -o $@ $^
+
++hp_tur.o: tur.c
++ $(CC) $(CFLAGS) -DCHECK_WWID -c -o $@ $<
++
+ install:
+ $(INSTALL_PROGRAM) -m 755 $(LIBS) $(DESTDIR)$(libdir)
+
+Index: multipath-tools/libmultipath/checkers/tur.c
+===================================================================
+--- multipath-tools.orig/libmultipath/checkers/tur.c
++++ multipath-tools/libmultipath/checkers/tur.c
+@@ -15,14 +15,101 @@
+
+ #include "checkers.h"
+
++#include "../libmultipath/debug.h"
+ #include "../libmultipath/sg_include.h"
+
+ #define TUR_CMD_LEN 6
+ #define HEAVY_CHECK_COUNT 10
+
++#ifdef CHECK_WWID
++#define MSG_TUR_UP "HP tur checker reports path is up"
++#define MSG_TUR_DOWN "HP tur checker reports path is down"
++#define MSG_TUR_GHOST "HP tur checker reports path is in standby state"
++#define EVPD 0x01
++#define PAGE_83 0x83
++#define INQUIRY_CMD 0x12
++#define INQUIRY_CMDLEN 6
++#define SCSI_INQ_BUFF_LEN 96
++#else
+ #define MSG_TUR_UP "tur checker reports path is up"
+ #define MSG_TUR_DOWN "tur checker reports path is down"
+ #define MSG_TUR_GHOST "tur checker reports path is in standby state"
++#endif
++
++#ifdef CHECK_WWID
++static int
++do_inq(struct checker * c, char * wwid)
++{
++ int ret = -1;
++ unsigned char inq_cmd[INQUIRY_CMDLEN] =
++ {INQUIRY_CMD, EVPD, PAGE_83, 0, SCSI_INQ_BUFF_LEN, 0 };
++ unsigned char sense_buffer[32];
++ unsigned char resp_buffer[SCSI_INQ_BUFF_LEN];
++ char *pbuff;
++
++ int m,k;
++ int retry_tur = 5;
++ struct sg_io_hdr io_hdr;
++
++retry:
++ memset(resp_buffer, 0, sizeof(resp_buffer));
++ memset(&io_hdr, 0, sizeof(struct sg_io_hdr));
++
++ io_hdr.interface_id = 'S';
++ io_hdr.cmd_len = sizeof(inq_cmd);
++ io_hdr.mx_sb_len = sizeof(sense_buffer);
++ io_hdr.dxfer_direction = -3; // Data transfer from the device.
++ io_hdr.dxfer_len = sizeof(resp_buffer);
++ io_hdr.dxferp = (unsigned char *)resp_buffer;
++ io_hdr.cmdp = inq_cmd;
++ io_hdr.sbp = sense_buffer;
++ io_hdr.timeout = 60; // IOCTL timeout value.
++
++ if (ioctl(c->fd, SG_IO, &io_hdr) < 0) {
++ condlog(0, "SG_IO ioctl failed: %s", strerror(errno));
++ return ret;
++ }
++ if (io_hdr.info & SG_INFO_OK_MASK){
++ int key = 0, asc, ascq;
++
++ if (io_hdr.host_status == DID_BUS_BUSY ||
++ io_hdr.host_status == DID_ERROR ||
++ io_hdr.host_status == DID_TRANSPORT_DISRUPTED) {
++ if (--retry_tur)
++ goto retry;
++ }
++ if (io_hdr.sb_len_wr > 3) {
++ if (io_hdr.sbp[0] == 0x72 || io_hdr.sbp[0] == 0x73) {
++ key = io_hdr.sbp[1] & 0x0f;
++ asc = io_hdr.sbp[2];
++ ascq = io_hdr.sbp[3];
++ } else if (io_hdr.sb_len_wr > 13 &&
++ ((io_hdr.sbp[0] & 0x7f) == 0x70 ||
++ (io_hdr.sbp[0] & 0x7f) == 0x71)) {
++ key = io_hdr.sbp[2] & 0x0f;
++ asc = io_hdr.sbp[12];
++ ascq = io_hdr.sbp[13];
++ }
++ }
++ if (key == 0x6) {
++ /* Unit Attention, retry */
++ if (--retry_tur)
++ goto retry;
++ }
++ return ret;
++ }
++
++ pbuff = (char *) resp_buffer;
++
++ wwid[0] = '3';
++ for (m = 8, k = 1; m < 11; ++m, k+=2)
++ sprintf(&wwid[k], "%02x", (unsigned int)pbuff[m] & 0xff);
++ for (m = 11; m < 24; ++m, k+=2)
++ sprintf(&wwid[k], "%02x", (unsigned int)pbuff[m] & 0xff);
++
++ return (ret = 0);
++}
++#endif
+
+ struct tur_checker_context {
+ void * dummy;
+@@ -30,6 +117,9 @@ struct tur_checker_context {
+
+ int libcheck_init (struct checker * c)
+ {
++#ifdef CHECK_WWID
++ memset(c->wwid, 0, WWID_SIZE);
++#endif
+ return 0;
+ }
+
+@@ -45,6 +135,9 @@ libcheck_check (struct checker * c)
+ unsigned char turCmdBlk[TUR_CMD_LEN] = { 0x00, 0, 0, 0, 0, 0 };
+ unsigned char sense_buffer[32];
+ int retry_tur = 5;
++#ifdef CHECK_WWID
++ char wwid[WWID_SIZE];
++#endif
+
+ retry:
+ memset(&io_hdr, 0, sizeof (struct sg_io_hdr));
+@@ -110,6 +203,24 @@ libcheck_check (struct checker * c)
+ MSG(c, MSG_TUR_DOWN);
+ return PATH_DOWN;
+ }
++#ifdef CHECK_WWID
++ if (!do_inq(c, wwid)) {
++
++ if(!strcmp(c->wwid, "\0")) {
++ strcpy(c->wwid, wwid);
++ goto up;
++ }
++
++ if (strcmp(c->wwid , wwid)) {
++ condlog(0,
++ "hp_tur: Lun collided. new_wwid %s old_wwid %s",
++ wwid, c->wwid);
++ MSG(c, MSG_TUR_DOWN);
++ return PATH_DOWN;
++ }
++ }
++up:
++#endif
+ MSG(c, MSG_TUR_UP);
+ return PATH_UP;
+ }
+Index: multipath-tools/multipath.conf.annotated
+===================================================================
+--- multipath-tools.orig/multipath.conf.annotated
++++ multipath-tools/multipath.conf.annotated
+@@ -86,7 +86,8 @@
+ # # name : path_checker, checker
+ # # scope : multipath & multipathd
+ # # desc : the default method used to determine the paths' state
+-# # values : readsector0|tur|emc_clariion|hp_sw|directio|rdac|cciss_tur
++# # values : readsector0|tur|emc_clariion|hp_sw|directio|rdac|
++# cciss_tur|hp_tur
+ # # default : directio
+ # #
+ # path_checker directio
+@@ -456,7 +457,7 @@
+ # # scope : multipathd
+ # # desc : path checking alorithm to use to check path state
+ # # values : readsector0|tur|emc_clariion|hp_sw|directio|rdac|
+-# # cciss_tur
++# # cciss_tur|hp_tur
+ # #
+ # path_checker directio
+ #
projects / people / pmueller / ipfire-3.x.git / blobdiff