* By Gerald Combs <gerald@wireshark.org>
* Copyright 1999 Gerald Combs
*
+ * C-Syle: 2 space indents
+ *
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
} ldlm_cmd_t;
#define LDLM_FIRST_OPC LDLM_ENQUEUE
+enum seq_rpc_opc {
+ SEQ_QUERY = 700,
+ SEQ_LAST_OPC,
+ SEQ_FIRST_OPC = SEQ_QUERY
+};
+
#define LDLM_FL_LOCK_CHANGED 0x000001
#define LDLM_FL_BLOCK_GRANTED 0x000002
#define LDLM_FL_BLOCK_CONV 0x000004
static gint ett_lustre_qunit_data_old2 = -1;
static gint ett_lustre_qunit_data_old = -1;
static gint ett_lustre_ldlm_lock_flags = -1 ;
+static gint ett_lustre_seq_range = -1;
+static gint ett_lustre_mdt_ioepoch = -1;
+static gint ett_lustre_capa = -1;
/* -----------------------------------------------*/
/* Header field declarations */
static int hf_lustre_mdt_rec_create_cr_bias = -1;
static int hf_lustre_mdt_rec_create_cr_flags_l = -1;
static int hf_lustre_mdt_rec_create_cr_flags_h = -1;
-static int hf_lustre_mdt_rec_create_cr_padding_3 = -1;
+static int hf_lustre_mdt_rec_create_cr_umask = -1;
static int hf_lustre_mdt_rec_create_cr_padding_4 = -1;
static int hf_lustre_mdt_rec_link = -1 ;
static int hf_lustre_mdt_rec_setxattr_sx_padding_10 = -1;
static int hf_lustre_mdt_rec_setxattr_sx_padding_11 = -1;
+static int hf_lustre_seq_opc = -1;
+static int hf_lustre_seq_range = -1;
+static int hf_lustre_seq_range_start = -1;
+static int hf_lustre_seq_range_end = -1;
+static int hf_lustre_seq_range_index = -1;
+static int hf_lustre_seq_range_flags = -1;
+
+static int hf_lustre_mdt_ioepoch = -1;
+static int hf_lustre_mdt_ioepoch_handle = -1;
+static int hf_lustre_mdt_ioepoch_ioepoch = -1;
+static int hf_lustre_mdt_ioepoch_flags = -1;
+static int hf_lustre_mdt_ioepoch_padding = -1;
+
+static int hf_lustre_capa = -1;
+
static int hf_lustre_lustre_handle_cookie = -1;
static int hf_lustre_ptlrpc_body_pb_last_committed = -1;
static int hf_lustre_ptlrpc_body_pb_version = -1;
static int hf_lustre_lustre_msg_v1_lm_bufcount = -1;
static int hf_lustre_obd_ioobj_ioo_id = -1;
static int hf_lustre_ptlrpc_body_pb_slv = -1;
+static int hf_lustre_ptlrpc_body_pb_pre_version = -1;
+static int hf_lustre_ptlrpc_body_pb_padding = -1;
+static int hf_lustre_ptlrpc_body_pb_jobid = -1;
static int hf_lustre_lustre_msg_v1_lm_handle = -1;
static int hf_lustre_ost_lvb_lvb_atime = -1;
static int hf_lustre_ptlrpc_body_pb_timeout = -1;
static int hf_lustre_lov_desc_ld_padding_2 = -1;
static int hf_lustre_llog_logid_rec_lid_tail = -1;
static int hf_lustre_obdo_o_grant = -1;
-static int hf_lustre_obdo_o_padding_2 = -1;
+static int hf_lustre_obdo_o_uid_h = -1;
+static int hf_lustre_obdo_o_gid_h = -1;
static int hf_lustre_quota_adjust_qunit_qaq_iunit_sz = -1;
static int hf_lustre_llog_unlink_rec_padding = -1;
static int hf_lustre_ldlm_lock_desc_l_req_mode = -1;
{0x000002 , "LDLM_FL_BLOCK_GRANTED"},
{0x000004 , "LDLM_FL_BLOCK_CONV"},
{0x000008 , "LDLM_FL_BLOCK_WAIT"},
- {0x000010 , "LDLM_FL_CBPENDING"},
+ {0x000010 , "LDLM_FL_CBPENDING"},
{0x000020 , "LDLM_FL_AST_SENT"},
- {0x000040 , "LDLM_FL_WAIT_NOREPROC"},
- {0x000080 , "LDLM_FL_CANCEL"},
+ {0x000040 , "LDLM_FL_WAIT_NOREPROC"},
+ {0x000080 , "LDLM_FL_CANCEL"},
{0x000100 , "LDLM_FL_REPLAY"},
{0x000200 , "LDLM_FL_INTENT_ONLY"},
- {0x000400 , "LDLM_FL_LOCAL_ONLY"},
- {0x000800 , "LDLM_FL_FAILED"},
+ {0x000400 , "LDLM_FL_LOCAL_ONLY"},
+ {0x000800 , "LDLM_FL_FAILED"},
{0x001000 , "LDLM_FL_HAS_INTENT"},
- {0x002000 , "LDLM_FL_CANCELING"},
- {0x004000 , "LDLM_FL_LOCAL"},
- {0x008000 , "LDLM_FL_WARN"},
+ {0x002000 , "LDLM_FL_CANCELING"},
+ {0x004000 , "LDLM_FL_LOCAL"},
+ {0x008000 , "LDLM_FL_WARN"},
{0x010000 , "LDLM_FL_DISCARD_DATA"},
{0x020000 , "LDLM_FL_NO_TIMEOUT"},
{0x040000 , "LDLM_FL_BLOCK_NOWAIT"},
{0x080000 , "LDLM_FL_TEST_LOCK"},
- {0x100000 , "LDLM_FL_LVB_READY"},
- {0x200000 , "LDLM_FL_KMS_IGNORE"},
- {0x400000 , "LDLM_FL_NO_LRU"},
+ {0x100000 , "LDLM_FL_LVB_READY"},
+ {0x200000 , "LDLM_FL_KMS_IGNORE"},
+ {0x400000 , "LDLM_FL_NO_LRU"},
{0x800000 , "LDLM_FL_CANCEL_ON_BLOCK"},
- {0x1000000 , "LDLM_FL_CP_REQD"},
- {0x2000000 , "LDLM_FL_CLEANED"},
- {0x4000000 , "LDLM_FL_ATOMIC_CB"},
- {0x10000000 , "LDLM_FL_BL_AST"},
- {0x20000000 , "LDLM_FL_BL_DONE"},
+ {0x1000000 , "LDLM_FL_CP_REQD"},
+ {0x2000000 , "LDLM_FL_CLEANED"},
+ {0x4000000 , "LDLM_FL_ATOMIC_CB"},
+ {0x10000000 , "LDLM_FL_BL_AST"},
+ {0x20000000 , "LDLM_FL_BL_DONE"},
{0x40000000 , "LDLM_FL_DENY_ON_CONTENTION"},
{0x80000000 , "LDLM_AST_DISCARD_DATA"},
{ 0, NULL }
{ 507, "LLOG_CATINFO"},
{ 508, "LLOG_ORIGIN_HANDLE_PREV_BLOCK"},
{ 509, "LLOG_ORIGIN_HANDLE_DESTROY"},
+ /* SEQ RPC opcodes */
+ { 700, "SEQ_QUERY"},
+ { 701, "SEQ_LAST_OPC"},
+ /* FLD RPC opcodes */
+ { 900, "FLD_QUERY"},
+ { 901, "FLD_LAST_OPC"},
{ 0, NULL }
};
/*const value_string lustre_ldlm_mode_t_vals[] = {*/
proto_tree *tree = NULL;
int old_offset;
-
-
old_offset=offset;
if (parent_tree) {
}
int
-lustre_dissect_struct_mdt_body(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *parent_tree _U_, int hf_index _U_)
+lustre_dissect_struct_mdt_body(tvbuff_t *tvb _U_, int offset _U_,
+ packet_info *pinfo _U_,
+ proto_tree *parent_tree _U_,
+ int hf_index _U_)
{
proto_item *item = NULL;
proto_tree *tree = NULL;
/* IDL: uint32 cr_bias; */
/* IDL: uint32 cr_flags_l; */
/* IDL: uint32 cr_flags_h; */
-/* IDL: uint32 cr_padding_3; */
+/* IDL: uint32 cr_umask; */
/* IDL: uint32 cr_padding_4; */
/* IDL: } */
}
static int
-lustre_dissect_element_mdt_rec_create_cr_padding_3(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *tree _U_)
+lustre_dissect_element_mdt_rec_create_cr_umask(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *tree _U_)
{
- offset=dissect_uint32(tvb, offset, pinfo, tree, hf_lustre_mdt_rec_create_cr_padding_3);
+ offset=dissect_uint32(tvb, offset, pinfo, tree, hf_lustre_mdt_rec_create_cr_umask);
return offset;
}
}
int
-lustre_dissect_struct_mdt_rec_create(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *parent_tree _U_, int hf_index _U_)
+lustre_dissect_struct_mdt_rec_create(tvbuff_t *tvb _U_, int offset _U_,
+ packet_info *pinfo _U_,
+ proto_tree *parent_tree _U_,
+ int hf_index _U_)
{
proto_item *item = NULL;
proto_tree *tree = NULL;
int old_offset;
guint32 cr_opcode ;
-
-
old_offset=offset;
if (parent_tree) {
offset=lustre_dissect_element_mdt_rec_create_cr_flags_h(tvb, offset, pinfo, tree);
- offset=lustre_dissect_element_mdt_rec_create_cr_padding_3(tvb, offset, pinfo, tree);
+ offset=lustre_dissect_element_mdt_rec_create_cr_umask(tvb, offset, pinfo, tree);
offset=lustre_dissect_element_mdt_rec_create_cr_padding_4(tvb, offset, pinfo, tree);
-
proto_item_set_len(item, offset-old_offset);
-
return offset;
}
}
int
-lustre_dissect_struct_mdt_rec_setxattr(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *parent_tree _U_, int hf_index _U_)
+ lustre_dissect_struct_mdt_rec_setxattr(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *parent_tree _U_, int hf_index _U_)
{
proto_item *item = NULL;
proto_tree *tree = NULL;
static int
lustre_dissect_struct_obd_uuid(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *parent_tree _U_, int hf_index _U_)
{
-
/* the lenght of the string is 40 bytes max, with \0 inside */
-
proto_tree_add_item(parent_tree, hf_index, tvb, offset, 40, TRUE);
-
offset+=40;
return offset;
}
int
lustre_dissect_struct_ldlm_intent(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *parent_tree _U_, int hf_index _U_)
{
- // proto_item *item = NULL;
- //proto_tree *tree = NULL;
- int old_offset;
guint64 intent_opc;
proto_item * opcode_item = NULL;
proto_tree * opcode_tree = NULL;
- old_offset=offset;
- // if (parent_tree) {
- // item = proto_tree_add_item(parent_tree, hf_index, tvb, offset, -1, TRUE);
- // tree = proto_item_add_subtree(item, ett_lustre_ldlm_intent);
- // //tree = parent_tree; /* TODO : !!!!!!!!!!!!!!! ATTENTIon à revoir,
- // //fait rapidement pour ne pas avoir le subtree */
- // }
-
-
intent_opc = tvb_get_letoh64(tvb,offset);
if (parent_tree){
opcode_item = proto_tree_add_item(parent_tree, hf_lustre_ldlm_intent_opc, tvb, offset, 8, TRUE);
offset=ldlm_opcode_process(tvb, offset, pinfo, parent_tree, intent_opc);
-
-
return offset;
}
proto_item *item = NULL;
proto_tree *tree = NULL;
int old_offset;
- guint32 lock_flag ;
+ guint32 lock_flag;
guint32 ldlm_type;
old_offset=offset;
}
lock_flag = tvb_get_letohl(tvb,offset);
- offset=lustre_dissect_element_ldlm_lock_flags(tvb, offset, pinfo, tree, hf_lustre_ldlm_request_lock_flags);
+ offset=lustre_dissect_element_ldlm_lock_flags(tvb, offset, pinfo, tree,
+ hf_lustre_ldlm_request_lock_flags);
offset=lustre_dissect_element_ldlm_request_lock_count(tvb, offset, pinfo, tree);
}
-
-
/* IDL: struct ldlm_reply { */
/* IDL: uint32 lock_flags; */
/* IDL: uint32 lock_padding; */
/* IDL: uint64 lock_policy_res2; */
/* IDL: } */
-
static int
lustre_dissect_element_ldlm_lock_flags(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *parent_tree _U_, int hf_index _U_)
{
/* IDL: } o_handle; */
/* IDL: struct llog_cookie { */
/* IDL: } o_lcookie; */
-/* IDL: uint64 o_padding_2; */
+/* IDL: uint32 o_uid_h; */
+/* IDL: uint32 o_gid_h; */
/* IDL: uint64 o_padding_3; */
/* IDL: uint64 o_padding_4; */
/* IDL: uint64 o_padding_5; */
static int
lustre_dissect_element_obdo_o_parent_ver(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *tree _U_)
{
- offset=dissect_uint64(tvb, offset, pinfo, tree, hf_lustre_obdo_o_parent_ver);
+ offset=dissect_uint32(tvb, offset, pinfo, tree, hf_lustre_obdo_o_parent_ver);
return offset;
}
}
static int
-lustre_dissect_element_obdo_o_padding_2(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *tree _U_)
+lustre_dissect_element_obdo_o_uid_h(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *tree _U_)
{
- offset=dissect_uint64(tvb, offset, pinfo, tree, hf_lustre_obdo_o_padding_2);
+ offset=dissect_uint32(tvb, offset, pinfo, tree, hf_lustre_obdo_o_uid_h);
+
+ return offset;
+}
+
+static int
+lustre_dissect_element_obdo_o_gid_h(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *tree _U_)
+{
+ offset=dissect_uint32(tvb, offset, pinfo, tree, hf_lustre_obdo_o_gid_h);
return offset;
}
int old_offset;
-
old_offset=offset;
if (parent_tree) {
offset=lustre_dissect_element_obdo_o_lcookie(tvb, offset, pinfo, tree);
- offset=lustre_dissect_element_obdo_o_padding_2(tvb, offset, pinfo, tree);
+ offset=lustre_dissect_element_obdo_o_uid_h(tvb, offset, pinfo, tree);
+
+ offset=lustre_dissect_element_obdo_o_gid_h(tvb, offset, pinfo, tree);
offset=lustre_dissect_element_obdo_o_padding_3(tvb, offset, pinfo, tree);
proto_tree *tree = NULL;
int old_offset;
-
-
old_offset=offset;
if (parent_tree) {
return offset;
}
+int
+lustre_dissect_struct_seq_opc(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *parent_tree _U_)
+{
+ offset=dissect_uint32(tvb, offset, pinfo, parent_tree, hf_lustre_seq_opc);
+ /* Pad out to 8 bytes */
+ offset=add_extra_padding(tvb,offset,pinfo,parent_tree);
+
+ return offset;
+}
+
+int
+lustre_dissect_struct_seq_range(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *parent_tree _U_, int hf_index _U_)
+{
+ proto_item *item = NULL;
+ proto_tree *tree = NULL;
+ int old_offset;
+
+ old_offset=offset;
+
+ if (parent_tree) {
+ item = proto_tree_add_item(parent_tree, hf_index, tvb, offset, -1, TRUE);
+ tree = proto_item_add_subtree(item, ett_lustre_seq_range);
+ }
+
+ offset=dissect_uint64(tvb, offset, pinfo, tree, hf_lustre_seq_range_start);
+ offset=dissect_uint64(tvb, offset, pinfo, tree, hf_lustre_seq_range_end);
+ offset=dissect_uint32(tvb, offset, pinfo, tree, hf_lustre_seq_range_index);
+ offset=dissect_uint32(tvb, offset, pinfo, tree, hf_lustre_seq_range_flags);
+
+ if (item)
+ proto_item_set_len(item, offset-old_offset);
+
+ return offset;
+}
+
+int
+lustre_dissect_struct_mdt_ioepoch(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *parent_tree _U_, int hf_index _U_)
+{
+ proto_item *item = NULL;
+ proto_tree *tree = NULL;
+ int old_offset;
+
+ old_offset=offset;
+
+ if (parent_tree) {
+ item = proto_tree_add_item(parent_tree, hf_index, tvb, offset, -1, TRUE);
+ tree = proto_item_add_subtree(item, ett_lustre_mdt_ioepoch);
+ }
+
+ offset=lustre_dissect_struct_handle_cookie(tvb, offset, pinfo, tree, hf_lustre_mdt_ioepoch_handle);
+ offset=dissect_uint64(tvb, offset, pinfo, tree, hf_lustre_mdt_ioepoch_ioepoch);
+ offset=dissect_uint32(tvb, offset, pinfo, tree, hf_lustre_mdt_ioepoch_flags);
+ offset=dissect_uint32(tvb, offset, pinfo, tree, hf_lustre_mdt_ioepoch_padding);
+
+ if (item)
+ proto_item_set_len(item, offset-old_offset);
+ return offset;
+}
+
+int
+lustre_dissect_struct_capa(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *parent_tree _U_, int hf_index _U_, guint32 buf_num)
+{
+ proto_item *item = NULL;
+ proto_tree *tree = NULL;
+ int old_offset;
+ int data_len;
+
+ old_offset=offset;
+
+ if(buf_num+1>LUSTRE_BUFCOUNT)
+ return offset;
+
+ data_len = tvb_get_letohl(tvb, LUSTRE_BUFLEN_OFF + sizeof(guint32) * buf_num);
+ if (data_len == 0)
+ return offset;
+
+ if (parent_tree) {
+ item = proto_tree_add_item(parent_tree, hf_index, tvb, offset, -1, TRUE);
+ tree = proto_item_add_subtree(item, ett_lustre_capa);
+ }
+
+ g_print("BUG: decode of lustre_capa NYI\n");
+ if (check_col(pinfo->cinfo, COL_INFO))
+ col_append_str(pinfo->cinfo, COL_PROTOCOL, "BUG");
+
+ offset+=120;
+
+ if (item)
+ proto_item_set_len(item, offset-old_offset);
+ return offset;
+}
+
+
/* ------------------------------------------------------------------------- */
/* dissect string .
lustre_dissect_element_string (tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *parent_tree _U_, int hf_index _U_, guint32 buf_num)
{
proto_item *item = NULL;
-
int old_offset;
guint32 string_len;
old_offset=offset;
- // if (parent_tree) { item = proto_tree_add_item(parent_tree, hf_index, tvb,
- // offset, -1, TRUE); // tree = proto_item_add_subtree(item,
- // ett_lustre); }
+ /* if (parent_tree) {
+ * item = proto_tree_add_item(parent_tree, hf_index, tvb, offset, -1, TRUE);
+ * tree = proto_item_add_subtree(item, ett_lustre);
+ * }
+ */
if(buf_num+1>LUSTRE_BUFCOUNT)
return offset;
string_len = tvb_get_letohl(tvb, LUSTRE_BUFLEN_OFF + 4 * buf_num) ; /* 4 because a buflen is on a guint32 */
+ /* g_print("buf_num:%d (max:%d) BUFLEN_OFF:%#x strlen:%d\n",
+ buf_num, LUSTRE_BUFCOUNT,
+ LUSTRE_BUFLEN_OFF, string_len);*/
+
proto_tree_add_item(parent_tree, hf_index, tvb, offset, string_len, TRUE);
if(string_len>1)
display_info_fstr(parent_tree, pinfo->cinfo, COL_INFO, " filename : %s",
- (const gchar *) tvb_get_string(tvb,offset,string_len) );
+ (const gchar *) tvb_get_string(tvb,offset,string_len) );
offset+=string_len;
proto_item_set_len(item, offset-old_offset);
offset=add_extra_padding(tvb,offset,pinfo,parent_tree); /* after a string we must be aligned to 8 bytes. */
-
return offset;
}
{
proto_item *item = NULL;
- guint32 data_len ;
+ guint32 data_len;
int old_offset;
old_offset=offset;
if(buf_num+1>LUSTRE_BUFCOUNT)
return offset;
- data_len = tvb_get_letohl(tvb, LUSTRE_BUFLEN_OFF + 4 * buf_num) ; /* 4 because a buflen is on a guint32 */
+ data_len = tvb_get_letohl(tvb, LUSTRE_BUFLEN_OFF + sizeof(guint32) * buf_num);
proto_tree_add_item(parent_tree, hf_index, tvb, offset, data_len, TRUE);
offset+=data_len;
/* ------------------------------------------------------------------------ */
+/* Process REINT opcode requests */
static int reint_opcode_process(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree * tree _U_)
{
guint32 opcode ;
hf_lustre_ldlm_request) ;
/*TODO : need to be check*/
break;
- case REINT_UNLINK : /* mds_unlink_unpack : [mdt_rec_unlink][filename][ldlm_req] */
- /* [mdt_rec_unlink][filename][ldlm_req][..]*/
+ case REINT_UNLINK :
+ /* reint_unlink_client: [mdt_rec_unlink][capa1][filename][ldlm_req] */
offset=lustre_dissect_struct_mdt_rec_unlink(tvb, offset, pinfo, tree, hf_lustre_mdt_rec_unlink);
- offset=lustre_dissect_element_string(tvb, offset, pinfo, tree, hf_lustre_reint_name, LUSTRE_REQ_REC_OFF+1);
- if ( (tvb_get_letohl(tvb,LUSTRE_BUFLEN_OFF+4*(LUSTRE_REQ_REC_OFF +2))) == 112) /* TODO : ugly .. but
+ offset=lustre_dissect_struct_capa(tvb, offset, pinfo, tree, hf_lustre_capa, LUSTRE_REQ_REC_OFF+1);
+ if ( (tvb_get_letohl(tvb,LUSTRE_BUFLEN_OFF+4*(LUSTRE_REQ_REC_OFF +2))) == 112) { /* TODO : ugly .. but
for now we have to do this */
offset=lustre_dissect_struct_obd_quotactl(tvb, offset, pinfo, tree, hf_lustre_obd_quotactl);
- else
- offset=lustre_dissect_struct_ldlm_request(tvb, offset, pinfo, tree, hf_lustre_ldlm_request) ;
+ } else {
+ offset=lustre_dissect_element_string(tvb, offset, pinfo, tree, hf_lustre_reint_name, LUSTRE_REQ_REC_OFF+2);
+ offset=lustre_dissect_struct_ldlm_request(tvb, offset, pinfo, tree, hf_lustre_ldlm_request) ;
+ }
break;
case REINT_RENAME : /*mds_rename_unpack : [mdt_rec_rename][filename source][filename target_name][ldlm_request] */
offset=lustre_dissect_struct_mdt_rec_rename(tvb, offset, pinfo, tree, hf_lustre_mdt_rec_rename);
offset=lustre_dissect_struct_mdt_body(tvb, offset, pinfo, tree, hf_lustre_mdt_body) ;
break;
- case MDS_CLOSE: /* TODO : check the corresponding structure in lustre code */
+ case MDS_CLOSE:
if(pb_type==PTL_RPC_MSG_REQUEST)
- { /* [mdt_body] [lov_mds_md][log_cookie] */
- offset=lustre_dissect_struct_mdt_body(tvb, offset, pinfo, tree, hf_lustre_mdt_body) ;
- if(LUSTRE_BUFCOUNT>=3)
- offset=lustre_dissect_struct_lov_mds_md_v1(tvb,offset,pinfo,tree,hf_lustre_lov_mds_md_v1);
- if(LUSTRE_BUFCOUNT>=4)
- if( tvb_get_letohl(tvb,LUSTRE_BUFLEN_OFF+4*(LUSTRE_REQ_REC_OFF+2)) > 0)
- offset=lustre_dissect_struct_llog_cookie(tvb,offset,pinfo,tree,hf_lustre_llog_cookie);
+ { /* [mdt_ioepoch][rec_reint][capa1] */
+ offset=lustre_dissect_struct_mdt_ioepoch(tvb, offset, pinfo, tree, hf_lustre_mdt_ioepoch);
+
+ if(LUSTRE_BUFCOUNT>=3)
+ offset=lustre_dissect_struct_mdt_rec_setattr(tvb, offset, pinfo, tree, hf_lustre_mdt_rec_setattr);
+
+ if(LUSTRE_BUFCOUNT>=4)
+ offset=lustre_dissect_struct_capa(tvb,offset,pinfo,tree, hf_lustre_capa, 4);
}
if(pb_type==PTL_RPC_MSG_REPLY)
{ /* [mdt_body][md][cookie] TODO : check that (reread the code about shrink in lustre) */
case MDS_REINT:
/* the structure depend on the intent_opcode */
if(pb_type==PTL_RPC_MSG_REQUEST)
- offset=reint_opcode_process(tvb, offset, pinfo, tree);
+ offset=reint_opcode_process(tvb, offset, pinfo, tree);
if(pb_type==PTL_RPC_MSG_REPLY)
{
- /*[mdt_body][??][llog_logid_rec] */
- offset=lustre_dissect_struct_mdt_body(tvb, offset, pinfo, tree, hf_lustre_mdt_body) ;
- if(tvb_get_letohl(tvb,LUSTRE_BUFLEN_OFF+4*(LUSTRE_REQ_REC_OFF+1)) > 0){
- /* OPEN, RENAME, and UNLINK */
- if(tvb_get_letohl(tvb, LUSTRE_BUFLEN_OFF+4*(LUSTRE_REQ_REC_OFF+1)) > 0){ /* rec_unlink or rec_rename */
- offset=lustre_dissect_element_data(tvb, offset, pinfo, tree, hf_lustre_mds_xattr_eadata,
- LUSTRE_REQ_REC_OFF+1); // replace by eadata TODO TODO //
- if(tvb_get_letohl(tvb,LUSTRE_BUFLEN_OFF+4*(LUSTRE_REQ_REC_OFF+2)) > 0) /* with unlink or rename we have 4 buffers handler.c line 1691*/
- offset=lustre_dissect_element_data(tvb, offset, pinfo, tree,
- hf_lustre_mds_xattr_eadata, LUSTRE_REQ_REC_OFF+2); // replace withe eadata TODO TODO //
- }
- }
-
+ /*[mdt_body][??][llog_logid_rec] */
+ offset=lustre_dissect_struct_mdt_body(tvb, offset, pinfo, tree, hf_lustre_mdt_body) ;
+ if(tvb_get_letohl(tvb,LUSTRE_BUFLEN_OFF+4*(LUSTRE_REQ_REC_OFF+1)) > 0){
+ /* OPEN, RENAME, and UNLINK */
+ /* rec_unlink or rec_rename */
+ if(tvb_get_letohl(tvb, LUSTRE_BUFLEN_OFF+4*(LUSTRE_REQ_REC_OFF+1)) > 0){
+ offset=lustre_dissect_element_data(tvb, offset, pinfo, tree,
+ hf_lustre_mds_xattr_eadata,
+ LUSTRE_REQ_REC_OFF+1); // replace by eadata TODO TODO //
+ if(tvb_get_letohl(tvb,LUSTRE_BUFLEN_OFF+4*(LUSTRE_REQ_REC_OFF+2)) > 0) /* with unlink or rename we have 4 buffers handler.c line 1691*/
+ offset=lustre_dissect_element_data(tvb, offset, pinfo, tree,
+ hf_lustre_mds_xattr_eadata, LUSTRE_REQ_REC_OFF+2); // replace withe eadata TODO TODO //
+ }
+ }
}
break;
case MDS_SET_INFO:
static int
lustre_ldlm_opcode_process(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree * tree _U_, guint32 opc _U_, guint32 pb_type)
{
-
- switch (opc)
- {
- case LDLM_ENQUEUE:
- /*[ldlm_request] if we have one more buffer it's [intent_opcode] and the opcode give us the
- * corresponding intent structure [intent] */
- if(pb_type==PTL_RPC_MSG_REQUEST)
- {
- offset=lustre_dissect_struct_ldlm_request(tvb, offset, pinfo, tree, hf_lustre_ldlm_request) ;
- if (LUSTRE_BUFCOUNT>=3)
- offset=lustre_dissect_struct_ldlm_intent(tvb, offset, pinfo, tree, hf_lustre_ldlm_intent);
- }
- if(pb_type==PTL_RPC_MSG_REPLY)
- {
- guint32 ldlm_type;
- guint32 magic;
- /*[ldlm_reply]*/
- offset=lustre_dissect_struct_ldlm_reply(tvb, offset, pinfo, tree, hf_lustre_ldlm_reply,&ldlm_type) ;
- if(LUSTRE_BUFCOUNT>2 && (tvb_get_letohl(tvb,LUSTRE_BUFLEN_OFF+4*2) == 40))
- /* TODO :this code need to be check and test, the lustre corresponding code is'nt explicit, so
- * not sure to have this buffer, but in example it works fine
- */
- offset=lustre_dissect_struct_ost_lvb(tvb, offset, pinfo, tree, hf_lustre_ost_lvb);
- else
- if(LUSTRE_BUFCOUNT>2)
- {
- offset=lustre_dissect_struct_mdt_body(tvb, offset, pinfo, tree, hf_lustre_mdt_body) ;
- /*g_print("buflen_off+4*3 = %d", tvb_get_letohl(tvb,LUSTRE_BUFLEN_OFF+4*LUSTRE_DLM_INTENT_REC_OFF));*/
- if(LUSTRE_BUFCOUNT>2 &&
- (tvb_get_letohl(tvb,LUSTRE_BUFLEN_OFF+4*LUSTRE_DLM_INTENT_REC_OFF) > 0))
- {
- magic=tvb_get_letohl(tvb, offset); /* TODO : replace this with a macro */
- switch(magic)
- {
- case LOV_MAGIC_V1:
- offset=lustre_dissect_struct_lov_mds_md_v1(tvb,offset,pinfo,tree,hf_lustre_lov_mds_md_v1);
- break;
- default:
- offset=lustre_dissect_element_data(tvb, offset, pinfo, tree,
- hf_lustre_extra_padding, LUSTRE_DLM_INTENT_REC_OFF);
- break;
- };
- }
- }
+ switch (opc) {
+ case LDLM_ENQUEUE:
+ /* [ldlm_request] if we have one more buffer it's
+ * [intent_opcode] and the opcode give us the corresponding
+ * intent structure [intent] */
+ if (pb_type==PTL_RPC_MSG_REQUEST)
+ {
+ offset=lustre_dissect_struct_ldlm_request(tvb, offset, pinfo, tree,
+ hf_lustre_ldlm_request);
+ if (LUSTRE_BUFCOUNT>=3)
+ offset=lustre_dissect_struct_ldlm_intent(tvb, offset, pinfo, tree,
+ hf_lustre_ldlm_intent);
+ }
+ if (pb_type==PTL_RPC_MSG_REPLY)
+ {
+ guint32 ldlm_type;
+ guint32 magic;
+ /*[ldlm_reply]*/
+ offset=lustre_dissect_struct_ldlm_reply(tvb, offset, pinfo, tree,
+ hf_lustre_ldlm_reply,
+ &ldlm_type) ;
+ if (LUSTRE_BUFCOUNT>2 && (tvb_get_letohl(tvb,LUSTRE_BUFLEN_OFF+sizeof(guint32)*2) == 40))
+ /* TODO :this code need to be check and test, the
+ * lustre corresponding code is'nt explicit, so not
+ * sure to have this buffer, but in example it works
+ * fine
+ */
+ offset=lustre_dissect_struct_ost_lvb(tvb, offset, pinfo, tree,
+ hf_lustre_ost_lvb);
+
+ else if (LUSTRE_BUFCOUNT>2) {
+ offset=lustre_dissect_struct_mdt_body(tvb, offset, pinfo, tree,
+ hf_lustre_mdt_body) ;
+ /*g_print("buflen_off+4*3 = %d", tvb_get_letohl(tvb,LUSTRE_BUFLEN_OFF+4*LUSTRE_DLM_INTENT_REC_OFF));*/
+ if(LUSTRE_BUFCOUNT>2 &&
+ (tvb_get_letohl(tvb,LUSTRE_BUFLEN_OFF+4*LUSTRE_DLM_INTENT_REC_OFF) > 0))
+ {
+ magic=tvb_get_letohl(tvb, offset); /* TODO : replace this with a macro */
+ switch(magic)
+ {
+ case LOV_MAGIC_V1:
+ offset=lustre_dissect_struct_lov_mds_md_v1(tvb,offset,pinfo,tree,hf_lustre_lov_mds_md_v1);
+ break;
+ default:
+ offset=lustre_dissect_element_data(tvb, offset, pinfo, tree,
+ hf_lustre_extra_padding, LUSTRE_DLM_INTENT_REC_OFF);
+ break;
+ };
+ }
}
- break;
-
- case LDLM_CONVERT:
- if(pb_type==PTL_RPC_MSG_REQUEST)
- /*[ldlm_request]*/
- offset=lustre_dissect_struct_ldlm_request(tvb, offset, pinfo, tree, hf_lustre_ldlm_request) ;
- if(pb_type==PTL_RPC_MSG_REPLY)
- /*[ldlm_reply]*/
- offset=lustre_dissect_struct_ldlm_reply(tvb, offset, pinfo, tree, hf_lustre_ldlm_reply, NULL) ;
- break;
+ }
+ break;
- case LDLM_CANCEL:
- if(pb_type==PTL_RPC_MSG_REQUEST)
- /*[ldlm_request]*/
- offset=lustre_dissect_struct_ldlm_request(tvb, offset, pinfo, tree, hf_lustre_ldlm_request) ;
- /*[nothing en reply]*/
- break;
+ case LDLM_CONVERT:
+ if(pb_type==PTL_RPC_MSG_REQUEST)
+ /*[ldlm_request]*/
+ offset=lustre_dissect_struct_ldlm_request(tvb, offset, pinfo, tree, hf_lustre_ldlm_request) ;
+ if(pb_type==PTL_RPC_MSG_REPLY)
+ /*[ldlm_reply]*/
+ offset=lustre_dissect_struct_ldlm_reply(tvb, offset, pinfo, tree, hf_lustre_ldlm_reply, NULL) ;
+ break;
+
+ case LDLM_CANCEL:
+ if(pb_type==PTL_RPC_MSG_REQUEST)
+ /*[ldlm_request]*/
+ offset=lustre_dissect_struct_ldlm_request(tvb, offset, pinfo, tree, hf_lustre_ldlm_request) ;
+ /*[nothing en reply]*/
+ break;
- case LDLM_BL_CALLBACK: /* TODO : check the corresponding code in lustre*/
- if(pb_type==PTL_RPC_MSG_REQUEST)
- /*[ldlm_request]*/
- offset=lustre_dissect_struct_ldlm_request(tvb, offset, pinfo, tree, hf_lustre_ldlm_request) ;
- break;
+ case LDLM_BL_CALLBACK: /* TODO : check the corresponding code in lustre*/
+ if(pb_type==PTL_RPC_MSG_REQUEST)
+ /*[ldlm_request]*/
+ offset=lustre_dissect_struct_ldlm_request(tvb, offset, pinfo, tree, hf_lustre_ldlm_request) ;
+ break;
- case LDLM_CP_CALLBACK:
- if(pb_type==PTL_RPC_MSG_REQUEST){
- /*[ldlm_request] if the third buffer exist we have [lvb data] so it's [ost_lvb] : TODO :
- * check that */
- offset=lustre_dissect_struct_ldlm_request(tvb, offset, pinfo, tree, hf_lustre_ldlm_request) ;
- if(LUSTRE_BUFCOUNT>=3)
- offset=lustre_dissect_struct_ost_lvb(tvb,offset,pinfo,tree,hf_lustre_ost_lvb);
- }
- /*reply : [nothing] */
- break;
+ case LDLM_CP_CALLBACK:
+ if(pb_type==PTL_RPC_MSG_REQUEST){
+ /*[ldlm_request] if the third buffer exist we have [lvb data] so it's [ost_lvb] : TODO :
+ * check that */
+ offset=lustre_dissect_struct_ldlm_request(tvb, offset, pinfo, tree, hf_lustre_ldlm_request) ;
+ if(LUSTRE_BUFCOUNT>=3)
+ offset=lustre_dissect_struct_ost_lvb(tvb,offset,pinfo,tree,hf_lustre_ost_lvb);
+ }
+ /*reply : [nothing] */
+ break;
- case LDLM_GL_CALLBACK:
- if(pb_type==PTL_RPC_MSG_REQUEST)
- /*[ldlm_request] */
- offset=lustre_dissect_struct_ldlm_request(tvb, offset, pinfo, tree, hf_lustre_ldlm_request) ;
- else
- if(pb_type==PTL_RPC_MSG_REPLY)
- /*reply : [ost_lvb] <-- need to be check*/
- offset=lustre_dissect_struct_ost_lvb(tvb, offset, pinfo, tree, hf_lustre_ost_lvb);
- break;
+ case LDLM_GL_CALLBACK:
+ if(pb_type==PTL_RPC_MSG_REQUEST)
+ /*[ldlm_request] */
+ offset=lustre_dissect_struct_ldlm_request(tvb, offset, pinfo, tree, hf_lustre_ldlm_request) ;
+ else
+ if(pb_type==PTL_RPC_MSG_REPLY)
+ /*reply : [ost_lvb] <-- need to be check*/
+ offset=lustre_dissect_struct_ost_lvb(tvb, offset, pinfo, tree, hf_lustre_ost_lvb);
+ break;
- default :
- break;
+ default :
+ break;
}
return offset;
}
return offset;
}
+static int
+lustre_seq_opcode_process(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_,
+ proto_tree * tree _U_, guint32 opc _U_, guint32 pb_type)
+{
+ switch (opc) {
+ case SEQ_QUERY:
+ if (pb_type == PTL_RPC_MSG_REQUEST)
+ offset=lustre_dissect_struct_seq_opc(tvb, offset, pinfo, tree);
+ offset=lustre_dissect_struct_seq_range(tvb, offset, pinfo, tree, hf_lustre_seq_range);
+ break;
+
+ default:
+ g_print("error: SEQ Opcode: %d unknown\n", opc);
+ if (check_col(pinfo->cinfo, COL_INFO))
+ col_append_str(pinfo->cinfo, COL_PROTOCOL, "BUG");
+ break;
+ };
+
+ return offset;
+}
/* process lustre opcode :
check if opcode is in range_opcode, and call the corresponding opcode process function */
static int
if( (opc>=LLOG_FIRST_OPC) && (opc<=LLOG_LAST_OPC)) /* LLOG Opcodes */
offset=lustre_llog_opcode_process( tvb , offset ,pinfo , tree , opc , pb_type) ;
- return offset ;
+ if( (opc >= SEQ_FIRST_OPC) && (opc <= SEQ_LAST_OPC) ) /* SEQ Opcodes */
+ offset=lustre_seq_opcode_process(tvb, offset, pinfo, tree, opc, pb_type);
+
+ return offset;
}
/* ----------------------------------------------- */
/* ----------------------------------------------- */
static int
-ldlm_opcode_process(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree * tree _U_, guint64 intent_opc _U_)
+ldlm_opcode_process(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_,
+ proto_tree * tree _U_, guint64 intent_opc _U_)
{
/* all corresponding code is in mdc_locks.c in function mdc_enqueue() */
/* if 0x0003 we have CREAT + OPEN
- */
+ */
if (intent_opc & IT_OPEN) {
/* mdc_intent_open_pack(), d'où [opcode][mdc_rec_create][name][eada] */
- offset=lustre_dissect_struct_mdt_rec_create(tvb, offset, pinfo, tree, hf_lustre_mdt_rec_create);
- offset=lustre_dissect_element_string(tvb, offset, pinfo, tree, hf_lustre_reint_name, LUSTRE_DLM_INTENT_REC_OFF+1);
- offset=lustre_dissect_element_data(tvb, offset, pinfo, tree, hf_lustre_mds_xattr_eadata,
- LUSTRE_DLM_INTENT_REC_OFF+2); /* TODO : replace hf with eada hf */
-
+ offset=lustre_dissect_struct_mdt_rec_create(tvb, offset, pinfo, tree,
+ hf_lustre_mdt_rec_create);
+ offset=lustre_dissect_element_string(tvb, offset, pinfo, tree,
+ hf_lustre_reint_name,
+ LUSTRE_DLM_INTENT_REC_OFF+3);
+ offset=lustre_dissect_element_data(tvb, offset, pinfo, tree,
+ hf_lustre_mds_xattr_eadata,
+ LUSTRE_DLM_INTENT_REC_OFF+4);
+ /* TODO : replace hf with eada hf */
}
+
if (intent_opc & IT_UNLINK){
/* mdc_intent_unlink_pack(), d'où [opcode][mdt_rec_unlink][name] */
- offset=lustre_dissect_struct_mdt_rec_unlink(tvb, offset, pinfo, tree, hf_lustre_mdt_rec_unlink);
- offset=lustre_dissect_element_string(tvb, offset, pinfo, tree, hf_lustre_reint_name, LUSTRE_DLM_INTENT_REC_OFF+1);
+ offset=lustre_dissect_struct_mdt_rec_unlink(tvb, offset, pinfo, tree,
+ hf_lustre_mdt_rec_unlink);
+ offset=lustre_dissect_element_string(tvb, offset, pinfo, tree,
+ hf_lustre_reint_name,
+ LUSTRE_DLM_INTENT_REC_OFF+1);
}
if (intent_opc & IT_GETATTR){
/* mdc_intent_lookup_pack, d'où [mdt_body][name] */
offset=lustre_dissect_struct_mdt_body(tvb, offset, pinfo, tree, hf_lustre_mdt_body) ;
- offset=lustre_dissect_element_string(tvb, offset, pinfo, tree, hf_lustre_reint_name, LUSTRE_DLM_INTENT_REC_OFF+1);
+ offset=lustre_dissect_element_string(tvb, offset, pinfo, tree, hf_lustre_reint_name,
+ LUSTRE_DLM_INTENT_REC_OFF+1);
}
if (intent_opc & IT_LOOKUP){
- /* mdc_intent_lookup_pack, d'où [mdt_body][name] */
- offset=lustre_dissect_struct_mdt_body(tvb, offset, pinfo, tree, hf_lustre_mdt_body) ;
- offset=lustre_dissect_element_string(tvb, offset, pinfo, tree, hf_lustre_reint_name, LUSTRE_DLM_INTENT_REC_OFF+1);
+ /* mdc_intent_lookup_pack, d'où [mdt_body][capa][name] */
+ offset=lustre_dissect_struct_mdt_body(tvb, offset, pinfo, tree, hf_lustre_mdt_body);
+ offset=lustre_dissect_struct_capa(tvb, offset, pinfo, tree, hf_lustre_capa, LUSTRE_DLM_INTENT_REC_OFF+1);
+ offset=lustre_dissect_element_string(tvb, offset, pinfo, tree, hf_lustre_reint_name,
+ LUSTRE_DLM_INTENT_REC_OFF+2);
}
return offset;
}
}
static int
+lustre_dissect_element_ptlrpc_body_pb_pre_version(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *tree _U_)
+{
+ offset=dissect_uint64(tvb, offset, pinfo, tree, hf_lustre_ptlrpc_body_pb_pre_version);
+
+ return offset;
+}
+
+static int
+lustre_dissect_element_ptlrpc_body_pb_padding(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *tree _U_)
+{
+ offset=dissect_uint64(tvb, offset, pinfo, tree, hf_lustre_ptlrpc_body_pb_padding);
+
+ return offset;
+}
+
+static int
+lustre_dissect_element_ptlrpc_body_pb_jobid(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *parent_tree _U_)
+{
+
+ /* the lenght of the string is 32 bytes max, with \0 inside */
+ proto_tree_add_item(parent_tree, hf_lustre_ptlrpc_body_pb_jobid, tvb, offset, 32, TRUE);
+
+ offset+=32;
+ return offset;
+}
+
+
+static int
lustre_dissect_struct_ptlrpc_body(tvbuff_t *tvb _U_, int offset _U_, packet_info *pinfo _U_, proto_tree *parent_tree _U_, int hf_index _U_, guint32 buf_len _U_ )
{
proto_item *item = NULL;
proto_tree *tree = NULL;
- int old_offset;
-
- guint32 opc, pb_type;
-
+ int old_offset, i;
+ guint32 opc, pb_type, pb_version;
old_offset=offset;
-
if (parent_tree) {
item = proto_tree_add_item(parent_tree, hf_index, tvb, offset, -1, TRUE);
tree = proto_item_add_subtree(item, ett_lustre_ptlrpc_body);
offset=lustre_dissect_element_ptlrpc_body_pb_type(tvb, offset, pinfo, tree);
+ pb_version = tvb_get_letohl(tvb, offset) & ~LUSTRE_VERSION_MASK;
+ //g_print("msg_v2_version_offset %d : version == %d \n", offset, pb_version);
offset=lustre_dissect_element_ptlrpc_body_pb_version(tvb, offset, pinfo, tree);
// g_print("msg_v2_opcode_offset %d \n", offset);
offset=lustre_dissect_element_ptlrpc_body_pb_slv(tvb, offset, pinfo, tree);
+ /* pb_pre_versions */
+ for(i = 0; i < 4; ++i) {
+ offset=lustre_dissect_element_ptlrpc_body_pb_pre_version(tvb, offset, pinfo, tree);
+ }
+
+ for(i = 0; i < 4; ++i) {
+ offset=lustre_dissect_element_ptlrpc_body_pb_padding(tvb, offset, pinfo, tree);
+ }
+ if (pb_version == LUSTRE_PTLRPC_MSG_VERSION && offset-old_offset < buf_len) {
+ offset=lustre_dissect_element_ptlrpc_body_pb_jobid(tvb, offset, pinfo, tree);
+ }
+
+ if (offset-old_offset != buf_len) {
+ g_print("ptlbody offset-old:%d buf_len:%d\n",
+ offset-old_offset, buf_len);
+ col_append_str(pinfo->cinfo, COL_PROTOCOL, "BUG");
+ }
proto_item_set_len(item, offset-old_offset);
offset=dissect_uint32(tvb, offset, pinfo, tree, hf_lustre_extra_padding);
}
-
-
current_buf_len = tvb_get_letohl(tvb, buf_len_offset);
offset=lustre_dissect_struct_ptlrpc_body(tvb,offset, pinfo, tree, hf_lustre_ptlrpc_body_pb, current_buf_len);
}
-
-
static void
dissect_lustre(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree)
{
{ &hf_lustre_mdt_body_capability,
{ "Capability", "lustre.mdt_body.capability", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_body_mode,
- { "Mode", "lustre.mdt_body.mode", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
+ { "Mode", "lustre.mdt_body.mode", FT_UINT32, BASE_OCT, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_body_uid,
{ "Uid", "lustre.mdt_body.uid", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_body_gid,
{ &hf_lustre_mdt_rec_setattr_sa_attr_flags,
{ "Sa Attr Flags", "lustre.mdt_rec_setattr.sa_attr_flags", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_setattr_sa_mode,
- { "Sa Mode", "lustre.mdt_rec_setattr.sa_mode", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
+ { "Sa Mode", "lustre.mdt_rec_setattr.sa_mode", FT_UINT32, BASE_OCT, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_setattr_sa_padding_2,
{ "Sa Padding 2", "lustre.mdt_rec_setattr.sa_padding_2", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_setattr_sa_padding_3,
{ &hf_lustre_mdt_rec_create_cr_suppgid2_h,
{ "Cr Suppgid2 H", "lustre.mdt_rec_create.cr_suppgid2_h", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_create_cr_fid1,
- { "Cr Fid1", "lustre.mdt_rec_create.cr_fid1", FT_NONE,
- BASE_NONE, NULL, 0, "", HFILL } },
+ { "Cr Fid1", "lustre.mdt_rec_create.cr_fid1", FT_NONE, BASE_NONE, NULL, 0, "", HFILL } },
{ &hf_lustre_mdt_rec_create_cr_fid2,
- { "Cr Fid2", "lustre.mdt_rec_create.cr_fid2", FT_NONE,
- BASE_NONE, NULL, 0, "", HFILL } },
+ { "Cr Fid2", "lustre.mdt_rec_create.cr_fid2", FT_NONE, BASE_NONE, NULL, 0, "", HFILL } },
{ &hf_lustre_mdt_rec_create_cr_old_handle,
{ "Cr Old Handle", "lustre.mdt_rec_create.cr_old_handle", FT_NONE, BASE_NONE, NULL, 0, "", HFILL } },
{ &hf_lustre_mdt_rec_create_cr_time,
{ &hf_lustre_mdt_rec_create_cr_ioepoch,
{ "Cr Ioepoch", "lustre.mdt_rec_create.cr_ioepoch", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_create_cr_padding_1,
- { "Cr Padding 1", "lustre.mdt_rec_create.cr_padding_1", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
+ { "Cr Padding 1", "lustre.mdt_rec_create.cr_padding_1", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_create_cr_mode,
- { "Cr Mode", "lustre.mdt_rec_create.cr_mode", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
+ { "Cr Mode", "lustre.mdt_rec_create.cr_mode", FT_UINT32, BASE_OCT, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_create_cr_bias,
{ "Cr Bias", "lustre.mdt_rec_create.cr_bias", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_create_cr_flags_l,
{ "Cr Flags L", "lustre.mdt_rec_create.cr_flags_l", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_create_cr_flags_h,
{ "Cr Flags H", "lustre.mdt_rec_create.cr_flags_h", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
- { &hf_lustre_mdt_rec_create_cr_padding_3,
- { "Cr Padding 3", "lustre.mdt_rec_create.cr_padding_3", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
+ { &hf_lustre_mdt_rec_create_cr_umask,
+ { "Cr Umask", "lustre.mdt_rec_create.cr_umask", FT_UINT32, BASE_OCT, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_create_cr_padding_4,
{ "Cr Padding 4", "lustre.mdt_rec_create.cr_padding_4", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_link,
{ "mdt rec link", "lustre.mdt_rec_link", FT_NONE, BASE_NONE, NULL , 0 , "", HFILL}},
{ &hf_lustre_mdt_rec_link_lk_opcode,
- { "Lk Opcode", "lustre.mdt_rec_link.lk_opcode", FT_UINT32, BASE_DEC,VALS(lustre_mds_reint_t_vals) , 0, "", HFILL }},
+ { "Lk Opcode", "lustre.mdt_rec_link.lk_opcode", FT_UINT32, BASE_DEC, VALS(lustre_mds_reint_t_vals) , 0, "", HFILL }},
{ &hf_lustre_mdt_rec_link_lk_cap,
{ "Lk Cap", "lustre.mdt_rec_link.lk_cap", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_link_lk_fsuid,
{ &hf_lustre_mdt_rec_unlink_ul_time,
{ "Ul Time", "lustre.mdt_rec_unlink.ul_time",FT_ABSOLUTE_TIME, ABSOLUTE_TIME_LOCAL, NULL, 0, "", HFILL } },
{ &hf_lustre_mdt_rec_unlink_ul_padding_2,
- { "Ul Padding 2", "lustre.mdt_rec_unlink.ul_padding_2", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
+ { "Ul Padding 2", "lustre.mdt_rec_unlink.ul_padding_2", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_unlink_ul_padding_3,
- { "Ul Padding 3", "lustre.mdt_rec_unlink.ul_padding_3", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
+ { "Ul Padding 3", "lustre.mdt_rec_unlink.ul_padding_3", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_unlink_ul_padding_4,
- { "Ul Padding 4", "lustre.mdt_rec_unlink.ul_padding_4", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
+ { "Ul Padding 4", "lustre.mdt_rec_unlink.ul_padding_4", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_unlink_ul_padding_5,
- { "Ul Padding 5", "lustre.mdt_rec_unlink.ul_padding_5", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
+ { "Ul Padding 5", "lustre.mdt_rec_unlink.ul_padding_5", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_unlink_ul_bias,
{ "Ul Bias", "lustre.mdt_rec_unlink.ul_bias", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_unlink_ul_mode,
- { "Ul Mode", "lustre.mdt_rec_unlink.ul_mode", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
+ { "Ul Mode", "lustre.mdt_rec_unlink.ul_mode", FT_UINT32, BASE_OCT, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_unlink_ul_padding_6,
{ "Ul Padding 6", "lustre.mdt_rec_unlink.ul_padding_6", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_unlink_ul_padding_7,
{ &hf_lustre_mdt_rec_rename_rn_bias,
{ "Rn Bias", "lustre.mdt_rec_rename.rn_bias", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_rename_rn_mode,
- { "Rn Mode", "lustre.mdt_rec_rename.rn_mode", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
+ { "Rn Mode", "lustre.mdt_rec_rename.rn_mode", FT_UINT32, BASE_OCT, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_rename_rn_padding_5,
{ "Rn Padding 5", "lustre.mdt_rec_rename.rn_padding_5", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mdt_rec_rename_rn_padding_6,
{ "Ioo Id", "lustre.obd_ioobj.ioo_id", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_ptlrpc_body_pb_slv,
{ "Pb Slv", "lustre.ptlrpc_body.pb_slv", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
+
+ { &hf_lustre_ptlrpc_body_pb_pre_version,
+ { "Pb Pre-Version", "lustre.ptlrpc_body.pb_pre_version", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
+ { &hf_lustre_ptlrpc_body_pb_padding,
+ { "Pb Padding", "lustre.ptlrpc_body.pb_padding", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
+ { &hf_lustre_ptlrpc_body_pb_jobid,
+ { "Pb JobId", "lustre.ptlrpc_body.pb_jobid", FT_STRING, BASE_NONE, NULL, 0, "", HFILL }},
+
{ &hf_lustre_lustre_msg_v1_lm_handle,
{ "Lm Handle", "lustre.lustre_msg_v1.lm_handle", FT_NONE,
BASE_NONE, NULL, 0, "", HFILL } },
{ &hf_lustre_ptlrpc_body_pb_last_xid,
{ "Pb Last Xid", "lustre.ptlrpc_body.pb_last_xid", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_ptlrpc_body_pb_status,
- { "Pb Status", "lustre.ptlrpc_body.pb_status", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
+ { "Pb Status", "lustre.ptlrpc_body.pb_status", FT_INT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_niobuf_remote_flags,
{ "Flags", "lustre.niobuf_remote.flags", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_ll_fid_id,
{ "mds reint new name", "lustre.mds_reint_new_name", FT_STRING, BASE_NONE, NULL, 0, "", HFILL }},
-
{ &hf_lustre_obdo_o_valid,
{ "O Valid", "lustre.obdo.o_valid", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_ldlm_reply_lock_flags,
{ &hf_lustre_ldlm_request_lock_flags,
{ "Lock Flags", "lustre.ldlm_request.lock_flags", FT_UINT32, BASE_HEX, NULL, 0 , "", HFILL }},
{ &hf_lustre_obdo_o_mode,
- { "O Mode", "lustre.obdo.o_mode", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
+ { "O Mode", "lustre.obdo.o_mode", FT_UINT32, BASE_OCT, NULL, 0, "", HFILL }},
{ &hf_lustre_mgs_target_info_mti_svname,
{ "Mti Svname", "lustre.mgs_target_info.mti_svname", FT_UINT8, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_llogd_body_lgd_logid,
BASE_NONE, NULL, 0, "", HFILL } },
{ &hf_lustre_obdo_o_grant,
{ "O Grant", "lustre.obdo.o_grant", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
- { &hf_lustre_obdo_o_padding_2,
- { "O Padding 2", "lustre.obdo.o_padding_2", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
+ { &hf_lustre_obdo_o_uid_h,
+ { "O Uid H", "lustre.obdo.o_uid_h", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
+ { &hf_lustre_obdo_o_gid_h,
+ { "O Gid H", "lustre.obdo.o_gid_h", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_quota_adjust_qunit_qaq_iunit_sz,
{ "Qaq Iunit Sz", "lustre.quota_adjust_qunit.qaq_iunit_sz", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_llog_unlink_rec_padding,
{ "End", "lustre.ldlm_flock.end", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }},
{ &hf_lustre_mgs_target_info_mti_nid_count,
{ "Mti Nid Count", "lustre.mgs_target_info.mti_nid_count", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL }},
- /* ----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- */
+ /* -------------------------------------------------------------------- */
{ &hf_lustre_mgs_target_info,
{ "mgs target info", "lustre.mgs_target_info", FT_NONE, BASE_NONE, NULL, 0, "", HFILL }},
{ &hf_lustre_mgs_send_param,
{ "mgs send param", "lustre.mgs_send_param", FT_NONE, BASE_NONE, NULL, 0, "", HFILL }},
- /* ----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- */
+ /* -------------------------------------------------------------------- */
{ &hf_lustre_ost_lvb,
{ "ost lvb data", "lustre.ost_lvb", FT_NONE, BASE_NONE, NULL, 0, "", HFILL }},
{ "Dqb Btime", "lustre.obd_dqblk.dqb_btime", FT_ABSOLUTE_TIME,
ABSOLUTE_TIME_LOCAL, NULL, 0, "", HFILL } },
{ &hf_lustre_obd_dqblk_dqb_ihardlimit,
- { "Dqb Ihardlimit", "lustre.obd_dqblk.dqb_ihardlimit", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL }}
-
+ { "Dqb Ihardlimit", "lustre.obd_dqblk.dqb_ihardlimit", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL } },
+
+ /* seq */
+ { &hf_lustre_seq_opc,
+ { "Seq OPC", "lustre.seq_opc", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL } },
+ { &hf_lustre_seq_range,
+ { "Seq Range", "lustre.range", FT_NONE, BASE_NONE, NULL, 0, "", HFILL } },
+ { &hf_lustre_seq_range_start,
+ { "Seq Range Start", "lustre.seq_range.start", FT_UINT64, BASE_HEX, NULL, 0, "", HFILL } },
+ { &hf_lustre_seq_range_end,
+ { "Seq Range End", "lustre.seq_range.end", FT_UINT64, BASE_HEX, NULL, 0, "", HFILL } },
+ { &hf_lustre_seq_range_index,
+ { "Seq Range Index", "lustre.seq_range.index", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL } },
+ { &hf_lustre_seq_range_flags,
+ { "Seq Range Flags", "lustre.seq_range.flags", FT_UINT32, BASE_HEX, NULL, 0, "", HFILL } },
+
+ /* struct mdt_ioepoch */
+ { &hf_lustre_mdt_ioepoch,
+ { "MDT ioepoch", "lustre.mdt_ioepoch", FT_NONE, BASE_NONE, NULL, 0, "", HFILL } },
+ { &hf_lustre_mdt_ioepoch_handle,
+ { "Handle", "lustre.mdt_ioepoch.handle", FT_NONE, BASE_NONE, NULL, 0, "", HFILL } },
+ { &hf_lustre_mdt_ioepoch_ioepoch,
+ { "ioepoch", "lustre.mdt_ioepoch.ioepoch", FT_UINT64, BASE_DEC, NULL, 0, "", HFILL } },
+ { &hf_lustre_mdt_ioepoch_flags,
+ { "flags", "lustre.mdt_ioepoch.flags", FT_UINT32, BASE_DEC, NULL, 0, "", HFILL } },
+ { &hf_lustre_mdt_ioepoch_padding,
+ { "Padding", "lustre.mdt_ioepoch.padding", FT_UINT32, BASE_HEX, NULL, 0, "", HFILL } },
+
+ /* struct lustre_capa */
+ { &hf_lustre_capa,
+ { "Capability", "lustre.capa", FT_NONE, BASE_NONE, NULL, 0, "", HFILL } },
};
&ett_lustre_qunit_data_old2,
&ett_lustre_qunit_data_old,
&ett_lustre_ldlm_lock_flags,
- &ett_lustre_llog_log_llh_flags
+ &ett_lustre_llog_log_llh_flags,
+ &ett_lustre_seq_range,
+ &ett_lustre_mdt_ioepoch,
+ &ett_lustre_capa,
};
proto_lustre = proto_register_protocol("Lustre", "lustre", "lustre");
dissector_add("lnet.ptl_index", MGS_REQUEST_PORTAL , lustre_handle);
dissector_add("lnet.ptl_index", MGS_REPLY_PORTAL , lustre_handle);
dissector_add("lnet.ptl_index", OST_REQUEST_PORTAL , lustre_handle);
- dissector_add("lnet.ptl_index", FLD_REQUEST_PORTAL, lustre_handle);
- dissector_add("lnet.ptl_index", SEQ_METADATA_PORTAL, lustre_handle);
- dissector_add("lnet.ptl_index", SEQ_DATA_PORTAL, lustre_handle);
- dissector_add("lnet.ptl_index", SEQ_CONTROLLER_PORTAL, lustre_handle);
- dissector_add("lnet.ptl_index", MGS_BULK_PORTAL, lustre_handle);
+ dissector_add("lnet.ptl_index", FLD_REQUEST_PORTAL, lustre_handle);
+ dissector_add("lnet.ptl_index", SEQ_METADATA_PORTAL, lustre_handle);
+ dissector_add("lnet.ptl_index", SEQ_DATA_PORTAL, lustre_handle);
+ dissector_add("lnet.ptl_index", SEQ_CONTROLLER_PORTAL, lustre_handle);
+ dissector_add("lnet.ptl_index", MGS_BULK_PORTAL, lustre_handle);
}
git://git.whamcloud.com / fs / lustre-release.git / commitdiff