const size_t size)
{
fwp_endpoint_t *fwp_epoint;
- int flags = 0;
fwp_epoint = endpoint->protocol_info.body;
- return fwp_send(fwp_epoint, msg, size, flags);
+ return fwp_send(fwp_epoint, msg, size);
}
int fwp_fna_send_sync(const fna_endpoint_data_t *endpoint, const void *msg,
const size_t size)
{
fwp_endpoint_t *fwp_epoint;
- int flags = 0;
fwp_epoint = endpoint->protocol_info.body;
- return fwp_send(fwp_epoint, msg, size, flags);
+ return fwp_send(fwp_epoint, msg, size);
}
int fwp_fna_send_async(const fna_endpoint_data_t *endpoint,const void *msg,
{
fwp_endpoint_t *fwp_epoint;
- fwp_epoint = (fwp_endpoint_t*) endpoint->protocol_info.body;
- return fwp_send(fwp_epoint, msg, size, MSG_DONTWAIT);
+ fwp_epoint = (fwp_endpoint_t*) endpoint->protocol_info.body;
+ return fwp_send(fwp_epoint, msg, size); /* FIXME */
}
/** FNA receive routines */
* On error, -1 is returned and errno is set appropriately.
*
*/
-int fwp_send(fwp_endpoint_d_t epointd,const void *msg, const size_t size,
- int flags)
+int fwp_send(fwp_endpoint_d_t epointd,const void *msg, const size_t size)
{
fwp_endpoint_t *fwp_epoint = epointd;
struct fwp_msgb *msgb;
ssize_t fwp_recv(fwp_endpoint_d_t epointd,
void *buffer, const size_t buffer_size,
unsigned int *from, int flags);
-int fwp_send(fwp_endpoint_d_t epointd, const void *msg, const size_t size,
- int flags);
+int fwp_send(fwp_endpoint_d_t epointd, const void *msg, const size_t size);
int fwp_endpoint_attr_init(fwp_endpoint_attr_t *attr);
static inline int fwp_endpoint_attr_setreliability(fwp_endpoint_attr_t *attr,
printf("Send endpoint 2 created\n");
fwp_send_endpoint_bind(sepoint_d2, vres_d2);
- fwp_send(sepoint_d1, msg1, sizeof(msg1), 0);
- fwp_send(sepoint_d1, msg2, sizeof(msg2), 0);
+ fwp_send(sepoint_d1, msg1, sizeof(msg1));
+ fwp_send(sepoint_d1, msg2, sizeof(msg2));
for (i = 0; i < 2; i++) {
if ((len = fwp_recv(repoint_d1, buffer, sizeof(buffer), &from,
printf("Send endpoint 1 created\n");
fwp_send_endpoint_bind(sepoint_d1, vres_d1);
- fwp_send(sepoint_d1, msg1, sizeof(msg1), 0);
+ fwp_send(sepoint_d1, msg1, sizeof(msg1));
printf("Sent msg1\n");
- fwp_send(sepoint_d1, msg2, sizeof(msg2), 0);
+ fwp_send(sepoint_d1, msg2, sizeof(msg2));
printf("Sent msg2\n");
pthread_join(thread, (void**) NULL);
for (count = 0; count < NUM; count++) {
sprintf(msg1,"msg%d",count);
- fwp_send(sepoint_d1, msg1, sizeof(msg1), 0);
+ fwp_send(sepoint_d1, msg1, sizeof(msg1));
clock_gettime(CLOCK_MONOTONIC, &sendtime);
printf("Sent: sec = %ld nsec = %ld \n", sendtime.tv_sec,
while (count < NUM){
count++;
sprintf(msg1,"msg%d sent\n",count);
- fwp_send(sepoint_d1, msg1, sizeof(msg1), 0);
+ fwp_send(sepoint_d1, msg1, sizeof(msg1));
printf(msg1);
/*clock_gettime(CLOCK_MONOTONIC, &sendtime);