forb_port_t *port = arg;
const forb_proto_t *proto = port->desc.proto;
FORB_CDR_Codec *c = &port->codec;
- size_t rcvd, len;
+ ssize_t rcvd;
+ size_t len;
forb_iop_message_header mh;
bool header_received = false;
extern UL_LOG_CUST(ulogd_forb_proto);
-size_t forb_proto_send(forb_peer_t *peer, FORB_CDR_Codec *codec)
+ssize_t forb_proto_send(forb_peer_t *peer, FORB_CDR_Codec *codec)
{
#if 0
* @return Length of the sent data (should be equal to @a len on
* success) or negative error code on error.
*/
- size_t (*send)(forb_peer_t *peer, const void *buf, size_t len);
+ ssize_t (*send)(forb_peer_t *peer, const void *buf, size_t len);
/**
* Called to free any protocol resources associated with the
* @return Length of the received data or negative error code
* on error.
*/
- size_t (*recv)(forb_port_t *port, void *buf, size_t len);
+ ssize_t (*recv)(forb_port_t *port, void *buf, size_t len);
/**
* Broadcasts/multicasts a message. All FORBs connected the
* @return Zero or positive number on success, negative error
* code on error.
*/
- size_t (*broadcast)(forb_port_t *port, const void *buf, size_t len);
+ ssize_t (*broadcast)(forb_port_t *port, const void *buf, size_t len);
/** Serializes the protocol specific address */
CORBA_boolean (*serialize_addr)(FORB_CDR_Codec *codec, const void *addr);
void (*register_cb)(forb_port_t *port);
};
-size_t forb_proto_send(forb_peer_t *peer, FORB_CDR_Codec *codec);
+ssize_t forb_proto_send(forb_peer_t *peer, FORB_CDR_Codec *codec);
forb_peer_t *
forb_get_next_hop(forb_t *forb, forb_server_id *server, fosa_abs_time_t *timeout);
}
-static size_t
+static ssize_t
inet_send(forb_peer_t *peer, const void *buf, size_t len)
{
struct inet_peer *ipeer = peer->proto_priv;
- size_t ret, sent;
+ ssize_t ret, sent;
if (!ipeer) {
ipeer = inet_connect(peer);
return epoll_ctl(p->epoll_fd, EPOLL_CTL_ADD, client, &ev);
}
-static size_t
+static ssize_t
inet_recv(forb_port_t *port, void *buf, size_t len)
{
struct inet_port *iport = port->desc.proto_priv;
#if 1
struct epoll_event ev;
- int ret, nfds;
+ ssize_t ret;
+ int nfds;
forb_peer_t *peer;
bool exported_new_peer = false;
return 0;
}
-static size_t
+static ssize_t
inet_broadcast(forb_port_t *port, const void *buf, size_t len)
{
struct inet_port *p = port->desc.proto_priv;
struct sockaddr_in addr;
- int ret;
+ ssize_t ret;
addr.sin_family = AF_INET;
addr.sin_port = htons(MCAST_PORT);
forb_uuid_to_string(str, (forb_uuid_t*)server->uuid, sizeof(str)));
}
-static size_t
+static ssize_t
unix_send(forb_peer_t *peer, const void *buf, size_t len)
{
unix_addr_t addr;
(struct sockaddr*)&addr, sizeof(addr));
}
-static size_t
+static ssize_t
unix_recv(forb_port_t *port, void *buf, size_t len)
{
struct unix_port *p = port->desc.proto_priv;
return 0;
}
-static size_t
+static ssize_t
unix_broadcast(forb_port_t *port, const void *buf, size_t len)
{
struct unix_port *p = port->desc.proto_priv;