oob/tcp: make mca_oob_tcp_msg_type_t an uint8_t
so no conversion is required when heterogeneous mode is enabled Signed-off-by: Gilles Gouaillardet <gilles@rist.or.jp>
Этот коммит содержится в:
родитель
c36b9e8888
Коммит
626e94b689
@ -13,6 +13,8 @@
|
|||||||
* All rights reserved.
|
* All rights reserved.
|
||||||
* Copyright (c) 2010-2011 Cisco Systems, Inc. All rights reserved.
|
* Copyright (c) 2010-2011 Cisco Systems, Inc. All rights reserved.
|
||||||
* Copyright (c) 2014-2017 Intel, Inc. All rights reserved.
|
* Copyright (c) 2014-2017 Intel, Inc. All rights reserved.
|
||||||
|
* Copyright (c) 2017 Research Organization for Information Science
|
||||||
|
* and Technology (RIST). All rights reserved.
|
||||||
*
|
*
|
||||||
* $COPYRIGHT$
|
* $COPYRIGHT$
|
||||||
*
|
*
|
||||||
@ -32,12 +34,12 @@
|
|||||||
* the message came from an external (to
|
* the message came from an external (to
|
||||||
* this component) source
|
* this component) source
|
||||||
*/
|
*/
|
||||||
typedef enum {
|
typedef uint8_t mca_oob_tcp_msg_type_t;
|
||||||
MCA_OOB_TCP_IDENT,
|
|
||||||
MCA_OOB_TCP_PROBE,
|
#define MCA_OOB_TCP_IDENT 1
|
||||||
MCA_OOB_TCP_PING,
|
#define MCA_OOB_TCP_PROBE 2
|
||||||
MCA_OOB_TCP_USER
|
#define MCA_OOB_TCP_PING 3
|
||||||
} mca_oob_tcp_msg_type_t;
|
#define MCA_OOB_TCP_USER 4
|
||||||
|
|
||||||
#define ORTE_MAX_RTD_SIZE 31
|
#define ORTE_MAX_RTD_SIZE 31
|
||||||
|
|
||||||
@ -54,14 +56,14 @@ typedef struct {
|
|||||||
* and let some other module try to send it
|
* and let some other module try to send it
|
||||||
*/
|
*/
|
||||||
orte_process_name_t dst;
|
orte_process_name_t dst;
|
||||||
/* type of message */
|
|
||||||
mca_oob_tcp_msg_type_t type;
|
|
||||||
/* the rml tag where this message is headed */
|
/* the rml tag where this message is headed */
|
||||||
orte_rml_tag_t tag;
|
orte_rml_tag_t tag;
|
||||||
/* the seq number of this message */
|
/* the seq number of this message */
|
||||||
uint32_t seq_num;
|
uint32_t seq_num;
|
||||||
/* number of bytes in message */
|
/* number of bytes in message */
|
||||||
uint32_t nbytes;
|
uint32_t nbytes;
|
||||||
|
/* type of message */
|
||||||
|
mca_oob_tcp_msg_type_t type;
|
||||||
/* routed module to be used */
|
/* routed module to be used */
|
||||||
char routed[ORTE_MAX_RTD_SIZE+1];
|
char routed[ORTE_MAX_RTD_SIZE+1];
|
||||||
} mca_oob_tcp_hdr_t;
|
} mca_oob_tcp_hdr_t;
|
||||||
@ -71,7 +73,6 @@ typedef struct {
|
|||||||
#define MCA_OOB_TCP_HDR_NTOH(h) \
|
#define MCA_OOB_TCP_HDR_NTOH(h) \
|
||||||
ORTE_PROCESS_NAME_NTOH((h)->origin); \
|
ORTE_PROCESS_NAME_NTOH((h)->origin); \
|
||||||
ORTE_PROCESS_NAME_NTOH((h)->dst); \
|
ORTE_PROCESS_NAME_NTOH((h)->dst); \
|
||||||
(h)->type = ntohl((h)->type); \
|
|
||||||
(h)->tag = ORTE_RML_TAG_NTOH((h)->tag); \
|
(h)->tag = ORTE_RML_TAG_NTOH((h)->tag); \
|
||||||
(h)->nbytes = ntohl((h)->nbytes);
|
(h)->nbytes = ntohl((h)->nbytes);
|
||||||
|
|
||||||
@ -81,7 +82,6 @@ typedef struct {
|
|||||||
#define MCA_OOB_TCP_HDR_HTON(h) \
|
#define MCA_OOB_TCP_HDR_HTON(h) \
|
||||||
ORTE_PROCESS_NAME_HTON((h)->origin); \
|
ORTE_PROCESS_NAME_HTON((h)->origin); \
|
||||||
ORTE_PROCESS_NAME_HTON((h)->dst); \
|
ORTE_PROCESS_NAME_HTON((h)->dst); \
|
||||||
(h)->type = htonl((h)->type); \
|
|
||||||
(h)->tag = ORTE_RML_TAG_HTON((h)->tag); \
|
(h)->tag = ORTE_RML_TAG_HTON((h)->tag); \
|
||||||
(h)->nbytes = htonl((h)->nbytes);
|
(h)->nbytes = htonl((h)->nbytes);
|
||||||
|
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user