Windows: invalidate data version on link creation
[openafs.git] / src / WINNT / afsd / cm_ioctl.c
1 /*
2  * Copyright 2000, International Business Machines Corporation and others.
3  * All Rights Reserved.
4  *
5  * This software has been released under the terms of the IBM Public
6  * License.  For details, see the LICENSE file in the top-level source
7  * directory or online at http://www.openafs.org/dl/license10.html
8  */
9
10 #include <afsconfig.h>
11 #include <afs/param.h>
12 #include <roken.h>
13
14 #include <afs/stds.h>
15 #include <afs/cellconfig.h>
16 #include <afs/afs_consts.h>
17 #include <afs/ptserver.h>
18 #include <ubik.h>
19
20 #include <windows.h>
21 #include <errno.h>
22 #include <stdlib.h>
23 #include <malloc.h>
24 #include <string.h>
25 #include <stdio.h>
26 #include <time.h>
27
28 #include <osi.h>
29
30 #include "afsd.h"
31 #include "afsd_init.h"
32 #include <WINNT\afsreg.h>
33
34 #include "smb.h"
35
36 #include <rx/rxkad.h>
37 #include "afsrpc.h"
38
39 #include "cm_rpc.h"
40 #include <strsafe.h>
41 #include <winioctl.h>
42 #include <rx\rx.h>
43
44 #include "cm_btree.h"
45
46 #ifdef _DEBUG
47 #include <crtdbg.h>
48 #endif
49
50 /* Copied from afs_tokens.h */
51 #define PIOCTL_LOGON    0x1
52 #define MAX_PATH 260
53
54 const char utf8_prefix[] = UTF8_PREFIX;
55 const int  utf8_prefix_size = sizeof(utf8_prefix) -  sizeof(char);
56
57 osi_mutex_t cm_Afsdsbmt_Lock;
58
59 extern afs_int32 cryptall;
60 extern char cm_NetbiosName[];
61 extern clientchar_t cm_NetbiosNameC[];
62
63 extern void afsi_log(char *pattern, ...);
64
65 void cm_InitIoctl(void)
66 {
67     lock_InitializeMutex(&cm_Afsdsbmt_Lock, "AFSDSBMT.INI Access Lock",
68                           LOCK_HIERARCHY_AFSDBSBMT_GLOBAL);
69 }
70
71 /*
72  * Utility function.  (Not currently in use.)
73  * This function forces all dirty buffers to the file server and
74  * then discards the status info.
75  */
76 afs_int32
77 cm_CleanFile(cm_scache_t *scp, cm_user_t *userp, cm_req_t *reqp)
78 {
79     long code;
80
81     if (RDR_Initialized &&
82         RDR_InvalidateObject(scp->fid.cell, scp->fid.volume, scp->fid.vnode, scp->fid.unique,
83                              scp->fid.hash, scp->fileType, AFS_INVALIDATE_FLUSHED))
84         code = CM_ERROR_WOULDBLOCK;
85     else
86         code = cm_FSync(scp, userp, reqp, FALSE);
87     if (!code) {
88         lock_ObtainWrite(&scp->rw);
89         cm_DiscardSCache(scp);
90         lock_ReleaseWrite(&scp->rw);
91     }
92     osi_Log2(afsd_logp,"cm_CleanFile scp 0x%x returns error: [%x]",scp, code);
93     return code;
94 }
95
96 /*
97  * Utility function.  Used within this file.
98  * scp must be held but not locked.
99  */
100 afs_int32
101 cm_FlushFile(cm_scache_t *scp, cm_user_t *userp, cm_req_t *reqp)
102 {
103     afs_int32 code;
104
105 #ifdef AFS_FREELANCE_CLIENT
106     if ( scp->fid.cell == AFS_FAKE_ROOT_CELL_ID && scp->fid.volume == AFS_FAKE_ROOT_VOL_ID ) {
107         cm_noteLocalMountPointChange(FALSE);
108         return 0;
109     }
110 #endif
111
112     /*
113      * The file system will forget all knowledge of the object
114      * when it receives this message.
115      */
116     if (RDR_Initialized &&
117         RDR_InvalidateObject(scp->fid.cell, scp->fid.volume, scp->fid.vnode, scp->fid.unique,
118                              scp->fid.hash, scp->fileType, AFS_INVALIDATE_FLUSHED))
119         code = CM_ERROR_WOULDBLOCK;
120     else
121         code = buf_FlushCleanPages(scp, userp, reqp);
122
123     if (scp->fileType == CM_SCACHETYPE_DIRECTORY)
124         lock_ObtainWrite(&scp->dirlock);
125     lock_ObtainWrite(&scp->rw);
126     cm_DiscardSCache(scp);
127     if (scp->fileType == CM_SCACHETYPE_DIRECTORY) {
128         cm_ResetSCacheDirectory(scp, 1);
129         lock_ReleaseWrite(&scp->dirlock);
130     }
131     lock_ReleaseWrite(&scp->rw);
132
133     osi_Log2(afsd_logp,"cm_FlushFile scp 0x%x returns error: [%x]",scp, code);
134     return code;
135 }
136
137 /*
138  * Utility function.  (Not currently in use)
139  * IoctlPath must be parsed or skipped prior to calling.
140  * scp must be held but not locked.
141  */
142 afs_int32
143 cm_FlushParent(cm_scache_t *scp, cm_user_t *userp, cm_req_t *reqp)
144 {
145     afs_int32 code = 0;
146     cm_scache_t * pscp;
147
148     pscp = cm_FindSCacheParent(scp);
149
150     /* now flush the file */
151     code = cm_FlushFile(pscp, userp, reqp);
152     cm_ReleaseSCache(pscp);
153
154     return code;
155 }
156
157 /*
158  * Utility function.  Used within this function.
159  */
160 afs_int32
161 cm_FlushVolume(cm_user_t *userp, cm_req_t *reqp, afs_uint32 cell, afs_uint32 volume)
162 {
163     afs_int32 code = 0;
164     cm_scache_t *scp;
165     unsigned int i;
166
167 #ifdef AFS_FREELANCE_CLIENT
168     if ( cell == AFS_FAKE_ROOT_CELL_ID && volume == AFS_FAKE_ROOT_VOL_ID ) {
169         cm_noteLocalMountPointChange(FALSE);
170         return 0;
171     }
172 #endif
173
174     lock_ObtainWrite(&cm_scacheLock);
175     for (i=0; i<cm_data.scacheHashTableSize; i++) {
176         for (scp = cm_data.scacheHashTablep[i]; scp; scp = scp->nextp) {
177             if (scp->fid.volume == volume && scp->fid.cell == cell) {
178                 cm_HoldSCacheNoLock(scp);
179                 lock_ReleaseWrite(&cm_scacheLock);
180
181                 /* now flush the file */
182                 code = cm_FlushFile(scp, userp, reqp);
183                 lock_ObtainWrite(&cm_scacheLock);
184                 cm_ReleaseSCacheNoLock(scp);
185             }
186         }
187     }
188     lock_ReleaseWrite(&cm_scacheLock);
189
190     return code;
191 }
192
193 /*
194  *  TranslateExtendedChars - This is a fix for TR 54482.
195  *
196  *  If an extended character (80 - FF) is entered into a file
197  *  or directory name in Windows, the character is translated
198  *  into the OEM character map before being passed to us.
199  *  The pioctl functions must match
200  *  this translation for paths given via our own commands (like
201  *  fs).  If we do not do this, then we will try to perform an
202  *  operation on a non-translated path, which we will fail to
203  *  find, since the path was created with the translated chars.
204  *  This function performs the required translation.
205  *
206  *  OEM character code pages are used by the non-Unicode SMB
207  *  mode.  Do not use if the CM_IOCTLFLAG_USEUTF8 is set.
208  */
209 void
210 TranslateExtendedChars(char *str)
211 {
212     if (!str || !*str)
213         return;
214
215     CharToOemA(str, str);
216 }
217
218 void cm_SkipIoctlPath(cm_ioctl_t *ioctlp)
219 {
220     size_t temp;
221
222     temp = strlen(ioctlp->inDatap) + 1;
223     ioctlp->inDatap += temp;
224 }
225
226
227 clientchar_t * cm_ParseIoctlStringAlloc(cm_ioctl_t *ioctlp, const char * ext_instrp)
228 {
229     clientchar_t * rs = NULL;
230     const char * instrp;
231
232     instrp = (ext_instrp)?ext_instrp:ioctlp->inDatap;
233
234     if ((ioctlp->flags & CM_IOCTLFLAG_USEUTF8) == CM_IOCTLFLAG_USEUTF8) {
235         rs = cm_Utf8ToClientStringAlloc(instrp, -1, NULL);
236     } else {
237         int cch;
238
239         /* Not a UTF-8 string */
240         if (smb_StoreAnsiFilenames) {
241             cch = cm_AnsiToClientString(instrp, -1, NULL, 0);
242 #ifdef DEBUG
243             osi_assert(cch > 0);
244 #endif
245             rs = malloc(cch * sizeof(clientchar_t));
246             cm_AnsiToClientString(instrp, -1, rs, cch);
247         } else {
248             cch = cm_OemToClientString(instrp, -1, NULL, 0);
249 #ifdef DEBUG
250             osi_assert(cch > 0);
251 #endif
252             rs = malloc(cch * sizeof(clientchar_t));
253             cm_OemToClientString(instrp, -1, rs, cch);
254         }
255     }
256
257     if (ext_instrp == NULL) {
258         ioctlp->inDatap += strlen(ioctlp->inDatap) + 1;
259     }
260     return rs;
261 }
262
263 int cm_UnparseIoctlString(cm_ioctl_t *ioctlp,
264                           char * ext_outp,
265                           const clientchar_t * cstr, int cchlen)
266 {
267     char *outp;
268     int cchout;
269
270     outp = ((ext_outp == NULL)? ioctlp->outDatap : ext_outp);
271
272     if ((ioctlp->flags & CM_IOCTLFLAG_USEUTF8) == CM_IOCTLFLAG_USEUTF8) {
273         cchout = cm_ClientStringToUtf8(cstr, cchlen, outp,
274                                        (int)(SMB_IOCTL_MAXDATA - (outp - ioctlp->outAllocp)));
275     } else {
276         if (smb_StoreAnsiFilenames) {
277             cchout = WideCharToMultiByte(CP_ACP, 0, cstr, cchlen,
278                                          outp,
279                                          (int)(SMB_IOCTL_MAXDATA - (outp - ioctlp->outAllocp)),
280                                          NULL, NULL);
281         } else {
282             cchout = WideCharToMultiByte(CP_OEMCP, 0, cstr, cchlen,
283                                          outp,
284                                          (int)(SMB_IOCTL_MAXDATA - (outp - ioctlp->outAllocp)),
285                                          NULL, NULL);
286         }
287     }
288
289     if (cchout > 0 && ext_outp == NULL) {
290         ioctlp->outDatap += cchout;
291     }
292
293     return cchout;
294 }
295
296 /*
297  * Must be called before XXX_ParseIoctlPath or cm_SkipIoctlPath
298  */
299 cm_ioctlQueryOptions_t *
300 cm_IoctlGetQueryOptions(struct cm_ioctl *ioctlp, struct cm_user *userp)
301 {
302     afs_uint32 pathlen = (afs_uint32) strlen(ioctlp->inDatap) + 1;
303     char *p = ioctlp->inDatap + pathlen;
304     cm_ioctlQueryOptions_t * optionsp = NULL;
305
306     if (ioctlp->inCopied > p - ioctlp->inAllocp) {
307         optionsp = (cm_ioctlQueryOptions_t *)p;
308         if (optionsp->size < 12 /* minimum size of struct */)
309             optionsp = NULL;
310     }
311
312     return optionsp;
313 }
314
315 /*
316  * Must be called after smb_ParseIoctlPath or cm_SkipIoctlPath
317  * or any other time that ioctlp->inDatap points at the
318  * cm_ioctlQueryOptions_t object.
319  */
320 void
321 cm_IoctlSkipQueryOptions(struct cm_ioctl *ioctlp, struct cm_user *userp)
322 {
323     cm_ioctlQueryOptions_t * optionsp = (cm_ioctlQueryOptions_t *)ioctlp->inDatap;
324     ioctlp->inDatap += optionsp->size;
325     ioctlp->inCopied -= optionsp->size;
326 }
327
328 /* format the specified path to look like "/afs/<cellname>/usr", by
329  * adding "/afs" (if necessary) in front, changing any \'s to /'s, and
330  * removing any trailing "/"'s. One weirdo caveat: "/afs" will be
331  * intentionally returned as "/afs/"--this makes submount manipulation
332  * easier (because we can always jump past the initial "/afs" to find
333  * the AFS path that should be written into afsdsbmt.ini).
334  */
335 void
336 cm_NormalizeAfsPath(clientchar_t *outpathp, long cchlen, clientchar_t *inpathp)
337 {
338     clientchar_t *cp;
339     clientchar_t bslash_mountRoot[256];
340
341     cm_ClientStrCpy(bslash_mountRoot, lengthof(bslash_mountRoot), cm_mountRootC);
342     bslash_mountRoot[0] = '\\';
343
344     if (!cm_ClientStrCmpNI(inpathp, cm_mountRootC, cm_mountRootCLen))
345         cm_ClientStrCpy(outpathp, cchlen, inpathp);
346     else if (!cm_ClientStrCmpNI(inpathp, bslash_mountRoot,
347                                 (int)cm_ClientStrLen(bslash_mountRoot)))
348         cm_ClientStrCpy(outpathp, cchlen, inpathp);
349     else if ((inpathp[0] == '/') || (inpathp[0] == '\\'))
350         cm_ClientStrPrintfN(outpathp, cchlen, _C("%s%s"), cm_mountRootC, inpathp);
351     else // inpathp looks like "<cell>/usr"
352         cm_ClientStrPrintfN(outpathp, cchlen, _C("%s/%s"), cm_mountRootC, inpathp);
353
354     for (cp = outpathp; *cp != 0; ++cp) {
355         if (*cp == '\\')
356             *cp = '/';
357     }
358
359     if (cm_ClientStrLen(outpathp) && (outpathp[cm_ClientStrLen(outpathp)-1] == '/')) {
360         outpathp[cm_ClientStrLen(outpathp)-1] = 0;
361     }
362
363     if (!cm_ClientStrCmpI(outpathp, cm_mountRootC)) {
364         cm_ClientStrCpy(outpathp, cchlen, cm_mountRootC);
365     }
366 }
367
368 void cm_NormalizeAfsPathAscii(char *outpathp, long outlen, char *inpathp)
369 {
370     char *cp;
371     char bslash_mountRoot[256];
372
373     strncpy(bslash_mountRoot, cm_mountRoot, sizeof(bslash_mountRoot) - 1);
374     bslash_mountRoot[0] = '\\';
375
376     if (!strnicmp (inpathp, cm_mountRoot, strlen(cm_mountRoot)))
377         StringCbCopy(outpathp, outlen, inpathp);
378     else if (!strnicmp (inpathp, bslash_mountRoot, strlen(bslash_mountRoot)))
379         StringCbCopy(outpathp, outlen, inpathp);
380     else if ((inpathp[0] == '/') || (inpathp[0] == '\\'))
381         StringCbPrintfA(outpathp, outlen, "%s%s", cm_mountRoot, inpathp);
382     else // inpathp looks like "<cell>/usr"
383         StringCbPrintfA(outpathp, outlen, "%s/%s", cm_mountRoot, inpathp);
384
385     for (cp = outpathp; *cp != 0; ++cp) {
386         if (*cp == '\\')
387             *cp = '/';
388     }
389
390     if (strlen(outpathp) && (outpathp[strlen(outpathp)-1] == '/')) {
391         outpathp[strlen(outpathp)-1] = 0;
392     }
393
394     if (!_stricmp (outpathp, cm_mountRoot)) {
395         StringCbCopy(outpathp, outlen, cm_mountRoot);
396     }
397 }
398
399
400 /*
401  * VIOCGETAL internals.
402  *
403  * Assumes that pioctl path has been parsed or skipped.
404  * scp is held but not locked.
405  */
406 afs_int32
407 cm_IoctlGetACL(cm_ioctl_t *ioctlp, cm_user_t *userp, cm_scache_t *scp, cm_req_t *reqp)
408 {
409     afs_int32 code;
410     cm_conn_t *connp;
411     AFSOpaque acl;
412     AFSFetchStatus fileStatus;
413     AFSVolSync volSync;
414     AFSFid afid;
415     int tlen;
416     struct rx_connection * rxconnp;
417
418     memset(&volSync, 0, sizeof(volSync));
419
420     /* now make the get acl call */
421 #ifdef AFS_FREELANCE_CLIENT
422     if ( scp->fid.cell == AFS_FAKE_ROOT_CELL_ID && scp->fid.volume == AFS_FAKE_ROOT_VOL_ID ) {
423         code = 0;
424         ioctlp->outDatap[0] ='\0';
425     } else
426 #endif
427     {
428         afid.Volume = scp->fid.volume;
429         afid.Vnode = scp->fid.vnode;
430         afid.Unique = scp->fid.unique;
431         do {
432             acl.AFSOpaque_val = ioctlp->outDatap;
433             acl.AFSOpaque_len = 0;
434             code = cm_ConnFromFID(&scp->fid, userp, reqp, &connp);
435             if (code)
436                 continue;
437
438             rxconnp = cm_GetRxConn(connp);
439             code = RXAFS_FetchACL(rxconnp, &afid, &acl, &fileStatus, &volSync);
440             rx_PutConnection(rxconnp);
441
442         } while (cm_Analyze(connp, userp, reqp, &scp->fid, 0, &volSync, NULL, NULL, code));
443         code = cm_MapRPCError(code, reqp);
444
445         if (code)
446             return code;
447     }
448     /* skip over return data */
449     tlen = (int)strlen(ioctlp->outDatap) + 1;
450     ioctlp->outDatap += tlen;
451
452     /* and return success */
453     return 0;
454 }
455
456
457 /*
458  * VIOC_FILE_CELL_NAME internals.
459  *
460  * Assumes that pioctl path has been parsed or skipped.
461  * scp is held but not locked.
462  */
463 afs_int32
464 cm_IoctlGetFileCellName(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *scp, cm_req_t *reqp)
465 {
466     afs_int32 code;
467     cm_cell_t *cellp;
468
469 #ifdef AFS_FREELANCE_CLIENT
470     if ( cm_freelanceEnabled &&
471          scp->fid.cell==AFS_FAKE_ROOT_CELL_ID &&
472          scp->fid.volume==AFS_FAKE_ROOT_VOL_ID &&
473          scp->fid.vnode==0x1 && scp->fid.unique==0x1 ) {
474         StringCbCopyA(ioctlp->outDatap, SMB_IOCTL_MAXDATA - (ioctlp->outDatap - ioctlp->outAllocp), "Freelance.Local.Root");
475         ioctlp->outDatap += strlen(ioctlp->outDatap) + 1;
476         code = 0;
477     } else
478 #endif /* AFS_FREELANCE_CLIENT */
479     {
480         cellp = cm_FindCellByID(scp->fid.cell, CM_FLAG_NOPROBE);
481         if (cellp) {
482             clientchar_t * cellname;
483
484             cellname = cm_FsStringToClientStringAlloc(cellp->name, -1, NULL);
485             if (cellname == NULL) {
486                 code = CM_ERROR_NOSUCHCELL;
487             } else {
488                 cm_UnparseIoctlString(ioctlp, NULL, cellname, -1);
489                 free(cellname);
490                 code = 0;
491             }
492         } else
493             code = CM_ERROR_NOSUCHCELL;
494     }
495
496     return code;
497 }
498
499
500 /*
501  * VIOCSETAL internals.
502  *
503  * Assumes that pioctl path has been parsed or skipped.
504  * scp is held but not locked.
505  */
506 afs_int32
507 cm_IoctlSetACL(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *scp, cm_req_t *reqp)
508 {
509     afs_int32 code;
510     cm_conn_t *connp;
511     AFSOpaque acl;
512     AFSFetchStatus fileStatus;
513     AFSVolSync volSync;
514     AFSFid fid;
515     struct rx_connection * rxconnp;
516
517     memset(&volSync, 0, sizeof(volSync));
518
519 #ifdef AFS_FREELANCE_CLIENT
520     if ( scp->fid.cell == AFS_FAKE_ROOT_CELL_ID && scp->fid.volume == AFS_FAKE_ROOT_VOL_ID ) {
521         code = CM_ERROR_NOACCESS;
522     } else
523 #endif
524     {
525         /* now make the get acl call */
526         fid.Volume = scp->fid.volume;
527         fid.Vnode = scp->fid.vnode;
528         fid.Unique = scp->fid.unique;
529         do {
530             acl.AFSOpaque_val = ioctlp->inDatap;
531             acl.AFSOpaque_len = (u_int)strlen(ioctlp->inDatap)+1;
532             code = cm_ConnFromFID(&scp->fid, userp, reqp, &connp);
533             if (code)
534                 continue;
535
536             rxconnp = cm_GetRxConn(connp);
537             code = RXAFS_StoreACL(rxconnp, &fid, &acl, &fileStatus, &volSync);
538             rx_PutConnection(rxconnp);
539
540         } while (cm_Analyze(connp, userp, reqp, &scp->fid, 1, &volSync, NULL, NULL, code));
541         code = cm_MapRPCError(code, reqp);
542
543         /* invalidate cache info, since we just trashed the ACL cache */
544         lock_ObtainWrite(&scp->rw);
545         cm_DiscardSCache(scp);
546         lock_ReleaseWrite(&scp->rw);
547
548         if (RDR_Initialized)
549             RDR_InvalidateObject(scp->fid.cell, scp->fid.volume, scp->fid.vnode, scp->fid.unique,
550                                  scp->fid.hash, scp->fileType, AFS_INVALIDATE_CREDS);
551     }
552
553     return code;
554 }
555
556 /*
557  * VIOC_FLUSHALL internals.
558  *
559  * Assumes that pioctl path has been parsed or skipped.
560  */
561 afs_int32
562 cm_IoctlFlushAllVolumes(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_req_t *reqp)
563 {
564     afs_int32 code;
565     cm_scache_t *scp;
566     unsigned int i;
567
568     lock_ObtainWrite(&cm_scacheLock);
569     for (i=0; i<cm_data.scacheHashTableSize; i++) {
570         for (scp = cm_data.scacheHashTablep[i]; scp; scp = scp->nextp) {
571             cm_HoldSCacheNoLock(scp);
572             lock_ReleaseWrite(&cm_scacheLock);
573
574             /* now flush the file */
575             code = cm_FlushFile(scp, userp, reqp);
576             lock_ObtainWrite(&cm_scacheLock);
577             cm_ReleaseSCacheNoLock(scp);
578         }
579     }
580     lock_ReleaseWrite(&cm_scacheLock);
581
582     return code;
583 }
584
585 /*
586  * VIOC_FLUSHVOLUME internals.
587  *
588  * Assumes that pioctl path has been parsed or skipped.
589  * scp is held but not locked.
590  */
591 afs_int32
592 cm_IoctlFlushVolume(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *scp, cm_req_t *reqp)
593 {
594     afs_int32 code;
595     afs_uint32 volume;
596     afs_uint32 cell;
597
598 #ifdef AFS_FREELANCE_CLIENT
599     if ( scp->fid.cell == AFS_FAKE_ROOT_CELL_ID && scp->fid.volume == AFS_FAKE_ROOT_VOL_ID ) {
600         code = CM_ERROR_NOACCESS;
601     } else
602 #endif
603     {
604         volume = scp->fid.volume;
605         cell = scp->fid.cell;
606         code = cm_FlushVolume(userp, reqp, cell, volume);
607     }
608     return code;
609 }
610
611 /*
612  * VIOCFLUSH internals.
613  *
614  * Assumes that pioctl path has been parsed or skipped.
615  * scp is held but not locked.
616  */
617 afs_int32
618 cm_IoctlFlushFile(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *scp, cm_req_t *reqp)
619 {
620     afs_int32 code;
621
622 #ifdef AFS_FREELANCE_CLIENT
623     if ( scp->fid.cell == AFS_FAKE_ROOT_CELL_ID && scp->fid.volume == AFS_FAKE_ROOT_VOL_ID ) {
624         code = CM_ERROR_NOACCESS;
625     } else
626 #endif
627     {
628         cm_FlushFile(scp, userp, reqp);
629     }
630     return 0;
631 }
632
633
634 /*
635  * VIOCSETVOLSTAT internals.
636  *
637  * Assumes that pioctl path has been parsed or skipped.
638  * scp is held but not locked.
639  */
640 afs_int32
641 cm_IoctlSetVolumeStatus(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *scp, cm_req_t *reqp)
642 {
643     afs_int32 code;
644     char volName[32];
645     char offLineMsg[256];
646     char motd[256];
647     cm_conn_t *tcp;
648     AFSFetchVolumeStatus volStat;
649     AFSStoreVolumeStatus storeStat;
650     cm_volume_t *tvp;
651     cm_cell_t *cellp;
652     char *cp;
653     clientchar_t *strp;
654     struct rx_connection * rxconnp;
655
656 #ifdef AFS_FREELANCE_CLIENT
657     if ( scp->fid.cell == AFS_FAKE_ROOT_CELL_ID && scp->fid.volume == AFS_FAKE_ROOT_VOL_ID ) {
658         code = CM_ERROR_NOACCESS;
659     } else
660 #endif
661     {
662         cellp = cm_FindCellByID(scp->fid.cell, 0);
663         osi_assertx(cellp, "null cm_cell_t");
664
665         if (scp->flags & CM_SCACHEFLAG_RO)
666             return CM_ERROR_READONLY;
667
668         code = cm_FindVolumeByID(cellp, scp->fid.volume, userp, reqp,
669                                  CM_GETVOL_FLAG_CREATE, &tvp);
670         if (code)
671             return code;
672
673         cm_PutVolume(tvp);
674
675         /* Copy the junk out, using cp as a roving pointer. */
676         memcpy((char *)&volStat, ioctlp->inDatap, sizeof(AFSFetchVolumeStatus));
677         ioctlp->inDatap += sizeof(AFSFetchVolumeStatus);
678
679         strp = cm_ParseIoctlStringAlloc(ioctlp, NULL);
680         cm_ClientStringToFsString(strp, -1, volName, lengthof(volName));
681         free(strp);
682
683         strp = cm_ParseIoctlStringAlloc(ioctlp, NULL);
684         cm_ClientStringToFsString(strp, -1, offLineMsg, lengthof(offLineMsg));
685         free(strp);
686
687         strp = cm_ParseIoctlStringAlloc(ioctlp, NULL);
688         cm_ClientStringToFsString(strp, -1, motd, lengthof(motd));
689         free(strp);
690
691         strp = NULL;
692
693         storeStat.Mask = 0;
694         if (volStat.MinQuota != -1) {
695             storeStat.MinQuota = volStat.MinQuota;
696             storeStat.Mask |= AFS_SETMINQUOTA;
697         }
698         if (volStat.MaxQuota != -1) {
699             storeStat.MaxQuota = volStat.MaxQuota;
700             storeStat.Mask |= AFS_SETMAXQUOTA;
701         }
702
703         do {
704             code = cm_ConnFromFID(&scp->fid, userp, reqp, &tcp);
705             if (code)
706                 continue;
707
708             rxconnp = cm_GetRxConn(tcp);
709             code = RXAFS_SetVolumeStatus(rxconnp, scp->fid.volume,
710                                          &storeStat, volName, offLineMsg, motd);
711             rx_PutConnection(rxconnp);
712
713         } while (cm_Analyze(tcp, userp, reqp, &scp->fid, 1, NULL, NULL, NULL, code));
714         code = cm_MapRPCError(code, reqp);
715     }
716
717     /* return on failure */
718     if (code)
719         return code;
720
721     /* we are sending parms back to make compat. with prev system.  should
722      * change interface later to not ask for current status, just set
723      * new status
724      */
725     cp = ioctlp->outDatap;
726     memcpy(cp, (char *)&volStat, sizeof(VolumeStatus));
727     cp += sizeof(VolumeStatus);
728     StringCbCopyA(cp, SMB_IOCTL_MAXDATA - (cp - ioctlp->outAllocp), volName);
729     cp += strlen(volName)+1;
730     StringCbCopyA(cp, SMB_IOCTL_MAXDATA - (cp - ioctlp->outAllocp), offLineMsg);
731     cp += strlen(offLineMsg)+1;
732     StringCbCopyA(cp, SMB_IOCTL_MAXDATA - (cp - ioctlp->outAllocp), motd);
733     cp += strlen(motd)+1;
734
735     /* now return updated return data pointer */
736     ioctlp->outDatap = cp;
737
738     return 0;
739 }
740
741
742 /*
743  * VIOCGETVOLSTAT internals.
744  *
745  * Assumes that pioctl path has been parsed or skipped.
746  * scp is held but not locked.
747  */
748 afs_int32
749 cm_IoctlGetVolumeStatus(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *scp, cm_req_t *reqp)
750 {
751     afs_int32 code;
752     char volName[32]="(unknown)";
753     char offLineMsg[256]="server temporarily inaccessible";
754     char motd[256]="server temporarily inaccessible";
755     cm_conn_t *connp;
756     AFSFetchVolumeStatus volStat;
757     char *cp;
758     char *Name;
759     char *OfflineMsg;
760     char *MOTD;
761     struct rx_connection * rxconnp;
762
763 #ifdef AFS_FREELANCE_CLIENT
764     if ( scp->fid.cell == AFS_FAKE_ROOT_CELL_ID && scp->fid.volume == AFS_FAKE_ROOT_VOL_ID ) {
765         code = 0;
766         strncpy(volName, "Freelance.Local.Root", sizeof(volName));
767         offLineMsg[0] = '\0';
768         strncpy(motd, "Freelance mode in use.", sizeof(motd));
769         volStat.Vid = scp->fid.volume;
770         volStat.MaxQuota = 0;
771         volStat.BlocksInUse = 100;
772         volStat.PartBlocksAvail = 0;
773         volStat.PartMaxBlocks = 100;
774     } else
775 #endif
776     {
777         Name = volName;
778         OfflineMsg = offLineMsg;
779         MOTD = motd;
780         do {
781             code = cm_ConnFromFID(&scp->fid, userp, reqp, &connp);
782             if (code) continue;
783
784             rxconnp = cm_GetRxConn(connp);
785             code = RXAFS_GetVolumeStatus(rxconnp, scp->fid.volume,
786                                          &volStat, &Name, &OfflineMsg, &MOTD);
787             rx_PutConnection(rxconnp);
788
789         } while (cm_Analyze(connp, userp, reqp, &scp->fid, 0, NULL, NULL, NULL, code));
790         code = cm_MapRPCError(code, reqp);
791     }
792
793     if (code)
794         return code;
795
796     /* Copy all this junk into msg->im_data, keeping track of the lengths. */
797     cp = ioctlp->outDatap;
798     memcpy(cp, (char *)&volStat, sizeof(AFSFetchVolumeStatus));
799     cp += sizeof(AFSFetchVolumeStatus);
800     StringCbCopyA(cp, SMB_IOCTL_MAXDATA - (cp - ioctlp->outAllocp), volName);
801     cp += strlen(volName)+1;
802     StringCbCopyA(cp, SMB_IOCTL_MAXDATA - (cp - ioctlp->outAllocp), offLineMsg);
803     cp += strlen(offLineMsg)+1;
804     StringCbCopyA(cp, SMB_IOCTL_MAXDATA - (cp - ioctlp->outAllocp), motd);
805     cp += strlen(motd)+1;
806
807     /* return new size */
808     ioctlp->outDatap = cp;
809
810     return 0;
811 }
812
813 /*
814  * VIOCGETFID internals.
815  *
816  * Assumes that pioctl path has been parsed or skipped.
817  * scp is held but not locked.
818  */
819 afs_int32
820 cm_IoctlGetFid(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *scp, cm_req_t *reqp)
821 {
822     char *cp;
823     cm_fid_t fid;
824
825     memset(&fid, 0, sizeof(cm_fid_t));
826     fid.cell   = scp->fid.cell;
827     fid.volume = scp->fid.volume;
828     fid.vnode  = scp->fid.vnode;
829     fid.unique = scp->fid.unique;
830
831     /* Copy all this junk into msg->im_data, keeping track of the lengths. */
832     cp = ioctlp->outDatap;
833     memcpy(cp, (char *)&fid, sizeof(cm_fid_t));
834     cp += sizeof(cm_fid_t);
835
836     /* return new size */
837     ioctlp->outDatap = cp;
838
839     return 0;
840 }
841
842 /*
843  * VIOC_GETFILETYPE internals.
844  *
845  * Assumes that pioctl path has been parsed or skipped.
846  * scp is held but not locked.
847  */
848 afs_int32
849 cm_IoctlGetFileType(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *scp, cm_req_t *reqp)
850 {
851     afs_int32 code = 0;
852     char *cp;
853     afs_uint32 fileType = 0;
854
855     if (scp->fileType == 0) {
856         lock_ObtainWrite(&scp->rw);
857         code = cm_SyncOp(scp, NULL, userp, reqp, 0,
858                          CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
859         if (code == 0)
860             cm_SyncOpDone(scp, NULL, CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
861         lock_ReleaseWrite(&scp->rw);
862     }
863
864     if (code == 0) {
865         fileType = scp->fileType;
866
867         /* Copy all this junk into msg->im_data, keeping track of the lengths. */
868         cp = ioctlp->outDatap;
869         memcpy(cp, (char *)&fileType, sizeof(fileType));
870         cp += sizeof(fileType);
871
872         /* return new size */
873         ioctlp->outDatap = cp;
874     }
875     return code;
876 }
877
878 /*
879  * VIOCGETOWNER internals.
880  *
881  * Assumes that pioctl path has been parsed or skipped.
882  * scp is held but not locked.
883  */
884 afs_int32
885 cm_IoctlGetOwner(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *scp, cm_req_t *reqp)
886 {
887     afs_int32 code = 0;
888     char *cp;
889
890     lock_ObtainWrite(&scp->rw);
891     code = cm_SyncOp(scp, NULL, userp, reqp, 0,
892                       CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
893     if (code == 0)
894         cm_SyncOpDone(scp, NULL, CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
895     lock_ReleaseWrite(&scp->rw);
896
897     if (code == 0) {
898         /* Copy all this junk into msg->im_data, keeping track of the lengths. */
899         cp = ioctlp->outDatap;
900         memcpy(cp, (char *)&scp->owner, sizeof(afs_uint32));
901         cp += sizeof(afs_uint32);
902         memcpy(cp, (char *)&scp->group, sizeof(afs_uint32));
903         cp += sizeof(afs_uint32);
904
905         /* return new size */
906         ioctlp->outDatap = cp;
907     }
908     return code;
909 }
910
911
912 /*
913  * VIOC_SETOWNER internals.
914  *
915  * Assumes that pioctl path has been parsed or skipped
916  * and that cm_ioctlQueryOptions_t have been parsed and skipped.
917  *
918  * scp is held but not locked.
919  *
920  */
921 afs_int32
922 cm_IoctlSetOwner(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *scp, cm_req_t *reqp)
923 {
924     afs_int32 code = 0;
925     char *cp;
926
927     lock_ObtainWrite(&scp->rw);
928     code = cm_SyncOp(scp, NULL, userp, reqp, 0,
929                       CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
930     if (code == 0)
931         cm_SyncOpDone(scp, NULL, CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
932     lock_ReleaseWrite(&scp->rw);
933
934     if (code == 0) {
935         afs_uint32 owner;
936         cm_attr_t attr;
937
938         memset(&attr, 0, sizeof(attr));
939
940         cp = ioctlp->inDatap;
941         memcpy((char *)&owner, cp, sizeof(afs_uint32));
942
943         attr.mask = CM_ATTRMASK_OWNER;
944         attr.owner = owner;
945
946         code = cm_SetAttr(scp, &attr, userp, reqp);
947     }
948     return code;
949 }
950
951
952 /*
953  * VIOC_SETGROUP internals.
954  *
955  * Assumes that pioctl path has been parsed or skipped
956  * and that cm_ioctlQueryOptions_t have been parsed and skipped.
957  *
958  */
959 afs_int32
960 cm_IoctlSetGroup(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *scp, cm_req_t *reqp)
961 {
962     afs_int32 code = 0;
963     char *cp;
964
965     lock_ObtainWrite(&scp->rw);
966     code = cm_SyncOp(scp, NULL, userp, reqp, 0,
967                       CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
968     if (code == 0)
969         cm_SyncOpDone(scp, NULL, CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
970     lock_ReleaseWrite(&scp->rw);
971
972     if (code == 0) {
973         afs_uint32 group;
974         cm_attr_t attr;
975
976         memset(&attr, 0, sizeof(attr));
977
978         cp = ioctlp->inDatap;
979         memcpy((char *)&group, cp, sizeof(afs_uint32));
980
981         attr.mask = CM_ATTRMASK_GROUP;
982         attr.group = group;
983
984         code = cm_SetAttr(scp, &attr, userp, reqp);
985     }
986     return code;
987 }
988
989
990 /*
991  * VIOCWHEREIS internals.
992  *
993  * Assumes that pioctl path has been parsed or skipped.
994  * scp is held but not locked.
995  */
996 afs_int32
997 cm_IoctlWhereIs(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *scp, cm_req_t *reqp)
998 {
999     afs_int32 code = 0;
1000     cm_cell_t *cellp;
1001     cm_volume_t *tvp;
1002     cm_serverRef_t **tsrpp, *current;
1003     cm_server_t *tsp;
1004     afs_uint32 volume;
1005     char *cp;
1006
1007     volume = scp->fid.volume;
1008
1009     cellp = cm_FindCellByID(scp->fid.cell, 0);
1010
1011     if (!cellp)
1012         return CM_ERROR_NOSUCHCELL;
1013
1014 #ifdef AFS_FREELANCE_CLIENT
1015     if ( cellp->cellID == AFS_FAKE_ROOT_CELL_ID) {
1016         struct in_addr addr;
1017
1018         addr.s_net = 127;
1019         addr.s_host = 0;
1020         addr.s_lh = 0;
1021         addr.s_impno = 1;
1022
1023         cp = ioctlp->outDatap;
1024
1025         memcpy(cp, (char *)&addr, sizeof(addr));
1026         cp += sizeof(addr);
1027
1028         /* still room for terminating NULL, add it on */
1029         addr.s_addr = 0;
1030         memcpy(cp, (char *)&addr, sizeof(addr));
1031         cp += sizeof(addr);
1032
1033         ioctlp->outDatap = cp;
1034     } else
1035 #endif
1036     {
1037         code = cm_FindVolumeByID(cellp, volume, userp, reqp, CM_GETVOL_FLAG_CREATE, &tvp);
1038         if (code)
1039             return code;
1040
1041         cp = ioctlp->outDatap;
1042
1043         tsrpp = cm_GetVolServers(tvp, volume, userp, reqp);
1044         if (tsrpp == NULL) {
1045             code = CM_ERROR_NOSUCHVOLUME;
1046         } else {
1047             lock_ObtainRead(&cm_serverLock);
1048             for (current = *tsrpp; current; current = current->next) {
1049                 tsp = current->server;
1050                 memcpy(cp, (char *)&tsp->addr.sin_addr.s_addr, sizeof(long));
1051                 cp += sizeof(long);
1052             }
1053             lock_ReleaseRead(&cm_serverLock);
1054             cm_FreeServerList(tsrpp, 0);
1055         }
1056         /* still room for terminating NULL, add it on */
1057         volume = 0;     /* reuse vbl */
1058         memcpy(cp, (char *)&volume, sizeof(long));
1059         cp += sizeof(long);
1060
1061         ioctlp->outDatap = cp;
1062         cm_PutVolume(tvp);
1063     }
1064     return code;
1065 }
1066
1067 /*
1068  * VIOC_AFS_STAT_MT_PT internals.
1069  *
1070  * Assumes that pioctl path has been parsed or skipped.
1071  * scp is held but not locked.
1072  */
1073 afs_int32
1074 cm_IoctlStatMountPoint(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *dscp, cm_req_t *reqp)
1075 {
1076     afs_int32 code;
1077     cm_scache_t *scp;
1078     clientchar_t *cp;
1079
1080     cp = cm_ParseIoctlStringAlloc(ioctlp, NULL);
1081
1082     code = cm_Lookup(dscp, cp[0] ? cp : L".", CM_FLAG_NOMOUNTCHASE, userp, reqp, &scp);
1083     if (code)
1084         goto done_2;
1085
1086     lock_ObtainWrite(&scp->rw);
1087     code = cm_SyncOp(scp, NULL, userp, reqp, 0,
1088                       CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
1089     if (code == 0)
1090         cm_SyncOpDone(scp, NULL, CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
1091     else
1092         goto done;
1093
1094     /* now check that this is a real mount point */
1095     if (scp->fileType != CM_SCACHETYPE_MOUNTPOINT) {
1096         code = CM_ERROR_INVAL;
1097         goto done;
1098     }
1099
1100     code = cm_ReadMountPoint(scp, userp, reqp);
1101     if (code == 0) {
1102         char * strp;
1103         strp = ioctlp->outDatap;
1104         StringCbCopyA(strp, SMB_IOCTL_MAXDATA - (strp - ioctlp->outAllocp), scp->mountPointStringp);
1105         strp += strlen(strp) + 1;
1106         ioctlp->outDatap = strp;
1107     }
1108
1109   done:
1110     lock_ReleaseWrite(&scp->rw);
1111     cm_ReleaseSCache(scp);
1112
1113  done_2:
1114     if (cp)
1115         free(cp);
1116
1117     return code;
1118 }
1119
1120 /*
1121  * VIOC_AFS_DELETE_MT_PT internals.
1122  *
1123  * Assumes that pioctl path has been parsed or skipped.
1124  * scp is held but not locked.
1125  */
1126 afs_int32
1127 cm_IoctlDeleteMountPoint(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *dscp, cm_req_t *reqp)
1128 {
1129     afs_int32 code;
1130     cm_scache_t *scp;
1131     clientchar_t *cp = NULL;
1132     fschar_t *originalName = NULL;
1133     cm_dirOp_t dirop;
1134
1135     cp = cm_ParseIoctlStringAlloc(ioctlp, NULL);
1136
1137     code = cm_Lookup(dscp, cp[0] ? cp : L".", CM_FLAG_NOMOUNTCHASE, userp, reqp, &scp);
1138
1139     /* if something went wrong, bail out now */
1140     if (code)
1141         goto done3;
1142
1143     lock_ObtainWrite(&scp->rw);
1144     code = cm_SyncOp(scp, NULL, userp, reqp, 0,
1145                      CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
1146     if (code)
1147         goto done2;
1148
1149     /* now check that this is a real mount point */
1150     if (scp->fileType != CM_SCACHETYPE_MOUNTPOINT) {
1151         code = CM_ERROR_INVAL;
1152         goto done1;
1153     }
1154
1155     /* time to make the RPC, so drop the lock */
1156     lock_ReleaseWrite(&scp->rw);
1157
1158 #ifdef USE_BPLUS
1159     code = cm_BeginDirOp(dscp, userp, reqp, CM_DIRLOCK_READ,
1160                          CM_DIROP_FLAG_NONE, &dirop);
1161     if (code == 0) {
1162         code = cm_BPlusDirLookupOriginalName(&dirop, cp, &originalName);
1163         /* The cm_Dir* functions can't be used to lookup the
1164            originalName.  Those functions only know of the original
1165            name. */
1166         cm_EndDirOp(&dirop);
1167     }
1168 #endif
1169
1170     /* If this name doesn't have a non-normalized name associated with
1171        it, we assume that what we had is what is actually present on
1172        the file server. */
1173
1174     if (originalName == NULL) {
1175         originalName = cm_ClientStringToFsStringAlloc(cp, -1, NULL);
1176     }
1177
1178     /* cp is a normalized name.  originalName is the actual name we
1179        saw on the fileserver. */
1180 #ifdef AFS_FREELANCE_CLIENT
1181     if (cm_freelanceEnabled && dscp == cm_data.rootSCachep) {
1182         /* we are removing the mount point to the root dir., so call
1183          * the freelance code to do the deletion. */
1184         osi_Log0(afsd_logp,"IoctlDeleteMountPoint from Freelance root dir");
1185         code = cm_FreelanceRemoveMount(originalName);
1186     } else
1187 #endif
1188     {
1189         /* easier to do it this way */
1190         code = cm_Unlink(dscp, originalName, cp, userp, reqp);
1191     }
1192     if (code == 0 && (dscp->flags & CM_SCACHEFLAG_ANYWATCH))
1193         smb_NotifyChange(FILE_ACTION_REMOVED,
1194                          FILE_NOTIFY_CHANGE_DIR_NAME,
1195                          dscp, cp, NULL, TRUE);
1196
1197     lock_ObtainWrite(&scp->rw);
1198   done1:
1199     cm_SyncOpDone(scp, NULL, CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
1200
1201   done2:
1202     cm_DiscardSCache(scp);
1203     lock_ReleaseWrite(&scp->rw);
1204     cm_ReleaseSCache(scp);
1205
1206     if (RDR_Initialized &&
1207         !RDR_InvalidateObject(scp->fid.cell, scp->fid.volume, scp->fid.vnode, scp->fid.unique,
1208                               scp->fid.hash, scp->fileType, AFS_INVALIDATE_DELETED))
1209         buf_ClearRDRFlag(scp, "deleted mp");
1210
1211   done3:
1212     if (originalName != NULL)
1213         free(originalName);
1214
1215     if (cp != NULL)
1216         free(cp);
1217
1218     return code;
1219 }
1220
1221 /*
1222  * VIOCCKSERV internals.
1223  *
1224  * Assumes that pioctl path has been parsed or skipped.
1225  */
1226 afs_int32
1227 cm_IoctlCheckServers(struct cm_ioctl *ioctlp, struct cm_user *userp)
1228 {
1229     cm_cell_t *cellp;
1230     chservinfo_t csi;
1231     char *tp;
1232     char *cp;
1233     long temp;
1234     cm_server_t *tsp, *csp;
1235     int haveCell;
1236
1237     tp = ioctlp->inDatap;
1238     haveCell = 0;
1239
1240     memcpy(&temp, tp, sizeof(temp));
1241     if (temp == 0x12345678) {   /* For afs3.3 version */
1242         memcpy(&csi, tp, sizeof(csi));
1243         if (csi.tinterval >= 0) {
1244             cp = ioctlp->outDatap;
1245             memcpy(cp, (char *)&cm_daemonCheckDownInterval, sizeof(long));
1246             ioctlp->outDatap += sizeof(long);
1247             if (csi.tinterval > 0) {
1248                 if (!smb_SUser(userp))
1249                     return CM_ERROR_NOACCESS;
1250                 cm_daemonCheckDownInterval = csi.tinterval;
1251             }
1252             return 0;
1253         }
1254         if (csi.tsize)
1255             haveCell = 1;
1256         temp = csi.tflags;
1257         cp = csi.tbuffer;
1258     } else {    /* For pre afs3.3 versions */
1259         memcpy((char *)&temp, ioctlp->inDatap, sizeof(long));
1260         ioctlp->inDatap = cp = ioctlp->inDatap + sizeof(long);
1261         if (cp - ioctlp->inAllocp < ioctlp->inCopied)   /* still more data available */
1262             haveCell = 1;
1263     }
1264
1265     /*
1266      * 1: fast check, don't contact servers.
1267      * 2: local cell only.
1268      */
1269     if (haveCell) {
1270         /* have cell name, too */
1271         cellp = cm_GetCell(cp, (temp & 1) ? CM_FLAG_NOPROBE : 0);
1272         if (!cellp)
1273             return CM_ERROR_NOSUCHCELL;
1274     }
1275     else
1276         cellp = (cm_cell_t *) 0;
1277     if (!cellp && (temp & 2)) {
1278         /* use local cell */
1279         fschar_t wscell[CELL_MAXNAMELEN+1];
1280         cm_GetRootCellName(wscell);
1281         cellp = cm_GetCell(wscell, 0);
1282     }
1283     if (!(temp & 1)) {  /* if not fast, call server checker routine */
1284         /* check down servers */
1285         cm_CheckServers(CM_FLAG_CHECKDOWNSERVERS | CM_FLAG_CHECKUPSERVERS, cellp);
1286     }
1287
1288     /* now return the current down server list */
1289     cp = ioctlp->outDatap;
1290     lock_ObtainRead(&cm_serverLock);
1291     for (tsp = cm_allServersp; tsp; tsp=tsp->allNextp) {
1292         if (cellp && tsp->cellp != cellp)
1293             continue;   /* cell spec'd and wrong */
1294         if (tsp->flags & CM_SERVERFLAG_DOWN) {
1295             /*
1296              * for a multi-homed file server, if one of the interfaces
1297              * is up, do not report the server as down.
1298              */
1299             if (tsp->type == CM_SERVER_FILE) {
1300                 for (csp = cm_allServersp; csp; csp=csp->allNextp) {
1301                     if (csp->type == CM_SERVER_FILE &&
1302                         !(csp->flags & CM_SERVERFLAG_DOWN) &&
1303                         afs_uuid_equal(&tsp->uuid, &csp->uuid)) {
1304                         break;
1305                     }
1306                 }
1307                 if (csp)    /* found alternate up interface */
1308                     continue;
1309             }
1310
1311             /*
1312              * all server types are being reported by ipaddr.  only report
1313              * a server once regardless of how many services are down.
1314              */
1315             for (tp = ioctlp->outDatap; tp < cp; tp += sizeof(long)) {
1316                 if (!memcmp(tp, (char *)&tsp->addr.sin_addr.s_addr, sizeof(long)))
1317                     break;
1318             }
1319
1320             if (tp == cp) {
1321                 memcpy(cp, (char *)&tsp->addr.sin_addr.s_addr, sizeof(long));
1322                 cp += sizeof(long);
1323             }
1324         }
1325     }
1326     lock_ReleaseRead(&cm_serverLock);
1327
1328     ioctlp->outDatap = cp;
1329     return 0;
1330 }
1331
1332 /*
1333  * VIOCCKBACK internals.
1334  *
1335  * Assumes that pioctl path has been parsed or skipped.
1336  */
1337 afs_int32
1338 cm_IoctlCheckVolumes(cm_ioctl_t *ioctlp, cm_user_t *userp)
1339 {
1340     cm_RefreshVolumes(0);
1341     return 0;
1342 }
1343
1344 /*
1345  * VIOCSETCACHESIZE internals.
1346  *
1347  * Assumes that pioctl path has been parsed or skipped.
1348  *
1349  * This function is no longer meaningful in the current day world
1350  * of persistent caches.  The buf_SetNBuffers() function will
1351  * inevitably fail.
1352  */
1353 afs_int32
1354 cm_IoctlSetCacheSize(struct cm_ioctl *ioctlp, struct cm_user *userp)
1355 {
1356     afs_int32 code;
1357     afs_uint64 temp;
1358
1359     memcpy(&temp, ioctlp->inDatap, sizeof(temp));
1360     if (temp == 0)
1361         temp = cm_data.buf_nOrigBuffers;
1362     else {
1363         /* temp is in 1K units, convert to # of buffers */
1364         temp = temp / (cm_data.buf_blockSize / 1024);
1365     }
1366
1367     /* now adjust the cache size */
1368     code = buf_SetNBuffers(temp);
1369
1370     return code;
1371 }
1372
1373 /*
1374  * VIOC_TRACECTL internals.
1375  *
1376  * Assumes that pioctl path has been parsed or skipped.
1377  */
1378 afs_int32
1379 cm_IoctlTraceControl(cm_ioctl_t *ioctlp, cm_user_t *userp)
1380 {
1381     afs_uint32 inValue;
1382
1383     memcpy(&inValue, ioctlp->inDatap, sizeof(afs_uint32));
1384
1385     /* print trace */
1386     if (inValue & 8) {
1387         afsd_ForceTrace(FALSE);
1388         buf_ForceTrace(FALSE);
1389     }
1390
1391     if (inValue & 2) {
1392         /* set tracing value to low order bit */
1393         if ((inValue & 1) == 0) {
1394             /* disable tracing */
1395             osi_LogDisable(afsd_logp);
1396             rx_DebugOnOff(FALSE);
1397         }
1398         else {
1399             /* enable tracing */
1400             osi_LogEnable(afsd_logp);
1401             rx_DebugOnOff(TRUE);
1402         }
1403     }
1404
1405     /* see if we're supposed to do a reset, too */
1406     if (inValue & 4) {
1407         osi_LogReset(afsd_logp);
1408     }
1409
1410     /* and copy out tracing flag */
1411     inValue = afsd_logp->enabled;       /* use as a temp vbl */
1412     memcpy(ioctlp->outDatap, &inValue, sizeof(afs_uint32));
1413     ioctlp->outDatap += sizeof(afs_uint32);
1414     return 0;
1415 }
1416
1417 /*
1418  * VIOCGETCACHEPARMS internals.
1419  *
1420  * Assumes that pioctl path has been parsed or skipped.
1421  */
1422 afs_int32
1423 cm_IoctlGetCacheParms(struct cm_ioctl *ioctlp, struct cm_user *userp)
1424 {
1425     cm_cacheParms_t parms;
1426
1427     memset(&parms, 0, sizeof(parms));
1428
1429     /* first we get, in 1K units, the cache size */
1430     parms.parms[0] = cm_data.buf_nbuffers * (cm_data.buf_blockSize / 1024);
1431
1432     /* and then the actual # of buffers in use (not in the free list, I guess,
1433      * will be what we do).
1434      */
1435     parms.parms[1] = (cm_data.buf_nbuffers - cm_data.buf_freeCount) * (cm_data.buf_blockSize / 1024);
1436
1437     memcpy(ioctlp->outDatap, &parms, sizeof(parms));
1438     ioctlp->outDatap += sizeof(parms);
1439
1440     return 0;
1441 }
1442
1443 /*
1444  * VIOCGETCELL internals.
1445  *
1446  * Assumes that pioctl path has been parsed or skipped.
1447  */
1448 afs_int32
1449 cm_IoctlGetCell(struct cm_ioctl *ioctlp, struct cm_user *userp)
1450 {
1451     long whichCell;
1452     long magic = 0;
1453     cm_cell_t *tcellp;
1454     cm_serverRef_t *serverRefp;
1455     cm_server_t *serverp;
1456     long i;
1457     char *cp;
1458     char *tp;
1459     char *basep;
1460
1461     tp = ioctlp->inDatap;
1462
1463     memcpy((char *)&whichCell, tp, sizeof(long));
1464     tp += sizeof(long);
1465
1466     /* see if more than one long passed in, ignoring the null pathname (the -1) */
1467     if (ioctlp->inCopied-1 > sizeof(afs_uint32)) {
1468         memcpy((char *)&magic, tp, sizeof(afs_uint32));
1469     }
1470
1471     lock_ObtainRead(&cm_cellLock);
1472     for (tcellp = cm_data.allCellsp; tcellp; tcellp = tcellp->allNextp) {
1473         if (whichCell == 0)
1474             break;
1475         whichCell--;
1476     }
1477     lock_ReleaseRead(&cm_cellLock);
1478     if (tcellp) {
1479         int max = 8;
1480         clientchar_t * cellnamep;
1481
1482         cp = ioctlp->outDatap;
1483
1484         if (magic == 0x12345678) {
1485             memcpy(cp, (char *)&magic, sizeof(long));
1486             max = 13;
1487         }
1488         memset(cp, 0, max * sizeof(long));
1489         basep = cp;
1490         lock_ObtainRead(&cm_serverLock);        /* for going down server list */
1491         for (i=0, serverRefp = tcellp->vlServersp;
1492              serverRefp && i<max;
1493              i++, serverRefp = serverRefp->next) {
1494             serverp = serverRefp->server;
1495             memcpy(cp, &serverp->addr.sin_addr.s_addr, sizeof(long));
1496             cp += sizeof(long);
1497         }
1498         lock_ReleaseRead(&cm_serverLock);
1499         ioctlp->outDatap = basep + max * sizeof(afs_int32);
1500
1501         cellnamep = cm_FsStringToClientStringAlloc(tcellp->name, -1, NULL);
1502         if (cellnamep) {
1503             cm_UnparseIoctlString(ioctlp, NULL, cellnamep, -1);
1504             free(cellnamep);
1505         } else {
1506             tcellp = NULL;
1507         }
1508     }
1509
1510     if (tcellp)
1511         return 0;
1512     else
1513         return CM_ERROR_NOMORETOKENS;   /* mapped to EDOM */
1514 }
1515
1516
1517 /*
1518  * VIOCNEWCELL internals.
1519  *
1520  * Assumes that pioctl path has been parsed or skipped.
1521  */
1522 afs_int32
1523 cm_IoctlNewCell(struct cm_ioctl *ioctlp, struct cm_user *userp)
1524 {
1525     /*
1526      * All that needs to be done is to refresh server information for all cells that
1527      * are already loaded.
1528
1529      * cell list will be cm_CellLock and cm_ServerLock will be held for write.
1530      */
1531
1532     cm_cell_t *cp;
1533     cm_cell_rock_t rock;
1534
1535     lock_ObtainWrite(&cm_cellLock);
1536
1537     for (cp = cm_data.allCellsp; cp; cp=cp->allNextp)
1538     {
1539         afs_int32 code;
1540
1541         /* delete all previous server lists - cm_FreeServerList will ask for write on cm_ServerLock*/
1542         cm_FreeServerList(&cp->vlServersp, CM_FREESERVERLIST_DELETE);
1543         lock_ReleaseWrite(&cm_cellLock);
1544
1545         rock.cellp = cp;
1546         rock.flags = 0;
1547         code = cm_SearchCellRegistry(1, cp->name, cp->name, cp->linkedName, cm_AddCellProc, &rock);
1548         if (code && code != CM_ERROR_FORCE_DNS_LOOKUP)
1549             code = cm_SearchCellFileEx(cp->name, cp->name, cp->linkedName, cm_AddCellProc, &rock);
1550         if (code) {
1551             if (cm_dnsEnabled) {
1552                 int ttl;
1553                 code = cm_SearchCellByDNS(cp->name, cp->name, &ttl, cm_AddCellProc, &rock);
1554                 if ( code == 0 ) { /* got cell from DNS */
1555                     lock_ObtainMutex(&cp->mx);
1556                     _InterlockedOr(&cp->flags, CM_CELLFLAG_DNS);
1557                     _InterlockedAnd(&cp->flags, ~CM_CELLFLAG_VLSERVER_INVALID);
1558                     cp->timeout = time(0) + ttl;
1559                     lock_ReleaseMutex(&cp->mx);
1560                 }
1561             }
1562         }
1563         else {
1564             lock_ObtainMutex(&cp->mx);
1565             _InterlockedAnd(&cp->flags, ~CM_CELLFLAG_DNS);
1566             lock_ReleaseMutex(&cp->mx);
1567         }
1568         if (code) {
1569             lock_ObtainMutex(&cp->mx);
1570             _InterlockedOr(&cp->flags, CM_CELLFLAG_VLSERVER_INVALID);
1571             lock_ReleaseMutex(&cp->mx);
1572             lock_ObtainWrite(&cm_cellLock);
1573         }
1574         else {
1575             lock_ObtainMutex(&cp->mx);
1576             _InterlockedAnd(&cp->flags, ~CM_CELLFLAG_VLSERVER_INVALID);
1577             lock_ReleaseMutex(&cp->mx);
1578             lock_ObtainWrite(&cm_cellLock);
1579             cm_RandomizeServer(&cp->vlServersp);
1580         }
1581     }
1582     lock_ReleaseWrite(&cm_cellLock);
1583     return 0;
1584 }
1585
1586 /*
1587  * VIOCNEWCELL2 internals.
1588  *
1589  * Assumes that pioctl path has been parsed or skipped.
1590  *
1591  * The pioctl data buffer consists of the following structure:
1592  *
1593  *  afs_uint32 flags
1594  *  afs_uint32 alternative fs port
1595  *  afs_uint32 alternative vl port
1596  *  afs_uint32 count of vldb servers
1597  *  char[]     cellname
1598  *  char[]     linkedcell
1599  *  n * char[] hostnames
1600  */
1601 afs_int32
1602 cm_IoctlNewCell2(struct cm_ioctl *ioctlp, struct cm_user *userp)
1603 {
1604     afs_uint32  code = 0;
1605     afs_uint32  flags = 0;
1606     afs_uint32  fsport = 0;
1607     afs_uint32  vlport = 0;
1608     afs_uint32  i, host_count = 0;
1609     char *      cellname = NULL;
1610     char *      linked_cellname = NULL;
1611     char *tp;
1612     size_t tplen;
1613     afs_uint32 *lp;
1614     char * hostname[AFS_MAXHOSTS];
1615     size_t len;
1616
1617     memset(hostname, 0, sizeof(hostname));
1618
1619     tp = ioctlp->inDatap;
1620     tplen = ioctlp->inCopied;
1621     lp = (afs_uint32 *)tp;
1622
1623     if (tplen >= 4 * sizeof(afs_uint32)) {
1624         flags = *lp++;
1625         fsport = *lp++;
1626         vlport = *lp++;
1627         host_count = *lp++;
1628         tp = (char *)lp;
1629         tplen -= 4 * sizeof(afs_uint32);
1630     }
1631
1632     if ( FAILED(StringCbLength(tp, tplen, &len)) ||
1633          len + 1 > CELL_MAXNAMELEN)
1634         return CM_ERROR_INVAL;
1635     cellname = tp;
1636     tp += len + 1;
1637     tplen -= (len + 1);
1638
1639     if ( FAILED(StringCbLength(tp, tplen, &len)) ||
1640          len + 1 > CELL_MAXNAMELEN)
1641         return CM_ERROR_INVAL;
1642     linked_cellname = tp;
1643     tp += len + 1;
1644     tplen -= (len + 1);
1645
1646     if (!(flags & VIOC_NEWCELL2_FLAG_USEDNS)) {
1647         for ( i=0; i<host_count; i++) {
1648             if ( FAILED(StringCbLength(tp, tplen, &len)) )
1649                 return CM_ERROR_INVAL;
1650             hostname[i] = tp;
1651             tp += len + 1;
1652             tplen -= (len + 1);
1653         }
1654     }
1655
1656     code = cm_CreateCellWithInfo( cellname, linked_cellname,
1657                                   vlport, host_count,
1658                                   hostname,
1659                                   (flags & VIOC_NEWCELL2_FLAG_USEDNS) ? CM_CELLFLAG_DNS : 0);
1660
1661     if (code == 0 && (flags & VIOC_NEWCELL2_FLAG_USEREG)) {
1662         cm_AddCellToRegistry( cellname, linked_cellname,
1663                               vlport, host_count,
1664                               hostname,
1665                               (flags & VIOC_NEWCELL2_FLAG_USEDNS) ? CM_CELLFLAG_DNS : 0);
1666     }
1667     return code;
1668 }
1669
1670 /*
1671  * VIOC_GET_WS_CELL internals.
1672  *
1673  * Assumes that pioctl path has been parsed or skipped.
1674  */
1675 afs_int32
1676 cm_IoctlGetWsCell(cm_ioctl_t *ioctlp, cm_user_t *userp)
1677 {
1678     afs_int32 code = 0;
1679
1680     if (cm_freelanceEnabled) {
1681         if (cm_GetRootCellName(ioctlp->outDatap))
1682             StringCbCopyA(ioctlp->outDatap, SMB_IOCTL_MAXDATA - (ioctlp->outDatap - ioctlp->outAllocp), "Freelance.Local.Root");
1683         ioctlp->outDatap += strlen(ioctlp->outDatap) +1;
1684     } else if (cm_data.rootCellp) {
1685         clientchar_t * cellnamep = cm_FsStringToClientStringAlloc(cm_data.rootCellp->name, -1, NULL);
1686         /* return the default cellname to the caller */
1687         if (cellnamep) {
1688             cm_UnparseIoctlString(ioctlp, NULL, cellnamep, -1);
1689             free(cellnamep);
1690         } else {
1691             code = CM_ERROR_NOSUCHCELL;
1692         }
1693     } else {
1694         /* if we don't know our default cell, return failure */
1695         code = CM_ERROR_NOSUCHCELL;
1696     }
1697
1698     return code;
1699 }
1700
1701 /*
1702  * VIOC_AFS_SYSNAME internals.
1703  *
1704  * Assumes that pioctl path has been parsed or skipped.
1705  *
1706  * In order to support both 32-bit and 64-bit sysname lists
1707  * we will treat bit-31 of the setSysName value as a flag
1708  * indicating which architecture is being indicated.  If unset
1709  * the architecture is 32-bit and if set the architecture is
1710  * 64-bit.  This change is backward compatible with cache
1711  * managers that do not support this extension.
1712  */
1713 afs_int32
1714 cm_IoctlSysName(struct cm_ioctl *ioctlp, struct cm_user *userp)
1715 {
1716     afs_uint32 setSysName;
1717     char *cp, *cp2;
1718     clientchar_t *inname = NULL;
1719     int t;
1720     unsigned int count;
1721     int arch64 = 0;
1722
1723     memcpy(&setSysName, ioctlp->inDatap, sizeof(afs_uint32));
1724     ioctlp->inDatap += sizeof(afs_uint32);
1725
1726     arch64 = (setSysName & 0x8000000) ? 1 : 0;
1727     setSysName &= 0x7FFFFFF;
1728
1729     if (setSysName) {
1730         /* check my args */
1731         if ( setSysName < 0 || setSysName > MAXNUMSYSNAMES )
1732             return EINVAL;
1733         cp2 = ioctlp->inDatap;
1734         for ( cp=ioctlp->inDatap, count = 0; count < setSysName; count++ ) {
1735             /* won't go past end of ioctlp->inDatap since
1736                maxsysname*num < ioctlp->inDatap length */
1737             t = (int)strlen(cp);
1738             if (t >= MAXSYSNAME || t <= 0)
1739                 return EINVAL;
1740             /* check for names that can shoot us in the foot */
1741             if (*cp == '.' && (cp[1] == 0 || (cp[1] == '.' && cp[2] == 0)))
1742                 return EINVAL;
1743             cp += t + 1;
1744         }
1745         /* args ok */
1746
1747         /* inname gets first entry in case we're being a translator */
1748         /* (we are never a translator) */
1749         inname = cm_ParseIoctlStringAlloc(ioctlp, NULL);
1750     }
1751
1752     /* Not xlating, so local case */
1753     if (setSysName) {
1754         /* Local guy; only root can change sysname */
1755         /* clear @sys entries from the dnlc, once afs_lookup can
1756          * do lookups of @sys entries and thinks it can trust them */
1757         /* privs ok, store the entry, ... */
1758
1759         cm_ClientStrCpy(arch64 ? cm_sysName64List[0] : cm_sysNameList[0], MAXSYSNAME, inname);
1760
1761         if (setSysName > 1) {       /* ... or list */
1762             for (count = 1; count < setSysName; ++count) {
1763                 clientchar_t * newsysname;
1764
1765                 if (!(arch64 ? cm_sysName64List[count] : cm_sysNameList[count]))
1766                     osi_panic("cm_IoctlSysName: no cm_sysNameList entry to write\n",
1767                               __FILE__, __LINE__);
1768
1769                 newsysname = cm_ParseIoctlStringAlloc(ioctlp, NULL);
1770                 cm_ClientStrCpy(arch64 ? cm_sysName64List[count] : cm_sysNameList[count], MAXSYSNAME, newsysname);
1771                 free(newsysname);
1772             }
1773         }
1774         if ( arch64 ) {
1775             cm_sysName64Count = setSysName;
1776             if (cm_sysName64Count)
1777                 RDR_SysName( AFS_SYSNAME_ARCH_64BIT, cm_sysName64Count, cm_sysName64List );
1778             else if (cm_sysNameCount)
1779                 RDR_SysName( AFS_SYSNAME_ARCH_64BIT, cm_sysNameCount, cm_sysNameList );
1780         } else {
1781             cm_sysNameCount = setSysName;
1782             RDR_SysName( AFS_SYSNAME_ARCH_32BIT, cm_sysNameCount, cm_sysNameList );
1783         }
1784     } else {
1785         afs_uint32 i32;
1786
1787         /* return the sysname list to the caller.
1788          * if there is no 64-bit list and 64-bit is requested, use the 32-bit list.
1789          */
1790         if ( arch64 && cm_sysName64Count == 0 )
1791             arch64 = 0;
1792
1793         i32 = arch64 ? cm_sysName64Count : cm_sysNameCount;
1794         memcpy(ioctlp->outDatap, &i32, sizeof(afs_int32));
1795         ioctlp->outDatap += sizeof(afs_int32);  /* skip found flag */
1796
1797         if (i32) {
1798             for ( count=0; count < i32 ; ++count) {   /* ... or list */
1799                 if ( !(arch64 ? cm_sysName64List[count] : cm_sysNameList[count]) ||
1800                      *(arch64 ? cm_sysName64List[count] : cm_sysNameList[count]) == _C('\0'))
1801                     osi_panic("cm_IoctlSysName: no cm_sysNameList entry to read\n",
1802                               __FILE__, __LINE__);
1803                 cm_UnparseIoctlString(ioctlp, NULL, arch64 ? cm_sysName64List[count] : cm_sysNameList[count], -1);
1804             }
1805         }
1806     }
1807
1808     if (inname) {
1809         free(inname);
1810         inname = NULL;
1811     }
1812
1813     /* done: success */
1814     return 0;
1815 }
1816
1817 /*
1818  * VIOC_GETCELLSTATUS internals.
1819  *
1820  * Assumes that pioctl path has been parsed or skipped.
1821  */
1822 afs_int32
1823 cm_IoctlGetCellStatus(struct cm_ioctl *ioctlp, struct cm_user *userp)
1824 {
1825     afs_uint32 temp;
1826     cm_cell_t *cellp;
1827     clientchar_t * cellnamep;
1828     fschar_t     * fscellnamep;
1829
1830     cellnamep = cm_ParseIoctlStringAlloc(ioctlp, NULL);
1831     fscellnamep = cm_ClientStringToFsStringAlloc(cellnamep, -1, NULL);
1832     cellp = cm_GetCell(fscellnamep, 0);
1833     free(fscellnamep);
1834     free(cellnamep);
1835
1836     if (!cellp)
1837         return CM_ERROR_NOSUCHCELL;
1838
1839     temp = 0;
1840     lock_ObtainMutex(&cellp->mx);
1841     if (cellp->flags & CM_CELLFLAG_SUID)
1842         temp |= CM_SETCELLFLAG_SUID;
1843     lock_ReleaseMutex(&cellp->mx);
1844
1845     /* now copy out parm */
1846     memcpy(ioctlp->outDatap, &temp, sizeof(afs_uint32));
1847     ioctlp->outDatap += sizeof(afs_uint32);
1848
1849     return 0;
1850 }
1851
1852 /*
1853  * VIOC_SETCELLSTATUS internals.
1854  *
1855  * Assumes that pioctl path has been parsed or skipped.
1856  */
1857 afs_int32
1858 cm_IoctlSetCellStatus(struct cm_ioctl *ioctlp, struct cm_user *userp)
1859 {
1860     afs_uint32 flags;
1861     cm_cell_t *cellp;
1862     clientchar_t *temp;
1863     fschar_t * cellnamep;
1864
1865     temp = cm_ParseIoctlStringAlloc(ioctlp, ioctlp->inDatap + 2*sizeof(afs_uint32));
1866     cellnamep = cm_ClientStringToFsStringAlloc(temp, -1, NULL);
1867     cellp = cm_GetCell(cellnamep, 0);
1868     free(temp);
1869     free(cellnamep);
1870
1871     if (!cellp)
1872         return CM_ERROR_NOSUCHCELL;
1873
1874     memcpy((char *)&flags, ioctlp->inDatap, sizeof(afs_uint32));
1875
1876     lock_ObtainMutex(&cellp->mx);
1877     if (flags & CM_SETCELLFLAG_SUID)
1878         _InterlockedOr(&cellp->flags, CM_CELLFLAG_SUID);
1879     else
1880         _InterlockedAnd(&cellp->flags, ~CM_CELLFLAG_SUID);
1881     lock_ReleaseMutex(&cellp->mx);
1882
1883     return 0;
1884 }
1885
1886 /*
1887  * VIOC_SETSPREFS internals.
1888  *
1889  * Assumes that pioctl path has been parsed or skipped.
1890  */
1891 afs_int32
1892 cm_IoctlSetSPrefs(struct cm_ioctl *ioctlp, struct cm_user *userp)
1893 {
1894     cm_SSetPref_t     *spin;    /* input */
1895     cm_SPref_t        *srvin;   /* one input component */
1896     cm_server_t       *tsp;
1897     int                i, vlonly, noServers, type;
1898     struct sockaddr_in tmp;
1899     unsigned short     rank;
1900
1901     spin           = (cm_SSetPref_t *)ioctlp->inDatap;
1902     noServers  = spin->num_servers;
1903     vlonly     = spin->flags;
1904     if ( vlonly )
1905         type = CM_SERVER_VLDB;
1906     else
1907         type = CM_SERVER_FILE;
1908
1909     for ( i=0; i < noServers; i++)
1910     {
1911         srvin          = &(spin->servers[i]);
1912         rank           = srvin->rank + (rand() & 0x000f);
1913         tmp.sin_addr   = srvin->host;
1914         switch (type) {
1915         case CM_SERVER_VLDB:
1916             tmp.sin_port = htons(7003);
1917             break;
1918         case CM_SERVER_FILE:
1919             tmp.sin_port = htons(7000);
1920             break;
1921         }
1922         tmp.sin_family = AF_INET;
1923
1924         tsp = cm_FindServer(&tmp, type, FALSE);
1925         if ( tsp )              /* an existing server - ref count increased */
1926         {
1927             lock_ObtainMutex(&tsp->mx);
1928             tsp->ipRank = rank;
1929             _InterlockedOr(&tsp->flags, CM_SERVERFLAG_PREF_SET);
1930             tsp->adminRank = tsp->ipRank;
1931             lock_ReleaseMutex(&tsp->mx);
1932
1933             switch (type) {
1934             case CM_SERVER_FILE:
1935                 /*
1936                  * find volumes which might have RO copy
1937                  * on server and change the ordering of
1938                  * their RO list
1939                  */
1940                 cm_ChangeRankVolume(tsp);
1941                 break;
1942             case CM_SERVER_VLDB:
1943                 /* set preferences for an existing vlserver */
1944                 cm_ChangeRankCellVLServer(tsp);
1945                 break;
1946             }
1947         }
1948         else    /* add a new server without a cell */
1949         {
1950             tsp = cm_NewServer(&tmp, type, NULL, NULL, CM_FLAG_NOPROBE); /* refcount = 1 */
1951             lock_ObtainMutex(&tsp->mx);
1952             tsp->ipRank = rank;
1953             _InterlockedOr(&tsp->flags, CM_SERVERFLAG_PREF_SET);
1954             tsp->adminRank = tsp->ipRank;
1955             lock_ReleaseMutex(&tsp->mx);
1956             tsp->ipRank = rank;
1957         }
1958         cm_PutServer(tsp);  /* decrease refcount */
1959     }
1960     return 0;
1961 }
1962
1963 /*
1964  * VIOC_GETSPREFS internals.
1965  *
1966  * Assumes that pioctl path has been parsed or skipped.
1967  */
1968 afs_int32
1969 cm_IoctlGetSPrefs(struct cm_ioctl *ioctlp, struct cm_user *userp)
1970 {
1971     cm_SPrefRequest_t *spin; /* input */
1972     cm_SPrefInfo_t    *spout;   /* output */
1973     cm_SPref_t        *srvout;   /* one output component */
1974     cm_server_t       *tsp;
1975     int                   i, vlonly, noServers;
1976
1977     spin      = (cm_SPrefRequest_t *)ioctlp->inDatap;
1978     spout     = (cm_SPrefInfo_t *) ioctlp->outDatap;
1979     srvout    = spout->servers;
1980     noServers = spin->num_servers;
1981     vlonly    = spin->flags & CM_SPREF_VLONLY;
1982     spout->num_servers = 0;
1983
1984     lock_ObtainRead(&cm_serverLock); /* get server lock */
1985
1986     for (tsp=cm_allServersp, i=0; tsp && noServers; tsp=tsp->allNextp,i++){
1987         if (spin->offset > i) {
1988             continue;    /* catch up to where we left off */
1989         }
1990
1991         if ( vlonly && (tsp->type != CM_SERVER_VLDB) )
1992             continue;   /* ignore fileserver for -vlserver option*/
1993         if ( !vlonly && (tsp->type != CM_SERVER_FILE) )
1994             continue;   /* ignore vlservers */
1995
1996         srvout->host = tsp->addr.sin_addr;
1997         srvout->rank = tsp->ipRank;
1998         srvout++;
1999         spout->num_servers++;
2000         noServers--;
2001     }
2002     lock_ReleaseRead(&cm_serverLock); /* release server lock */
2003
2004     if ( tsp )  /* we ran out of space in the output buffer */
2005         spout->next_offset = i;
2006     else
2007         spout->next_offset = 0;
2008     ioctlp->outDatap += sizeof(cm_SPrefInfo_t) +
2009         (spout->num_servers -1 ) * sizeof(cm_SPref_t) ;
2010     return 0;
2011 }
2012
2013
2014 /*
2015  * VIOC_AFS_CREATE_MT_PT internals.
2016  *
2017  * Assumes that pioctl path has been parsed or skipped.
2018  * dscp is held but not locked.
2019  */
2020 afs_int32
2021 cm_IoctlCreateMountPoint(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *dscp, cm_req_t *reqp, clientchar_t *leaf)
2022 {
2023     afs_int32 code;
2024     cm_attr_t tattr;
2025     clientchar_t *cp;
2026     fschar_t mpInfo[512];           /* mount point string */
2027     fschar_t fullCell[CELL_MAXNAMELEN];
2028     fschar_t *fscell = NULL;
2029     fschar_t *fsvolume = NULL;
2030     clientchar_t volume[VL_MAXNAMELEN];
2031     clientchar_t *mpp = NULL;
2032     clientchar_t *cell = NULL;
2033     cm_volume_t *volp = NULL;
2034     cm_cell_t *cellp = NULL;
2035     size_t len;
2036
2037    /*
2038      * The fs command allows the user to specify partial cell names on NT.  These must
2039      * be expanded to the full cell name for mount points so that the mount points will
2040      * work on UNIX clients.
2041      */
2042
2043     /* Extract the possibly partial cell name */
2044     mpp = cm_ParseIoctlStringAlloc(ioctlp, NULL);
2045     cell = cm_ClientCharNext(mpp);
2046     if (cp = cm_ClientStrChr(cell, ':')) {
2047
2048         /* Extract the volume name */
2049         *cp = 0;
2050         cm_ClientStrCpy(volume, lengthof(volume), cm_ClientCharNext(cp));
2051
2052         fscell = cm_ClientStringToFsStringAlloc(cell, -1, NULL);
2053         fsvolume = cm_ClientStringToFsStringAlloc(volume, -1, NULL);
2054
2055         /* Get the full name for this cell */
2056         cellp = cm_GetCell_Gen(fscell, fullCell, CM_FLAG_NOPROBE);
2057         if (!cellp) {
2058             code = CM_ERROR_NOSUCHCELL;
2059             goto done;
2060         }
2061
2062         StringCbPrintfA(mpInfo, sizeof(mpInfo), "%c%s:%s.", (char) *mpp,
2063                         fullCell, fsvolume);
2064
2065     } else {
2066         /* No cell name specified, so cell points at the volume instead. */
2067         fsvolume = cm_ClientStringToFsStringAlloc(cell, -1, NULL);
2068         cm_ClientStringToFsString(mpp, -1, mpInfo, lengthof(mpInfo));
2069         cellp = cm_FindCellByID(dscp->fid.cell, CM_FLAG_NOPROBE);
2070     }
2071
2072     /* remove the trailing dot if it is present */
2073     len = strlen(fsvolume);
2074     if (len > 1 && fsvolume[len-1] == '.')
2075         fsvolume[len-1] = '\0';
2076
2077     /* validate the target info */
2078     if (cm_VolNameIsID(fsvolume)) {
2079         code = cm_FindVolumeByID(cellp, atoi(fsvolume), userp, reqp,
2080                                 CM_GETVOL_FLAG_CREATE, &volp);
2081     } else {
2082         code = cm_FindVolumeByName(cellp, fsvolume, userp, reqp,
2083                                   CM_GETVOL_FLAG_CREATE, &volp);
2084     }
2085     if (code)
2086         goto done;
2087
2088 #ifdef AFS_FREELANCE_CLIENT
2089     if (cm_freelanceEnabled && dscp == cm_data.rootSCachep) {
2090         /* we are adding the mount point to the root dir, so call
2091          * the freelance code to do the add. */
2092         fschar_t * fsleaf = cm_ClientStringToFsStringAlloc(leaf, -1, NULL);
2093         osi_Log0(afsd_logp,"IoctlCreateMountPoint within Freelance root dir");
2094         code = cm_FreelanceAddMount(fsleaf, fullCell, fsvolume, *mpInfo == '%', NULL);
2095         free(fsleaf);
2096     } else
2097 #endif
2098     {
2099         /* create the symlink with mode 644.  The lack of X bits tells
2100          * us that it is a mount point.
2101          */
2102         tattr.mask = CM_ATTRMASK_UNIXMODEBITS | CM_ATTRMASK_CLIENTMODTIME;
2103         tattr.unixModeBits = 0644;
2104         tattr.clientModTime = time(NULL);
2105
2106         code = cm_SymLink(dscp, leaf, mpInfo, 0, &tattr, userp, reqp, NULL);
2107     }
2108
2109     if (code == 0) {
2110         if (dscp->flags & CM_SCACHEFLAG_ANYWATCH)
2111             smb_NotifyChange(FILE_ACTION_ADDED,
2112                              FILE_NOTIFY_CHANGE_DIR_NAME,
2113                              dscp, leaf, NULL, TRUE);
2114
2115         if (RDR_Initialized)
2116             RDR_InvalidateObject(dscp->fid.cell, dscp->fid.volume, dscp->fid.vnode, dscp->fid.unique,
2117                                  dscp->fid.hash, dscp->fileType, AFS_INVALIDATE_DATA_VERSION);
2118     }
2119
2120   done:
2121     if (volp)
2122         cm_PutVolume(volp);
2123     if (mpp)
2124         free(mpp);
2125     if (fscell)
2126         free(fscell);
2127     if (fsvolume)
2128         free(fsvolume);
2129
2130     return code;
2131 }
2132
2133 /*
2134  * VIOC_SYMLINK internals.
2135  *
2136  * Assumes that pioctl path has been parsed or skipped.
2137  * dscp is held but not locked.
2138  */
2139 afs_int32
2140 cm_IoctlSymlink(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *dscp, cm_req_t *reqp, clientchar_t *leaf)
2141 {
2142     afs_int32 code;
2143     cm_attr_t tattr;
2144     char *cp;
2145
2146     if (!(ioctlp->flags & CM_IOCTLFLAG_USEUTF8)) {
2147         /* Translate chars for the linked to name */
2148         TranslateExtendedChars(ioctlp->inDatap);
2149     }
2150
2151     cp = ioctlp->inDatap;               /* contents of link */
2152
2153 #ifdef AFS_FREELANCE_CLIENT
2154     if (cm_freelanceEnabled && dscp == cm_data.rootSCachep) {
2155         /* we are adding the symlink to the root dir., so call
2156          * the freelance code to do the add. */
2157         fschar_t *fsleaf;
2158
2159         if (cp[0] == cp[1] && cp[1] == '\\' &&
2160             !_strnicmp(cm_NetbiosName,cp+2,strlen(cm_NetbiosName)))
2161         {
2162             /* skip \\AFS\ or \\AFS\all\ */
2163             char * p;
2164             p = cp + 2 + strlen(cm_NetbiosName) + 1;
2165             if ( !_strnicmp("all", p, 3) )
2166                 p += 4;
2167             cp = p;
2168         }
2169
2170         osi_Log0(afsd_logp,"IoctlSymlink within Freelance root dir");
2171         fsleaf = cm_ClientStringToFsStringAlloc(leaf, -1, NULL);
2172         code = cm_FreelanceAddSymlink(fsleaf, cp, NULL);
2173         free(fsleaf);
2174     } else
2175 #endif
2176     {
2177         /* Create symlink with mode 0755. */
2178         tattr.mask = CM_ATTRMASK_UNIXMODEBITS;
2179         tattr.unixModeBits = 0755;
2180
2181         code = cm_SymLink(dscp, leaf, cp, 0, &tattr, userp, reqp, NULL);
2182     }
2183
2184     if (code == 0) {
2185         if (dscp->flags & CM_SCACHEFLAG_ANYWATCH)
2186             smb_NotifyChange(FILE_ACTION_ADDED,
2187                              FILE_NOTIFY_CHANGE_FILE_NAME
2188                              | FILE_NOTIFY_CHANGE_DIR_NAME,
2189                              dscp, leaf, NULL, TRUE);
2190
2191         if (RDR_Initialized)
2192             RDR_InvalidateObject(dscp->fid.cell, dscp->fid.volume, dscp->fid.vnode, dscp->fid.unique,
2193                                  dscp->fid.hash, dscp->fileType, AFS_INVALIDATE_DATA_VERSION);
2194     }
2195
2196     return code;
2197 }
2198
2199
2200 /*
2201  * VIOC_LISTSYMLINK internals.
2202  *
2203  * Assumes that pioctl path has been parsed or skipped.
2204  * dscp is held but not locked.
2205  */
2206 afs_int32
2207 cm_IoctlListlink(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *dscp, cm_req_t *reqp)
2208 {
2209     afs_int32 code;
2210     cm_scache_t *scp;
2211     char *cp;
2212     cm_space_t *spacep;
2213     cm_scache_t *newRootScp;
2214     clientchar_t *clientp;
2215
2216     if (!(ioctlp->flags & CM_IOCTLFLAG_USEUTF8)) {
2217         /* Translate chars for the link name */
2218         TranslateExtendedChars(ioctlp->inDatap);
2219     }
2220     cp = ioctlp->inDatap;
2221
2222     clientp = cm_Utf8ToClientStringAlloc(cp, -1, NULL);
2223     code = cm_Lookup(dscp, clientp[0] ? clientp : L".", CM_FLAG_NOMOUNTCHASE, userp, reqp, &scp);
2224     free(clientp);
2225     if (code)
2226         return code;
2227
2228     /* Check that it's a real symlink */
2229     if (scp->fileType != CM_SCACHETYPE_SYMLINK &&
2230         scp->fileType != CM_SCACHETYPE_DFSLINK &&
2231         scp->fileType != CM_SCACHETYPE_INVALID) {
2232         cm_ReleaseSCache(scp);
2233         return CM_ERROR_INVAL;
2234     }
2235
2236     code = cm_AssembleLink(scp, "", &newRootScp, &spacep, userp, reqp);
2237     cm_ReleaseSCache(scp);
2238     if (code == 0) {
2239         char * linkstr;
2240         cp = ioctlp->outDatap;
2241         if (newRootScp != NULL) {
2242             StringCbCopyA(cp, SMB_IOCTL_MAXDATA - (cp - ioctlp->outAllocp), cm_mountRoot);
2243             StringCbCatA(cp, SMB_IOCTL_MAXDATA - (cp - ioctlp->outAllocp), "/");
2244             cp += strlen(cp);
2245         }
2246
2247         linkstr = cm_ClientStringToFsStringAlloc(spacep->wdata, -1, NULL);
2248         StringCbCopyA(cp, SMB_IOCTL_MAXDATA - (cp - ioctlp->outAllocp), linkstr);
2249         cp += strlen(cp) + 1;
2250         ioctlp->outDatap = cp;
2251         cm_FreeSpace(spacep);
2252         free(linkstr);
2253         if (newRootScp != NULL)
2254             cm_ReleaseSCache(newRootScp);
2255         code = 0;
2256     } else if (code == CM_ERROR_PATH_NOT_COVERED &&
2257                 scp->fileType == CM_SCACHETYPE_DFSLINK ||
2258                code == CM_ERROR_NOSUCHPATH &&
2259                 scp->fileType == CM_SCACHETYPE_INVALID) {
2260
2261         cp = ioctlp->outDatap;
2262         StringCbCopyA(cp, SMB_IOCTL_MAXDATA - (cp - ioctlp->outAllocp), scp->mountPointStringp);
2263         cp += strlen(cp) + 1;
2264         ioctlp->outDatap = cp;
2265         code = 0;
2266     }
2267
2268     return code;
2269 }
2270
2271 /*
2272  * VIOC_ISSYMLINK internals.
2273  *
2274  * Assumes that pioctl path has been parsed or skipped.
2275  * dscp is held but not locked.
2276  */
2277 afs_int32
2278 cm_IoctlIslink(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *dscp, cm_req_t *reqp)
2279 {/*CHECK FOR VALID SYMLINK*/
2280     afs_int32 code;
2281     cm_scache_t *scp;
2282     char *cp;
2283     clientchar_t *clientp;
2284
2285     if (!(ioctlp->flags & CM_IOCTLFLAG_USEUTF8)) {
2286         /* Translate chars for the link name */
2287         TranslateExtendedChars(ioctlp->inDatap);
2288     }
2289     cp = ioctlp->inDatap;
2290
2291     clientp = cm_Utf8ToClientStringAlloc(cp, -1, NULL);
2292     code = cm_Lookup(dscp, clientp[0] ? clientp : L".", CM_FLAG_NOMOUNTCHASE, userp, reqp, &scp);
2293     free(clientp);
2294     if (code)
2295         return code;
2296
2297     /* Check that it's a real symlink */
2298     if (scp->fileType != CM_SCACHETYPE_SYMLINK &&
2299         scp->fileType != CM_SCACHETYPE_DFSLINK &&
2300         scp->fileType != CM_SCACHETYPE_INVALID)
2301         code = CM_ERROR_INVAL;
2302     cm_ReleaseSCache(scp);
2303     return code;
2304 }
2305
2306 /*
2307  * VIOC_DELSYMLINK internals.
2308  *
2309  * Assumes that pioctl path has been parsed or skipped.
2310  * dscp is held but not locked.
2311  */
2312 afs_int32
2313 cm_IoctlDeletelink(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *dscp, cm_req_t *reqp)
2314 {
2315     afs_int32 code;
2316     cm_scache_t *scp;
2317     char *cp;
2318     char * originalName = NULL;
2319     cm_dirOp_t dirop;
2320     clientchar_t *clientp;
2321
2322     if (!(ioctlp->flags & CM_IOCTLFLAG_USEUTF8)) {
2323         /* Translate chars for the link name */
2324         TranslateExtendedChars(ioctlp->inDatap);
2325     }
2326     cp = ioctlp->inDatap;
2327
2328     clientp = cm_Utf8ToClientStringAlloc(cp, -1, NULL);
2329     code = cm_Lookup(dscp, clientp[0] ? clientp : L".", CM_FLAG_NOMOUNTCHASE, userp, reqp, &scp);
2330
2331     /* if something went wrong, bail out now */
2332     if (code)
2333         goto done3;
2334
2335     lock_ObtainWrite(&scp->rw);
2336     code = cm_SyncOp(scp, NULL, userp, reqp, 0,
2337                       CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
2338     if (code)
2339         goto done2;
2340
2341     /* now check that this is a real symlink */
2342     if (scp->fileType != CM_SCACHETYPE_SYMLINK &&
2343         scp->fileType != CM_SCACHETYPE_DFSLINK &&
2344         scp->fileType != CM_SCACHETYPE_INVALID) {
2345         code = CM_ERROR_INVAL;
2346         goto done1;
2347     }
2348
2349     /* time to make the RPC, so drop the lock */
2350     lock_ReleaseWrite(&scp->rw);
2351
2352 #ifdef USE_BPLUS
2353     code = cm_BeginDirOp(dscp, userp, reqp, CM_DIRLOCK_READ,
2354                          CM_DIROP_FLAG_NONE, &dirop);
2355     if (code == 0) {
2356         code = cm_BPlusDirLookupOriginalName(&dirop, clientp, &originalName);
2357         /* cm_Dir*() functions can't be used to lookup the original
2358            name since those functions only know of the original
2359            name. */
2360         cm_EndDirOp(&dirop);
2361     }
2362 #endif
2363
2364     /* If this name doesn't have a non-normalized name associated with
2365        it, we assume that what we had is what is actually present on
2366        the file server. */
2367
2368     if (originalName == NULL)
2369         originalName = cp;
2370
2371     /* cp is a normalized name.  originalName is the actual name we
2372        saw on the fileserver. */
2373
2374
2375 #ifdef AFS_FREELANCE_CLIENT
2376     if (cm_freelanceEnabled && dscp == cm_data.rootSCachep) {
2377         /* we are adding the mount point to the root dir., so call
2378          * the freelance code to do the add. */
2379         osi_Log0(afsd_logp,"IoctlDeletelink from Freelance root dir");
2380         code = cm_FreelanceRemoveSymlink(originalName);
2381     } else
2382 #endif
2383     {
2384         /* easier to do it this way */
2385         code = cm_Unlink(dscp, originalName, clientp, userp, reqp);
2386     }
2387     if (code == 0 && (dscp->flags & CM_SCACHEFLAG_ANYWATCH))
2388         smb_NotifyChange(FILE_ACTION_REMOVED,
2389                           FILE_NOTIFY_CHANGE_FILE_NAME
2390                           | FILE_NOTIFY_CHANGE_DIR_NAME,
2391                           dscp, clientp, NULL, TRUE);
2392
2393     if (originalName != NULL && originalName != cp) {
2394         free(originalName);
2395         originalName = NULL;
2396     }
2397
2398     lock_ObtainWrite(&scp->rw);
2399   done1:
2400     cm_SyncOpDone(scp, NULL, CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
2401
2402   done2:
2403     cm_DiscardSCache(scp);
2404     lock_ReleaseWrite(&scp->rw);
2405     cm_ReleaseSCache(scp);
2406
2407     if (RDR_Initialized &&
2408         !RDR_InvalidateObject(scp->fid.cell, scp->fid.volume, scp->fid.vnode, scp->fid.unique,
2409                               scp->fid.hash, scp->fileType, AFS_INVALIDATE_DELETED))
2410         buf_ClearRDRFlag(scp, "deleted link");
2411
2412   done3:
2413     free(clientp);
2414
2415     return code;
2416 }
2417
2418 #ifdef QUERY_AFSID
2419 /* Utility function.  Not currently used.
2420  * This function performs a PTS lookup which has traditionally
2421  * not been performed by the cache manager.
2422  */
2423 afs_int32
2424 cm_UsernameToId(char *uname, cm_ucell_t * ucellp, afs_uint32* uid)
2425 {
2426     afs_int32 code;
2427     namelist lnames;
2428     idlist lids;
2429     static struct afsconf_cell info;
2430     struct rx_connection *serverconns[MAXSERVERS];
2431     struct rx_securityClass *sc[3];
2432     afs_int32 scIndex = 2;      /* authenticated - we have a token */
2433     struct ubik_client *pruclient = NULL;
2434     struct afsconf_dir *tdir;
2435     int i;
2436     char * p, * r;
2437
2438     memset(&info, 0, sizeof(info));
2439     tdir = afsconf_Open(AFSDIR_CLIENT_ETC_DIRPATH);
2440     code = afsconf_GetCellInfo(tdir, ucellp->cellp->name, "afsprot", &info);
2441     afsconf_Close(tdir);
2442
2443     sc[0] = 0;
2444     sc[1] = 0;
2445     sc[2] = 0;
2446
2447     /* we have the token that was given to us in the settoken
2448      * call.   we just have to use it.
2449      */
2450     scIndex = 2;        /* kerberos ticket */
2451     sc[2] = rxkad_NewClientSecurityObject(rxkad_clear, &ucellp->sessionKey,
2452                                           ucellp->kvno, ucellp->ticketLen,
2453                                           ucellp->ticketp);
2454
2455     memset(serverconns, 0, sizeof(serverconns));        /* terminate list!!! */
2456     for (i = 0; i < info.numServers; i++)
2457         serverconns[i] =
2458             rx_NewConnection(info.hostAddr[i].sin_addr.s_addr,
2459                              info.hostAddr[i].sin_port, PRSRV, sc[scIndex],
2460                              scIndex);
2461
2462     code = ubik_ClientInit(serverconns, &pruclient);
2463     if (code) {
2464         if (info.linkedCell)
2465             free(info.linkedCell);
2466         return code;
2467     }
2468
2469     code = rxs_Release(sc[scIndex]);
2470
2471     lids.idlist_len = 0;
2472     lids.idlist_val = 0;
2473     lnames.namelist_len = 1;
2474     lnames.namelist_val = (prname *) malloc(PR_MAXNAMELEN);
2475     strncpy(lnames.namelist_val[0], uname, PR_MAXNAMELEN);
2476     lnames.namelist_val[0][PR_MAXNAMELEN-1] = '\0';
2477     for ( p=lnames.namelist_val[0], r=NULL; *p; p++ ) {
2478         if (isupper(*p))
2479             *p = tolower(*p);
2480         if (*p == '@')
2481             r = p;
2482     }
2483     if (r && !cm_stricmp_utf8(r+1,ucellp->cellp->name))
2484         *r = '\0';
2485
2486     code = ubik_PR_NameToID(pruclient, 0, &lnames, &lids);
2487     if (lids.idlist_val) {
2488         *uid = *lids.idlist_val;
2489         free(lids.idlist_val);
2490     }
2491     if (lnames.namelist_val)
2492         free(lnames.namelist_val);
2493
2494     if ( pruclient ) {
2495         ubik_ClientDestroy(pruclient);
2496         pruclient = NULL;
2497     }
2498
2499     if (info.linkedCell)
2500         free(info.linkedCell);
2501     return 0;
2502 }
2503 #endif /* QUERY_AFSID */
2504
2505 #if 0
2506 /* This has been copied to smb_IoctlSetToken in its entirety.
2507  * An equivalent version will need to be produced for the
2508  * redirector and some extensive refactoring might be required.
2509  */
2510 afs_int32
2511 cm_IoctlSetToken(struct cm_ioctl *ioctlp, struct cm_user *userp)
2512 {
2513     char *saveDataPtr;
2514     char *tp;
2515     int ticketLen;
2516     char *ticket;
2517     int ctSize;
2518     struct ClearToken ct;
2519     cm_cell_t *cellp;
2520     cm_ucell_t *ucellp;
2521     char *uname = NULL;
2522     afs_uuid_t uuid;
2523     int flags;
2524     char sessionKey[8];
2525     char *smbname;
2526     int release_userp = 0;
2527     char * wdir = NULL;
2528
2529     saveDataPtr = ioctlp->inDatap;
2530
2531     cm_SkipIoctlPath(ioctlp);
2532
2533     tp = ioctlp->inDatap;
2534
2535     /* ticket length */
2536     memcpy(&ticketLen, tp, sizeof(ticketLen));
2537     tp += sizeof(ticketLen);
2538     if (ticketLen < MINKTCTICKETLEN || ticketLen > MAXKTCTICKETLEN)
2539         return CM_ERROR_INVAL;
2540
2541     /* remember ticket and skip over it for now */
2542     ticket = tp;
2543     tp += ticketLen;
2544
2545     /* clear token size */
2546     memcpy(&ctSize, tp, sizeof(ctSize));
2547     tp += sizeof(ctSize);
2548     if (ctSize != sizeof(struct ClearToken))
2549         return CM_ERROR_INVAL;
2550
2551     /* clear token */
2552     memcpy(&ct, tp, ctSize);
2553     tp += ctSize;
2554     if (ct.AuthHandle == -1)
2555         ct.AuthHandle = 999;    /* more rxvab compat stuff */
2556
2557     /* more stuff, if any */
2558     if (ioctlp->inCopied > tp - saveDataPtr) {
2559         /* flags:  logon flag */
2560         memcpy(&flags, tp, sizeof(int));
2561         tp += sizeof(int);
2562
2563         /* cell name */
2564         cellp = cm_GetCell(tp, CM_FLAG_CREATE | CM_FLAG_NOPROBE);
2565         if (!cellp)
2566             return CM_ERROR_NOSUCHCELL;
2567         tp += strlen(tp) + 1;
2568
2569         /* user name */
2570         uname = tp;
2571         tp += strlen(tp) + 1;
2572
2573         if (flags & PIOCTL_LOGON) {
2574             /* SMB user name with which to associate tokens */
2575             smbname = tp;
2576             osi_Log2(smb_logp,"cm_IoctlSetToken for user [%s] smbname [%s]",
2577                      osi_LogSaveString(smb_logp,uname), osi_LogSaveString(smb_logp,smbname));
2578             fprintf(stderr, "SMB name = %s\n", smbname);
2579             tp += strlen(tp) + 1;
2580         } else {
2581             osi_Log1(smb_logp,"cm_IoctlSetToken for user [%s]",
2582                      osi_LogSaveString(smb_logp, uname));
2583         }
2584
2585                 /* uuid */
2586         memcpy(&uuid, tp, sizeof(uuid));
2587         if (!cm_FindTokenEvent(uuid, sessionKey))
2588             return CM_ERROR_INVAL;
2589     } else {
2590         cellp = cm_data.rootCellp;
2591         osi_Log0(smb_logp,"cm_IoctlSetToken - no name specified");
2592     }
2593
2594     if (flags & PIOCTL_LOGON) {
2595         clientchar_t *cname;
2596
2597         cname = cm_FsStringToClientStringAlloc(smbname, -1, NULL);
2598
2599         userp = smb_FindCMUserByName(cname, ioctlp->fidp->vcp->rname,
2600                                      SMB_FLAG_CREATE|SMB_FLAG_AFSLOGON);
2601         if (cname)
2602             free(cname);
2603         release_userp = 1;
2604     }
2605
2606     /* store the token */
2607     lock_ObtainMutex(&userp->mx);
2608     ucellp = cm_GetUCell(userp, cellp);
2609     osi_Log1(smb_logp,"cm_IoctlSetToken ucellp %lx", ucellp);
2610     ucellp->ticketLen = ticketLen;
2611     if (ucellp->ticketp)
2612         free(ucellp->ticketp);  /* Discard old token if any */
2613     ucellp->ticketp = malloc(ticketLen);
2614     memcpy(ucellp->ticketp, ticket, ticketLen);
2615     /*
2616      * Get the session key from the RPC, rather than from the pioctl.
2617      */
2618     /*
2619     memcpy(&ucellp->sessionKey, ct.HandShakeKey, sizeof(ct.HandShakeKey));
2620     */
2621     memcpy(ucellp->sessionKey.data, sessionKey, sizeof(sessionKey));
2622     ucellp->kvno = ct.AuthHandle;
2623     ucellp->expirationTime = ct.EndTimestamp;
2624     ucellp->gen++;
2625 #ifdef QUERY_AFSID
2626     ucellp->uid = ANONYMOUSID;
2627 #endif
2628     if (uname) {
2629         StringCbCopyA(ucellp->userName, MAXKTCNAMELEN, uname);
2630 #ifdef QUERY_AFSID
2631         cm_UsernameToId(uname, ucellp, &ucellp->uid);
2632 #endif
2633     }
2634     _InterlockedOr(&ucellp->flags, CM_UCELLFLAG_RXKAD);
2635     lock_ReleaseMutex(&userp->mx);
2636
2637     if (flags & PIOCTL_LOGON) {
2638         ioctlp->flags |= CM_IOCTLFLAG_LOGON;
2639     }
2640
2641     cm_ResetACLCache(cellp, userp);
2642
2643     if (release_userp)
2644         cm_ReleaseUser(userp);
2645
2646     return 0;
2647 }
2648 #endif
2649
2650 /*
2651  * VIOC_GETTOK internals.
2652  *
2653  * Assumes that pioctl path has been parsed or skipped.
2654  */
2655 afs_int32
2656 cm_IoctlGetTokenIter(struct cm_ioctl *ioctlp, struct cm_user *userp)
2657 {
2658     char *tp, *cp;
2659     int iterator;
2660     int temp;
2661     cm_ucell_t *ucellp;
2662     struct ClearToken ct;
2663
2664     tp = ioctlp->inDatap;
2665     cp = ioctlp->outDatap;
2666
2667     /* iterator */
2668     memcpy(&iterator, tp, sizeof(iterator));
2669     tp += sizeof(iterator);
2670
2671     lock_ObtainMutex(&userp->mx);
2672
2673     /* look for token */
2674     for (;;iterator++) {
2675         ucellp = cm_FindUCell(userp, iterator);
2676         if (!ucellp) {
2677             lock_ReleaseMutex(&userp->mx);
2678             return CM_ERROR_NOMORETOKENS;
2679         }
2680         if (ucellp->flags & CM_UCELLFLAG_RXKAD)
2681             break;
2682     }
2683
2684     /* new iterator */
2685     temp = ucellp->iterator + 1;
2686     memcpy(cp, &temp, sizeof(temp));
2687     cp += sizeof(temp);
2688
2689     /* ticket length */
2690     memcpy(cp, &ucellp->ticketLen, sizeof(ucellp->ticketLen));
2691     cp += sizeof(ucellp->ticketLen);
2692
2693     /* ticket */
2694     memcpy(cp, ucellp->ticketp, ucellp->ticketLen);
2695     cp += ucellp->ticketLen;
2696
2697     /* clear token size */
2698     temp = sizeof(ct);
2699     memcpy(cp, &temp, sizeof(temp));
2700     cp += sizeof(temp);
2701
2702     /* clear token */
2703     ct.AuthHandle = ucellp->kvno;
2704
2705     /*
2706      * This field is supposed to hold the session key
2707      * but we don't want to make it easier for someone
2708      * to attack the cache.  The user gave us the session
2709      * key in the first place.
2710      */
2711     memset(ct.HandShakeKey, 0, sizeof(ct.HandShakeKey));
2712     ct.ViceId = 37;                     /* XXX */
2713     ct.BeginTimestamp = 0;              /* XXX */
2714     ct.EndTimestamp = ucellp->expirationTime;
2715     memcpy(cp, &ct, sizeof(ct));
2716     cp += sizeof(ct);
2717
2718     /* Primary flag (unused) */
2719     temp = 0;
2720     memcpy(cp, &temp, sizeof(temp));
2721     cp += sizeof(temp);
2722
2723     /* cell name */
2724     StringCbCopyA(cp, SMB_IOCTL_MAXDATA - (cp - ioctlp->outAllocp), ucellp->cellp->name);
2725     cp += strlen(cp) + 1;
2726
2727     /* user name */
2728     StringCbCopyA(cp, SMB_IOCTL_MAXDATA - (cp - ioctlp->outAllocp), ucellp->userName);
2729     cp += strlen(cp) + 1;
2730
2731     ioctlp->outDatap = cp;
2732
2733     lock_ReleaseMutex(&userp->mx);
2734
2735     return 0;
2736 }
2737
2738 /*
2739  * VIOC_NEWGETTOK internals.
2740  *
2741  * Assumes that pioctl path has been parsed or skipped.
2742  */
2743 afs_int32
2744 cm_IoctlGetToken(struct cm_ioctl *ioctlp, struct cm_user *userp)
2745 {
2746     char *cp;
2747     int temp;
2748     cm_cell_t *cellp;
2749     cm_ucell_t *ucellp;
2750     struct ClearToken ct;
2751     char *tp;
2752     afs_uuid_t uuid;
2753
2754     tp = ioctlp->inDatap;
2755
2756     cp = ioctlp->outDatap;
2757
2758     /* cell name is right here */
2759     cellp = cm_GetCell(tp, 0);
2760     if (!cellp)
2761         return CM_ERROR_NOSUCHCELL;
2762     tp += strlen(tp) + 1;
2763
2764     /* uuid */
2765     memcpy(&uuid, tp, sizeof(uuid));
2766
2767     lock_ObtainMutex(&userp->mx);
2768
2769     ucellp = cm_GetUCell(userp, cellp);
2770     if (!ucellp || !(ucellp->flags & CM_UCELLFLAG_RXKAD)) {
2771         lock_ReleaseMutex(&userp->mx);
2772         return CM_ERROR_NOMORETOKENS;
2773     }
2774
2775     /* ticket length */
2776     memcpy(cp, &ucellp->ticketLen, sizeof(ucellp->ticketLen));
2777     cp += sizeof(ucellp->ticketLen);
2778
2779     /* ticket */
2780     memcpy(cp, ucellp->ticketp, ucellp->ticketLen);
2781     cp += ucellp->ticketLen;
2782
2783     /* clear token size */
2784     temp = sizeof(ct);
2785     memcpy(cp, &temp, sizeof(temp));
2786     cp += sizeof(temp);
2787
2788     /* clear token */
2789     ct.AuthHandle = ucellp->kvno;
2790
2791     /* do not give out the session key */
2792     memset(ct.HandShakeKey, 0, sizeof(ct.HandShakeKey));
2793     ct.ViceId = 37;                     /* XXX */
2794     ct.BeginTimestamp = 0;              /* XXX */
2795     ct.EndTimestamp = ucellp->expirationTime;
2796     memcpy(cp, &ct, sizeof(ct));
2797     cp += sizeof(ct);
2798
2799     /* Primary flag (unused) */
2800     temp = 0;
2801     memcpy(cp, &temp, sizeof(temp));
2802     cp += sizeof(temp);
2803
2804     /* cell name */
2805     StringCbCopyA(cp, SMB_IOCTL_MAXDATA - (cp - ioctlp->outAllocp), ucellp->cellp->name);
2806     cp += strlen(cp) + 1;
2807
2808     /* user name */
2809     StringCbCopyA(cp, SMB_IOCTL_MAXDATA - (cp - ioctlp->outAllocp), ucellp->userName);
2810     cp += strlen(cp) + 1;
2811
2812     ioctlp->outDatap = cp;
2813
2814     lock_ReleaseMutex(&userp->mx);
2815
2816     cm_RegisterNewTokenEvent(uuid, ucellp->sessionKey.data, NULL);
2817
2818     return 0;
2819 }
2820
2821 /*
2822  * VIOCDELTOK internals.
2823  *
2824  * Assumes that pioctl path has been parsed or skipped.
2825  */
2826 afs_int32
2827 cm_IoctlDelToken(struct cm_ioctl *ioctlp, struct cm_user *userp)
2828 {
2829     char *cp;
2830     cm_cell_t *cellp;
2831     cm_ucell_t *ucellp;
2832
2833     cp = ioctlp->outDatap;
2834
2835     /* cell name is right here */
2836     cellp = cm_GetCell(ioctlp->inDatap, 0);
2837     if (!cellp)
2838         return CM_ERROR_NOSUCHCELL;
2839
2840     lock_ObtainMutex(&userp->mx);
2841
2842     ucellp = cm_GetUCell(userp, cellp);
2843     if (!ucellp) {
2844         lock_ReleaseMutex(&userp->mx);
2845         return CM_ERROR_NOMORETOKENS;
2846     }
2847
2848     osi_Log1(smb_logp,"cm_IoctlDelToken ucellp %lx", ucellp);
2849
2850     if (ucellp->ticketp) {
2851         free(ucellp->ticketp);
2852         ucellp->ticketp = NULL;
2853     }
2854     ucellp->ticketLen = 0;
2855     memset(ucellp->sessionKey.data, 0, 8);
2856     ucellp->kvno = 0;
2857     ucellp->expirationTime = 0;
2858     ucellp->userName[0] = '\0';
2859     _InterlockedAnd(&ucellp->flags, ~CM_UCELLFLAG_RXKAD);
2860     ucellp->gen++;
2861
2862     lock_ReleaseMutex(&userp->mx);
2863
2864     cm_ResetACLCache(cellp, userp);
2865
2866     return 0;
2867 }
2868
2869 /*
2870  * VIOCDELALLTOK internals.
2871  *
2872  * Assumes that pioctl path has been parsed or skipped.
2873  */
2874 afs_int32
2875 cm_IoctlDelAllToken(struct cm_ioctl *ioctlp, struct cm_user *userp)
2876 {
2877     cm_ucell_t *ucellp;
2878
2879     lock_ObtainMutex(&userp->mx);
2880
2881     for (ucellp = userp->cellInfop; ucellp; ucellp = ucellp->nextp) {
2882         osi_Log1(smb_logp,"cm_IoctlDelAllToken ucellp %lx", ucellp);
2883
2884         if (ucellp->ticketp) {
2885             free(ucellp->ticketp);
2886             ucellp->ticketp = NULL;
2887         }
2888         ucellp->ticketLen = 0;
2889         memset(ucellp->sessionKey.data, 0, 8);
2890         ucellp->kvno = 0;
2891         ucellp->expirationTime = 0;
2892         ucellp->userName[0] = '\0';
2893         _InterlockedAnd(&ucellp->flags, ~CM_UCELLFLAG_RXKAD);
2894         ucellp->gen++;
2895     }
2896
2897     lock_ReleaseMutex(&userp->mx);
2898
2899     cm_ResetACLCache(NULL, userp);
2900
2901     return 0;
2902 }
2903
2904 /*
2905  * VIOC_MAKESUBMOUNT internals.  (This function should be deprecated)
2906  *
2907  * Assumes that pioctl path has been parsed or skipped.
2908  */
2909 afs_int32
2910 cm_IoctlMakeSubmount(cm_ioctl_t *ioctlp, cm_user_t *userp)
2911 {
2912     char afspath[MAX_PATH];
2913     char *submountreqp;
2914     int nextAutoSubmount;
2915     HKEY hkSubmounts;
2916     DWORD dwType, dwSize;
2917     DWORD status;
2918     DWORD dwIndex;
2919     DWORD dwSubmounts;
2920
2921     /* Serialize this one, to prevent simultaneous mods
2922      * to afsdsbmt.ini
2923      */
2924     lock_ObtainMutex(&cm_Afsdsbmt_Lock);
2925
2926     /* Parse the input parameters--first the required afs path,
2927      * then the requested submount name (which may be "").
2928      */
2929     cm_NormalizeAfsPathAscii(afspath, sizeof(afspath), ioctlp->inDatap);
2930     submountreqp = ioctlp->inDatap + (strlen(ioctlp->inDatap)+1);
2931
2932     /* If the caller supplied a suggested submount name, see if
2933      * that submount name is in use... if so, the submount's path
2934      * has to match our path.
2935      */
2936
2937     RegCreateKeyEx( HKEY_LOCAL_MACHINE,
2938                     AFSREG_CLT_OPENAFS_SUBKEY "\\Submounts",
2939                     0,
2940                     "AFS",
2941                     REG_OPTION_NON_VOLATILE,
2942                     KEY_READ|KEY_WRITE|KEY_QUERY_VALUE,
2943                     NULL,
2944                     &hkSubmounts,
2945                     NULL );
2946
2947     if (submountreqp && *submountreqp) {
2948         char submountPath[MAX_PATH];
2949
2950         dwSize = sizeof(submountPath);
2951         status = RegQueryValueEx( hkSubmounts, submountreqp, 0,
2952                                   &dwType, submountPath, &dwSize);
2953
2954         if (status != ERROR_SUCCESS) {
2955
2956             /* The suggested submount name isn't in use now--
2957              * so we can safely map the requested submount name
2958              * to the supplied path. Remember not to write the
2959              * leading "/afs" when writing out the submount.
2960              */
2961             RegSetValueEx( hkSubmounts, submountreqp, 0,
2962                            REG_EXPAND_SZ,
2963                            (strlen(&afspath[strlen(cm_mountRoot)])) ?
2964                            &afspath[strlen(cm_mountRoot)]:"/",
2965                            (strlen(&afspath[strlen(cm_mountRoot)])) ?
2966                            (DWORD)strlen(&afspath[strlen(cm_mountRoot)])+1:2);
2967
2968             RegCloseKey( hkSubmounts );
2969             StringCbCopyA(ioctlp->outDatap, SMB_IOCTL_MAXDATA - (ioctlp->outDatap - ioctlp->outAllocp), submountreqp);
2970             ioctlp->outDatap += strlen(ioctlp->outDatap) +1;
2971             lock_ReleaseMutex(&cm_Afsdsbmt_Lock);
2972             return 0;
2973         }
2974
2975         /* The suggested submount name is already in use--if the
2976          * supplied path matches the submount's path, we can still
2977          * use the suggested submount name.
2978          */
2979         if (!strcmp (submountPath, afspath)) {
2980             StringCbCopyA(ioctlp->outDatap, SMB_IOCTL_MAXDATA - (ioctlp->outDatap - ioctlp->outAllocp), submountreqp);
2981             ioctlp->outDatap += strlen(ioctlp->outDatap) +1;
2982             RegCloseKey( hkSubmounts );
2983             lock_ReleaseMutex(&cm_Afsdsbmt_Lock);
2984             return 0;
2985         }
2986     }
2987
2988     RegQueryInfoKey( hkSubmounts,
2989                      NULL,  /* lpClass */
2990                      NULL,  /* lpcClass */
2991                      NULL,  /* lpReserved */
2992                      NULL,  /* lpcSubKeys */
2993                      NULL,  /* lpcMaxSubKeyLen */
2994                      NULL,  /* lpcMaxClassLen */
2995                      &dwSubmounts, /* lpcValues */
2996                      NULL,  /* lpcMaxValueNameLen */
2997                      NULL,  /* lpcMaxValueLen */
2998                      NULL,  /* lpcbSecurityDescriptor */
2999                      NULL   /* lpftLastWriteTime */
3000                      );
3001
3002
3003     /* Having obtained a list of all available submounts, start
3004      * searching that list for a path which matches the requested
3005      * AFS path. We'll also keep track of the highest "auto15"/"auto47"
3006      * submount, in case we need to add a new one later.
3007      */
3008
3009     nextAutoSubmount = 1;
3010
3011     for ( dwIndex = 0; dwIndex < dwSubmounts; dwIndex ++ ) {
3012         char submountPath[MAX_PATH] = "";
3013         DWORD submountPathLen = sizeof(submountPath);
3014         char submountName[MAX_PATH];
3015         DWORD submountNameLen = sizeof(submountName);
3016
3017         dwType = 0;
3018         RegEnumValue( hkSubmounts, dwIndex, submountName, &submountNameLen, NULL,
3019                       &dwType, submountPath, &submountPathLen);
3020         if (dwType == REG_EXPAND_SZ) {
3021             char buf[MAX_PATH];
3022             StringCbCopyA(buf, MAX_PATH, submountPath);
3023             submountPathLen = ExpandEnvironmentStrings(buf, submountPath, MAX_PATH);
3024             if (submountPathLen > MAX_PATH)
3025                 continue;
3026         }
3027
3028         /* If this is an Auto### submount, remember its ### value */
3029         if ((!strnicmp (submountName, "auto", 4)) &&
3030              (isdigit (submountName[strlen("auto")]))) {
3031             int thisAutoSubmount;
3032             thisAutoSubmount = atoi (&submountName[strlen("auto")]);
3033             nextAutoSubmount = max (nextAutoSubmount,
3034                                      thisAutoSubmount+1);
3035         }
3036
3037         if ((submountPathLen == 0) ||
3038              (submountPathLen == sizeof(submountPath) - 1)) {
3039             continue;
3040         }
3041
3042         /* See if the path for this submount matches the path
3043          * that our caller specified. If so, we can return
3044          * this submount.
3045          */
3046         if (!strcmp (submountPath, afspath)) {
3047             StringCbCopyA(ioctlp->outDatap, SMB_IOCTL_MAXDATA - (ioctlp->outDatap - ioctlp->outAllocp), submountName);
3048             ioctlp->outDatap += strlen(ioctlp->outDatap) +1;
3049             RegCloseKey(hkSubmounts);
3050             lock_ReleaseMutex(&cm_Afsdsbmt_Lock);
3051             return 0;
3052
3053         }
3054     }
3055
3056     /* We've been through the entire list of existing submounts, and
3057      * didn't find any which matched the specified path. So, we'll
3058      * just have to add one. Remember not to write the leading "/afs"
3059      * when writing out the submount.
3060      */
3061
3062     StringCbPrintfA(ioctlp->outDatap, SMB_IOCTL_MAXDATA - (ioctlp->outDatap - ioctlp->outAllocp), "auto%ld", nextAutoSubmount);
3063
3064     RegSetValueEx( hkSubmounts,
3065                    ioctlp->outDatap,
3066                    0,
3067                    REG_EXPAND_SZ,
3068                    (strlen(&afspath[strlen(cm_mountRoot)])) ?
3069                    &afspath[strlen(cm_mountRoot)]:"/",
3070                    (strlen(&afspath[strlen(cm_mountRoot)])) ?
3071                    (DWORD)strlen(&afspath[strlen(cm_mountRoot)])+1:2);
3072
3073     ioctlp->outDatap += strlen(ioctlp->outDatap) +1;
3074     RegCloseKey(hkSubmounts);
3075     lock_ReleaseMutex(&cm_Afsdsbmt_Lock);
3076     return 0;
3077 }
3078
3079 /*
3080  * VIOC_GETRXKCRYPT internals.
3081  *
3082  * Assumes that pioctl path has been parsed or skipped.
3083  */
3084 afs_int32
3085 cm_IoctlGetRxkcrypt(cm_ioctl_t *ioctlp, cm_user_t *userp)
3086 {
3087     memcpy(ioctlp->outDatap, &cryptall, sizeof(cryptall));
3088     ioctlp->outDatap += sizeof(cryptall);
3089
3090     return 0;
3091 }
3092
3093 /*
3094  * VIOC_SETRXKCRYPT internals.
3095  *
3096  * Assumes that pioctl path has been parsed or skipped.
3097  */
3098 afs_int32
3099 cm_IoctlSetRxkcrypt(cm_ioctl_t *ioctlp, cm_user_t *userp)
3100 {
3101     afs_int32 c = cryptall;
3102
3103     memcpy(&cryptall, ioctlp->inDatap, sizeof(cryptall));
3104
3105     if (c != cryptall) {
3106         if (cryptall == 1)
3107             LogEvent(EVENTLOG_INFORMATION_TYPE, MSG_CRYPT_ON);
3108         else if (cryptall == 2)
3109             LogEvent(EVENTLOG_INFORMATION_TYPE, MSG_CRYPT_AUTH);
3110         else
3111             LogEvent(EVENTLOG_INFORMATION_TYPE, MSG_CRYPT_OFF);
3112     }
3113     return 0;
3114 }
3115
3116 /*
3117  * VIOC_RXSTAT_PROC internals.
3118  *
3119  * Assumes that pioctl path has been parsed or skipped.
3120  */
3121 afs_int32
3122 cm_IoctlRxStatProcess(struct cm_ioctl *ioctlp, struct cm_user *userp)
3123 {
3124     afs_int32 flags;
3125     int code = 0;
3126
3127     memcpy((char *)&flags, ioctlp->inDatap, sizeof(afs_int32));
3128     if (!(flags & AFSCALL_RXSTATS_MASK) || (flags & ~AFSCALL_RXSTATS_MASK)) {
3129         return -1;
3130     }
3131     if (flags & AFSCALL_RXSTATS_ENABLE) {
3132         rx_enableProcessRPCStats();
3133     }
3134     if (flags & AFSCALL_RXSTATS_DISABLE) {
3135         rx_disableProcessRPCStats();
3136     }
3137     if (flags & AFSCALL_RXSTATS_CLEAR) {
3138         rx_clearProcessRPCStats(AFS_RX_STATS_CLEAR_ALL);
3139     }
3140     return 0;
3141 }
3142
3143 /*
3144  * VIOC_RXSTAT_PEER internals.
3145  *
3146  * Assumes that pioctl path has been parsed or skipped.
3147  */
3148 afs_int32
3149 cm_IoctlRxStatPeer(struct cm_ioctl *ioctlp, struct cm_user *userp)
3150 {
3151     afs_int32 flags;
3152     int code = 0;
3153
3154     memcpy((char *)&flags, ioctlp->inDatap, sizeof(afs_int32));
3155     if (!(flags & AFSCALL_RXSTATS_MASK) || (flags & ~AFSCALL_RXSTATS_MASK)) {
3156         return -1;
3157     }
3158     if (flags & AFSCALL_RXSTATS_ENABLE) {
3159         rx_enablePeerRPCStats();
3160     }
3161     if (flags & AFSCALL_RXSTATS_DISABLE) {
3162         rx_disablePeerRPCStats();
3163     }
3164     if (flags & AFSCALL_RXSTATS_CLEAR) {
3165         rx_clearPeerRPCStats(AFS_RX_STATS_CLEAR_ALL);
3166     }
3167     return 0;
3168 }
3169
3170 /*
3171  * VIOC_UNICODECTL internals.
3172  *
3173  * Assumes that pioctl path has been parsed or skipped.
3174  */
3175 afs_int32
3176 cm_IoctlUnicodeControl(struct cm_ioctl *ioctlp, struct cm_user * userp)
3177 {
3178     afs_int32 result = 0;
3179 #ifdef SMB_UNICODE
3180     afs_uint32 cmd;
3181
3182     memcpy(&cmd, ioctlp->inDatap, sizeof(afs_uint32));
3183
3184     if (cmd & 2) {
3185         /* Setting the Unicode flag */
3186         LONG newflag;
3187
3188         newflag = ((cmd & 1) == 1);
3189
3190         InterlockedExchange(&smb_UseUnicode, newflag);
3191     }
3192
3193     result = smb_UseUnicode;
3194 #else
3195     result = 2;
3196 #endif
3197
3198     memcpy(ioctlp->outDatap, &result, sizeof(result));
3199     ioctlp->outDatap += sizeof(result);
3200
3201     return 0;
3202 }
3203
3204 /*
3205  * VIOC_UUIDCTL internals.
3206  *
3207  * Assumes that pioctl path has been parsed or skipped.
3208  */
3209 afs_int32
3210 cm_IoctlUUIDControl(struct cm_ioctl * ioctlp, struct cm_user *userp)
3211 {
3212     afs_uint32 cmd;
3213     afsUUID uuid;
3214
3215     memcpy(&cmd, ioctlp->inDatap, sizeof(afs_uint32));
3216
3217     if (cmd) {             /* generate a new UUID */
3218         UuidCreate((UUID *) &uuid);
3219         cm_data.Uuid = uuid;
3220         cm_ForceNewConnectionsAllServers();
3221     }
3222
3223     memcpy(ioctlp->outDatap, &cm_data.Uuid, sizeof(cm_data.Uuid));
3224     ioctlp->outDatap += sizeof(cm_data.Uuid);
3225
3226     return 0;
3227 }
3228
3229
3230
3231 /*
3232  * functions to dump contents of various structures.
3233  * In debug build (linked with crt debug library) will dump allocated but not freed memory
3234  */
3235 extern int cm_DumpSCache(FILE *outputFile, char *cookie, int lock);
3236 extern int cm_DumpBufHashTable(FILE *outputFile, char *cookie, int lock);
3237
3238 /*
3239  * VIOC_TRACEMEMDUMP internals.
3240  *
3241  * Assumes that pioctl path has been parsed or skipped.
3242  * dscp is held but not locked.
3243  */
3244 afs_int32
3245 cm_IoctlMemoryDump(struct cm_ioctl *ioctlp, struct cm_user *userp)
3246 {
3247     afs_int32 inValue = 0;
3248     HANDLE hLogFile;
3249     char logfileName[MAX_PATH+1];
3250     char *cookie;
3251     DWORD dwSize;
3252
3253 #ifdef _DEBUG
3254     static _CrtMemState memstate;
3255 #endif
3256
3257     memcpy(&inValue, ioctlp->inDatap, sizeof(afs_int32));
3258
3259     dwSize = GetEnvironmentVariable("TEMP", logfileName, sizeof(logfileName));
3260     if ( dwSize == 0 || dwSize > sizeof(logfileName) )
3261     {
3262         GetWindowsDirectory(logfileName, sizeof(logfileName));
3263     }
3264     strncat(logfileName, "\\afsd_alloc.log", sizeof(logfileName));
3265
3266     hLogFile = CreateFile(logfileName, GENERIC_WRITE, FILE_SHARE_WRITE, NULL, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
3267
3268     if (!hLogFile)
3269     {
3270       /* error */
3271       inValue = -1;
3272       memcpy(ioctlp->outDatap, &inValue, sizeof(afs_int32));
3273       ioctlp->outDatap += sizeof(afs_int32);
3274
3275       return 0;
3276     }
3277
3278     SetFilePointer(hLogFile, 0, NULL, FILE_END);
3279
3280     cookie = inValue ? "b" : "e";
3281
3282 #ifdef _DEBUG
3283
3284     if (inValue)
3285     {
3286       _CrtMemCheckpoint(&memstate);
3287     }
3288     else
3289     {
3290         _CrtSetReportMode(_CRT_WARN, _CRTDBG_MODE_FILE);
3291         _CrtSetReportFile(_CRT_WARN, hLogFile);
3292         _CrtMemDumpAllObjectsSince(&memstate);
3293     }
3294 #endif
3295
3296     /* dump all interesting data */
3297     cm_MemDumpDirStats(hLogFile, cookie, 1);
3298     cm_MemDumpBPlusStats(hLogFile, cookie, 1);
3299     cm_DumpCells(hLogFile, cookie, 1);
3300     cm_DumpVolumes(hLogFile, cookie, 1);
3301     cm_DumpSCache(hLogFile, cookie, 1);
3302     cm_DumpBufHashTable(hLogFile, cookie, 1);
3303     cm_DumpServers(hLogFile, cookie, 1);
3304     smb_DumpVCP(hLogFile, cookie, 1);
3305     rx_DumpCalls(hLogFile, cookie);
3306     rx_DumpPackets(hLogFile, cookie);
3307
3308     CloseHandle(hLogFile);
3309
3310     inValue = 0;        /* success */
3311     memcpy(ioctlp->outDatap, &inValue, sizeof(long));
3312     ioctlp->outDatap += sizeof(long);
3313
3314     return 0;
3315 }
3316
3317 /* Utility functon.  Not currently used. */
3318 static afs_int32
3319 cm_CheckServersStatus(cm_serverRef_t *serversp)
3320 {
3321     afs_int32 code = 0;
3322     cm_serverRef_t *tsrp;
3323     cm_server_t *tsp;
3324     int someBusy = 0, someOffline = 0, allOffline = 1, allBusy = 1, allDown = 1;
3325
3326     if (serversp == NULL) {
3327         osi_Log1(afsd_logp, "cm_CheckServersStatus returning 0x%x", CM_ERROR_ALLDOWN);
3328         return CM_ERROR_ALLDOWN;
3329     }
3330
3331     lock_ObtainRead(&cm_serverLock);
3332     for (tsrp = serversp; tsrp; tsrp=tsrp->next) {
3333         if (tsrp->status == srv_deleted)
3334             continue;
3335         if (tsp = tsrp->server) {
3336             cm_GetServerNoLock(tsp);
3337             if (!(tsp->flags & CM_SERVERFLAG_DOWN)) {
3338                 allDown = 0;
3339                 if (tsrp->status == srv_busy) {
3340                     allOffline = 0;
3341                     someBusy = 1;
3342                 } else if (tsrp->status == srv_offline) {
3343                     allBusy = 0;
3344                     someOffline = 1;
3345                 } else {
3346                     allOffline = 0;
3347                     allBusy = 0;
3348                     cm_PutServerNoLock(tsp);
3349                     goto done;
3350                 }
3351             }
3352             cm_PutServerNoLock(tsp);
3353         }
3354     }
3355     lock_ReleaseRead(&cm_serverLock);
3356
3357     if (allDown)
3358         code = CM_ERROR_ALLDOWN;
3359     else if (allBusy)
3360         code = CM_ERROR_ALLBUSY;
3361     else if (allOffline || (someBusy && someOffline))
3362         code = CM_ERROR_ALLOFFLINE;
3363
3364   done:
3365     osi_Log1(afsd_logp, "cm_CheckServersStatus returning 0x%x", code);
3366     return code;
3367 }
3368
3369 /*
3370  * VIOC_PATH_AVAILABILITY internals.
3371  *
3372  * Assumes that pioctl path has been parsed or skipped.
3373  * scp is held but not locked.
3374  */
3375 afs_int32
3376 cm_IoctlPathAvailability(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *scp, cm_req_t *reqp)
3377 {
3378     afs_int32 code;
3379     cm_cell_t *cellp;
3380     cm_volume_t *tvp;
3381     cm_vol_state_t *statep;
3382     afs_uint32 volume;
3383
3384 #ifdef AFS_FREELANCE_CLIENT
3385     if ( scp->fid.cell == AFS_FAKE_ROOT_CELL_ID && scp->fid.volume == AFS_FAKE_ROOT_VOL_ID ) {
3386         code = 0;
3387     } else
3388 #endif
3389     {
3390         volume = scp->fid.volume;
3391
3392         cellp = cm_FindCellByID(scp->fid.cell, 0);
3393
3394         if (!cellp)
3395             return CM_ERROR_NOSUCHCELL;
3396
3397         code = cm_FindVolumeByID(cellp, volume, userp, reqp, CM_GETVOL_FLAG_CREATE, &tvp);
3398         if (code)
3399             return code;
3400
3401         statep = cm_VolumeStateByID(tvp, volume);
3402         switch (statep->state) {
3403         case vl_online:
3404         case vl_unknown:
3405             code = 0;
3406             break;
3407         case vl_busy:
3408             code = CM_ERROR_ALLBUSY;
3409             break;
3410         case vl_offline:
3411             code = CM_ERROR_ALLOFFLINE;
3412             break;
3413         case vl_alldown:
3414             code = CM_ERROR_ALLDOWN;
3415             break;
3416         }
3417         cm_PutVolume(tvp);
3418     }
3419     return code;
3420 }
3421
3422 /*
3423  * VIOC_VOLSTAT_TEST internals.
3424  *
3425  * Assumes that pioctl path has been parsed or skipped.
3426  */
3427 afs_int32
3428 cm_IoctlVolStatTest(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_req_t *reqp)
3429 {
3430     afs_int32 code;
3431     cm_cell_t *cellp = NULL;
3432     cm_volume_t *volp;
3433     cm_vol_state_t *statep;
3434     struct VolStatTest * testp;
3435     afs_uint32 n;
3436
3437     testp = (struct VolStatTest *)ioctlp->inDatap;
3438
3439 #ifdef AFS_FREELANCE_CLIENT
3440     if (testp->fid.cell == -1)
3441         return CM_ERROR_NOACCESS;
3442 #endif
3443
3444     if (testp->flags & VOLSTAT_TEST_CHECK_VOLUME) {
3445         cm_CheckOfflineVolumes();
3446         return 0;
3447     }
3448
3449     if (testp->flags & VOLSTAT_TEST_NETWORK_UP) {
3450         cm_VolStatus_Network_Started(cm_NetbiosName
3451 #ifdef _WIN64
3452                                   , cm_NetbiosName
3453 #endif
3454                                   );
3455         return 0;
3456     }
3457
3458     if (testp->flags & VOLSTAT_TEST_NETWORK_DOWN) {
3459         cm_VolStatus_Network_Stopped(cm_NetbiosName
3460 #ifdef _WIN64
3461                                   , cm_NetbiosName
3462 #endif
3463                                   );
3464         return 0;
3465     }
3466
3467     if (testp->cellname[0]) {
3468         n = atoi(testp->cellname);
3469         if (n)
3470             testp->fid.cell = n;
3471         else
3472             cellp = cm_GetCell(testp->cellname, 0);
3473     }
3474
3475     if (testp->fid.cell > 0) {
3476         cellp = cm_FindCellByID(testp->fid.cell, 0);
3477     }
3478
3479     if (!cellp)
3480         return CM_ERROR_NOSUCHCELL;
3481
3482     if (testp->volname[0]) {
3483         n = atoi(testp->volname);
3484         if (n)
3485             testp->fid.volume = n;
3486         else
3487             code = cm_FindVolumeByName(cellp, testp->volname, userp, reqp, CM_GETVOL_FLAG_NO_LRU_UPDATE, &volp);
3488     }
3489
3490     if (testp->fid.volume > 0)
3491         code = cm_FindVolumeByID(cellp, testp->fid.volume, userp, reqp, CM_GETVOL_FLAG_NO_LRU_UPDATE, &volp);
3492
3493     if (code)
3494         return code;
3495
3496     if (testp->fid.volume)
3497         statep = cm_VolumeStateByID(volp, testp->fid.volume);
3498     else
3499         statep = cm_VolumeStateByName(volp, testp->volname);
3500
3501     if (statep) {
3502         statep->state = testp->state;
3503         code = cm_VolStatus_Change_Notification(cellp->cellID, statep->ID, testp->state);
3504     }
3505
3506     cm_PutVolume(volp);
3507
3508     return code;
3509 }
3510
3511 /*
3512  * VIOC_GETUNIXMODE internals.
3513  *
3514  * Assumes that pioctl path has been parsed or skipped.
3515  * scp is held but not locked.
3516  */
3517 afs_int32
3518 cm_IoctlGetUnixMode(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *scp, cm_req_t *reqp)
3519 {
3520     afs_int32 code = 0;
3521     char *cp;
3522
3523     lock_ObtainWrite(&scp->rw);
3524     code = cm_SyncOp(scp, NULL, userp, reqp, 0,
3525                       CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
3526     if (code == 0)
3527         cm_SyncOpDone(scp, NULL, CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
3528     lock_ReleaseWrite(&scp->rw);
3529
3530     if (code == 0) {
3531         /* Copy all this junk into msg->im_data, keeping track of the lengths. */
3532         cp = ioctlp->outDatap;
3533         memcpy(cp, (char *)&scp->unixModeBits, sizeof(afs_uint32));
3534         cp += sizeof(afs_uint32);
3535
3536         /* return new size */
3537         ioctlp->outDatap = cp;
3538     }
3539     return code;
3540 }
3541
3542
3543 /*
3544  * VIOC_SETUNIXMODE internals.
3545  *
3546  * Assumes that pioctl path has been parsed or skipped
3547  * and that cm_ioctlQueryOptions_t have been parsed and skipped.
3548  *
3549  * scp is held but not locked.
3550  */
3551 afs_int32
3552 cm_IoctlSetUnixMode(struct cm_ioctl *ioctlp, struct cm_user *userp, cm_scache_t *scp, cm_req_t *reqp)
3553 {
3554     afs_int32 code = 0;
3555     char *cp;
3556
3557     lock_ObtainWrite(&scp->rw);
3558     code = cm_SyncOp(scp, NULL, userp, reqp, 0,
3559                       CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
3560     if (code == 0)
3561         cm_SyncOpDone(scp, NULL, CM_SCACHESYNC_NEEDCALLBACK | CM_SCACHESYNC_GETSTATUS);
3562     lock_ReleaseWrite(&scp->rw);
3563
3564     if (code == 0) {
3565         afs_uint32 unixModeBits;
3566         cm_attr_t attr;
3567
3568         memset(&attr, 0, sizeof(attr));
3569
3570         cp = ioctlp->inDatap;
3571         memcpy((char *)&unixModeBits, cp, sizeof(afs_uint32));
3572
3573         attr.mask = CM_ATTRMASK_UNIXMODEBITS;
3574         attr.unixModeBits = unixModeBits;
3575
3576         code = cm_SetAttr(scp, &attr, userp, reqp);
3577     }
3578     return code;
3579 }
3580
3581 /*
3582  * VIOC_GETVERIFYDATA internals.
3583  *
3584  * Assumes that pioctl path has been parsed or skipped.
3585  */
3586 afs_int32
3587 cm_IoctlGetVerifyData(cm_ioctl_t *ioctlp)
3588 {
3589     memcpy(ioctlp->outDatap, &cm_verifyData, sizeof(cm_verifyData));
3590     ioctlp->outDatap += sizeof(cm_verifyData);
3591
3592     return 0;
3593 }
3594
3595 /*
3596  * VIOC_SETVERIFYDATA internals.
3597  *
3598  * Assumes that pioctl path has been parsed or skipped.
3599  */
3600 afs_int32
3601 cm_IoctlSetVerifyData(cm_ioctl_t *ioctlp)
3602 {
3603     memcpy(&cm_verifyData, ioctlp->inDatap, sizeof(cm_verifyData));
3604
3605     return 0;
3606 }
3607