OpenMPI  0.1.1
btl_sctp_endpoint.h
1 /*
2  * Copyright (c) 2004-2005 The Trustees of Indiana University and Indiana
3  * University Research and Technology
4  * Corporation. All rights reserved.
5  * Copyright (c) 2004-2006 The University of Tennessee and The University
6  * of Tennessee Research Foundation. All rights
7  * reserved.
8  * Copyright (c) 2004-2005 High Performance Computing Center Stuttgart,
9  * University of Stuttgart. All rights reserved.
10  * Copyright (c) 2004-2005 The Regents of the University of California.
11  * All rights reserved.
12  * $COPYRIGHT$
13  *
14  * Additional copyrights may follow
15  *
16  * $HEADER$
17  */
18 
19 #ifndef MCA_BTL_SCTP_ENDPOINT_H
20 #define MCA_BTL_SCTP_ENDPOINT_H
21 
22 #include "opal/class/opal_list.h"
23 #include "opal/mca/event/event.h"
24 #include "btl_sctp_frag.h"
25 #include "btl_sctp.h"
26 BEGIN_C_DECLS
27 
28 #define MCA_BTL_SCTP_ENDPOINT_CACHE 1
29 
30 /**
31  * State of SCTP endpoint connection.
32  */
33 
34 typedef enum {
35  MCA_BTL_SCTP_CONNECTING = 0,
36  MCA_BTL_SCTP_CONNECT_ACK,
37  MCA_BTL_SCTP_CLOSED,
38  MCA_BTL_SCTP_FAILED,
39  MCA_BTL_SCTP_CONNECTED,
40  MCA_BTL_SCTP_SHUTDOWN
41 } mca_btl_sctp_state_t;
42 
43 /**
44  * An abstraction that represents a connection to a endpoint process.
45  * An instance of mca_btl_base_endpoint_t is associated w/ each process
46  * and BTL pair at startup. However, connections to the endpoint
47  * are established dynamically on an as-needed basis:
48  */
49 
51  opal_list_item_t super;
52  struct mca_btl_sctp_module_t* endpoint_btl; /**< BTL instance that created this connection */
53  struct mca_btl_sctp_proc_t* endpoint_proc; /**< proc structure corresponding to endpoint */
54  struct mca_btl_sctp_addr_t* endpoint_addr; /**< address of endpoint */
55  int endpoint_sd; /**< socket connection to endpoint */
56 #if MCA_BTL_SCTP_ENDPOINT_CACHE
57  char* endpoint_cache; /**< cache for the recv (reduce the number of recv syscall) */
58  char* endpoint_cache_pos; /**< current position in the cache */
59  size_t endpoint_cache_length; /**< length of the data in the cache */
60 #endif /* MCA_BTL_SCTP_ENDPOINT_CACHE */
61  struct mca_btl_sctp_frag_t* endpoint_send_frag; /**< current send frag being processed */
62  struct mca_btl_sctp_frag_t* endpoint_recv_frag; /**< current recv frag being processed */
63  mca_btl_sctp_state_t endpoint_state; /**< current state of the connection */
64  size_t endpoint_retries; /**< number of connection retries attempted */
65  opal_list_t endpoint_frags; /**< list of pending frags to send */
66  opal_mutex_t endpoint_send_lock; /**< lock for concurrent access to endpoint state */
67  opal_mutex_t endpoint_recv_lock; /**< lock for concurrent access to endpoint state */
68  opal_event_t endpoint_send_event; /**< event for async processing of send frags */
69  opal_event_t endpoint_recv_event; /**< event for async processing of recv frags */
70  bool endpoint_nbo; /**< convert headers to network byte order? */
71  int endpoint_has_initialized;
72  int endpoint_in_list;
73 };
74 
78 
80  opal_list_item_t super;
81  mca_btl_sctp_endpoint_t *endpoint;
82 };
85 
86 
87 int mca_btl_sctp_set_socket_options(int sd);
88 void mca_btl_sctp_endpoint_close(mca_btl_base_endpoint_t*);
89 int mca_btl_sctp_endpoint_send(mca_btl_base_endpoint_t*, struct mca_btl_sctp_frag_t*);
90 bool mca_btl_sctp_endpoint_accept(mca_btl_base_endpoint_t*, struct sockaddr_in*, int);
91 void mca_btl_sctp_endpoint_shutdown(mca_btl_base_endpoint_t*);
92 
93 END_C_DECLS
94 #endif
struct mca_btl_sctp_proc_t * endpoint_proc
proc structure corresponding to endpoint
Definition: btl_sctp_endpoint.h:53
SCTP fragment derived type.
Definition: btl_sctp_frag.h:43
Structure to represent a single event.
Definition: event_struct.h:87
Definition: mutex_unix.h:53
The opal_list_t interface is used to provide a generic doubly-linked list container for Open MPI...
char * endpoint_cache
cache for the recv (reduce the number of recv syscall)
Definition: btl_sctp_endpoint.h:57
size_t endpoint_retries
number of connection retries attempted
Definition: btl_openib_endpoint.h:192
Definition: opal_list.h:98
opal_event_t endpoint_recv_event
event for async processing of recv frags
Definition: btl_sctp_endpoint.h:69
opal_event_t endpoint_send_event
event for async processing of send frags
Definition: btl_sctp_endpoint.h:68
struct mca_btl_sctp_addr_t * endpoint_addr
address of endpoint
Definition: btl_sctp_endpoint.h:54
opal_mutex_t endpoint_send_lock
lock for concurrent access to endpoint state
Definition: btl_sctp_endpoint.h:66
struct mca_btl_sctp_frag_t * endpoint_recv_frag
current recv frag being processed
Definition: btl_sctp_endpoint.h:62
State of ELAN endpoint connection.
Definition: btl_elan_endpoint.h:33
Structure used to publish SCTP connection information to peers.
Definition: btl_sctp_addr.h:38
Definition: opal_list.h:147
int endpoint_sd
socket connection to endpoint
Definition: btl_sctp_endpoint.h:55
char * endpoint_cache_pos
current position in the cache
Definition: btl_sctp_endpoint.h:58
size_t endpoint_cache_length
length of the data in the cache
Definition: btl_sctp_endpoint.h:59
struct mca_btl_sctp_frag_t * endpoint_send_frag
current send frag being processed
Definition: btl_sctp_endpoint.h:61
struct mca_btl_sctp_module_t * endpoint_btl
BTL instance that created this connection.
Definition: btl_sctp_endpoint.h:52
opal_mutex_t endpoint_recv_lock
lock for concurrent access to endpoint state
Definition: btl_sctp_endpoint.h:67
mca_btl_sctp_state_t endpoint_state
current state of the connection
Definition: btl_sctp_endpoint.h:63
opal_list_t endpoint_frags
list of pending frags to send
Definition: btl_sctp_endpoint.h:65
bool endpoint_nbo
convert headers to network byte order?
Definition: btl_sctp_endpoint.h:70
BTL Module Interface.
Definition: btl_sctp.h:103
Represents the state of a remote process and the set of addresses that it exports.
Definition: btl_sctp_proc.h:37
Definition: btl_sctp_endpoint.h:79
#define OBJ_CLASS_DECLARATION(NAME)
Declaration for class descriptor.
Definition: opal_object.h:236