Skip to content

Commit 3327fa5

Browse files
committed
usnic: minor code cleanups
1 parent f9c65a7 commit 3327fa5

File tree

5 files changed

+10
-14
lines changed

5 files changed

+10
-14
lines changed

opal/mca/btl/usnic/btl_usnic.h

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ extern opal_rng_buff_t opal_btl_usnic_rand_buff;
9393

9494
/* Set to >0 to randomly drop received frags. The higher the number,
9595
the more frequent the drops. */
96-
#define WANT_RECV_FRAG_DROPS 0
96+
#define WANT_RECV_DROPS 0
9797
/* Set to >0 to randomly fail to send an ACK, mimicing a lost ACK.
9898
The higher the number, the more frequent the failed-to-send-ACK. */
9999
#define WANT_FAIL_TO_SEND_ACK 0
@@ -102,10 +102,10 @@ extern opal_rng_buff_t opal_btl_usnic_rand_buff;
102102
the failed-to-resend-frag. */
103103
#define WANT_FAIL_TO_RESEND_FRAG 0
104104

105-
#if WANT_RECV_FRAG_DROPS > 0
106-
#define FAKE_RECV_FRAG_DROP (opal_rand(&opal_btl_usnic_rand_buff) < WANT_RECV_FRAG_DROPS)
105+
#if WANT_RECV_DROPS > 0
106+
#define FAKE_RECV_DROP (opal_rand(&opal_btl_usnic_rand_buff) < WANT_RECV_DROPS)
107107
#else
108-
#define FAKE_RECV_FRAG_DROP 0
108+
#define FAKE_RECV_DROP 0
109109
#endif
110110

111111
#if WANT_FAIL_TO_SEND_ACK > 0

opal/mca/btl/usnic/btl_usnic_ack.c

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -252,6 +252,7 @@ opal_btl_usnic_ack_complete(opal_btl_usnic_module_t *module,
252252
opal_btl_usnic_ack_segment_t *ack)
253253
{
254254
opal_btl_usnic_ack_segment_return(module, ack);
255+
++module->mod_channels[ack->ss_channel].credits;
255256
}
256257

257258
/*****************************************************************************/

opal/mca/btl/usnic/btl_usnic_component.c

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1143,27 +1143,18 @@ static int usnic_handle_completion(
11431143
case OPAL_BTL_USNIC_SEG_ACK:
11441144
opal_btl_usnic_ack_complete(module,
11451145
(opal_btl_usnic_ack_segment_t *)seg);
1146-
{ opal_btl_usnic_send_segment_t *sseg = (opal_btl_usnic_send_segment_t *)seg;
1147-
++module->mod_channels[sseg->ss_channel].credits;
1148-
}
11491146
break;
11501147

11511148
/**** Send of frag segment completion ****/
11521149
case OPAL_BTL_USNIC_SEG_FRAG:
11531150
opal_btl_usnic_frag_send_complete(module,
11541151
(opal_btl_usnic_frag_segment_t*)seg);
1155-
{ opal_btl_usnic_send_segment_t *sseg = (opal_btl_usnic_send_segment_t *)seg;
1156-
++module->mod_channels[sseg->ss_channel].credits;
1157-
}
11581152
break;
11591153

11601154
/**** Send of chunk segment completion ****/
11611155
case OPAL_BTL_USNIC_SEG_CHUNK:
11621156
opal_btl_usnic_chunk_send_complete(module,
11631157
(opal_btl_usnic_chunk_segment_t*)seg);
1164-
{ opal_btl_usnic_send_segment_t *sseg = (opal_btl_usnic_send_segment_t *)seg;
1165-
++module->mod_channels[sseg->ss_channel].credits;
1166-
}
11671158
break;
11681159

11691160
/**** Receive completions ****/

opal/mca/btl/usnic/btl_usnic_recv.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ void opal_btl_usnic_recv_call(opal_btl_usnic_module_t *module,
7777

7878
/* Find out who sent this segment */
7979
endpoint = seg->rs_endpoint;
80-
if (FAKE_RECV_FRAG_DROP || OPAL_UNLIKELY(NULL == endpoint)) {
80+
if (FAKE_RECV_DROP || OPAL_UNLIKELY(NULL == endpoint)) {
8181
/* No idea who this was from, so drop it */
8282
#if MSGDEBUG1
8383
opal_output(0, "=== Unknown sender; dropped: seq %" UDSEQ,

opal/mca/btl/usnic/btl_usnic_send.c

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,8 @@ opal_btl_usnic_frag_send_complete(opal_btl_usnic_module_t *module,
6666

6767
/* see if this endpoint needs to be made ready-to-send */
6868
opal_btl_usnic_check_rts(frag->sf_endpoint);
69+
70+
++module->mod_channels[sseg->ss_channel].credits;
6971
}
7072

7173
/*
@@ -97,6 +99,8 @@ opal_btl_usnic_chunk_send_complete(opal_btl_usnic_module_t *module,
9799

98100
/* see if this endpoint needs to be made ready-to-send */
99101
opal_btl_usnic_check_rts(frag->sf_endpoint);
102+
103+
++module->mod_channels[sseg->ss_channel].credits;
100104
}
101105

102106
/* Responsible for completing non-fastpath parts of a put or send operation,

0 commit comments

Comments
 (0)