ReactOS 0.4.15-dev-8428-g6910fa6
nfs41_server.c File Reference
#include <windows.h>
#include <strsafe.h>
#include <stdio.h>
#include "wintirpc.h"
#include "rpc/rpc.h"
#include "name_cache.h"
#include "daemon_debug.h"
#include "nfs41.h"
#include "util.h"
Include dependency graph for nfs41_server.c:

Go to the source code of this file.

Classes

struct  server_list
 
struct  server_info
 

Macros

#define SRVLVL   2 /* dprintf level for server logging */
 
#define server_entry(pos)   list_container(pos, nfs41_server, entry)
 

Functions

void nfs41_server_list_init ()
 
static int server_compare (const struct list_entry *entry, const void *value)
 
static int server_entry_find (IN struct server_list *servers, IN const struct server_info *info, OUT struct list_entry **entry_out)
 
static int server_create (IN const struct server_info *info, OUT nfs41_server **server_out)
 
static void server_free (IN nfs41_server *server)
 
static __inline void server_ref_locked (IN nfs41_server *server)
 
void nfs41_server_ref (IN nfs41_server *server)
 
void nfs41_server_deref (IN nfs41_server *server)
 
static void server_addrs_add (IN OUT struct server_addrs *addrs, IN const netaddr4 *addr)
 
void nfs41_server_addrs (IN nfs41_server *server, OUT multi_addr4 *addrs)
 
int nfs41_server_find_or_create (IN const char *server_owner_major_id, IN const char *server_scope, IN const netaddr4 *addr, OUT nfs41_server **server_out)
 
int nfs41_server_resolve (IN const char *hostname, IN unsigned short port, OUT multi_addr4 *addrs)
 

Variables

static struct server_list g_server_list
 

Macro Definition Documentation

◆ server_entry

#define server_entry (   pos)    list_container(pos, nfs41_server, entry)

Definition at line 45 of file nfs41_server.c.

◆ SRVLVL

#define SRVLVL   2 /* dprintf level for server logging */

Definition at line 35 of file nfs41_server.c.

Function Documentation

◆ nfs41_server_addrs()

void nfs41_server_addrs ( IN nfs41_server server,
OUT multi_addr4 addrs 
)

Definition at line 203 of file nfs41_server.c.

