#include "compat.h"
//#include <glog/logging.h>
#include "swift.h"
+#include "../kernel/mptp.h"
using namespace std;
using namespace swift;
// SOCKMGMT
evutil_socket_t Channel::Bind (Address address, sckrwecb_t callbacks) {
- struct sockaddr_in addr = address;
+ struct sockaddr_mptp *addr = address.addr;
evutil_socket_t fd;
- int len = sizeof(struct sockaddr_in), sndbuf=1<<20, rcvbuf=1<<20;
+ int len = sizeof(struct sockaddr_mptp) + addr->count*sizeof(struct mptp_dest), sndbuf=1<<20, rcvbuf=1<<20;
#define dbnd_ensure(x) { if (!(x)) { \
print_error("binding fails"); close_socket(fd); return INVALID_SOCKET; } }
- dbnd_ensure ( (fd = socket(AF_INET, SOCK_DGRAM, 0)) >= 0 );
+ dbnd_ensure ( (fd = socket(AF_INET, SOCK_DGRAM, IPPROTO_MPTP)) >= 0 );
dbnd_ensure( make_socket_nonblocking(fd) ); // FIXME may remove this
int enable = true;
dbnd_ensure ( setsockopt(fd, SOL_SOCKET, SO_SNDBUF,
dbnd_ensure ( setsockopt(fd, SOL_SOCKET, SO_RCVBUF,
(setsockoptptr_t)&rcvbuf, sizeof(int)) == 0 );
//setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, (setsockoptptr_t)&enable, sizeof(int));
- dbnd_ensure ( ::bind(fd, (sockaddr*)&addr, len) == 0 );
+ dbnd_ensure ( ::bind(fd, (sockaddr*)addr, len) == 0 );
callbacks.sock = fd;
sock_open[sock_count++] = callbacks;
int Channel::SendTo (evutil_socket_t sock, const Address& addr, struct evbuffer *evb) {
int length = evbuffer_get_length(evb);
- int r = sendto(sock,(const char *)evbuffer_pullup(evb, length),length,0,
- (struct sockaddr*)&(addr.addr),sizeof(struct sockaddr_in));
+ int addr_len = sizeof(struct sockaddr_mptp) + addr.addr->count * sizeof(struct mptp_dest);
+ struct iovec iov[1];
+ struct msghdr msg;
+ memset(&msg, 0, sizeof(msg));
+ memset(&iov, 0, sizeof(iov));
+ iov[0].iov_base = evbuffer_pullup(evb, length);
+ iov[0].iov_len = length;
+ msg.msg_iov = iov;
+ msg.msg_iovlen = 1;
+ msg.msg_name = addr.addr;
+ msg.msg_namelen = addr_len;
+ int r = sendmsg(sock, &msg, 0);
if (r<0) {
print_error("can't send");
evbuffer_drain(evb, length); // Arno: behaviour is to pretend the packet got lost
}
int Channel::RecvFrom (evutil_socket_t sock, Address& addr, struct evbuffer *evb) {
- socklen_t addrlen = sizeof(struct sockaddr_in);
+ socklen_t addrlen = sizeof(struct sockaddr_mptp) + addr.addr->count * sizeof(mptp_dest);
struct evbuffer_iovec vec;
if (evbuffer_reserve_space(evb, SWIFT_MAX_RECV_DGRAM_SIZE, &vec, 1) < 0) {
print_error("error on evbuffer_reserve_space");
return 0;
}
- int length = recvfrom (sock, (char *)vec.iov_base, SWIFT_MAX_RECV_DGRAM_SIZE, 0,
- (struct sockaddr*)&(addr.addr), &addrlen);
+ struct iovec iov[1];
+ struct msghdr msg;
+ memset(&msg, 0, sizeof(msg));
+ memset(&iov, 0, sizeof(iov));
+ iov[0].iov_base = vec.iov_base;
+ iov[0].iov_len = SWIFT_MAX_RECV_DGRAM_SIZE;
+ msg.msg_iov = iov;
+ msg.msg_iovlen = 1;
+ msg.msg_name = addr.addr;
+ msg.msg_namelen = addrlen;
+ int length = recvmsg(sock, &msg, 0);
if (length<0) {
length = 0;
print_error("cannot lookup address");
return;
} else {
- addr.sin_addr.s_addr = *(u_long *) h->h_addr_list[0];
+ addr->dests[0].addr = *(u_long *) h->h_addr_list[0];
}
}