Added ptl_ib_peer.c and modified D_PRINT macros

This commit was SVN r2065.

src/mca/ptl/ib/src/ptl_ib.c

@@ -154,8 +154,7 @@ void mca_ptl_ib_request_return(struct mca_ptl_base_module_t* ptl,
  *  on to the peer.
  */
 
-int mca_ptl_ib_send(
-    struct mca_ptl_base_module_t* ptl,
+int mca_ptl_ib_send( struct mca_ptl_base_module_t* ptl,
     struct mca_ptl_base_peer_t* ptl_peer,
     struct mca_pml_base_send_request_t* sendreq,
     size_t offset,

src/mca/ptl/ib/src/ptl_ib_peer.c

@@ -0,0 +1,39 @@
+#include "include/types.h"
+#include "mca/pml/base/pml_base_sendreq.h"
+#include "mca/ns/base/base.h"
+#include "ptl_ib.h"
+#include "ptl_ib_addr.h"
+#include "ptl_ib_peer.h"
+#include "ptl_ib_proc.h"
+#include "ptl_ib_sendfrag.h"
+
+static void mca_ptl_ib_peer_construct(mca_ptl_base_peer_t* module_peer);
+static void mca_ptl_ib_peer_destruct(mca_ptl_base_peer_t* module_peer);
+
+OBJ_CLASS_INSTANCE(mca_ptl_ib_peer_t, 
+        ompi_list_item_t, mca_ptl_ib_peer_construct, 
+        mca_ptl_ib_peer_destruct);
+
+/*
+ * Initialize state of the peer instance.
+ */
+
+static void mca_ptl_ib_peer_construct(mca_ptl_base_peer_t* module_peer)
+{
+    module_peer->peer_module = 0;
+    module_peer->peer_proc = 0;
+    module_peer->peer_addr = 0;
+    module_peer->peer_send_frag = 0;
+    module_peer->peer_recv_frag = 0;
+    module_peer->peer_send_event.ev_flags = 0;
+    module_peer->peer_recv_event.ev_flags = 0;
+    module_peer->peer_state = MCA_PTL_IB_NOT_OPENED;
+    module_peer->peer_retries = 0;
+    OBJ_CONSTRUCT(&module_peer->peer_frags, ompi_list_t);
+    OBJ_CONSTRUCT(&module_peer->peer_send_lock, ompi_mutex_t);
+    OBJ_CONSTRUCT(&module_peer->peer_recv_lock, ompi_mutex_t);
+}
+
+static void mca_ptl_ib_peer_destruct(mca_ptl_base_peer_t* module_peer)
+{
+}

src/mca/ptl/ib/src/ptl_ib_vapi.h

@@ -31,9 +31,8 @@
 /* Debug Print */
 #if 1
 #define D_PRINT(fmt, args...) {                                     \
-    fprintf(stderr, "[%s:%d:%s] ", __FILE__, __LINE__, __func__);   \
-    fprintf(stderr, fmt, ## args);                                  \
-    fflush(stderr);                                                 \
+    ompi_output(0, "[%s:%d:%s] " fmt, __FILE__, __LINE__, __func__, \
+        ##args);                                                    \
 }
 #else
 #define D_PRINT(fmt, args...)