206{
207 struct server_addrs *saddrs = &server->addrs;
208 uint32_t i, j;
209
210 /* make a copy of the server's addrs, with most recent first */
211 AcquireSRWLockShared(&saddrs->lock);
212 j = saddrs->next_index;
213 for (i = 0; i < saddrs->addrs.count; i++) {
214 /* decrement/wrap j */
216 memcpy(&addrs->arr[i], &saddrs->addrs.arr[j], sizeof(netaddr4));
217 }
218 ReleaseSRWLockShared(&saddrs->lock);
219}
UINT32 uint32_t
Definition: types.h:75
VOID WINAPI ReleaseSRWLockShared(PSRWLOCK Lock)
Definition: sync.c:43
VOID WINAPI AcquireSRWLockShared(PSRWLOCK Lock)
Definition: sync.c:15
GLsizei GLenum const GLvoid GLsizei GLenum GLbyte GLbyte GLbyte GLdouble GLdouble GLdouble GLfloat GLfloat GLfloat GLint GLint GLint GLshort GLshort GLshort GLubyte GLubyte GLubyte GLuint GLuint GLuint GLushort GLushort GLushort GLbyte GLbyte GLbyte GLbyte GLdouble GLdouble GLdouble GLdouble GLfloat GLfloat GLfloat GLfloat GLint GLint GLint GLint GLshort GLshort GLshort GLshort GLubyte GLubyte GLubyte GLubyte GLuint GLuint GLuint GLuint GLushort GLushort GLushort GLushort GLboolean const GLdouble const GLfloat const GLint const GLshort const GLbyte const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLdouble const GLfloat const GLfloat const GLint const GLint const GLshort const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort GLenum GLenum GLenum GLfloat GLenum GLint GLenum GLenum GLenum GLfloat GLenum GLenum GLint GLenum GLfloat GLenum GLint GLint GLushort GLenum GLenum GLfloat GLenum GLenum GLint GLfloat const GLubyte GLenum GLenum GLenum const GLfloat GLenum GLenum const GLint GLenum GLint GLint GLsizei GLsizei GLint GLenum GLenum const GLvoid GLenum GLenum const GLfloat GLenum GLenum const GLint GLenum GLenum const GLdouble GLenum GLenum const GLfloat GLenum GLenum const GLint GLsizei GLuint GLfloat GLuint GLbitfield GLfloat GLint GLuint GLboolean GLenum GLfloat GLenum GLbitfield GLenum GLfloat GLfloat GLint GLint const GLfloat GLenum GLfloat GLfloat GLint GLint GLfloat GLfloat GLint GLint const GLfloat GLint GLfloat GLfloat GLint GLfloat GLfloat GLint GLfloat GLfloat const GLdouble const GLfloat const GLdouble const GLfloat GLint i
Definition: glfuncs.h:248
GLsizei GLenum const GLvoid GLsizei GLenum GLbyte GLbyte GLbyte GLdouble GLdouble GLdouble GLfloat GLfloat GLfloat GLint GLint GLint GLshort GLshort GLshort GLubyte GLubyte GLubyte GLuint GLuint GLuint GLushort GLushort GLushort GLbyte GLbyte GLbyte GLbyte GLdouble GLdouble GLdouble GLdouble GLfloat GLfloat GLfloat GLfloat GLint GLint GLint GLint GLshort GLshort GLshort GLshort GLubyte GLubyte GLubyte GLubyte GLuint GLuint GLuint GLuint GLushort GLushort GLushort GLushort GLboolean const GLdouble const GLfloat const GLint const GLshort const GLbyte const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLdouble const GLfloat const GLfloat const GLint const GLint const GLshort const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort GLenum GLenum GLenum GLfloat GLenum GLint GLenum GLenum GLenum GLfloat GLenum GLenum GLint GLenum GLfloat GLenum GLint GLint GLushort GLenum GLenum GLfloat GLenum GLenum GLint GLfloat const GLubyte GLenum GLenum GLenum const GLfloat GLenum GLenum const GLint GLenum GLint GLint GLsizei GLsizei GLint GLenum GLenum const GLvoid GLenum GLenum const GLfloat GLenum GLenum const GLint GLenum GLenum const GLdouble GLenum GLenum const GLfloat GLenum GLenum const GLint GLsizei GLuint GLfloat GLuint GLbitfield GLfloat GLint GLuint GLboolean GLenum GLfloat GLenum GLbitfield GLenum GLfloat GLfloat GLint GLint const GLfloat GLenum GLfloat GLfloat GLint GLint GLfloat GLfloat GLint GLint const GLfloat GLint GLfloat GLfloat GLint GLfloat GLfloat GLint GLfloat GLfloat const GLdouble const GLfloat const GLdouble const GLfloat GLint GLint GLint j
Definition: glfuncs.h:250
#define memcpy(s1, s2, n)
Definition: mkisofs.h:878
#define NFS41_ADDRS_PER_SERVER
Definition: nfs41_const.h:49
netaddr4 arr[NFS41_ADDRS_PER_SERVER]
Definition: nfs41_types.h:91
uint32_t count
Definition: nfs41_types.h:92
uint32_t next_index
Definition: nfs41.h:75
multi_addr4 addrs
Definition: nfs41.h:74
SRWLOCK lock
Definition: nfs41.h:76
static rfbScreenInfoPtr server
Definition: vnc.c:74

◆ nfs41_server_deref()

void nfs41_server_deref ( IN nfs41_server server)

Definition at line 155 of file nfs41_server.c.

157{
159
160 server->ref_count--;
161 dprintf(SRVLVL, "nfs41_server_deref(%s) count %d\n",
162 server->owner, server->ref_count);
163 if (server->ref_count == 0) {
164 list_remove(&server->entry);
166 }
167
169}
static void list_remove(struct list_entry *entry)
Definition: list.h:90
static void server_free(IN nfs41_server *server)
Definition: nfs41_server.c:128
#define SRVLVL
Definition: nfs41_server.c:35
static struct server_list g_server_list
Definition: nfs41_server.c:43
#define dprintf
Definition: regdump.c:33
void WINAPI LeaveCriticalSection(LPCRITICAL_SECTION)
void WINAPI EnterCriticalSection(LPCRITICAL_SECTION)

Referenced by nfs41_client_free(), and update_server().

◆ nfs41_server_find_or_create()

