Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history 
yaml
---
r: 54479
b: refs/heads/master
c: 617e82e
h: refs/heads/master
i:
  54477: 9c72874
  54475: 3440d03
  54471: 5fde2a3
  54463: 4147868
v: v3
  • Loading branch information
David Teigland authored and Steven Whitehouse committed May 1, 2007
1 parent c2dcb45 commit 245c41a
Show file tree
Hide file tree
Showing 2 changed files with 38 additions and 31 deletions.
2 changes: 1 addition & 1 deletion [refs]
View file
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: f391a4ead61e4510ff385815ddaf3c0777fbad1b
refs/heads/master: 617e82e10ccf96a13eb2efd5eac4abef44a87d02
67 changes: 37 additions & 30 deletions trunk/fs/dlm/lowcomms.c
View file
Original file line number Diff line number Diff line change
Expand Up @@ -395,7 +395,8 @@ static void sctp_init_failed(void)
}

/* Something happened to an association */
static void process_sctp_notification(struct connection *con, struct msghdr *msg, char *buf)
static void process_sctp_notification(struct connection *con,
struct msghdr *msg, char *buf)
{
union sctp_notification *sn = (union sctp_notification *)buf;

Expand All @@ -422,7 +423,7 @@ static void process_sctp_notification(struct connection *con, struct msghdr *msg
*/
if ((int)sn->sn_assoc_change.sac_assoc_id <= 0) {
log_print("COMM_UP for invalid assoc ID %d",
(int)sn->sn_assoc_change.sac_assoc_id);
(int)sn->sn_assoc_change.sac_assoc_id);
sctp_init_failed();
return;
}
Expand Down Expand Up @@ -465,10 +466,12 @@ static void process_sctp_notification(struct connection *con, struct msghdr *msg

/* Peel off a new sock */
parg.associd = sn->sn_assoc_change.sac_assoc_id;
ret = kernel_getsockopt(con->sock, IPPROTO_SCTP, SCTP_SOCKOPT_PEELOFF,
ret = kernel_getsockopt(con->sock, IPPROTO_SCTP,
SCTP_SOCKOPT_PEELOFF,
(void *)&parg, &parglen);
if (ret) {
log_print("Can't peel off a socket for connection %d to node %d: err=%d\n",
log_print("Can't peel off a socket for "
"connection %d to node %d: err=%d\n",
parg.associd, nodeid, ret);
}
file = fget(parg.sd);
Expand All @@ -478,7 +481,7 @@ static void process_sctp_notification(struct connection *con, struct msghdr *msg
put_unused_fd(parg.sd);

log_print("got new/restarted association %d nodeid %d",
(int)sn->sn_assoc_change.sac_assoc_id, nodeid);
(int)sn->sn_assoc_change.sac_assoc_id, nodeid);

/* Send any pending writes */
clear_bit(CF_CONNECT_PENDING, &new_con->flags);
Expand Down Expand Up @@ -587,7 +590,7 @@ static int receive_from_sock(struct connection *con)
msg.msg_controllen = sizeof(incmsg);

process_sctp_notification(con, &msg,
page_address(con->rx_page) + con->cb.base);
page_address(con->rx_page) + con->cb.base);
mutex_unlock(&con->sock_mutex);
return 0;
}
Expand All @@ -601,10 +604,10 @@ static int receive_from_sock(struct connection *con)
con->cb.base, con->cb.len,
PAGE_CACHE_SIZE);
if (ret == -EBADMSG) {
printk(KERN_INFO "dlm: lowcomms: addr=%p, base=%u, len=%u, "
"iov_len=%u, iov_base[0]=%p, read=%d\n",
page_address(con->rx_page), con->cb.base, con->cb.len,
len, iov[0].iov_base, r);
log_print("lowcomms: addr=%p, base=%u, len=%u, "
"iov_len=%u, iov_base[0]=%p, read=%d",
page_address(con->rx_page), con->cb.base, con->cb.len,
len, iov[0].iov_base, r);
}
if (ret < 0)
goto out_close;
Expand Down Expand Up @@ -680,7 +683,7 @@ static int tcp_accept_from_sock(struct connection *con)
/* Get the new node's NODEID */
make_sockaddr(&peeraddr, 0, &len);
if (dlm_addr_to_nodeid(&peeraddr, &nodeid)) {
printk("dlm: connect from non cluster node\n");
log_print("connect from non cluster node");
sock_release(newsock);
mutex_unlock(&con->sock_mutex);
return -1;
Expand All @@ -705,7 +708,7 @@ static int tcp_accept_from_sock(struct connection *con)
if (!othercon) {
othercon = kmem_cache_zalloc(con_cache, GFP_KERNEL);
if (!othercon) {
printk("dlm: failed to allocate incoming socket\n");
log_print("failed to allocate incoming socket");
mutex_unlock(&newcon->sock_mutex);
result = -ENOMEM;
goto accept_err;
Expand Down Expand Up @@ -748,7 +751,7 @@ static int tcp_accept_from_sock(struct connection *con)
sock_release(newsock);

if (result != -EAGAIN)
printk("dlm: error accepting connection from node: %d\n", result);
log_print("error accepting connection from node: %d", result);
return result;
}

Expand Down Expand Up @@ -826,7 +829,8 @@ static void sctp_init_assoc(struct connection *con)

ret = kernel_sendmsg(base_con->sock, &outmessage, iov, 1, len);
if (ret < 0) {
log_print("Send first packet to node %d failed: %d", con->nodeid, ret);
log_print("Send first packet to node %d failed: %d",
con->nodeid, ret);

/* Try again later */
clear_bit(CF_CONNECT_PENDING, &con->flags);
Expand Down Expand Up @@ -929,18 +933,18 @@ static struct socket *tcp_create_listen_sock(struct connection *con,
addr_len = sizeof(struct sockaddr_in6);

/* Create a socket to communicate with */
result = sock_create_kern(dlm_local_addr[0]->ss_family, SOCK_STREAM, IPPROTO_TCP, &sock);
result = sock_create_kern(dlm_local_addr[0]->ss_family, SOCK_STREAM,
IPPROTO_TCP, &sock);
if (result < 0) {
printk("dlm: Can't create listening comms socket\n");
log_print("Can't create listening comms socket");
goto create_out;
}

result = kernel_setsockopt(sock, SOL_SOCKET, SO_REUSEADDR,
(char *)&one, sizeof(one));

if (result < 0) {
printk("dlm: Failed to set SO_REUSEADDR on socket: result=%d\n",
result);
log_print("Failed to set SO_REUSEADDR on socket: %d", result);
}
sock->sk->sk_user_data = con;
con->rx_action = tcp_accept_from_sock;
Expand All @@ -951,7 +955,7 @@ static struct socket *tcp_create_listen_sock(struct connection *con,
make_sockaddr(saddr, dlm_config.ci_tcp_port, &addr_len);
result = sock->ops->bind(sock, (struct sockaddr *) saddr, addr_len);
if (result < 0) {
printk("dlm: Can't bind to port %d\n", dlm_config.ci_tcp_port);
log_print("Can't bind to port %d", dlm_config.ci_tcp_port);
sock_release(sock);
sock = NULL;
con->sock = NULL;
Expand All @@ -960,12 +964,12 @@ static struct socket *tcp_create_listen_sock(struct connection *con,
result = kernel_setsockopt(sock, SOL_SOCKET, SO_KEEPALIVE,
(char *)&one, sizeof(one));
if (result < 0) {
printk("dlm: Set keepalive failed: %d\n", result);
log_print("Set keepalive failed: %d", result);
}

result = sock->ops->listen(sock, 5);
if (result < 0) {
printk("dlm: Can't listen on port %d\n", dlm_config.ci_tcp_port);
log_print("Can't listen on port %d", dlm_config.ci_tcp_port);
sock_release(sock);
sock = NULL;
goto create_out;
Expand Down Expand Up @@ -994,8 +998,11 @@ static void init_local(void)
}
}

/* Bind to an IP address. SCTP allows multiple address so it can do multi-homing */
static int add_sctp_bind_addr(struct connection *sctp_con, struct sockaddr_storage *addr, int addr_len, int num)
/* Bind to an IP address. SCTP allows multiple address so it can do
multi-homing */
static int add_sctp_bind_addr(struct connection *sctp_con,
struct sockaddr_storage *addr,
int addr_len, int num)
{
int result = 0;

Expand Down Expand Up @@ -1048,10 +1055,10 @@ static int sctp_listen_for_all(void)
result = kernel_setsockopt(sock, SOL_SOCKET, SO_RCVBUF,
(char *)&bufsize, sizeof(bufsize));
if (result)
log_print("Error increasing buffer space on socket: %d", result);
log_print("Error increasing buffer space on socket %d", result);

result = kernel_setsockopt(sock, SOL_SCTP, SCTP_EVENTS,
(char *)&subscribe, sizeof(subscribe));
(char *)&subscribe, sizeof(subscribe));
if (result < 0) {
log_print("Failed to set SCTP_EVENTS on socket: result=%d",
result);
Expand Down Expand Up @@ -1102,7 +1109,8 @@ static int tcp_listen_for_all(void)

/* We don't support multi-homed hosts */
if (dlm_local_addr[1] != NULL) {
log_print("TCP protocol can't handle multi-homed hosts, try SCTP");
log_print("TCP protocol can't handle multi-homed hosts, "
"try SCTP");
return -EINVAL;
}

Expand Down Expand Up @@ -1148,8 +1156,7 @@ static struct writequeue_entry *new_writequeue_entry(struct connection *con,
return entry;
}

void *dlm_lowcomms_get_buffer(int nodeid, int len,
gfp_t allocation, char **ppc)
void *dlm_lowcomms_get_buffer(int nodeid, int len, gfp_t allocation, char **ppc)
{
struct connection *con;
struct writequeue_entry *e;
Expand Down Expand Up @@ -1253,8 +1260,7 @@ static void send_to_sock(struct connection *con)
goto out;
if (ret <= 0)
goto send_error;
}
else {
} else {
/* Don't starve people filling buffers */
cond_resched();
}
Expand Down Expand Up @@ -1426,6 +1432,7 @@ int dlm_lowcomms_start(void)

init_local();
if (!dlm_local_count) {
error = -ENOTCONN;
log_print("no local IP address has been set");
goto out;
}
Expand Down

0 comments on commit 245c41a

Please sign in to comment.