linux-imx

/* AFS vlserver probing

 *

 * Copyright (C) 2018 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 Licence

 * as published by the Free Software Foundation; either version

 * 2 of the Licence, 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 bool afs_vl_probe_done(struct afs_vlserver *server)

{

    if (!atomic_dec_and_test(&server->probe_outstanding))

        return false;

​

    wake_up_var(&server->probe_outstanding);

    clear_bit_unlock(AFS_VLSERVER_FL_PROBING, &server->flags);

    wake_up_bit(&server->flags, AFS_VLSERVER_FL_PROBING);

    return true;

}

​

/*

 * Process the result of probing a vlserver.  This is called after successful

 * or failed delivery of an VL.GetCapabilities operation.

 */

void afs_vlserver_probe_result(struct afs_call *call)

{

    struct afs_addr_list *alist = call->alist;

    struct afs_vlserver *server = call->reply[0];

    unsigned int server_index = (long)call->reply[1];

    unsigned int index = call->addr_ix;

    unsigned int rtt = UINT_MAX;

    bool have_result = false;

    u64 _rtt;

    int ret = call->error;

​

    _enter("%s,%u,%u,%d,%d", server->name, server_index, index, ret, call->abort_code);

​

    spin_lock(&server->probe_lock);

​

    switch (ret) {

    case 0:

        server->probe.error = 0;

        goto responded;

    case -ECONNABORTED:

        if (!server->probe.responded) {

            server->probe.abort_code = call->abort_code;

            server->probe.error = ret;

        }

        goto responded;

    case -ENOMEM:

    case -ENONET:

        server->probe.local_failure = true;

        afs_io_error(call, afs_io_error_vl_probe_fail);

        goto out;

    case -ECONNRESET: /* Responded, but call expired. */