@@ -360,8 +360,18 @@ component_query(struct ompi_win_t *win, void **base, size_t size, int disp_unit,
360360                struct  ompi_communicator_t  * comm , struct  ompi_info_t  * info ,
361361                int  flavor )
362362{
363+     int  ret ;
364+ 
363365    if  (MPI_WIN_FLAVOR_SHARED  ==  flavor ) return  -1 ;
364366
367+     ret  =  PtlGetUid (mca_osc_portals4_component .matching_ni_h , & mca_osc_portals4_component .uid );
368+     if  (PTL_OK  !=  ret ) {
369+       opal_output_verbose (1 , ompi_osc_base_framework .framework_output ,
370+                           "%s:%d: PtlGetUid failed: %d\n" ,
371+                           __FILE__ , __LINE__ , ret );
372+       return  OMPI_ERROR ;
373+     }
374+ 
365375    return  20 ;
366376}
367377
@@ -482,7 +492,7 @@ component_select(struct ompi_win_t *win, void **base, size_t size, int disp_unit
482492        me .length  =  size ;
483493    }
484494    me .ct_handle  =  PTL_CT_NONE ;
485-     me .uid  =  PTL_UID_ANY ;
495+     me .uid  =  mca_osc_portals4_component . uid ;
486496    me .options  =  PTL_ME_OP_PUT  | PTL_ME_OP_GET  | PTL_ME_NO_TRUNCATE  | PTL_ME_EVENT_SUCCESS_DISABLE ;
487497    me .match_id .phys .nid  =  PTL_NID_ANY ;
488498    me .match_id .phys .pid  =  PTL_PID_ANY ;
@@ -505,7 +515,7 @@ component_select(struct ompi_win_t *win, void **base, size_t size, int disp_unit
505515    me .start  =  & module -> state ;
506516    me .length  =  sizeof (module -> state );
507517    me .ct_handle  =  PTL_CT_NONE ;
508-     me .uid  =  PTL_UID_ANY ;
518+     me .uid  =  mca_osc_portals4_component . uid ;
509519    me .options  =  PTL_ME_OP_PUT  | PTL_ME_OP_GET  | PTL_ME_NO_TRUNCATE  | PTL_ME_EVENT_SUCCESS_DISABLE ;
510520    me .match_id .phys .nid  =  PTL_NID_ANY ;
511521    me .match_id .phys .pid  =  PTL_PID_ANY ;
0 commit comments