ReactOS 0.4.15-dev-8419-g7f0e8a3
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

◆ getacl_upcall_args

◆ getattr_upcall_args

◆ getexattr_upcall_args

◆ lock_upcall_args

◆ mount_upcall_args

◆ nfs41_upcall

◆ nfs41_upcall_op

◆ open_upcall_args

◆ readdir_upcall_args

◆ readwrite_upcall_args

◆ setacl_upcall_args

◆ setattr_upcall_args

◆ setexattr_upcall_args

◆ symlink_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

Function Documentation

◆ upcall_cancel()

void upcall_cancel ( IN nfs41_upcall upcall)

Definition at line 189 of file upcall.c.

191{
192 const nfs41_upcall_op *op = g_upcall_op_table[upcall->opcode];
193 if (op && op->cancel)
194 op->cancel(upcall);
195}
UINT op
Definition: effect.c:236
nfs41_updowncall_list upcall
Definition: nfs41_driver.c:273
static const nfs41_upcall_op * g_upcall_op_table[]
Definition: upcall.c:48

Referenced by thread_main().

◆ upcall_cleanup()

void upcall_cleanup ( IN nfs41_upcall upcall)

Definition at line 197 of file upcall.c.

199{
200 const nfs41_upcall_op *op = g_upcall_op_table[upcall->opcode];
201 if (op && op->cleanup && upcall->status != NFSD_VERSION_MISMATCH)
202 op->cleanup(upcall);
203
204 if (upcall->state_ref && upcall->state_ref != INVALID_HANDLE_VALUE) {
205 nfs41_open_state_deref(upcall->state_ref);
206 upcall->state_ref = NULL;
207 }
208 if (upcall->root_ref && upcall->root_ref != INVALID_HANDLE_VALUE) {
209 nfs41_root_deref(upcall->root_ref);
210 upcall->root_ref = NULL;
211 }
212}
#define NULL
Definition: types.h:112
#define INVALID_HANDLE_VALUE
Definition: compat.h:731
void nfs41_root_deref(IN nfs41_root *root)
Definition: namespace.c:100
void nfs41_open_state_deref(IN nfs41_open_state *state)
Definition: open.c:104
#define NFSD_VERSION_MISMATCH
Definition: upcall.h:28

Referenced by thread_main().

◆ upcall_handle()

int upcall_handle ( IN nfs41_upcall upcall)

Definition at line 138 of file upcall.c.

140{
141 int status = NO_ERROR;
142 const nfs41_upcall_op *op;
143
144 op = g_upcall_op_table[upcall->opcode];
145 if (op == NULL || op->handle == NULL) {
147 eprintf("upcall '%s' missing handle function!\n",
148 opcode2string(upcall->opcode));
149 goto out;
150 }
151
152 upcall->status = op->handle(upcall);
153out:
154 return status;
155}
void eprintf(LPCSTR format,...)
Definition: daemon_debug.c:86
const char * opcode2string(DWORD opcode)
Definition: daemon_debug.c:280
#define NO_ERROR
Definition: dderror.h:5
#define ERROR_NOT_SUPPORTED
Definition: compat.h:100
static FILE * out
Definition: regtests2xml.c:44
Definition: ps.c:97

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.

162{
163 const nfs41_upcall_op *op;
164 unsigned char *orig_buf = buffer;
165 const uint32_t total = length, orig_len = length;
166
167 /* marshall common elements */
168write_downcall:
169 length = orig_len;
170 buffer = orig_buf;
171 safe_write(&buffer, &length, &upcall->xid, sizeof(upcall->xid));
172 safe_write(&buffer, &length, &upcall->opcode, sizeof(upcall->opcode));
173 safe_write(&buffer, &length, &upcall->status, sizeof(upcall->status));
174 safe_write(&buffer, &length, &upcall->last_error, sizeof(upcall->last_error));
175
176 if (upcall->status)
177 goto out;
178
179 /* marshall the operation's results */
180 op = g_upcall_op_table[upcall->opcode];
181 if (op && op->marshall) {
182 if ((upcall->status = op->marshall(buffer, &length, upcall)))
183 goto write_downcall;
184 }
185out:
186 *length_out = total - length;
187}
int safe_write(unsigned char **pos, uint32_t *remaining, void *src, uint32_t src_len)
Definition: util.c:44
UINT32 uint32_t
Definition: types.h:75
size_t total
GLuint buffer
Definition: glext.h:5915
GLuint GLsizei GLsizei * length
Definition: glext.h:6040

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.

79{
80 int status;
81 const nfs41_upcall_op *op;
83
85 if (!length) {
86 eprintf("empty upcall\n");
87 upcall->status = status = 102;
88 goto out;
89 }
90
91 dprintf(2, "received %d bytes upcall data: processing upcall\n", length);
92 print_hexbuf(4, (unsigned char *)"upcall buffer: ", buffer, length);
93
94 /* parse common elements */
96 if (status) goto out;
97 status = safe_read(&buffer, &length, &upcall->xid, sizeof(uint64_t));
98 if (status) goto out;
99 status = safe_read(&buffer, &length, &upcall->opcode, sizeof(uint32_t));
100 if (status) goto out;
101 status = safe_read(&buffer, &length, &upcall->root_ref, sizeof(HANDLE));
102 if (status) goto out;
103 status = safe_read(&buffer, &length, &upcall->state_ref, sizeof(HANDLE));
104 if (status) goto out;
105
106 dprintf(2, "time=%ld version=%d xid=%d opcode=%s session=0x%x open_state=0x%x\n",
107 time(NULL), version, upcall->xid, opcode2string(upcall->opcode), upcall->root_ref,
108 upcall->state_ref);
109 if (version != NFS41D_VERSION) {
110 eprintf("received version %d expecting version %d\n", version, NFS41D_VERSION);
112 goto out;
113 }
114 if (upcall->opcode >= g_upcall_op_table_size) {
116 eprintf("unrecognized upcall opcode %d!\n", upcall->opcode);
117 goto out;
118 }
119 if (upcall->root_ref != INVALID_HANDLE_VALUE)
120 nfs41_root_ref(upcall->root_ref);
121 if (upcall->state_ref != INVALID_HANDLE_VALUE)
122 nfs41_open_state_ref(upcall->state_ref);
123
124 /* parse the operation's arguments */
125 op = g_upcall_op_table[upcall->opcode];
126 if (op && op->parse) {
127 status = op->parse(buffer, length, upcall);
128 if (status) {
129 eprintf("parsing of upcall '%s' failed with %d.\n",
130 opcode2string(upcall->opcode), status);
131 goto out;
132 }
133 }
134out:
135 return status;
136}
int safe_read(unsigned char **pos, uint32_t *remaining, void *dest, uint32_t dest_len)
Definition: util.c:33
void print_hexbuf(int level, unsigned char *title, unsigned char *buf, int len)
Definition: daemon_debug.c:98
UINT64 uint64_t
Definition: types.h:77
static const WCHAR version[]
Definition: asmname.c:66
unsigned long DWORD
Definition: ntddk_ex.h:95
__u16 time
Definition: mkdosfs.c:8
void nfs41_root_ref(IN nfs41_root *root)
Definition: namespace.c:92
void nfs41_open_state_ref(IN nfs41_open_state *state)
Definition: open.c:96
DWORD NFS41D_VERSION
Definition: nfs41_daemon.c:42
#define dprintf
Definition: regdump.c:33
static const uint32_t g_upcall_op_table_size
Definition: upcall.c:72
#define ZeroMemory
Definition: winbase.h:1712

Referenced by thread_main().