int nfs41_server_find_or_create ( IN const char server_owner_major_id,
IN const char server_scope,
IN const netaddr4 addr,
OUT nfs41_server **  server_out 
)

Definition at line 221 of file nfs41_server.c.

226{
227 struct server_info info;
228 struct list_entry *entry;
230 int status;
231
232 info.owner = server_owner_major_id;
233 info.scope = server_scope;
234
235 dprintf(SRVLVL, "--> nfs41_server_find_or_create(%s)\n", info.owner);
236
238
239 /* search for an existing server */
241 if (entry == NULL) {
242 /* create a new server */
244 if (status == NO_ERROR) {
245 /* add it to the list */
246 list_add_tail(&g_server_list.head, &server->entry);
247 *server_out = server;
248
249 dprintf(SRVLVL, "<-- nfs41_server_find_or_create() "
250 "returning new server %p\n", server);
251 } else {
252 dprintf(SRVLVL, "<-- nfs41_server_find_or_create() "
253 "returning %d\n", status);
254 }
255 } else {
258
259 dprintf(SRVLVL, "<-- nfs41_server_find_or_create() "
260 "returning existing server %p\n", server);
261 }
262
263 if (server) {
264 /* register the address used to connect */
265 server_addrs_add(&server->addrs, addr);
266
268 }
269
270 *server_out = server;
272 return status;
273}
static void list_add_tail(struct list_entry *head, struct list_entry *entry)
Definition: list.h:83
static struct list_entry * list_search(const struct list_entry *head, const void *value, list_compare_fn compare)
Definition: list.h:102
#define NO_ERROR
Definition: dderror.h:5
#define NULL
Definition: types.h:112
GLenum const GLvoid * addr
Definition: glext.h:9621
uint32_t entry
Definition: isohybrid.c:63
#define server_entry(pos)
Definition: nfs41_server.c:45
static __inline void server_ref_locked(IN nfs41_server *server)
Definition: nfs41_server.c:137
static void server_addrs_add(IN OUT struct server_addrs *addrs, IN const netaddr4 *addr)
Definition: nfs41_server.c:171
static int server_compare(const struct list_entry *entry, const void *value)
Definition: nfs41_server.c:75
static int server_create(IN const struct server_info *info, OUT nfs41_server **server_out)
Definition: nfs41_server.c:94
Definition: list.h:27
Definition: ps.c:97

Referenced by update_server().

◆ nfs41_server_list_init()

void nfs41_server_list_init ( )

Definition at line 48 of file nfs41_server.c.

49{
52}
static void list_init(struct list_entry *head)
Definition: list.h:51
VOID WINAPI InitializeCriticalSection(OUT LPCRITICAL_SECTION lpCriticalSection)
Definition: synch.c:751

Referenced by ServiceStart().

◆ nfs41_server_ref()

void nfs41_server_ref ( IN nfs41_server server)

Definition at line 145 of file nfs41_server.c.

◆ nfs41_server_resolve()

int nfs41_server_resolve ( IN const char hostname,
IN unsigned short  port,
OUT multi_addr4 addrs 
)

Definition at line 275 of file nfs41_server.c.

