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?
>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;
}
_______________________________________________
openib-general mailing list
openib-general@openib.org
http://openib.org/mailman/listinfo/openib-general
To unsubscribe, please visit http://openib.org/mailman/listinfo/openib-general
