]> rtime.felk.cvut.cz Git - frescor/frsh-include.git/blobdiff - frsh_distributed.h
Added the hash table for contracts
[frescor/frsh-include.git] / frsh_distributed.h
index be1f98884760c9596dea6a210d61a9ed5c1882b3..c23fd7efe9888879782625cb07e51e79cdf0ee7b 100644 (file)
  **/
 
 /**
- * frsh_network_message_get_max_size()
+ * frsh_network_get_max_message_size()
  *
  * This operation gives the maximum number of bytes that can be sent
  * at a time through the send function when using the network designated by
  *   invalid \n
  *
  **/
-int frsh_network_message_get_max_size
+int frsh_network_get_max_message_size
    (const frsh_resource_id_t resource_id,
     const frsh_network_address_t destination,
     size_t *max_size);
@@ -352,6 +352,7 @@ int frsh_send_endpoint_create
   (frsh_resource_id_t     network_id,
    frsh_network_address_t    destination,
    frsh_stream_id_t       stream_id,
+   frsh_send_endpoint_protocol_info_t protocol_info,
    frsh_send_endpoint_t  *endpoint);
 
 /**
@@ -364,7 +365,8 @@ int frsh_send_endpoint_get_params
     (const frsh_send_endpoint_t  *endpoint,
      frsh_resource_id_t        *network_id,
      frsh_network_address_t       *destination,
-     frsh_stream_id_t          *stream);
+     frsh_stream_id_t          *stream,
+     frsh_send_endpoint_protocol_info_t  *protocol_info);
 
 /**
  * frsh_send_endpoint_destroy()
@@ -470,8 +472,6 @@ int frsh_send_sync
    void                       *msg,
    size_t                      size);
 
-
-
 /**
  * frsh_send_endpoint_get_status()
  *
@@ -514,10 +514,9 @@ int frsh_receive_endpoint_create
   (frsh_resource_id_t        network_id,
    frsh_stream_id_t          stream_id,
    frsh_endpoint_queueing_info_t queueing_info,
-   frsh_protocol_info_t     protocol_info,
+   frsh_receive_endpoint_protocol_info_t protocol_info,
    frsh_receive_endpoint_t  *endpoint);
 
-
 /**
  * frsh_receive_endpoint_get_params()
  *
@@ -525,11 +524,11 @@ int frsh_receive_endpoint_create
  * endpoint at creation time.
  **/
 int frsh_receive_endpoint_get_params
-    (frsh_resource_id_t        *network_id,
+     (const frsh_receive_endpoint_t  *endpoint,
+     frsh_resource_id_t        *network_id,
      frsh_stream_id_t          *stream,
      frsh_endpoint_queueing_info_t   *queueing_info,
-     frsh_protocol_info_t      *protocol_info,
-     const frsh_receive_endpoint_t  *endpoint);
+     frsh_receive_endpoint_protocol_info_t   *protocol_info);
 
 /**
  * frsh_receive_endpoint_destroy()
@@ -575,7 +574,8 @@ int frsh_receive_sync
   (const frsh_receive_endpoint_t  *endpoint,
    void                          *buffer,
    size_t                         buffer_size,
-   size_t                        *message_size);
+   size_t                        *message_size,
+   frsh_network_address_t *from);
 
 /**
  * frsh_receive_async()
@@ -595,7 +595,8 @@ int frsh_receive_async
   (const frsh_receive_endpoint_t  *endpoint,
    void                          *buffer,
    size_t                         buffer_size,
-   size_t                        *message_size);
+   size_t                        *message_size,
+   frsh_network_address_t *from);
 
 
 /**