linux-imx

/* AFS server record management

 *

 * Copyright (C) 2002, 2007 Red Hat, Inc. All Rights Reserved.

 * Written by David Howells (dhowells@redhat.com)

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version

 * 2 of the License, or (at your option) any later version.

 */

​

#include <linux/sched.h>

#include <linux/slab.h>

#include "afs_fs.h"

#include "internal.h"

#include "protocol_yfs.h"

​

static unsigned afs_server_gc_delay = 10;   /* Server record timeout in seconds */

static unsigned afs_server_update_delay = 30;   /* Time till VLDB recheck in secs */

​

static void afs_inc_servers_outstanding(struct afs_net *net)

{

    atomic_inc(&net->servers_outstanding);

}

​

static void afs_dec_servers_outstanding(struct afs_net *net)

{

    if (atomic_dec_and_test(&net->servers_outstanding))

        wake_up_var(&net->servers_outstanding);

}

​

/*

 * Find a server by one of its addresses.

 */

struct afs_server *afs_find_server(struct afs_net *net,

                   const struct sockaddr_rxrpc *srx)

{

    const struct sockaddr_in6 *a = &srx->transport.sin6, *b;

    const struct afs_addr_list *alist;

    struct afs_server *server = NULL;

    unsigned int i;

    bool ipv6 = true;

    int seq = 0, diff;

​

    if (srx->transport.sin6.sin6_addr.s6_addr32[0] == 0 ||

        srx->transport.sin6.sin6_addr.s6_addr32[1] == 0 ||

        srx->transport.sin6.sin6_addr.s6_addr32[2] == htonl(0xffff))

        ipv6 = false;

​

    rcu_read_lock();

​

    do {

        if (server)

            afs_put_server(net, server);

        server = NULL;

        read_seqbegin_or_lock(&net->fs_addr_lock, &seq);

​

        if (ipv6) {

            hlist_for_each_entry_rcu(server, &net->fs_addresses6, addr6_link) {

                alist = rcu_dereference(server->addresses);

                for (i = alist->nr_ipv4; i < alist->nr_addrs; i++) {

                    b = &alist->addrs[i].transport.sin6;

                    diff = ((u16 __force)a->sin6_port -

                        (u16 __force)b->sin6_port);

                    if (diff == 0)

                        diff = memcmp(&a->sin6_addr,

                                  &b->sin6_addr,

                                  sizeof(struct in6_addr));

                    if (diff == 0)

                        goto found;

                }

            }

        } else {

            hlist_for_each_entry_rcu(server, &net->fs_addresses4, addr4_link) {

                alist = rcu_dereference(server->addresses);

                for (i = 0; i < alist->nr_ipv4; i++) {

                    b = &alist->addrs[i].transport.sin6;

                    diff = ((u16 __force)a->sin6_port -

                        (u16 __force)b->sin6_port);

                    if (diff == 0)

                        diff = ((u32 __force)a->sin6_addr.s6_addr32[3] -

                            (u32 __force)b->sin6_addr.s6_addr32[3]);

                    if (diff == 0)

                        goto found;

                }

            }

        }

​

        server = NULL;

    found:

        if (server && !atomic_inc_not_zero(&server->usage))

            server = NULL;