@@ -344,27 +344,27 @@ typedef struct uct_tcp_ep_addr {
344344 * TCP endpoint
345345 */
346346struct uct_tcp_ep {
347- uct_base_ep_t super ;
348- uint8_t conn_retries ; /* Number of connection attempts done */
349- uint8_t conn_state ; /* State of connection with peer */
350- ucs_event_set_types_t events ; /* Current notifications */
351- uint16_t flags ; /* Endpoint flags */
352- int fd ; /* Socket file descriptor */
353- int stale_fd ; /* Old file descriptor which should be
354- * closed as soon as the EP is connected
355- * using the new fd */
356- uct_tcp_ep_cm_id_t cm_id ; /* EP connection manager ID */
357- uct_tcp_ep_ctx_t tx ; /* TX resources */
358- uct_tcp_ep_ctx_t rx ; /* RX resources */
359- ucs_queue_head_t pending_q ; /* Pending operations */
360- ucs_queue_head_t put_comp_q ; /* Flush completions waiting for
361- * outstanding PUTs acknowledgment */
347+ uct_base_ep_t super ;
348+ uint8_t conn_retries ; /* Number of connection attempts done */
349+ uint8_t conn_state ; /* State of connection with peer */
350+ ucs_event_set_types_t events ; /* Current notifications */
351+ uint16_t flags ; /* Endpoint flags */
352+ int fd ; /* Socket file descriptor */
353+ int stale_fd ; /* Old file descriptor which should be
354+ * closed as soon as the EP is connected
355+ * using the new fd */
356+ uct_tcp_ep_cm_id_t cm_id ; /* EP connection manager ID */
357+ uct_tcp_ep_ctx_t tx ; /* TX resources */
358+ uct_tcp_ep_ctx_t rx ; /* RX resources */
359+ ucs_queue_head_t pending_q ; /* Pending operations */
360+ ucs_queue_head_t put_comp_q ; /* Flush completions waiting for
361+ * outstanding PUTs acknowledgment */
362362 union {
363- ucs_list_link_t list ; /* List element to insert into TCP EP list */
364- ucs_conn_match_elem_t elem ; /* Connection matching element, used by EPs
365- * created with CONNECT_TO_IFACE method */
363+ ucs_list_link_t list ; /* List element to insert into TCP EP list */
364+ ucs_conn_match_elem_t elem ; /* Connection matching element, used by EPs
365+ * created with CONNECT_TO_IFACE method */
366366 };
367- char peer_addr [0 ]; /* Remote iface addr */
367+ char peer_addr [0 ]; /* Remote iface addr */
368368};
369369
370370
@@ -447,30 +447,30 @@ typedef struct uct_tcp_iface {
447447 * TCP interface configuration
448448 */
449449typedef struct uct_tcp_iface_config {
450- uct_iface_config_t super ;
451- size_t tx_seg_size ;
452- size_t rx_seg_size ;
453- size_t max_iov ;
454- size_t sendv_thresh ;
455- int prefer_default ;
456- int put_enable ;
457- int conn_nb ;
458- unsigned max_poll ;
459- unsigned max_conn_retries ;
460- int sockopt_nodelay ;
461- uct_tcp_send_recv_buf_config_t sockopt ;
462- unsigned syn_cnt ;
463- uct_iface_mpool_config_t tx_mpool ;
464- uct_iface_mpool_config_t rx_mpool ;
465- ucs_range_spec_t port_range ;
466- double max_bw ;
450+ uct_iface_config_t super ;
451+ size_t tx_seg_size ;
452+ size_t rx_seg_size ;
453+ size_t max_iov ;
454+ size_t sendv_thresh ;
455+ int prefer_default ;
456+ int put_enable ;
457+ int conn_nb ;
458+ unsigned max_poll ;
459+ unsigned max_conn_retries ;
460+ int sockopt_nodelay ;
461+ uct_tcp_send_recv_buf_config_t sockopt ;
462+ unsigned syn_cnt ;
463+ uct_iface_mpool_config_t tx_mpool ;
464+ uct_iface_mpool_config_t rx_mpool ;
465+ ucs_range_spec_t port_range ;
466+ double max_bw ;
467467 struct {
468- ucs_time_t idle ;
469- unsigned long cnt ;
470- ucs_time_t intvl ;
468+ ucs_time_t idle ;
469+ unsigned long cnt ;
470+ ucs_time_t intvl ;
471471 } keepalive ;
472- ucs_ternary_auto_value_t ep_bind_src_addr ;
473- uct_tcp_reachability_mode_t reachability_mode ;
472+ ucs_ternary_auto_value_t ep_bind_src_addr ;
473+ uct_tcp_reachability_mode_t reachability_mode ;
474474} uct_tcp_iface_config_t ;
475475
476476
0 commit comments