[openib-general] Unknown SMP Recv

Sasha Khapyorsky sashak at voltaire.com
Fri Feb 9 13:41:19 PST 2007


On Fri, 2007-02-09 at 21:19 +0100, Michael Arndt wrote:
> Hi,
> 
> > It is strange, I did similar thing (you can see in
> > management/diags/src/mcm_rereg_test.c) and it worked fine for me.
> 
> What location is that?

Do

  git clone git://git.openfabrics.org/~halr/management

and find this as management/diags/src/mcm_rereg_test.c .

Or you can look at this via gitweb interface:
http://git.openfabrics.org/git

Sasha

> >Which libibumad version you are using? Also I understand you did some
> >changes in the stack, is it related to user_mad? Could you publish this?
> 
> I use OFED-1.1 and attached libibumad version. The stack where I have tested 
> this context wasn't changed to exclude this. It is a diploma thesis and will 
> publish as soon as posible ;)...in german ...sorry.
> 
> The hole example code Hal was asking for is below. I have marked the 
> position with /* here */. Currently is the retry parameter zero, but I also 
> tested 3.
> 
> Thanks Michael
> 
> // ---- Includes --------------------------------
> #include <infiniband/umad.h>
> #include <string.h>
> #include <errno.h>
> 
> #include "sender.h"
> 
> // ---- Defines und Deklarationen ---------------
> 
>  static const uint8_t  CLASS_SUBN_DIRECTED_ROUTE = 0x81;
>  static const uint8_t  CLASS_SUBN_LID_ROUTE = 0x1;
> 
>  static int long drmad_tid = 0x123;
> 
>  // Prototypes
> 
>  void drsmp_get_init(void *umad, DRPath *path, uint16_t attr, int mod);
>  void drsmp_set_init(void *umad, DRPath *path, uint16_t attr, int mod, void 
> *data);
>  char * drmad_status_str(struct drsmp *drsmp);
>  int str2DRPath(char *str, DRPath *path);
>  int set_bit(int nr, void *method_mask);
> 
> 
> 
> // ---- Main ------------------------------------
> 
> int main (void){
> 
>  int Port_ID = 0;
>  int Agent_ID = 0;
>  int ret;
>  int i;
>  int length, timeout_ms = 10000;
> 
> 
>  void *umad;
>  struct drsmp *smp;
> 
> 
> // ---- Einstellungen ---------------------------
>  int Portnummer = 1;
>  char Devicename [2][UMAD_CA_NAME_LEN];
>  DRPath Path;
>  char Path_Str[64];
> 
>  uint16_t attribute = MAD_ATTR_PORT_INFO; // PortInfo
>  int modifier = 1;
> 
>  struct _register_info{
>   int Management_Class;
>   int Management_Version;
>   uint8_t RMPP_Version;
>   uint32_t Method_Mask[4];
>  } Register_Info;
> 
>  // ++ Wertzuweisung ++
> 
>  Register_Info.Management_Class = CLASS_SUBN_DIRECTED_ROUTE;
>  Register_Info.Management_Version = 1;
>  Register_Info.RMPP_Version = 0;
> 
>  set_bit(0x01,&(Register_Info.Method_Mask));
>  set_bit(0x02,&(Register_Info.Method_Mask));
>  set_bit(0x81,&(Register_Info.Method_Mask));
>  set_bit(0x03,&(Register_Info.Method_Mask));
>  set_bit(0x05,&(Register_Info.Method_Mask));
>  set_bit(0x06,&(Register_Info.Method_Mask));
> 
>  sprintf(Path_Str,"0,1,1,1");
> 
> 
> // ---- Init Phase ------------------------------
>  printf("... Init Lib ...");
>  umad_init();
>  printf("done\n\n");
> 
>  // ++ Debug ++
>  umad_debug(0);
> 
>  printf("... Get CAs Names ...");
>  ret = umad_get_cas_names(Devicename,2);
>  if (!ret) {
>   printf("Fehler: umad_get_cas_names: %i\n",ret);
>   return -1;
>  }
>  else {
>   printf("done\n\n");
>   for (i = 0;i < ret;i++){
>    printf("Devicename: %s\n",Devicename[i]);
>   }
> 
>  }
>  // ++ Open ++
>  printf("... Open Port ...");
>  if ((Port_ID = umad_open_port(Devicename[0],Portnummer)) < 0)
>  {
>   printf("Fehler: umad_open_port: %i\n",Port_ID);
>   return -1;
>  }
>  else printf("done\n\n");
>  // ++ Register ++
>  printf("... Register User Mad ...");
>  if ((Agent_ID = umad_register(Port_ID,Register_Info.Management_Class,
>             Register_Info.Management_Version,
>             Register_Info.RMPP_Version,
>             0)) < 0){
>   printf("Fehler: umad_register : %i\n",Agent_ID);
>   goto Exit;
>  }
>  else printf("done\n\n");
> // ---- Paket bauen -----------------------------
> 
>  printf("... Paket allokieren ...");
>  if (!(umad = umad_alloc(1, umad_size() + IB_MAD_SIZE))){
>   printf("Fehler: umad_alloc\n");
>   goto Exit;
>  }
>  printf("done\n\n");
> 
>  smp = umad_get_mad(umad);
>  printf("... Smp Pointer ... done\n");
> 
>  if ((str2DRPath(Path_Str, &Path)) < 0) printf("Fehler: str2DRPath\n");
> 
>  printf("... SMP bauen ...");
>  drsmp_get_init(umad,&Path,attribute,modifier);
>  printf("... done ...\n\n");
> 
> 
>  //xdump(stderr, "before send:\n", smp, 256);
>  dump_dr_smp(smp);
> 
>  length = IB_MAD_SIZE;
> 
> /* here */
>  for (i = 0; i < 10; i++){
>      printf("... Send Mad ...");
>        if ((ret = umad_send(Port_ID, Agent_ID, umad, length, 200, 0)) < 0)
>           printf("Fehler: umad_send : %i\n",ret);
>        else printf("done\n\n");
>  }
> 
> /*
>  for (i = 0; i < 10; i++){
>    printf("... Recv Mad ...");
>    if (umad_recv(Port_ID, umad, &length, timeout_ms) != Agent_ID)
>         printf("Fehler umad_recv: %s\n", drmad_status_str(smp));
>    else printf("done\n\n");
>  }
> */
> 
>  dump_dr_smp(smp);
>  switch (attribute){
>   case MAD_ATTR_NODE_INFO : dump_node_info((const struct 
> node_info*)&(smp->data[0])); break;
>   case MAD_ATTR_PORT_INFO : dump_port_info(0,0,0,(const struct 
> port_info*)&(smp->data[0])); break;
>  }
> 
> 
> // ---- Down Phase ------------------------------ 
> Exit:
>  printf("... Unregister User Mad ...");
>  if (umad_unregister(Port_ID,Agent_ID) < 0)
>   printf("Fehler: umad_unregister\n");
>  else printf("done\n\n");
> 
>  printf("... Close Port ...");
>  if (Port_ID != -1)
>   if ((umad_close_port(Port_ID)) != 0){
>    printf("Fehler: umad_close_port\n");
>   }
>   else printf("done\n\n");
>  else printf("nix zu tun\n\n");
> 
> }
> 
> // ---- SMP Paket -------------------------------
> 
> 
> void drsmp_get_init(void *umad, DRPath *path, uint16_t attr, int mod)
> {
>    struct drsmp *smp = (struct drsmp *)(umad_get_mad(umad));
> 
>    memset(smp, 0, sizeof (*smp));
> 
>    smp->base_version  = 1;
>    smp->mgmt_class    = CLASS_SUBN_DIRECTED_ROUTE;
>    smp->class_version = 1;
> 
>    smp->method        = 0x01;
>    smp->attr_id      = (uint16_t)htons((uint16_t)attr);
>    smp->attr_mod     = htonl(mod);
>    smp->tid           = htonll(drmad_tid++);
>    smp->dr_slid       = 0xffff;
>    smp->dr_dlid       = 0xffff;
> 
>    umad_set_addr(umad, 0xffff, 0, 0, 0);
> 
>    if (path)
>       memcpy(smp->initial_path, path->path, path->hop_cnt+1);
> 
>    smp->hop_cnt = path->hop_cnt;
> }
> 
> void drsmp_set_init(void *umad, DRPath *path, uint16_t attr, int mod, void 
> *data)
> {
>    struct drsmp *smp = (struct drsmp *)(umad_get_mad(umad));
> 
>    memset(smp, 0, sizeof (*smp));
> 
>    smp->method        = 2;    /* SET */
>    smp->attr_id      = (uint16_t)htons((uint16_t)attr);
>    smp->attr_mod     = htonl(mod);
>    smp->tid           = htonll(drmad_tid++);
>    smp->dr_slid       = 0xffff;
>    smp->dr_dlid       = 0xffff;
> 
>    umad_set_addr(umad, 0xffff, 0, 0, 0);
> 
>    if (path)
>       memcpy(smp->initial_path, path->path, path->hop_cnt+1);
> 
>    if (data)
>       memcpy(smp->data, data, sizeof smp->data);
> 
>    smp->hop_cnt = path->hop_cnt;
> }
> 
> int str2DRPath(char *str, DRPath *path)
> {
>    char *s;
> 
>    path->hop_cnt = -1;
> 
>    //DEBUG("DR str: %s", str);
>    while (str && *str) {
>       if ((s = strchr(str, ',')))
>          *s = 0;
>       path->path[++path->hop_cnt] = atoi(str);
>       if (!s)
>          break;
>       str = s+1;
>    }
> 
> #if 0
>    if (path->path[0] != 0 ||
>       (path->hop_cnt > 0 && dev_port && path->path[1] != dev_port)) {
>       DEBUG("hop 0 != 0 or hop 1 != dev_port");
>       return -1;
>    }
> #endif
> 
>    return path->hop_cnt;
> }
> 
> 




More information about the general mailing list