279{
281 char service[16];
282 struct addrinfo hints = { 0 }, *res, *info;
283 struct netconfig *nconf;
284 struct netbuf addr;
285 char *netid, *uaddr;
286
287 dprintf(SRVLVL, "--> nfs41_server_resolve(%s:%u)\n",
288 hostname, port);
289
290 addrs->count = 0;
291
292 StringCchPrintfA(service, 16, "%u", port);
293
294 /* request a list of tcp addrs for the given hostname,port */
295 hints.ai_family = AF_UNSPEC;
296 hints.ai_socktype = SOCK_STREAM;
297 hints.ai_protocol = IPPROTO_TCP;
298
299 if (getaddrinfo(hostname, service, &hints, &res) != 0)
300 goto out;
301
302 for (info = res; info != NULL; info = info->ai_next) {
303 /* find the appropriate entry in /etc/netconfig */
304 switch (info->ai_family) {
305 case AF_INET: netid = "tcp"; break;
306 case AF_INET6: netid = "tcp6"; break;
307 default: continue;
308 }
309
310 nconf = getnetconfigent(netid);
311 if (nconf == NULL)
312 continue;
313
314 /* convert to a transport-independent universal address */
315 addr.buf = info->ai_addr;
316 addr.maxlen = addr.len = (unsigned int)info->ai_addrlen;
317
318 uaddr = taddr2uaddr(nconf, &addr);
319 freenetconfigent(nconf);
320
321 if (uaddr == NULL)
322 continue;
323
324 StringCchCopyA(addrs->arr[addrs->count].netid,
325 NFS41_NETWORK_ID_LEN+1, netid);
326 StringCchCopyA(addrs->arr[addrs->count].uaddr,
327 NFS41_UNIVERSAL_ADDR_LEN+1, uaddr);
328 freeuaddr(uaddr);
329
331 if (++addrs->count >= NFS41_ADDRS_PER_SERVER)
332 break;
333 }
335out:
336 if (status)
337 dprintf(SRVLVL, "<-- nfs41_server_resolve(%s:%u) returning "
338 "error %d\n", hostname, port, status);
339 else
340 dprintf(SRVLVL, "<-- nfs41_server_resolve(%s:%u) returning "
341 "%s\n", hostname, port, addrs->arr[0].uaddr);
342 return status;
343}
char * hostname
Definition: ftp.c:88
USHORT port
Definition: uri.c:228
unsigned int(__cdecl typeof(jpeg_read_scanlines))(struct jpeg_decompress_struct *
Definition: typeof.h:31
#define IPPROTO_TCP
Definition: ip.h:196
#define SOCK_STREAM
Definition: tcpip.h:118
#define AF_INET
Definition: tcpip.h:117
void freenetconfigent(struct netconfig *netconfigp)
Definition: getnetconfig.c:530
struct netconfig * getnetconfigent(char *netid) const
Definition: getnetconfig.c:432
GLuint res
Definition: glext.h:9613
#define NFS41_UNIVERSAL_ADDR_LEN
Definition: nfs41_const.h:53
#define NFS41_NETWORK_ID_LEN
Definition: nfs41_const.h:56
static FILE * out
Definition: regtests2xml.c:44
char * taddr2uaddr(const struct netconfig *nconf, const struct netbuf *nbuf)
Definition: rpc_generic.c:609
void freeuaddr(char *uaddr)
Definition: rpc_generic.c:628
namespace GUID const ADDRINFOEXW * hints
Definition: sock.c:80
STRSAFEAPI StringCchCopyA(STRSAFE_LPSTR pszDest, size_t cchDest, STRSAFE_LPCSTR pszSrc)
Definition: strsafe.h:145
STRSAFEAPI StringCchPrintfA(STRSAFE_LPSTR pszDest, size_t cchDest, STRSAFE_LPCSTR pszFormat,...)
Definition: strsafe.h:520
Definition: types.h:144
#define ERROR_BAD_NET_NAME
Definition: winerror.h:159
#define AF_INET6
Definition: winsock.h:369
#define AF_UNSPEC
Definition: winsock.h:344
#define getaddrinfo
Definition: wspiapi.h:44
#define freeaddrinfo
Definition: wspiapi.h:46

Referenced by handle_mount(), and referral_mount_location().

◆ server_addrs_add()

static void server_addrs_add ( IN OUT struct server_addrs addrs,
IN const netaddr4 addr 
)
static

Definition at line 171 of file nfs41_server.c.

174{
175 /* we keep a list of addrs used to connect to each server. once it gets
176 * bigger than NFS41_ADDRS_PER_SERVER, overwrite the oldest addrs. use
177 * server_addrs.next_index to implement a circular array */
178
179 AcquireSRWLockExclusive(&addrs->lock);
180
181 if (multi_addr_find(&addrs->addrs, addr, NULL)) {
182 dprintf(SRVLVL, "server_addrs_add() found existing addr '%s'.\n",
183 addr->uaddr);
184 } else {
185 /* overwrite the address at 'next_index' */
186 StringCchCopyA(addrs->addrs.arr[addrs->next_index].netid,
187 NFS41_NETWORK_ID_LEN+1, addr->netid);
188 StringCchCopyA(addrs->addrs.arr[addrs->next_index].uaddr,
190
191 /* increment/wrap next_index */
192 addrs->next_index = (addrs->next_index + 1) % NFS41_ADDRS_PER_SERVER;
193 /* update addrs.count if necessary */
194 if (addrs->addrs.count < addrs->next_index)
195 addrs->addrs.count = addrs->next_index;
196
197 dprintf(SRVLVL, "server_addrs_add() added new addr '%s'.\n",
198 addr->uaddr);
199 }
200 ReleaseSRWLockExclusive(&addrs->lock);
201}
bool_t multi_addr_find(IN const multi_addr4 *addrs, IN const netaddr4 *addr, OUT OPTIONAL uint32_t *index_out)
Definition: util.c:218
VOID WINAPI AcquireSRWLockExclusive(PSRWLOCK Lock)
Definition: sync.c:8
VOID WINAPI ReleaseSRWLockExclusive(PSRWLOCK Lock)
Definition: sync.c:36

Referenced by nfs41_server_find_or_create().

◆ server_compare()

static int server_compare ( const struct list_entry entry,
const void value 
)
static

Definition at line 75 of file nfs41_server.c.

78{
80 const struct server_info *info = (const struct server_info*)value;
81 const int diff = strncmp(server->scope, info->scope, NFS4_OPAQUE_LIMIT);
82 return diff ? diff : strncmp(server->owner, info->owner, NFS4_OPAQUE_LIMIT);
83}
int strncmp(const char *String1, const char *String2, ACPI_SIZE Count)
Definition: utclib.c:534
#define NFS4_OPAQUE_LIMIT
Definition: nfs41_const.h:31
Definition: pdh_main.c:94

Referenced by nfs41_server_find_or_create(), and server_entry_find().

◆ server_create()

static int server_create ( IN const struct server_info info,
OUT nfs41_server **  server_out 
)
static

Definition at line 94 of file nfs41_server.c.

97{
98 int status = NO_ERROR;
100
101 server = calloc(1, sizeof(nfs41_server));
102 if (server == NULL) {
104 eprintf("failed to allocate server %s\n", info->owner);
105 goto out;
106 }
107
110 InitializeSRWLock(&server->addrs.lock);
111 nfs41_superblock_list_init(&server->superblocks);
112
113 status = nfs41_name_cache_create(&server->name_cache);
114 if (status) {
115 eprintf("nfs41_name_cache_create() failed with %d\n", status);
116 goto out_free;
117 }
118out:
119 *server_out = server;
120 return status;
121
122out_free:
123 free(server);
124 server = NULL;
125 goto out;
126}
void eprintf(LPCSTR format,...)
Definition: daemon_debug.c:86
#define free
Definition: debug_ros.c:5
VOID WINAPI InitializeSRWLock(PSRWLOCK Lock)
Definition: sync.c:29
int nfs41_name_cache_create(OUT struct nfs41_name_cache **cache_out)
Definition: name_cache.c:752
void nfs41_superblock_list_init(IN nfs41_superblock_list *superblocks)
#define calloc
Definition: rosglue.h:14
DWORD WINAPI GetLastError(void)
Definition: except.c:1042

Referenced by nfs41_server_find_or_create().

◆ server_entry_find()

static int server_entry_find ( IN struct server_list servers,
IN const struct server_info info,
OUT struct list_entry **  entry_out 
)
static

Definition at line 85 of file nfs41_server.c.

89{
90 *entry_out = list_search(&servers->head, info, server_compare);
91 return *entry_out ? NO_ERROR : ERROR_FILE_NOT_FOUND;
92}
#define ERROR_FILE_NOT_FOUND
Definition: disk.h:79

◆ server_free()

static void server_free ( IN nfs41_server server)
static

Definition at line 128 of file nfs41_server.c.

130{
131 dprintf(SRVLVL, "server_free(%s)\n", server->owner);
132 nfs41_superblock_list_free(&server->superblocks);
133 nfs41_name_cache_free(&server->name_cache);
134 free(server);
135}
int nfs41_name_cache_free(IN struct nfs41_name_cache **cache_out)
Definition: name_cache.c:796
void nfs41_superblock_list_free(IN nfs41_superblock_list *superblocks)

Referenced by nfs41_server_deref().

◆ server_ref_locked()

static __inline void server_ref_locked ( IN nfs41_server server)
static

Definition at line 137 of file nfs41_server.c.

139{
140 server->ref_count++;
141 dprintf(SRVLVL, "nfs41_server_ref(%s) count %d\n",
142 server->owner, server->ref_count);
143}

Referenced by nfs41_server_find_or_create(), and nfs41_server_ref().

Variable Documentation

◆ g_server_list