Commit d7e83e6b authored by Pavel Shilovsky's avatar Pavel Shilovsky

Fix tunnel port problem for 2.6.29

parent 4e3ec5c4
...@@ -1361,13 +1361,16 @@ cifs_parse_mount_options(char *options, const char *devname, ...@@ -1361,13 +1361,16 @@ cifs_parse_mount_options(char *options, const char *devname,
} }
static struct TCP_Server_Info * static struct TCP_Server_Info *
cifs_find_tcp_session(struct sockaddr_storage *addr) cifs_find_tcp_session(struct sockaddr_storage *addr, unsigned short int port)
{ {
struct list_head *tmp; struct list_head *tmp;
struct TCP_Server_Info *server; struct TCP_Server_Info *server;
struct sockaddr_in *addr4 = (struct sockaddr_in *) addr; struct sockaddr_in *addr4 = (struct sockaddr_in *) addr;
struct sockaddr_in6 *addr6 = (struct sockaddr_in6 *) addr; struct sockaddr_in6 *addr6 = (struct sockaddr_in6 *) addr;
if (!port)
port = CIFS_PORT;
write_lock(&cifs_tcp_ses_lock); write_lock(&cifs_tcp_ses_lock);
list_for_each(tmp, &cifs_tcp_ses_list) { list_for_each(tmp, &cifs_tcp_ses_list) {
server = list_entry(tmp, struct TCP_Server_Info, server = list_entry(tmp, struct TCP_Server_Info,
...@@ -1382,12 +1385,14 @@ cifs_find_tcp_session(struct sockaddr_storage *addr) ...@@ -1382,12 +1385,14 @@ cifs_find_tcp_session(struct sockaddr_storage *addr)
continue; continue;
if (addr->ss_family == AF_INET && if (addr->ss_family == AF_INET &&
(addr4->sin_addr.s_addr != ((addr4->sin_addr.s_addr !=
server->addr.sockAddr.sin_addr.s_addr)) server->addr.sockAddr.sin_addr.s_addr) ||
(htons(port) != server->addr.sockAddr.sin_port)))
continue; continue;
else if (addr->ss_family == AF_INET6 && else if (addr->ss_family == AF_INET6 &&
!ipv6_addr_equal(&server->addr.sockAddr6.sin6_addr, (!ipv6_addr_equal(&server->addr.sockAddr6.sin6_addr,
&addr6->sin6_addr)) &addr6->sin6_addr) ||
(htons(port) != server->addr.sockAddr.sin_port)))
continue; continue;
++server->srv_count; ++server->srv_count;
...@@ -1474,7 +1479,7 @@ cifs_get_tcp_session(struct smb_vol *volume_info) ...@@ -1474,7 +1479,7 @@ cifs_get_tcp_session(struct smb_vol *volume_info)
} }
/* see if we already have a matching tcp_ses */ /* see if we already have a matching tcp_ses */
tcp_ses = cifs_find_tcp_session(&addr); tcp_ses = cifs_find_tcp_session(&addr, volume_info->port);
if (tcp_ses) if (tcp_ses)
return tcp_ses; return tcp_ses;
...@@ -1743,7 +1748,7 @@ ipv4_connect(struct TCP_Server_Info *server) ...@@ -1743,7 +1748,7 @@ ipv4_connect(struct TCP_Server_Info *server)
{ {
int rc = 0; int rc = 0;
bool connected = false; bool connected = false;
__be16 orig_port = 0; bool orig_port_error = false;
struct socket *socket = server->ssocket; struct socket *socket = server->ssocket;
if (socket == NULL) { if (socket == NULL) {
...@@ -1761,20 +1766,18 @@ ipv4_connect(struct TCP_Server_Info *server) ...@@ -1761,20 +1766,18 @@ ipv4_connect(struct TCP_Server_Info *server)
cifs_reclassify_socket4(socket); cifs_reclassify_socket4(socket);
} }
/* user overrode default port */ /* user overrode default port or we perform reconnect */
if (server->addr.sockAddr.sin_port) { if (server->addr.sockAddr.sin_port) {
rc = socket->ops->connect(socket, (struct sockaddr *) rc = socket->ops->connect(socket, (struct sockaddr *)
&server->addr.sockAddr, &server->addr.sockAddr,
sizeof(struct sockaddr_in), 0); sizeof(struct sockaddr_in), 0);
if (rc >= 0) if (rc >= 0)
connected = true; connected = true;
else
orig_port_error = true;
} }
if (!connected) { if (!orig_port_error && !connected) {
/* save original port so we can retry user specified port
later if fall back ports fail this time */
orig_port = server->addr.sockAddr.sin_port;
/* do not retry on the same port we just failed on */ /* do not retry on the same port we just failed on */
if (server->addr.sockAddr.sin_port != htons(CIFS_PORT)) { if (server->addr.sockAddr.sin_port != htons(CIFS_PORT)) {
server->addr.sockAddr.sin_port = htons(CIFS_PORT); server->addr.sockAddr.sin_port = htons(CIFS_PORT);
...@@ -1786,7 +1789,8 @@ ipv4_connect(struct TCP_Server_Info *server) ...@@ -1786,7 +1789,8 @@ ipv4_connect(struct TCP_Server_Info *server)
connected = true; connected = true;
} }
} }
if (!connected) {
if (!orig_port_error && !connected) {
server->addr.sockAddr.sin_port = htons(RFC1001_PORT); server->addr.sockAddr.sin_port = htons(RFC1001_PORT);
rc = socket->ops->connect(socket, (struct sockaddr *) rc = socket->ops->connect(socket, (struct sockaddr *)
&server->addr.sockAddr, &server->addr.sockAddr,
...@@ -1798,15 +1802,12 @@ ipv4_connect(struct TCP_Server_Info *server) ...@@ -1798,15 +1802,12 @@ ipv4_connect(struct TCP_Server_Info *server)
/* give up here - unless we want to retry on different /* give up here - unless we want to retry on different
protocol families some day */ protocol families some day */
if (!connected) { if (!connected) {
if (orig_port)
server->addr.sockAddr.sin_port = orig_port;
cFYI(1, ("Error %d connecting to server via ipv4", rc)); cFYI(1, ("Error %d connecting to server via ipv4", rc));
sock_release(socket); sock_release(socket);
server->ssocket = NULL; server->ssocket = NULL;
return rc; return rc;
} }
/* /*
* Eventually check for other socket options to change from * Eventually check for other socket options to change from
* the default. sock_setsockopt not used because it expects * the default. sock_setsockopt not used because it expects
...@@ -1895,7 +1896,7 @@ ipv6_connect(struct TCP_Server_Info *server) ...@@ -1895,7 +1896,7 @@ ipv6_connect(struct TCP_Server_Info *server)
{ {
int rc = 0; int rc = 0;
bool connected = false; bool connected = false;
__be16 orig_port = 0; bool orig_port_error = false;
struct socket *socket = server->ssocket; struct socket *socket = server->ssocket;
if (socket == NULL) { if (socket == NULL) {
...@@ -1921,13 +1922,11 @@ ipv6_connect(struct TCP_Server_Info *server) ...@@ -1921,13 +1922,11 @@ ipv6_connect(struct TCP_Server_Info *server)
sizeof(struct sockaddr_in6), 0); sizeof(struct sockaddr_in6), 0);
if (rc >= 0) if (rc >= 0)
connected = true; connected = true;
else
orig_port_error = true;
} }
if (!connected) { if (!orig_port_error && !connected) {
/* save original port so we can retry user specified port
later if fall back ports fail this time */
orig_port = server->addr.sockAddr6.sin6_port;
/* do not retry on the same port we just failed on */ /* do not retry on the same port we just failed on */
if (server->addr.sockAddr6.sin6_port != htons(CIFS_PORT)) { if (server->addr.sockAddr6.sin6_port != htons(CIFS_PORT)) {
server->addr.sockAddr6.sin6_port = htons(CIFS_PORT); server->addr.sockAddr6.sin6_port = htons(CIFS_PORT);
...@@ -1938,7 +1937,8 @@ ipv6_connect(struct TCP_Server_Info *server) ...@@ -1938,7 +1937,8 @@ ipv6_connect(struct TCP_Server_Info *server)
connected = true; connected = true;
} }
} }
if (!connected) {
if (!orig_port_error && !connected) {
server->addr.sockAddr6.sin6_port = htons(RFC1001_PORT); server->addr.sockAddr6.sin6_port = htons(RFC1001_PORT);
rc = socket->ops->connect(socket, (struct sockaddr *) rc = socket->ops->connect(socket, (struct sockaddr *)
&server->addr.sockAddr6, &server->addr.sockAddr6,
...@@ -1950,8 +1950,6 @@ ipv6_connect(struct TCP_Server_Info *server) ...@@ -1950,8 +1950,6 @@ ipv6_connect(struct TCP_Server_Info *server)
/* give up here - unless we want to retry on different /* give up here - unless we want to retry on different
protocol families some day */ protocol families some day */
if (!connected) { if (!connected) {
if (orig_port)
server->addr.sockAddr6.sin6_port = orig_port;
cFYI(1, ("Error %d connecting to server via ipv6", rc)); cFYI(1, ("Error %d connecting to server via ipv6", rc));
sock_release(socket); sock_release(socket);
server->ssocket = NULL; server->ssocket = NULL;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment