upcall.h File Reference

#include "nfs41_ops.h"
#include "from_kernel.h"

Include dependency graph for upcall.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	__mount_upcall_args
struct	__open_upcall_args
struct	__close_upcall_args
struct	__readwrite_upcall_args
struct	__lock_upcall_args
struct	__unlock_upcall_args
struct	__getattr_upcall_args
struct	__setattr_upcall_args
struct	__getexattr_upcall_args
struct	__setexattr_upcall_args
struct	__readdir_upcall_args
struct	__symlink_upcall_args
struct	__volume_upcall_args
struct	__getacl_upcall_args
struct	__setacl_upcall_args
union	__upcall_args
struct	__nfs41_upcall
struct	__nfs41_upcall_op

Macros
#define	NFSD_VERSION_MISMATCH   116

Typedefs
typedef struct __mount_upcall_args	mount_upcall_args
typedef struct __open_upcall_args	open_upcall_args
typedef struct __close_upcall_args	close_upcall_args
typedef struct __readwrite_upcall_args	readwrite_upcall_args
typedef struct __lock_upcall_args	lock_upcall_args
typedef struct __unlock_upcall_args	unlock_upcall_args
typedef struct __getattr_upcall_args	getattr_upcall_args
typedef struct __setattr_upcall_args	setattr_upcall_args
typedef struct __getexattr_upcall_args	getexattr_upcall_args
typedef struct __setexattr_upcall_args	setexattr_upcall_args
typedef struct __readdir_upcall_args	readdir_upcall_args
typedef struct __symlink_upcall_args	symlink_upcall_args
typedef struct __volume_upcall_args	volume_upcall_args
typedef struct __getacl_upcall_args	getacl_upcall_args
typedef struct __setacl_upcall_args	setacl_upcall_args
typedef union __upcall_args	upcall_args
typedef struct __nfs41_upcall	nfs41_upcall
typedef int(*	upcall_parse_proc) (unsigned char *, uint32_t, nfs41_upcall *)
typedef int(*	upcall_handle_proc) (nfs41_upcall *)
typedef int(*	upcall_marshall_proc) (unsigned char *, uint32_t *, nfs41_upcall *)
typedef void(*	upcall_cancel_proc) (nfs41_upcall *)
typedef void(*	upcall_cleanup_proc) (nfs41_upcall *)
typedef struct __nfs41_upcall_op	nfs41_upcall_op

Functions
int	upcall_parse (IN unsigned char *buffer, IN uint32_t length, OUT nfs41_upcall *upcall)
int	upcall_handle (IN nfs41_upcall *upcall)
void	upcall_marshall (IN nfs41_upcall *upcall, OUT unsigned char *buffer, IN uint32_t length, OUT uint32_t *length_out)
void	upcall_cancel (IN nfs41_upcall *upcall)
void	upcall_cleanup (IN nfs41_upcall *upcall)

Macro Definition Documentation

NFSD_VERSION_MISMATCH

#define NFSD_VERSION_MISMATCH   116

Definition at line 28 of file upcall.h.

Typedef Documentation

close_upcall_args

typedef struct __close_upcall_args close_upcall_args

getacl_upcall_args

typedef struct __getacl_upcall_args getacl_upcall_args

getattr_upcall_args

typedef struct __getattr_upcall_args getattr_upcall_args

getexattr_upcall_args

typedef struct __getexattr_upcall_args getexattr_upcall_args

lock_upcall_args

typedef struct __lock_upcall_args lock_upcall_args

mount_upcall_args

typedef struct __mount_upcall_args mount_upcall_args

nfs41_upcall

typedef struct __nfs41_upcall nfs41_upcall

nfs41_upcall_op

typedef struct __nfs41_upcall_op nfs41_upcall_op

open_upcall_args

typedef struct __open_upcall_args open_upcall_args

readdir_upcall_args

typedef struct __readdir_upcall_args readdir_upcall_args

readwrite_upcall_args

typedef struct __readwrite_upcall_args readwrite_upcall_args

setacl_upcall_args

typedef struct __setacl_upcall_args setacl_upcall_args

setattr_upcall_args

typedef struct __setattr_upcall_args setattr_upcall_args

setexattr_upcall_args

typedef struct __setexattr_upcall_args setexattr_upcall_args

symlink_upcall_args

typedef struct __symlink_upcall_args symlink_upcall_args

unlock_upcall_args

typedef struct __unlock_upcall_args unlock_upcall_args

upcall_args

typedef union __upcall_args upcall_args

upcall_cancel_proc

typedef void(* upcall_cancel_proc) (nfs41_upcall *)

Definition at line 215 of file upcall.h.

upcall_cleanup_proc

typedef void(* upcall_cleanup_proc) (nfs41_upcall *)

Definition at line 216 of file upcall.h.

upcall_handle_proc

typedef int(* upcall_handle_proc) (nfs41_upcall *)

Definition at line 213 of file upcall.h.

upcall_marshall_proc

typedef int(* upcall_marshall_proc) (unsigned char *, uint32_t *, nfs41_upcall *)

Definition at line 214 of file upcall.h.

upcall_parse_proc

typedef int(* upcall_parse_proc) (unsigned char *, uint32_t, nfs41_upcall *)

Definition at line 212 of file upcall.h.

volume_upcall_args

typedef struct __volume_upcall_args volume_upcall_args

Function Documentation

upcall_cancel()

void upcall_cancel

(

IN nfs41_upcall *

upcall

)

Definition at line 189 of file upcall.c.

{
    const nfs41_upcall_op *op = g_upcall_op_table[upcall->opcode];
    if (op && op->cancel)
        op->cancel(upcall);
}

Referenced by thread_main().

upcall_cleanup()

void upcall_cleanup

(

IN nfs41_upcall *

upcall

)

Definition at line 197 of file upcall.c.

{
    const nfs41_upcall_op *op = g_upcall_op_table[upcall->opcode];
    if (op && op->cleanup && upcall->status != NFSD_VERSION_MISMATCH)
        op->cleanup(upcall);

    if (upcall->state_ref && upcall->state_ref != INVALID_HANDLE_VALUE) {
        nfs41_open_state_deref(upcall->state_ref);
        upcall->state_ref = NULL;
    }
    if (upcall->root_ref && upcall->root_ref != INVALID_HANDLE_VALUE) {
        nfs41_root_deref(upcall->root_ref);
        upcall->root_ref = NULL;
    }
}

Referenced by thread_main().

upcall_handle()

int upcall_handle

(

IN nfs41_upcall *

upcall

)

Definition at line 138 of file upcall.c.

{
    int status = NO_ERROR;
    const nfs41_upcall_op *op;

    op = g_upcall_op_table[upcall->opcode];
    if (op == NULL || op->handle == NULL) {
        status = ERROR_NOT_SUPPORTED;
        eprintf("upcall '%s' missing handle function!\n",
            opcode2string(upcall->opcode));
        goto out;
    }

    upcall->status = op->handle(upcall);
out:
    return status;
}

Referenced by thread_main().

upcall_marshall()

void upcall_marshall	(	IN nfs41_upcall *	upcall,
		OUT unsigned char *	buffer,
		IN uint32_t	length,
		OUT uint32_t *	length_out
	)

Definition at line 157 of file upcall.c.

{
    const nfs41_upcall_op *op;
    unsigned char *orig_buf = buffer;
    const uint32_t total = length, orig_len = length;

    /* marshall common elements */
write_downcall:
    length = orig_len;
    buffer = orig_buf;
    safe_write(&buffer, &length, &upcall->xid, sizeof(upcall->xid));
    safe_write(&buffer, &length, &upcall->opcode, sizeof(upcall->opcode));
    safe_write(&buffer, &length, &upcall->status, sizeof(upcall->status));
    safe_write(&buffer, &length, &upcall->last_error, sizeof(upcall->last_error));

    if (upcall->status)
        goto out;

    /* marshall the operation's results */
    op = g_upcall_op_table[upcall->opcode];
    if (op && op->marshall) {
        if ((upcall->status = op->marshall(buffer, &length, upcall)))
            goto write_downcall;
    }
out:
    *length_out = total - length;
}

Referenced by thread_main().

upcall_parse()

int upcall_parse	(	IN unsigned char *	buffer,
		IN uint32_t	length,
		OUT nfs41_upcall *	upcall
	)

Definition at line 75 of file upcall.c.

{
    int status;
    const nfs41_upcall_op *op;
    DWORD version;

    ZeroMemory(upcall, sizeof(nfs41_upcall));
    if (!length) {
        eprintf("empty upcall\n");
        upcall->status = status = 102;
        goto out;
    }

    dprintf(2, "received %d bytes upcall data: processing upcall\n", length);
    print_hexbuf(4, (unsigned char *)"upcall buffer: ", buffer, length);

    /* parse common elements */
    status = safe_read(&buffer, &length, &version, sizeof(uint32_t));
    if (status) goto out;
    status = safe_read(&buffer, &length, &upcall->xid, sizeof(uint64_t));
    if (status) goto out;
    status = safe_read(&buffer, &length, &upcall->opcode, sizeof(uint32_t));
    if (status) goto out;
    status = safe_read(&buffer, &length, &upcall->root_ref, sizeof(HANDLE));
    if (status) goto out;
    status = safe_read(&buffer, &length, &upcall->state_ref, sizeof(HANDLE));
    if (status) goto out;

    dprintf(2, "time=%ld version=%d xid=%d opcode=%s session=0x%x open_state=0x%x\n", 
        time(NULL), version, upcall->xid, opcode2string(upcall->opcode), upcall->root_ref, 
        upcall->state_ref);
    if (version != NFS41D_VERSION) {
        eprintf("received version %d expecting version %d\n", version, NFS41D_VERSION);
        upcall->status = status = NFSD_VERSION_MISMATCH;
        goto out;
    }
    if (upcall->opcode >= g_upcall_op_table_size) {
        status = ERROR_NOT_SUPPORTED;
        eprintf("unrecognized upcall opcode %d!\n", upcall->opcode);
        goto out;
    }
    if (upcall->root_ref != INVALID_HANDLE_VALUE)
        nfs41_root_ref(upcall->root_ref);
    if (upcall->state_ref != INVALID_HANDLE_VALUE)
        nfs41_open_state_ref(upcall->state_ref);

    /* parse the operation's arguments */
    op = g_upcall_op_table[upcall->opcode];
    if (op && op->parse) {
        status = op->parse(buffer, length, upcall);
        if (status) {
            eprintf("parsing of upcall '%s' failed with %d.\n",
                opcode2string(upcall->opcode), status);
            goto out;
        }
    }
out:
    return status;
}

Referenced by thread_main().