volser: Set but not used variables
[openafs.git] / src / volser / vsprocs.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
13 #include <stdio.h>
14 #include <sys/types.h>
15 #include <sys/stat.h>
16 #include <string.h>
17 #ifdef  AFS_AIX_ENV
18 #include <sys/statfs.h>
19 #endif
20 #ifdef AFS_NT40_ENV
21 #include <fcntl.h>
22 #include <winsock2.h>
23 #else
24 #include <sys/file.h>
25 #include <netinet/in.h>
26 #endif
27
28 #include <lock.h>
29 #include <afs/voldefs.h>
30 #include <rx/xdr.h>
31 #include <rx/rx.h>
32 #include <afs/vlserver.h>
33 #include <afs/nfs.h>
34 #include <afs/cellconfig.h>
35 #include <afs/keys.h>
36 #include <ubik.h>
37 #include <afs/afsint.h>
38 #include "volser.h"
39 #include "volint.h"
40 #include "lockdata.h"
41 #include <afs/com_err.h>
42 #include <rx/rxkad.h>
43 #include <afs/kautils.h>
44 #include <afs/cmd.h>
45 #include <afs/ihandle.h>
46 #ifdef AFS_NT40_ENV
47 #include <afs/ntops.h>
48 #endif
49 #include <afs/vnode.h>
50 #include <afs/volume.h>
51 #include <errno.h>
52 #define ERRCODE_RANGE 8         /* from error_table.h */
53 #define CLOCKSKEW   2           /* not really skew, but resolution */
54 #define CLOCKADJ(x) (((x) < CLOCKSKEW) ? 0 : (x) - CLOCKSKEW)
55
56 /* for UV_MoveVolume() recovery */
57
58 #include <afs/procmgmt.h>       /* signal(), kill(), wait(), etc. */
59 #include <setjmp.h>
60
61 #include "volser_internal.h"
62 #include "volser_prototypes.h"
63 #include "vsutils_prototypes.h"
64 #include "lockprocs_prototypes.h"
65
66 struct ubik_client *cstruct;
67 int verbose = 0, noresolve = 0;
68
69 struct release {
70     afs_uint32 crtime;
71     afs_uint32 uptime;
72     afs_int32 vldbEntryIndex;
73 };
74
75 /* Utility macros used by rest of this source file */
76 #define EPRINT(ec, es) \
77 do { \
78         fprintf(STDERR, "\n"); \
79         fprintf(STDERR, (es)); \
80         PrintError("   ",ec); \
81 } while (0)
82
83 #define EPRINT1(ec, es, ep1) \
84 do { \
85         fprintf(STDERR, "\n"); \
86         fprintf(STDERR, (es), (ep1)); \
87         PrintError("   ",ec); \
88 } while (0)
89
90 #define EPRINT2(ec, es, ep1, ep2) \
91 do { \
92         fprintf(STDERR, "\n"); \
93         fprintf(STDERR, (es), (ep1), (ep2)); \
94         PrintError("   ",ec); \
95 } while (0)
96
97 #define EPRINT3(ec, es, ep1, ep2, ep3) \
98 do { \
99         fprintf(STDERR, "\n"); \
100         fprintf(STDERR, (es), (ep1), (ep2), (ep3)); \
101         PrintError("   ",ec); \
102 } while (0)
103
104 #define EGOTO(where, ec, es) \
105 do { \
106         if (ec) { \
107                 EPRINT((ec),(es)); \
108                 error = (ec); \
109                 goto where; \
110         } \
111 } while (0)
112
113 #define EGOTO1(where, ec, es, ep1) \
114 do { \
115         if (ec) { \
116                 EPRINT1((ec),(es),(ep1)); \
117                 error = (ec); \
118                 goto where; \
119         } \
120 } while (0)
121
122 #define EGOTO2(where, ec, es, ep1, ep2) \
123 do { \
124         if (ec) { \
125                 EPRINT2((ec),(es),(ep1),(ep2)); \
126                 error = (ec); \
127                 goto where; \
128         } \
129 } while (0)
130
131 #define EGOTO3(where, ec, es, ep1, ep2, ep3) \
132 do { \
133         if (ec) { \
134                 EPRINT3((ec),(es),(ep1),(ep2),(ep3)); \
135                 error = (ec); \
136                 goto where; \
137         } \
138 } while (0)
139
140 #define VPRINT(es) \
141         { if (verbose) { fprintf(STDOUT, (es)); fflush(STDOUT); } }
142 #define VPRINT1(es, p) \
143         { if (verbose) { fprintf(STDOUT, (es), (p)); fflush(STDOUT); } }
144 #define VPRINT2(es, p1, p2) \
145         { if (verbose) { fprintf(STDOUT, (es), (p1), (p2)); fflush(STDOUT); } }
146 #define VPRINT3(es, p1, p2, p3) \
147         { if (verbose) { fprintf(STDOUT, (es), (p1), (p2), (p3)); fflush(STDOUT); } }
148 #define VDONE \
149         { if (verbose) { fprintf(STDOUT, " done\n"); fflush(STDOUT); } }
150 #define VEPRINT(es) \
151         { if (verbose) { fprintf(STDERR, (es)); fflush(STDERR); } }
152 #define VEPRINT1(es, p) \
153         { if (verbose) { fprintf(STDERR, (es), (p)); fflush(STDERR); } }
154 #define VEPRINT2(es, p1, p2) \
155         { if (verbose) { fprintf(STDERR, (es), (p1), (p2)); fflush(STDERR); } }
156 #define VEPRINT3(es, p1, p2, p3) \
157         { if (verbose) { fprintf(STDERR, (es), (p1), (p2), (p3)); fflush(STDERR); } }
158 #define VEDONE \
159         { if (verbose) { fprintf(STDERR, " done\n"); fflush(STDERR); } }
160
161
162
163 /* getting rid of this */
164 #define ERROR_EXIT(code) {error=(code); goto error_exit;}
165
166
167 /* Protos for static routines */
168 #if 0
169 static afs_int32 CheckAndDeleteVolume(struct rx_connection *aconn,
170                                       afs_int32 apart, afs_uint32 okvol,
171                                       afs_uint32 delvol);
172 #endif
173 static int DelVol(struct rx_connection *conn, afs_uint32 vid, afs_int32 part,
174                   afs_int32 flags);
175 static int GetTrans(struct nvldbentry *vldbEntryPtr, afs_int32 index,
176                     struct rx_connection **connPtr, afs_int32 * transPtr,
177                     afs_uint32 * crtimePtr, afs_uint32 * uptimePtr);
178 static int SimulateForwardMultiple(struct rx_connection *fromconn,
179                                    afs_int32 fromtid, afs_int32 fromdate,
180                                    manyDests * tr, afs_int32 flags,
181                                    void *cookie, manyResults * results);
182 static afs_int32 CheckVolume(volintInfo * volumeinfo, afs_uint32 aserver,
183                              afs_int32 apart, afs_int32 * modentry,
184                              afs_uint32 * maxvolid, struct nvldbentry *aentry);
185
186
187 /*map the partition <partId> into partition name <partName>*/
188 void
189 MapPartIdIntoName(afs_int32 partId, char *partName)
190 {
191     if (partId < 26) {          /* what if partId > = 26 ? */
192         strcpy(partName, "/vicep");
193         partName[6] = partId + 'a';
194         partName[7] = '\0';
195         return;
196     } else if (partId < VOLMAXPARTS) {
197         strcpy(partName, "/vicep");
198         partId -= 26;
199         partName[6] = 'a' + (partId / 26);
200         partName[7] = 'a' + (partId % 26);
201         partName[8] = '\0';
202         return;
203     }
204 }
205
206 int
207 yesprompt(char *str)
208 {
209     int response, c;
210     int code;
211
212     fprintf(STDERR, "Do you want to %s? [yn](n): ", str);
213     response = c = getchar();
214     while (!(c == EOF || c == '\n'))
215         c = getchar();          /*skip to end of line */
216     code = (response == 'y' || response == 'Y');
217     return code;
218 }
219
220
221 int
222 PrintError(char *msg, afs_int32 errcode)
223 {
224     fprintf(STDERR, "%s", msg);
225     /*replace by a big switch statement */
226     switch (errcode) {
227     case 0:
228         break;
229     case -1:
230         fprintf(STDERR, "Possible communication failure\n");
231         break;
232     case VSALVAGE:
233         fprintf(STDERR, "Volume needs to be salvaged\n");
234         break;
235     case VNOVNODE:
236         fprintf(STDERR, "Bad vnode number quoted\n");
237         break;
238     case VNOVOL:
239         fprintf(STDERR,
240                 "Volume not attached, does not exist, or not on line\n");
241         break;
242     case VVOLEXISTS:
243         fprintf(STDERR, "Volume already exists\n");
244         break;
245     case VNOSERVICE:
246         fprintf(STDERR, "Volume is not in service\n");
247         break;
248     case VOFFLINE:
249         fprintf(STDERR, "Volume is off line\n");
250         break;
251     case VONLINE:
252         fprintf(STDERR, "Volume is already on line\n");
253         break;
254     case VDISKFULL:
255         fprintf(STDERR, "Partition is full\n");
256         break;
257     case VOVERQUOTA:
258         fprintf(STDERR, "Volume max quota exceeded\n");
259         break;
260     case VBUSY:
261         fprintf(STDERR, "Volume temporarily unavailable\n");
262         break;
263     case VMOVED:
264         fprintf(STDERR, "Volume has moved to another server\n");
265         break;
266     case VL_IDEXIST:
267         fprintf(STDERR, "VLDB: volume Id exists in the vldb\n");
268         break;
269     case VL_IO:
270         fprintf(STDERR, "VLDB: a read terminated too early\n");
271         break;
272     case VL_NAMEEXIST:
273         fprintf(STDERR, "VLDB: volume entry exists in the vldb\n");
274         break;
275     case VL_CREATEFAIL:
276         fprintf(STDERR, "VLDB: internal creation failure\n");
277         break;
278     case VL_NOENT:
279         fprintf(STDERR, "VLDB: no such entry\n");
280         break;
281     case VL_EMPTY:
282         fprintf(STDERR, "VLDB: vldb database is empty\n");
283         break;
284     case VL_ENTDELETED:
285         fprintf(STDERR, "VLDB: entry is deleted (soft delete)\n");
286         break;
287     case VL_BADNAME:
288         fprintf(STDERR, "VLDB: volume name is illegal\n");
289         break;
290     case VL_BADINDEX:
291         fprintf(STDERR, "VLDB: index was out of range\n");
292         break;
293     case VL_BADVOLTYPE:
294         fprintf(STDERR, "VLDB: bad volume type\n");
295         break;
296     case VL_BADSERVER:
297         fprintf(STDERR, "VLDB: illegal server number (not within limits)\n");
298         break;
299     case VL_BADPARTITION:
300         fprintf(STDERR, "VLDB: bad partition number\n");
301         break;
302     case VL_REPSFULL:
303         fprintf(STDERR, "VLDB: run out of space for replication sites\n");
304         break;
305     case VL_NOREPSERVER:
306         fprintf(STDERR, "VLDB: no such repsite server exists\n");
307         break;
308     case VL_DUPREPSERVER:
309         fprintf(STDERR, "VLDB: replication site server already exists\n");
310         break;
311     case VL_RWNOTFOUND:
312         fprintf(STDERR, "VLDB: parent r/w entry not found\n");
313         break;
314     case VL_BADREFCOUNT:
315         fprintf(STDERR, "VLDB: illegal reference count number\n");
316         break;
317     case VL_SIZEEXCEEDED:
318         fprintf(STDERR, "VLDB: vldb size for attributes exceeded\n");
319         break;
320     case VL_BADENTRY:
321         fprintf(STDERR, "VLDB: bad incoming vldb entry\n");
322         break;
323     case VL_BADVOLIDBUMP:
324         fprintf(STDERR, "VLDB: illegal max volid increment\n");
325         break;
326     case VL_IDALREADYHASHED:
327         fprintf(STDERR, "VLDB: (RO/BACK) Id already hashed\n");
328         break;
329     case VL_ENTRYLOCKED:
330         fprintf(STDERR, "VLDB: vldb entry is already locked\n");
331         break;
332     case VL_BADVOLOPER:
333         fprintf(STDERR, "VLDB: bad volume operation code\n");
334         break;
335     case VL_BADRELLOCKTYPE:
336         fprintf(STDERR, "VLDB: bad release lock type\n");
337         break;
338     case VL_RERELEASE:
339         fprintf(STDERR, "VLDB: status report: last release was aborted\n");
340         break;
341     case VL_BADSERVERFLAG:
342         fprintf(STDERR, "VLDB: invalid replication site server flag\n");
343         break;
344     case VL_PERM:
345         fprintf(STDERR, "VLDB: no permission access for call\n");
346         break;
347     case VOLSERREAD_DUMPERROR:
348         fprintf(STDERR,
349                 "VOLSER:  Problems encountered in reading the dump file !\n");
350         break;
351     case VOLSERDUMPERROR:
352         fprintf(STDERR, "VOLSER: Problems encountered in doing the dump !\n");
353         break;
354     case VOLSERATTACH_ERROR:
355         fprintf(STDERR, "VOLSER: Could not attach the volume\n");
356         break;
357     case VOLSERDETACH_ERROR:
358         fprintf(STDERR, "VOLSER: Could not detach the volume\n");
359         break;
360     case VOLSERILLEGAL_PARTITION:
361         fprintf(STDERR, "VOLSER: encountered illegal partition number\n");
362         break;
363     case VOLSERBAD_ACCESS:
364         fprintf(STDERR, "VOLSER: permission denied, not a super user\n");
365         break;
366     case VOLSERVLDB_ERROR:
367         fprintf(STDERR, "VOLSER: error detected in the VLDB\n");
368         break;
369     case VOLSERBADNAME:
370         fprintf(STDERR, "VOLSER: error in volume name\n");
371         break;
372     case VOLSERVOLMOVED:
373         fprintf(STDERR, "VOLSER: volume has moved\n");
374         break;
375     case VOLSERBADOP:
376         fprintf(STDERR, "VOLSER: illegal operation\n");
377         break;
378     case VOLSERBADRELEASE:
379         fprintf(STDERR, "VOLSER: release could not be completed\n");
380         break;
381     case VOLSERVOLBUSY:
382         fprintf(STDERR, "VOLSER: volume is busy\n");
383         break;
384     case VOLSERNO_MEMORY:
385         fprintf(STDERR, "VOLSER: volume server is out of memory\n");
386         break;
387     case VOLSERNOVOL:
388         fprintf(STDERR,
389                 "VOLSER: no such volume - location specified incorrectly or volume does not exist\n");
390         break;
391     case VOLSERMULTIRWVOL:
392         fprintf(STDERR,
393                 "VOLSER: multiple RW volumes with same ID, one of which should be deleted\n");
394         break;
395     case VOLSERFAILEDOP:
396         fprintf(STDERR,
397                 "VOLSER: not all entries were successfully processed\n");
398         break;
399     default:
400         {
401             initialize_KA_error_table();
402             initialize_RXK_error_table();
403             initialize_KTC_error_table();
404             initialize_ACFG_error_table();
405             initialize_CMD_error_table();
406             initialize_VL_error_table();
407
408             fprintf(STDERR, "%s: %s\n", afs_error_table_name(errcode),
409                     afs_error_message(errcode));
410             break;
411         }
412     }
413     return 0;
414 }
415
416 void init_volintInfo(struct volintInfo *vinfo) {
417     memset(vinfo, 0, sizeof(struct volintInfo));
418
419     vinfo->maxquota = -1;
420     vinfo->dayUse = -1;
421     vinfo->creationDate = -1;
422     vinfo->updateDate = -1;
423     vinfo->flags = -1;
424     vinfo->spare0 = -1;
425     vinfo->spare1 = -1;
426     vinfo->spare2 = -1;
427     vinfo->spare3 = -1;
428 }
429
430 static struct rx_securityClass *uvclass = 0;
431 static int uvindex = -1;
432 /* called by VLDBClient_Init to set the security module to be used in the RPC */
433 int
434 UV_SetSecurity(struct rx_securityClass *as, afs_int32 aindex)
435 {
436     uvindex = aindex;
437     uvclass = as;
438     return 0;
439 }
440
441 /* bind to volser on <port> <aserver> */
442 /* takes server address in network order, port in host order.  dumb */
443 struct rx_connection *
444 UV_Bind(afs_uint32 aserver, afs_int32 port)
445 {
446     struct rx_connection *tc;
447
448     tc = rx_NewConnection(aserver, htons(port), VOLSERVICE_ID, uvclass,
449                           uvindex);
450     return tc;
451 }
452
453 static int
454 AFSVolCreateVolume_retry(struct rx_connection *z_conn,
455                        afs_int32 partition, char *name, afs_int32 type,
456                        afs_int32 parent, afs_uint32 *volid, afs_int32 *trans)
457 {
458     afs_int32 code;
459     int retries = 3;
460     while (retries) {
461         code = AFSVolCreateVolume(z_conn, partition, name, type, parent,
462                                   volid, trans);
463         if (code != VOLSERVOLBUSY)
464             break;
465         retries--;
466 #ifdef AFS_PTHREAD_ENV
467         sleep(3-retries);
468 #else
469         IOMGR_Sleep(3-retries);
470 #endif
471     }
472     return code;
473 }
474
475 static int
476 AFSVolTransCreate_retry(struct rx_connection *z_conn,
477                         afs_int32 volume, afs_int32 partition,
478                         afs_int32 flags, afs_int32 * trans)
479 {
480     afs_int32 code;
481     int retries = 3;
482     while (retries) {
483         code = AFSVolTransCreate(z_conn, volume, partition, flags, trans);
484         if (code != VOLSERVOLBUSY)
485             break;
486         retries--;
487 #ifdef AFS_PTHREAD_ENV
488         sleep(3-retries);
489 #else
490         IOMGR_Sleep(3-retries);
491 #endif
492     }
493     return code;
494 }
495
496 #if 0
497 /* if <okvol> is allright(indicated by beibg able to
498  * start a transaction, delete the <delvol> */
499 static afs_int32
500 CheckAndDeleteVolume(struct rx_connection *aconn, afs_int32 apart,
501                      afs_uint32 okvol, afs_uint32 delvol)
502 {
503     afs_int32 error, code, tid, rcode;
504     error = 0;
505     code = 0;
506
507     if (okvol == 0) {
508         code = AFSVolTransCreate_retry(aconn, delvol, apart, ITOffline, &tid);
509         if (!error && code)
510             error = code;
511         code = AFSVolDeleteVolume(aconn, tid);
512         if (!error && code)
513             error = code;
514         code = AFSVolEndTrans(aconn, tid, &rcode);
515         if (!code)
516             code = rcode;
517         if (!error && code)
518             error = code;
519         return error;
520     } else {
521         code = AFSVolTransCreate_retry(aconn, okvol, apart, ITOffline, &tid);
522         if (!code) {
523             code = AFSVolEndTrans(aconn, tid, &rcode);
524             if (!code)
525                 code = rcode;
526             if (!error && code)
527                 error = code;
528             code = AFSVolTransCreate_retry(aconn, delvol, apart, ITOffline, &tid);
529             if (!error && code)
530                 error = code;
531             code = AFSVolDeleteVolume(aconn, tid);
532             if (!error && code)
533                 error = code;
534             code = AFSVolEndTrans(aconn, tid, &rcode);
535             if (!code)
536                 code = rcode;
537             if (!error && code)
538                 error = code;
539         } else
540             error = code;
541         return error;
542     }
543 }
544
545 #endif
546
547 /* called by EmuerateEntry, show vldb entry in a reasonable format */
548 void
549 SubEnumerateEntry(struct nvldbentry *entry)
550 {
551     int i;
552     char pname[10];
553     int isMixed = 0;
554     char hoststr[16];
555
556 #ifdef notdef
557     fprintf(STDOUT, "   readWriteID %-10u ", entry->volumeId[RWVOL]);
558     if (entry->flags & RW_EXISTS)
559         fprintf(STDOUT, " valid \n");
560     else
561         fprintf(STDOUT, " invalid \n");
562     fprintf(STDOUT, "   readOnlyID  %-10u ", entry->volumeId[ROVOL]);
563     if (entry->flags & RO_EXISTS)
564         fprintf(STDOUT, " valid \n");
565     else
566         fprintf(STDOUT, " invalid \n");
567     fprintf(STDOUT, "   backUpID    %-10u ", entry->volumeId[BACKVOL]);
568     if (entry->flags & BACK_EXISTS)
569         fprintf(STDOUT, " valid \n");
570     else
571         fprintf(STDOUT, " invalid \n");
572     if ((entry->cloneId != 0) && (entry->flags & RO_EXISTS))
573         fprintf(STDOUT, "    releaseClone %-10u \n", entry->cloneId);
574 #else
575     if (entry->flags & RW_EXISTS)
576         fprintf(STDOUT, "    RWrite: %-10u", entry->volumeId[RWVOL]);
577     if (entry->flags & RO_EXISTS)
578         fprintf(STDOUT, "    ROnly: %-10u", entry->volumeId[ROVOL]);
579     if (entry->flags & BACK_EXISTS)
580         fprintf(STDOUT, "    Backup: %-10u", entry->volumeId[BACKVOL]);
581     if ((entry->cloneId != 0) && (entry->flags & RO_EXISTS))
582         fprintf(STDOUT, "    RClone: %-10lu", (unsigned long)entry->cloneId);
583     fprintf(STDOUT, "\n");
584 #endif
585     fprintf(STDOUT, "    number of sites -> %lu\n",
586             (unsigned long)entry->nServers);
587     for (i = 0; i < entry->nServers; i++) {
588         if (entry->serverFlags[i] & NEW_REPSITE)
589             isMixed = 1;
590     }
591     for (i = 0; i < entry->nServers; i++) {
592         MapPartIdIntoName(entry->serverPartition[i], pname);
593         fprintf(STDOUT, "       server %s partition %s ",
594                 noresolve ? afs_inet_ntoa_r(entry->serverNumber[i], hoststr) :
595                 hostutil_GetNameByINet(entry->serverNumber[i]), pname);
596         if (entry->serverFlags[i] & ITSRWVOL)
597             fprintf(STDOUT, "RW Site ");
598         else
599             fprintf(STDOUT, "RO Site ");
600         if (isMixed) {
601             if (entry->serverFlags[i] & NEW_REPSITE)
602                 fprintf(STDOUT," -- New release");
603             else
604                 if (!(entry->serverFlags[i] & ITSRWVOL))
605                     fprintf(STDOUT," -- Old release");
606         } else {
607             if (entry->serverFlags[i] & RO_DONTUSE)
608                 fprintf(STDOUT, " -- Not released");
609         }
610         fprintf(STDOUT, "\n");
611     }
612
613     return;
614
615 }
616
617 /*enumerate the vldb entry corresponding to <entry> */
618 void
619 EnumerateEntry(struct nvldbentry *entry)
620 {
621
622     fprintf(STDOUT, "\n");
623     fprintf(STDOUT, "%s \n", entry->name);
624     SubEnumerateEntry(entry);
625     return;
626 }
627
628 /* forcibly remove a volume.  Very dangerous call */
629 int
630 UV_NukeVolume(afs_uint32 server, afs_int32 partid, afs_uint32 volid)
631 {
632     struct rx_connection *tconn;
633     afs_int32 code;
634
635     tconn = UV_Bind(server, AFSCONF_VOLUMEPORT);
636     if (tconn) {
637         code = AFSVolNukeVolume(tconn, partid, volid);
638         rx_DestroyConnection(tconn);
639     } else
640         code = 0;
641     return code;
642 }
643
644 /* like df. Return usage of <pname> on <server> in <partition> */
645 int
646 UV_PartitionInfo64(afs_uint32 server, char *pname,
647                    struct diskPartition64 *partition)
648 {
649     struct rx_connection *aconn;
650     afs_int32 code = 0;
651
652     aconn = (struct rx_connection *)0;
653     aconn = UV_Bind(server, AFSCONF_VOLUMEPORT);
654     code = AFSVolPartitionInfo64(aconn, pname, partition);
655     if (code == RXGEN_OPCODE) {
656         struct diskPartition *dpp =
657             (struct diskPartition *)malloc(sizeof(struct diskPartition));
658         code = AFSVolPartitionInfo(aconn, pname, dpp);
659         if (!code) {
660             strncpy(partition->name, dpp->name, 32);
661             strncpy(partition->devName, dpp->devName, 32);
662             partition->lock_fd = dpp->lock_fd;
663             partition->free = dpp->free;
664             partition->minFree = dpp->minFree;
665         }
666         free(dpp);
667     }
668     if (code) {
669         fprintf(STDERR, "Could not get information on partition %s\n", pname);
670         PrintError("", code);
671     }
672     if (aconn)
673         rx_DestroyConnection(aconn);
674     return code;
675 }
676
677 /* old interface to create volumes */
678 int
679 UV_CreateVolume(afs_uint32 aserver, afs_int32 apart, char *aname,
680                 afs_uint32 * anewid)
681 {
682     afs_int32 code;
683     *anewid = 0;
684     code = UV_CreateVolume2(aserver, apart, aname, 5000, 0, 0, 0, 0, anewid);
685     return code;
686 }
687
688 /* less old interface to create volumes */
689 int
690 UV_CreateVolume2(afs_uint32 aserver, afs_int32 apart, char *aname,
691                  afs_int32 aquota, afs_int32 aspare1, afs_int32 aspare2,
692                  afs_int32 aspare3, afs_int32 aspare4, afs_uint32 * anewid)
693 {
694     afs_uint32 roid = 0, bkid = 0;
695     return UV_CreateVolume3(aserver, apart, aname, aquota, aspare1, aspare2,
696         aspare3, aspare4, anewid, &roid, &bkid);
697 }
698
699 /**
700  * Create a volume on the given server and partition
701  *
702  * @param aserver  server to create volume on
703  * @param spart  partition to create volume on
704  * @param aname  name of new volume
705  * @param aquota  quota for new volume
706  * @param anewid  contains the desired volume id for the new volume. If
707  *                *anewid == 0, a new id will be chosen, and will be placed
708  *                in *anewid when UV_CreateVolume3 returns.
709  * @param aroid  contains the desired RO volume id. If NULL, the RO id entry
710  *               will be unset. If *aroid == 0, an id will be chosen, and
711  *               will be placed in *anewid when UV_CreateVolume3 returns.
712  * @param abkid  same as aroid, except for the BK volume id instead of the
713  *               RO volume id.
714  * @return 0 on success, error code otherwise.
715  */
716 int
717 UV_CreateVolume3(afs_uint32 aserver, afs_int32 apart, char *aname,
718                  afs_int32 aquota, afs_int32 aspare1, afs_int32 aspare2,
719                  afs_int32 aspare3, afs_int32 aspare4, afs_uint32 * anewid,
720                  afs_uint32 * aroid, afs_uint32 * abkid)
721 {
722     struct rx_connection *aconn;
723     afs_int32 tid;
724     afs_int32 code;
725     afs_int32 error;
726     afs_int32 rcode, vcode;
727     afs_int32 lastid;
728     struct nvldbentry entry, storeEntry;        /*the new vldb entry */
729     struct volintInfo tstatus;
730
731     tid = 0;
732     aconn = (struct rx_connection *)0;
733     error = 0;
734
735     init_volintInfo(&tstatus);
736     tstatus.maxquota = aquota;
737
738     aconn = UV_Bind(aserver, AFSCONF_VOLUMEPORT);
739
740     if (aroid && *aroid) {
741         VPRINT1("Using RO volume ID %d.\n", *aroid);
742     }
743     if (abkid && *abkid) {
744         VPRINT1("Using BK volume ID %d.\n", *abkid);
745     }
746
747     if (*anewid) {
748         vcode = VLDB_GetEntryByID(*anewid, -1, &entry);
749         if (!vcode) {
750             fprintf(STDERR, "Volume ID %d already exists\n", *anewid);
751             return VVOLEXISTS;
752         }
753         VPRINT1("Using volume ID %d.\n", *anewid);
754     } else {
755         vcode = ubik_VL_GetNewVolumeId(cstruct, 0, 1, anewid);
756         EGOTO1(cfail, vcode, "Could not get an Id for volume %s\n", aname);
757
758         if (aroid && *aroid == 0) {
759             vcode = ubik_VL_GetNewVolumeId(cstruct, 0, 1, aroid);
760             EGOTO1(cfail, vcode, "Could not get an RO Id for volume %s\n", aname);
761         }
762
763         if (abkid && *abkid == 0) {
764             vcode = ubik_VL_GetNewVolumeId(cstruct, 0, 1, abkid);
765             EGOTO1(cfail, vcode, "Could not get a BK Id for volume %s\n", aname);
766         }
767     }
768
769     /* rw,ro, bk id are related in the default case */
770     /* If caller specified RW id, but not RO/BK ids, have them be RW+1 and RW+2 */
771     lastid = *anewid;
772     if (aroid && *aroid == 0) {
773         *aroid = ++lastid;
774     }
775     if (abkid && *abkid == 0) {
776         *abkid = ++lastid;
777     }
778
779     code =
780         AFSVolCreateVolume_retry(aconn, apart, aname, volser_RW, 0, anewid, &tid);
781     EGOTO2(cfail, code, "Failed to create the volume %s %u \n", aname,
782            *anewid);
783
784     code = AFSVolSetInfo(aconn, tid, &tstatus);
785     if (code)
786         EPRINT(code, "Could not change quota, continuing...\n");
787
788     code = AFSVolSetFlags(aconn, tid, 0);       /* bring it online (mark it InService */
789     EGOTO2(cfail, code, "Could not bring the volume %s %u online \n", aname,
790            *anewid);
791
792     VPRINT2("Volume %s %u created and brought online\n", aname, *anewid);
793
794     /* set up the vldb entry for this volume */
795     strncpy(entry.name, aname, VOLSER_OLDMAXVOLNAME);
796     entry.nServers = 1;
797     entry.serverNumber[0] = aserver;    /* this should have another
798                                          * level of indirection later */
799     entry.serverPartition[0] = apart;   /* this should also have
800                                          * another indirection level */
801     entry.flags = RW_EXISTS;    /* this records that rw volume exists */
802     entry.serverFlags[0] = ITSRWVOL;    /*this rep site has rw  vol */
803     entry.volumeId[RWVOL] = *anewid;
804     entry.volumeId[ROVOL] = aroid ? *aroid : 0;
805     entry.volumeId[BACKVOL] = abkid ? *abkid : 0;
806     entry.cloneId = 0;
807     /*map into right byte order, before passing to xdr, the stuff has to be in host
808      * byte order. Xdr converts it into network order */
809     MapNetworkToHost(&entry, &storeEntry);
810     /* create the vldb entry */
811     vcode = VLDB_CreateEntry(&storeEntry);
812     if (vcode) {
813         fprintf(STDERR,
814                 "Could not create a VLDB entry for the volume %s %lu\n",
815                 aname, (unsigned long)*anewid);
816         /*destroy the created volume */
817         VPRINT1("Deleting the newly created volume %u\n", *anewid);
818         AFSVolDeleteVolume(aconn, tid);
819         error = vcode;
820         goto cfail;
821     }
822     VPRINT2("Created the VLDB entry for the volume %s %u\n", aname, *anewid);
823     /* volume created, now terminate the transaction and release the connection */
824     code = AFSVolEndTrans(aconn, tid, &rcode);  /*if it crashes before this
825                                                  * the volume will come online anyway when transaction timesout , so if
826                                                  * vldb entry exists then the volume is guaranteed to exist too wrt create */
827     tid = 0;
828     if (code) {
829         fprintf(STDERR,
830                 "Failed to end the transaction on the volume %s %lu\n", aname,
831                 (unsigned long)*anewid);
832         error = code;
833         goto cfail;
834     }
835
836   cfail:
837     if (tid) {
838         code = AFSVolEndTrans(aconn, tid, &rcode);
839         if (code)
840             fprintf(STDERR, "WARNING: could not end transaction\n");
841     }
842     if (aconn)
843         rx_DestroyConnection(aconn);
844     PrintError("", error);
845     return error;
846 }
847
848 /* create a volume, given a server, partition number, volume name --> sends
849 * back new vol id in <anewid>*/
850 int
851 UV_AddVLDBEntry(afs_uint32 aserver, afs_int32 apart, char *aname,
852                 afs_uint32 aid)
853 {
854     struct rx_connection *aconn;
855     afs_int32 error;
856     afs_int32 vcode;
857     struct nvldbentry entry, storeEntry;        /*the new vldb entry */
858
859     aconn = (struct rx_connection *)0;
860     error = 0;
861
862     /* set up the vldb entry for this volume */
863     strncpy(entry.name, aname, VOLSER_OLDMAXVOLNAME);
864     entry.nServers = 1;
865     entry.serverNumber[0] = aserver;    /* this should have another
866                                          * level of indirection later */
867     entry.serverPartition[0] = apart;   /* this should also have
868                                          * another indirection level */
869     entry.flags = RW_EXISTS;    /* this records that rw volume exists */
870     entry.serverFlags[0] = ITSRWVOL;    /*this rep site has rw  vol */
871     entry.volumeId[RWVOL] = aid;
872 #ifdef notdef
873     entry.volumeId[ROVOL] = anewid + 1; /* rw,ro, bk id are related in the default case */
874     entry.volumeId[BACKVOL] = *anewid + 2;
875 #else
876     entry.volumeId[ROVOL] = 0;
877     entry.volumeId[BACKVOL] = 0;
878 #endif
879     entry.cloneId = 0;
880     /*map into right byte order, before passing to xdr, the stuff has to be in host
881      * byte order. Xdr converts it into network order */
882     MapNetworkToHost(&entry, &storeEntry);
883     /* create the vldb entry */
884     vcode = VLDB_CreateEntry(&storeEntry);
885     if (vcode) {
886         fprintf(STDERR,
887                 "Could not create a VLDB entry for the  volume %s %lu\n",
888                 aname, (unsigned long)aid);
889         error = vcode;
890         goto cfail;
891     }
892     VPRINT2("Created the VLDB entry for the volume %s %u\n", aname, aid);
893
894   cfail:
895     if (aconn)
896         rx_DestroyConnection(aconn);
897     PrintError("", error);
898     return error;
899 }
900
901 /* Delete the volume <volid>on <aserver> <apart>
902  * the physical entry gets removed from the vldb only if the ref count
903  * becomes zero
904  */
905 int
906 UV_DeleteVolume(afs_uint32 aserver, afs_int32 apart, afs_uint32 avolid)
907 {
908     struct rx_connection *aconn = (struct rx_connection *)0;
909     afs_int32 ttid = 0;
910     afs_int32 code, rcode;
911     afs_int32 error = 0;
912     struct nvldbentry entry, storeEntry;
913     int islocked = 0;
914     afs_int32 avoltype = -1, vtype;
915     int notondisk = 0, notinvldb = 0;
916
917     /* Find and read bhe VLDB entry for this volume */
918     code = ubik_VL_SetLock(cstruct, 0, avolid, avoltype, VLOP_DELETE);
919     if (code) {
920         if (code != VL_NOENT) {
921             EGOTO1(error_exit, code,
922                    "Could not lock VLDB entry for the volume %u\n", avolid);
923         }
924         notinvldb = 1;
925     } else {
926         islocked = 1;
927
928         code = VLDB_GetEntryByID(avolid, avoltype, &entry);
929         EGOTO1(error_exit, code, "Could not fetch VLDB entry for volume %u\n",
930                avolid);
931         MapHostToNetwork(&entry);
932
933         if (verbose)
934             EnumerateEntry(&entry);
935     }
936
937     /* Whether volume is in the VLDB or not. Delete the volume on disk */
938     aconn = UV_Bind(aserver, AFSCONF_VOLUMEPORT);
939     code = AFSVolTransCreate_retry(aconn, avolid, apart, ITOffline, &ttid);
940     if (code) {
941         if (code == VNOVOL) {
942             notondisk = 1;
943         } else {
944             EGOTO1(error_exit, code, "Transaction on volume %u failed\n",
945                    avolid);
946         }
947     } else {
948         VPRINT1("Trying to delete the volume %u ...", avolid);
949
950         code = AFSVolDeleteVolume(aconn, ttid);
951         EGOTO1(error_exit, code, "Could not delete the volume %u \n", avolid);
952
953         code = AFSVolEndTrans(aconn, ttid, &rcode);
954         code = (code ? code : rcode);
955         ttid = 0;
956         EGOTO1(error_exit, code,
957                "Could not end the transaction for the volume %u \n", avolid);
958         VDONE;
959     }
960
961     /* Now update the VLDB entry.
962      * But first, verify we have a VLDB entry.
963      * Whether volume is on disk or not. Delete the volume in VLDB.
964      */
965     if (notinvldb)
966         ERROR_EXIT(0);
967
968     if (avolid == entry.volumeId[BACKVOL]) {
969         /* Its a backup volume, modify the VLDB entry. Check that the
970          * backup volume is on the server/partition we asked to delete.
971          */
972         if (!(entry.flags & BACK_EXISTS) || !Lp_Match(aserver, apart, &entry)) {
973             notinvldb = 2;      /* Not on this server and partition */
974             ERROR_EXIT(0);
975         }
976
977         VPRINT1("Marking the backup volume %u deleted in the VLDB\n", avolid);
978
979         entry.flags &= ~BACK_EXISTS;
980         vtype = BACKVOL;
981     }
982
983     else if (avolid == entry.volumeId[ROVOL]) {
984         /* Its a read-only volume, modify the VLDB entry. Check that the
985          * readonly volume is on the server/partition we asked to delete.
986          * If flags does not have RO_EIXSTS set, then this may mean the RO
987          * hasn't been released (and could exist in VLDB).
988          */
989         if (!Lp_ROMatch(aserver, apart, &entry)) {
990             notinvldb = 2;      /* Not found on this server and partition */
991             ERROR_EXIT(0);
992         }
993
994         if (verbose)
995             fprintf(STDOUT,
996                     "Marking the readonly volume %lu deleted in the VLDB\n",
997                     (unsigned long)avolid);
998
999         Lp_SetROValue(&entry, aserver, apart, 0, 0);    /* delete the site */
1000         entry.nServers--;
1001         if (!Lp_ROMatch(0, 0, &entry))
1002             entry.flags &= ~RO_EXISTS;  /* This was the last ro volume */
1003         vtype = ROVOL;
1004     }
1005
1006     else if (avolid == entry.volumeId[RWVOL]) {
1007         /* It's a rw volume, delete the backup volume, modify the VLDB entry.
1008          * Check that the readwrite volumes is on the server/partition we
1009          * asked to delete.
1010          */
1011         if (!(entry.flags & RW_EXISTS) || !Lp_Match(aserver, apart, &entry)) {
1012             notinvldb = 2;      /* Not found on this server and partition */
1013             ERROR_EXIT(0);
1014         }
1015
1016         /* Delete backup if it exists */
1017         code =
1018             AFSVolTransCreate_retry(aconn, entry.volumeId[BACKVOL], apart,
1019                                     ITOffline, &ttid);
1020
1021         if (!code) {
1022             if (verbose) {
1023                 fprintf(STDOUT, "Trying to delete the backup volume %u ...",
1024                         entry.volumeId[BACKVOL]);
1025                 fflush(STDOUT);
1026             }
1027             code = AFSVolDeleteVolume(aconn, ttid);
1028             EGOTO1(error_exit, code, "Could not delete the volume %u \n",
1029                    entry.volumeId[BACKVOL]);
1030
1031             code = AFSVolEndTrans(aconn, ttid, &rcode);
1032             ttid = 0;
1033             code = (code ? code : rcode);
1034             EGOTO1(error_exit, code,
1035                    "Could not end the transaction for the volume %u \n",
1036                    entry.volumeId[BACKVOL]);
1037             if (verbose)
1038                 fprintf(STDOUT, " done\n");
1039         }
1040
1041         if (verbose)
1042             fprintf(STDOUT,
1043                     "Marking the readwrite volume %lu%s deleted in the VLDB\n",
1044                     (unsigned long)avolid,
1045                     ((entry.
1046                       flags & BACK_EXISTS) ? ", and its backup volume," :
1047                      ""));
1048
1049         Lp_SetRWValue(&entry, aserver, apart, 0L, 0L);
1050         entry.nServers--;
1051         entry.flags &= ~(BACK_EXISTS | RW_EXISTS);
1052         vtype = RWVOL;
1053
1054         if (entry.flags & RO_EXISTS)
1055             fprintf(STDERR, "WARNING: ReadOnly copy(s) may still exist\n");
1056     }
1057
1058     else {
1059         notinvldb = 2;          /* Not found on this server and partition */
1060         ERROR_EXIT(0);
1061     }
1062
1063     /* Either delete or replace the VLDB entry */
1064     if ((entry.nServers <= 0) || !(entry.flags & (RO_EXISTS | RW_EXISTS))) {
1065         if (verbose)
1066             fprintf(STDOUT,
1067                     "Last reference to the VLDB entry for %lu - deleting entry\n",
1068                     (unsigned long)avolid);
1069         code = ubik_VL_DeleteEntry(cstruct, 0, avolid, vtype);
1070         EGOTO1(error_exit, code,
1071                "Could not delete the VLDB entry for the volume %u \n",
1072                avolid);
1073     } else {
1074         MapNetworkToHost(&entry, &storeEntry);
1075         code =
1076             VLDB_ReplaceEntry(avolid, vtype, &storeEntry,
1077                               (LOCKREL_OPCODE | LOCKREL_AFSID |
1078                                LOCKREL_TIMESTAMP));
1079         EGOTO1(error_exit, code,
1080                "Could not update the VLDB entry for the volume %u \n",
1081                avolid);
1082     }
1083     islocked = 0;
1084
1085   error_exit:
1086     if (error)
1087         EPRINT(error, "\n");
1088
1089     if (notondisk && notinvldb) {
1090         EPRINT2(VOLSERNOVOL, "Volume %u does not exist %s\n", avolid,
1091                 ((notinvldb == 2) ? "on server and partition" : ""));
1092         if (!error)
1093             error = VOLSERNOVOL;
1094     } else if (notondisk) {
1095         fprintf(STDERR,
1096                 "WARNING: Volume %lu did not exist on the partition\n",
1097                 (unsigned long)avolid);
1098     } else if (notinvldb) {
1099         fprintf(STDERR, "WARNING: Volume %lu does not exist in VLDB %s\n",
1100                 (unsigned long)avolid,
1101                 ((notinvldb == 2) ? "on server and partition" : ""));
1102     }
1103
1104     if (ttid) {
1105         code = AFSVolEndTrans(aconn, ttid, &rcode);
1106         code = (code ? code : rcode);
1107         if (code) {
1108             fprintf(STDERR, "Could not end transaction on the volume %lu\n",
1109                     (unsigned long)avolid);
1110             PrintError("", code);
1111             if (!error)
1112                 error = code;
1113         }
1114     }
1115
1116     if (islocked) {
1117         code =
1118             ubik_VL_ReleaseLock(cstruct, 0, avolid, -1,
1119                                 (LOCKREL_OPCODE | LOCKREL_AFSID |
1120                                  LOCKREL_TIMESTAMP));
1121         if (code) {
1122             EPRINT1(code,
1123                     "Could not release the lock on the VLDB entry for the volume %u \n",
1124                     avolid);
1125             if (!error)
1126                 error = code;
1127         }
1128     }
1129
1130     if (aconn)
1131         rx_DestroyConnection(aconn);
1132     return error;
1133 }
1134
1135 /* add recovery to UV_MoveVolume */
1136
1137 #define TESTC   0               /* set to test recovery code, clear for production */
1138
1139 jmp_buf env;
1140 int interrupt = 0;
1141
1142 static void *
1143 do_interrupt(void * unused)
1144 {
1145     if (interrupt) {
1146 #if !defined(AFS_PTHREAD_ENV) && !defined(AFS_NT40_ENV)
1147         /* Avoid UNIX LWP from getting confused that our stack has suddenly
1148          * changed. This will avoid some sanity checks, but until a better way
1149          * is found, the only alternative is always crashing and burning on at
1150          * least the stack-overflow check. */
1151         lwp_cpptr->stack = NULL;
1152 #endif
1153         longjmp(env, 0);
1154     }
1155
1156     fprintf(STDOUT, "\nSIGINT handler: vos move operation in progress\n");
1157     fprintf(STDOUT,
1158             "WARNING: may leave AFS storage and metadata in indeterminate state\n");
1159     fprintf(STDOUT, "enter second control-c to exit\n");
1160     fflush(STDOUT);
1161
1162     interrupt = 1;
1163     return NULL;
1164 }
1165
1166 static void
1167 sigint_handler(int x)
1168 {
1169 #ifdef AFS_PTHREAD_ENV
1170     do_interrupt(NULL);
1171 #else
1172     IOMGR_SoftSig(do_interrupt, 0);
1173 #endif
1174     (void)signal(SIGINT, sigint_handler);
1175 }
1176
1177 /* Move volume <afromvol> on <afromserver> <afrompart> to <atoserver>
1178  * <atopart>.  The operation is almost idempotent.  The following
1179  * flags are recognized:
1180  *
1181  *     RV_NOCLONE - don't use a copy clone
1182  */
1183
1184 int
1185 UV_MoveVolume2(afs_uint32 afromvol, afs_uint32 afromserver, afs_int32 afrompart,
1186                afs_uint32 atoserver, afs_int32 atopart, int flags)
1187 {
1188     /* declare stuff 'volatile' that may be used from setjmp/longjmp and may
1189      * be changing during the move */
1190     struct rx_connection * volatile toconn;
1191     struct rx_connection * volatile fromconn;
1192     afs_int32 volatile fromtid;
1193     afs_int32 volatile totid;
1194     afs_int32 volatile clonetid;
1195     afs_uint32 volatile newVol;
1196     afs_uint32 volatile volid;
1197     afs_uint32 volatile backupId;
1198     int volatile islocked;
1199     int volatile pntg;
1200
1201     char vname[64];
1202     char *volName = 0;
1203     char tmpName[VOLSER_MAXVOLNAME + 1];
1204     afs_int32 rcode;
1205     afs_int32 fromDate;
1206     afs_int32 tmp;
1207     afs_uint32 tmpVol;
1208     struct restoreCookie cookie;
1209     afs_int32 vcode, code;
1210     struct volser_status tstatus;
1211     struct destServer destination;
1212
1213     struct nvldbentry entry, storeEntry;
1214     int i;
1215     afs_int32 error;
1216     char in, lf;                /* for test code */
1217     int same;
1218     char hoststr[16];
1219
1220 #ifdef  ENABLE_BUGFIX_1165
1221     volEntries volumeInfo;
1222     struct volintInfo *infop = 0;
1223 #endif
1224
1225     islocked = 0;
1226     fromconn = (struct rx_connection *)0;
1227     toconn = (struct rx_connection *)0;
1228     fromtid = 0;
1229     totid = 0;
1230     clonetid = 0;
1231     error = 0;
1232     volid = 0;
1233     pntg = 0;
1234     backupId = 0;
1235     newVol = 0;
1236
1237     /* support control-c processing */
1238     if (setjmp(env))
1239         goto mfail;
1240     (void)signal(SIGINT, sigint_handler);
1241
1242     if (TESTC) {
1243         fprintf(STDOUT,
1244                 "\nThere are three tests points - verifies all code paths through recovery.\n");
1245         fprintf(STDOUT, "First test point - operation not started.\n");
1246         fprintf(STDOUT, "...test here (y, n)? ");
1247         fflush(STDOUT);
1248         fscanf(stdin, "%c", &in);
1249         fscanf(stdin, "%c", &lf);       /* toss away */
1250         if (in == 'y') {
1251             fprintf(STDOUT, "type control-c\n");
1252             while (1) {
1253                 fprintf(stdout, ".");
1254                 fflush(stdout);
1255                 sleep(1);
1256             }
1257         }
1258         /* or drop through */
1259     }
1260
1261     vcode = VLDB_GetEntryByID(afromvol, -1, &entry);
1262     EGOTO1(mfail, vcode,
1263            "Could not fetch the entry for the volume  %u from the VLDB \n",
1264            afromvol);
1265
1266     if (entry.volumeId[RWVOL] != afromvol) {
1267         fprintf(STDERR, "Only RW volume can be moved\n");
1268         exit(1);
1269     }
1270
1271     vcode = ubik_VL_SetLock(cstruct, 0, afromvol, RWVOL, VLOP_MOVE);
1272     EGOTO1(mfail, vcode, "Could not lock entry for volume %u \n", afromvol);
1273     islocked = 1;
1274
1275     vcode = VLDB_GetEntryByID(afromvol, RWVOL, &entry);
1276     EGOTO1(mfail, vcode,
1277            "Could not fetch the entry for the volume  %u from the VLDB \n",
1278            afromvol);
1279
1280     backupId = entry.volumeId[BACKVOL];
1281     MapHostToNetwork(&entry);
1282
1283     if (!Lp_Match(afromserver, afrompart, &entry)) {
1284         /* the from server and partition do not exist in the vldb entry corresponding to volid */
1285         if (!Lp_Match(atoserver, atopart, &entry)) {
1286             /* the to server and partition do not exist in the vldb entry corresponding to volid */
1287             fprintf(STDERR, "The volume %lu is not on the specified site. \n",
1288                     (unsigned long)afromvol);
1289             fprintf(STDERR, "The current site is :");
1290             for (i = 0; i < entry.nServers; i++) {
1291                 if (entry.serverFlags[i] == ITSRWVOL) {
1292                     char pname[10];
1293                     MapPartIdIntoName(entry.serverPartition[i], pname);
1294                     fprintf(STDERR, " server %s partition %s \n",
1295                             noresolve ? afs_inet_ntoa_r(entry.serverNumber[i], hoststr) :
1296                             hostutil_GetNameByINet(entry.serverNumber[i]),
1297                             pname);
1298                 }
1299             }
1300             vcode =
1301                 ubik_VL_ReleaseLock(cstruct, 0, afromvol, -1,
1302                           (LOCKREL_OPCODE | LOCKREL_AFSID |
1303                            LOCKREL_TIMESTAMP));
1304             EGOTO1(mfail, vcode,
1305                    " Could not release lock on the VLDB entry for the volume %u \n",
1306                    afromvol);
1307
1308             return VOLSERVOLMOVED;
1309         }
1310
1311         /* delete the volume afromvol on src_server */
1312         /* from-info does not exist but to-info does =>
1313          * we have already done the move, but the volume
1314          * may still be existing physically on from fileserver
1315          */
1316         fromconn = UV_Bind(afromserver, AFSCONF_VOLUMEPORT);
1317         fromtid = 0;
1318         pntg = 1;
1319
1320         tmp = fromtid;
1321         code =
1322             AFSVolTransCreate_retry(fromconn, afromvol, afrompart, ITOffline,
1323                                     &tmp);
1324         fromtid = tmp;
1325
1326         if (!code) {            /* volume exists - delete it */
1327             VPRINT1("Setting flags on leftover source volume %u ...",
1328                     afromvol);
1329             code =
1330                 AFSVolSetFlags(fromconn, fromtid,
1331                                VTDeleteOnSalvage | VTOutOfService);
1332             EGOTO1(mfail, code,
1333                    "Failed to set flags on the leftover source volume %u\n",
1334                    afromvol);
1335             VDONE;
1336
1337             VPRINT1("Deleting leftover source volume %u ...", afromvol);
1338             code = AFSVolDeleteVolume(fromconn, fromtid);
1339             EGOTO1(mfail, code,
1340                    "Failed to delete the leftover source volume %u\n",
1341                    afromvol);
1342             VDONE;
1343
1344             VPRINT1("Ending transaction on leftover source volume %u ...",
1345                     afromvol);
1346             code = AFSVolEndTrans(fromconn, fromtid, &rcode);
1347             fromtid = 0;
1348             if (!code)
1349                 code = rcode;
1350             EGOTO1(mfail, code,
1351                    "Could not end the transaction for the leftover source volume %u \n",
1352                    afromvol);
1353             VDONE;
1354         }
1355
1356         /*delete the backup volume now */
1357         fromtid = 0;
1358         code =
1359             AFSVolTransCreate_retry(fromconn, backupId, afrompart, ITOffline,
1360                                     &tmp);
1361         fromtid = tmp;
1362
1363         if (!code) {            /* backup volume exists - delete it */
1364             VPRINT1("Setting flags on leftover backup volume %u ...",
1365                     backupId);
1366             code =
1367                 AFSVolSetFlags(fromconn, fromtid,
1368                                VTDeleteOnSalvage | VTOutOfService);
1369             EGOTO1(mfail, code,
1370                    "Failed to set flags on the backup volume %u\n", backupId);
1371             VDONE;
1372
1373             VPRINT1("Deleting leftover backup volume %u ...", backupId);
1374             code = AFSVolDeleteVolume(fromconn, fromtid);
1375             EGOTO1(mfail, code,
1376                    "Could not delete the leftover backup volume %u\n",
1377                    backupId);
1378             VDONE;
1379
1380             VPRINT1("Ending transaction on leftover backup volume %u ...",
1381                     backupId);
1382             code = AFSVolEndTrans(fromconn, fromtid, &rcode);
1383             fromtid = 0;
1384             if (!code)
1385                 code = rcode;
1386             EGOTO1(mfail, code,
1387                    "Could not end the transaction for the leftover backup volume %u\n",
1388                    backupId);
1389             VDONE;
1390         }
1391
1392         fromtid = 0;
1393         error = 0;
1394         goto mfail;
1395     }
1396
1397     /* From-info matches the vldb info about volid,
1398      * its ok start the move operation, the backup volume
1399      * on the old site is deleted in the process
1400      */
1401     if (afrompart == atopart) {
1402         same = VLDB_IsSameAddrs(afromserver, atoserver, &error);
1403         EGOTO2(mfail, error,
1404                "Failed to get info about server's %d address(es) from vlserver (err=%d); aborting call!\n",
1405                afromserver, error);
1406
1407         if (same) {
1408             EGOTO1(mfail, VOLSERVOLMOVED,
1409                    "Warning: Moving volume %u to its home partition ignored!\n",
1410                    afromvol);
1411         }
1412     }
1413
1414     pntg = 1;
1415     toconn = UV_Bind(atoserver, AFSCONF_VOLUMEPORT);    /* get connections to the servers */
1416     fromconn = UV_Bind(afromserver, AFSCONF_VOLUMEPORT);
1417     fromtid = totid = 0;        /* initialize to uncreated */
1418
1419     /* ***
1420      * clone the read/write volume locally.
1421      * ***/
1422
1423     VPRINT1("Starting transaction on source volume %u ...", afromvol);
1424     code = AFSVolTransCreate_retry(fromconn, afromvol, afrompart, ITBusy, &tmp);
1425     fromtid = tmp;
1426     EGOTO1(mfail, code, "Failed to create transaction on the volume %u\n",
1427            afromvol);
1428     VDONE;
1429
1430     if (!(flags & RV_NOCLONE)) {
1431         /* Get a clone id */
1432         VPRINT1("Allocating new volume id for clone of volume %u ...",
1433                 afromvol);
1434         newVol = tmpVol = 0;
1435         vcode = ubik_VL_GetNewVolumeId(cstruct, 0, 1, &tmpVol);
1436         newVol = tmpVol;
1437         EGOTO1(mfail, vcode,
1438                "Could not get an ID for the clone of volume %u from the VLDB\n",
1439                afromvol);
1440         VDONE;
1441
1442         /* Do the clone. Default flags on clone are set to delete on salvage and out of service */
1443         VPRINT1("Cloning source volume %u ...", afromvol);
1444         strcpy(vname, "move-clone-temp");
1445         code =
1446             AFSVolClone(fromconn, fromtid, 0, readonlyVolume, vname, &tmpVol);
1447         newVol = tmpVol;
1448         EGOTO1(mfail, code, "Failed to clone the source volume %u\n",
1449                afromvol);
1450         VDONE;
1451     }
1452
1453     /* lookup the name of the volume we just cloned */
1454     volid = afromvol;
1455     code = AFSVolGetName(fromconn, fromtid, &volName);
1456     EGOTO1(mfail, code, "Failed to get the name of the volume %u\n",
1457            afromvol);
1458
1459     VPRINT1("Ending the transaction on the source volume %u ...", afromvol);
1460     rcode = 0;
1461     code = AFSVolEndTrans(fromconn, fromtid, &rcode);
1462     fromtid = 0;
1463     if (!code)
1464         code = rcode;
1465     EGOTO1(mfail, code,
1466            "Failed to end the transaction on the source volume %u\n",
1467            afromvol);
1468     VDONE;
1469
1470     /* ***
1471      * Create the destination volume
1472      * ***/
1473
1474     if (!(flags & RV_NOCLONE)) {
1475         /* All of this is to get the fromDate */
1476         VPRINT1("Starting transaction on the cloned volume %u ...", newVol);
1477         tmp = clonetid;
1478         code =
1479             AFSVolTransCreate_retry(fromconn, newVol, afrompart, ITOffline,
1480                               &tmp);
1481         clonetid = tmp;
1482         EGOTO1(mfail, code,
1483                "Failed to start a transaction on the cloned volume%u\n",
1484                newVol);
1485         VDONE;
1486
1487         VPRINT1("Setting flags on cloned volume %u ...", newVol);
1488         code =
1489             AFSVolSetFlags(fromconn, clonetid,
1490                            VTDeleteOnSalvage | VTOutOfService); /*redundant */
1491         EGOTO1(mfail, code, "Could not set flags on the cloned volume %u\n",
1492                newVol);
1493         VDONE;
1494
1495         /* remember time from which we've dumped the volume */
1496         VPRINT1("Getting status of cloned volume %u ...", newVol);
1497         code = AFSVolGetStatus(fromconn, clonetid, &tstatus);
1498         EGOTO1(mfail, code,
1499                "Failed to get the status of the cloned volume %u\n",
1500                newVol);
1501         VDONE;
1502
1503         fromDate = CLOCKADJ(tstatus.creationDate);
1504     } else {
1505         /* With RV_NOCLONE, just do a full copy from the source */
1506         fromDate = 0;
1507     }
1508
1509
1510 #ifdef  ENABLE_BUGFIX_1165
1511     /*
1512      * Get the internal volume state from the source volume. We'll use such info (i.e. dayUse)
1513      * to copy it to the new volume (via AFSSetInfo later on) so that when we move volumes we
1514      * don't use this information...
1515      */
1516     volumeInfo.volEntries_val = (volintInfo *) 0;       /*this hints the stub to allocate space */
1517     volumeInfo.volEntries_len = 0;
1518     code = AFSVolListOneVolume(fromconn, afrompart, afromvol, &volumeInfo);
1519     EGOTO1(mfail, code,
1520            "Failed to get the volint Info of the cloned volume %u\n",
1521            afromvol);
1522
1523     infop = (volintInfo *) volumeInfo.volEntries_val;
1524     infop->maxquota = -1;       /* Else it will replace the default quota */
1525     infop->creationDate = -1;   /* Else it will use the source creation date */
1526     infop->updateDate = -1;     /* Else it will use the source update date */
1527 #endif
1528
1529     /* create a volume on the target machine */
1530     volid = afromvol;
1531     tmp = totid;
1532     code = AFSVolTransCreate_retry(toconn, volid, atopart, ITOffline, &tmp);
1533     totid = tmp;
1534     if (!code) {
1535         /* Delete the existing volume.
1536          * While we are deleting the volume in these steps, the transaction
1537          * we started against the cloned volume (clonetid above) will be
1538          * sitting idle. It will get cleaned up after 600 seconds
1539          */
1540         VPRINT1("Deleting pre-existing volume %u on destination ...", volid);
1541         code = AFSVolDeleteVolume(toconn, totid);
1542         EGOTO1(mfail, code,
1543                "Could not delete the pre-existing volume %u on destination\n",
1544                volid);
1545         VDONE;
1546
1547         VPRINT1
1548             ("Ending transaction on pre-existing volume %u on destination ...",
1549              volid);
1550         code = AFSVolEndTrans(toconn, totid, &rcode);
1551         totid = 0;
1552         if (!code)
1553             code = rcode;
1554         EGOTO1(mfail, code,
1555                "Could not end the transaction on pre-existing volume %u on destination\n",
1556                volid);
1557         VDONE;
1558     }
1559
1560     VPRINT1("Creating the destination volume %u ...", volid);
1561     tmp = totid;
1562     tmpVol = volid;
1563     code =
1564         AFSVolCreateVolume(toconn, atopart, volName, volser_RW, volid, &tmpVol,
1565                            &tmp);
1566     totid = tmp;
1567     volid = tmpVol;
1568     EGOTO1(mfail, code, "Failed to create the destination volume %u\n",
1569            volid);
1570     VDONE;
1571
1572     strncpy(tmpName, volName, VOLSER_OLDMAXVOLNAME);
1573     free(volName);
1574     volName = NULL;
1575
1576     VPRINT1("Setting volume flags on destination volume %u ...", volid);
1577     code =
1578         AFSVolSetFlags(toconn, totid, (VTDeleteOnSalvage | VTOutOfService));
1579     EGOTO1(mfail, code,
1580            "Failed to set the flags on the destination volume %u\n", volid);
1581     VDONE;
1582
1583     /***
1584      * Now dump the clone to the new volume
1585      ***/
1586
1587     destination.destHost = ntohl(atoserver);
1588     destination.destPort = AFSCONF_VOLUMEPORT;
1589     destination.destSSID = 1;
1590
1591     strncpy(cookie.name, tmpName, VOLSER_OLDMAXVOLNAME);
1592     cookie.type = RWVOL;
1593     cookie.parent = entry.volumeId[RWVOL];
1594     cookie.clone = 0;
1595
1596     if (!(flags & RV_NOCLONE)) {
1597         /* Copy the clone to the new volume */
1598         VPRINT2("Dumping from clone %u on source to volume %u on destination ...",
1599                 newVol, afromvol);
1600         code =
1601             AFSVolForward(fromconn, clonetid, 0, &destination, totid,
1602                           &cookie);
1603         EGOTO1(mfail, code, "Failed to move data for the volume %u\n", volid);
1604         VDONE;
1605
1606         VPRINT1("Ending transaction on cloned volume %u ...", newVol);
1607         code = AFSVolEndTrans(fromconn, clonetid, &rcode);
1608         if (!code)
1609             code = rcode;
1610         clonetid = 0;
1611         EGOTO1(mfail, code,
1612                "Failed to end the transaction on the cloned volume %u\n",
1613                newVol);
1614         VDONE;
1615     }
1616
1617     /* ***
1618      * reattach to the main-line volume, and incrementally dump it.
1619      * ***/
1620
1621     VPRINT1("Starting transaction on source volume %u ...", afromvol);
1622     tmp = fromtid;
1623     code = AFSVolTransCreate_retry(fromconn, afromvol, afrompart, ITBusy, &tmp);
1624     fromtid = tmp;
1625     EGOTO1(mfail, code,
1626            "Failed to create a transaction on the source volume %u\n",
1627            afromvol);
1628     VDONE;
1629
1630     /* now do the incremental */
1631     VPRINT2
1632         ("Doing the%s dump from source to destination for volume %u ... ",
1633          (flags & RV_NOCLONE) ? "" : " incremental",
1634          afromvol);
1635     code =
1636         AFSVolForward(fromconn, fromtid, fromDate, &destination, totid,
1637                       &cookie);
1638     EGOTO1(mfail, code,
1639            "Failed to do the%s dump from rw volume on old site to rw volume on newsite\n",
1640           (flags & RV_NOCLONE) ? "" : " incremental");
1641     VDONE;
1642
1643     /* now adjust the flags so that the new volume becomes official */
1644     VPRINT1("Setting volume flags on old source volume %u ...", afromvol);
1645     code = AFSVolSetFlags(fromconn, fromtid, VTOutOfService);
1646     EGOTO(mfail, code,
1647           "Failed to set the flags to make old source volume offline\n");
1648     VDONE;
1649
1650     VPRINT1("Setting volume flags on new source volume %u ...", afromvol);
1651     code = AFSVolSetFlags(toconn, totid, 0);
1652     EGOTO(mfail, code,
1653           "Failed to set the flags to make new source volume online\n");
1654     VDONE;
1655
1656 #ifdef  ENABLE_BUGFIX_1165
1657     VPRINT1("Setting volume status on destination volume %u ...", volid);
1658     code = AFSVolSetInfo(toconn, totid, infop);
1659     EGOTO1(mfail, code,
1660            "Failed to set volume status on the destination volume %u\n",
1661            volid);
1662     VDONE;
1663 #endif
1664
1665     /* put new volume online */
1666     VPRINT1("Ending transaction on destination volume %u ...", afromvol);
1667     code = AFSVolEndTrans(toconn, totid, &rcode);
1668     totid = 0;
1669     if (!code)
1670         code = rcode;
1671     EGOTO1(mfail, code,
1672            "Failed to end the transaction on the volume %u on the new site\n",
1673            afromvol);
1674     VDONE;
1675
1676     Lp_SetRWValue(&entry, afromserver, afrompart, atoserver, atopart);
1677     MapNetworkToHost(&entry, &storeEntry);
1678     storeEntry.flags &= ~BACK_EXISTS;
1679
1680     if (TESTC) {
1681         fprintf(STDOUT,
1682                 "Second test point - operation in progress but not complete.\n");
1683         fprintf(STDOUT, "...test here (y, n)? ");
1684         fflush(STDOUT);
1685         fscanf(stdin, "%c", &in);
1686         fscanf(stdin, "%c", &lf);       /* toss away */
1687         if (in == 'y') {
1688             fprintf(STDOUT, "type control-c\n");
1689             while (1) {
1690                 fprintf(stdout, ".");
1691                 fflush(stdout);
1692                 sleep(1);
1693             }
1694         }
1695         /* or drop through */
1696     }
1697
1698     VPRINT1("Releasing lock on VLDB entry for volume %u ...", afromvol);
1699     vcode =
1700         VLDB_ReplaceEntry(afromvol, -1, &storeEntry,
1701                           (LOCKREL_OPCODE | LOCKREL_AFSID |
1702                            LOCKREL_TIMESTAMP));
1703     if (vcode) {
1704         fprintf(STDERR,
1705                 " Could not release the lock on the VLDB entry for the volume %s %lu \n",
1706                 storeEntry.name, (unsigned long)afromvol);
1707         error = vcode;
1708         goto mfail;
1709     }
1710     islocked = 0;
1711     VDONE;
1712
1713     if (TESTC) {
1714         fprintf(STDOUT,
1715                 "Third test point - operation complete but no cleanup.\n");
1716         fprintf(STDOUT, "...test here (y, n)? ");
1717         fflush(STDOUT);
1718         fscanf(stdin, "%c", &in);
1719         fscanf(stdin, "%c", &lf);       /* toss away */
1720         if (in == 'y') {
1721             fprintf(STDOUT, "type control-c\n");
1722             while (1) {
1723                 fprintf(stdout, ".");
1724                 fflush(stdout);
1725                 sleep(1);
1726             }
1727         }
1728         /* or drop through */
1729     }
1730 #ifdef notdef
1731     /* This is tricky.  File server is very stupid, and if you mark the volume
1732      * as VTOutOfService, it may mark the *good* instance (if you're moving
1733      * between partitions on the same machine) as out of service.  Since
1734      * we're cleaning this code up in DEcorum, we're just going to kludge around
1735      * it for now by removing this call. */
1736     /* already out of service, just zap it now */
1737     code =
1738         AFSVolSetFlags(fromconn, fromtid, VTDeleteOnSalvage | VTOutOfService);
1739     if (code) {
1740         fprintf(STDERR,
1741                 "Failed to set the flags to make the old source volume offline\n");
1742         goto mfail;
1743     }
1744 #endif
1745     if (atoserver != afromserver) {
1746         /* set forwarding pointer for moved volumes */
1747         VPRINT1("Setting forwarding pointer for volume %u ...", afromvol);
1748         code = AFSVolSetForwarding(fromconn, fromtid, atoserver);
1749         EGOTO1(mfail, code,
1750                "Failed to set the forwarding pointer for the volume %u\n",
1751                afromvol);
1752         VDONE;
1753     }
1754
1755     VPRINT1("Deleting old volume %u on source ...", afromvol);
1756     code = AFSVolDeleteVolume(fromconn, fromtid);       /* zap original volume */
1757     EGOTO1(mfail, code, "Failed to delete the old volume %u on source\n",
1758            afromvol);
1759     VDONE;
1760
1761     VPRINT1("Ending transaction on old volume %u on the source ...",
1762             afromvol);
1763     code = AFSVolEndTrans(fromconn, fromtid, &rcode);
1764     fromtid = 0;
1765     if (!code)
1766         code = rcode;
1767     EGOTO1(mfail, code,
1768            "Failed to end the transaction on the old volume %u on the source\n",
1769            afromvol);
1770     VDONE;
1771
1772     /* Delete the backup volume on the original site */
1773     VPRINT1("Creating transaction for backup volume %u on source ...",
1774             backupId);
1775     tmp = fromtid;
1776     code =
1777         AFSVolTransCreate_retry(fromconn, backupId, afrompart, ITOffline, &tmp);
1778     fromtid = tmp;
1779     VDONE;
1780     if (!code) {
1781         VPRINT1("Setting flags on backup volume %u on source ...", backupId);
1782         code =
1783             AFSVolSetFlags(fromconn, fromtid,
1784                            VTDeleteOnSalvage | VTOutOfService);
1785         EGOTO1(mfail, code,
1786                "Failed to set the flags on the backup volume %u on the source\n",
1787                backupId);
1788         VDONE;
1789
1790         VPRINT1("Deleting the backup volume %u on the source ...", backupId);
1791         code = AFSVolDeleteVolume(fromconn, fromtid);
1792         EGOTO1(mfail, code,
1793                "Failed to delete the backup volume %u on the source\n",
1794                backupId);
1795         VDONE;
1796
1797         VPRINT1("Ending transaction on backup volume %u on source ...",
1798                 backupId);
1799         code = AFSVolEndTrans(fromconn, fromtid, &rcode);
1800         fromtid = 0;
1801         if (!code)
1802             code = rcode;
1803         EGOTO1(mfail, code,
1804                "Failed to end the transaction on the backup volume %u on the source\n",
1805                backupId);
1806         VDONE;
1807     } else
1808         code = 0;               /* no backup volume? that's okay */
1809
1810     fromtid = 0;
1811     if (!(flags & RV_NOCLONE)) {
1812         VPRINT1("Starting transaction on the cloned volume %u ...", newVol);
1813         tmp = clonetid;
1814         code =
1815             AFSVolTransCreate_retry(fromconn, newVol, afrompart, ITOffline,
1816                               &tmp);
1817         clonetid = tmp;
1818         EGOTO1(mfail, code,
1819                "Failed to start a transaction on the cloned volume%u\n",
1820                newVol);
1821         VDONE;
1822
1823         /* now delete the clone */
1824         VPRINT1("Deleting the cloned volume %u ...", newVol);
1825         code = AFSVolDeleteVolume(fromconn, clonetid);
1826         EGOTO1(mfail, code, "Failed to delete the cloned volume %u\n",
1827                newVol);
1828         VDONE;
1829
1830         VPRINT1("Ending transaction on cloned volume %u ...", newVol);
1831         code = AFSVolEndTrans(fromconn, clonetid, &rcode);
1832         if (!code)
1833             code = rcode;
1834         clonetid = 0;
1835         EGOTO1(mfail, code,
1836                "Failed to end the transaction on the cloned volume %u\n",
1837                newVol);
1838         VDONE;
1839     }
1840
1841     /* fall through */
1842     /* END OF MOVE */
1843
1844     if (TESTC) {
1845         fprintf(STDOUT, "Fourth test point - operation complete.\n");
1846         fprintf(STDOUT, "...test here (y, n)? ");
1847         fflush(STDOUT);
1848         fscanf(stdin, "%c", &in);
1849         fscanf(stdin, "%c", &lf);       /* toss away */
1850         if (in == 'y') {
1851             fprintf(STDOUT, "type control-c\n");
1852             while (1) {
1853                 fprintf(stdout, ".");
1854                 fflush(stdout);
1855                 sleep(1);
1856             }
1857         }
1858         /* or drop through */
1859     }
1860
1861     /* normal cleanup code */
1862
1863     if (entry.flags & RO_EXISTS)
1864         fprintf(STDERR, "WARNING : readOnly copies still exist \n");
1865
1866     if (islocked) {
1867         VPRINT1("Cleanup: Releasing VLDB lock on volume %u ...", afromvol);
1868         vcode =
1869             ubik_VL_ReleaseLock(cstruct, 0, afromvol, -1,
1870                       (LOCKREL_OPCODE | LOCKREL_AFSID | LOCKREL_TIMESTAMP));
1871         if (vcode) {
1872             VPRINT("\n");
1873             fprintf(STDERR,
1874                     " Could not release the lock on the VLDB entry for the volume %lu \n",
1875                     (unsigned long)afromvol);
1876             if (!error)
1877                 error = vcode;
1878         }
1879         VDONE;
1880     }
1881
1882     if (fromtid) {
1883         VPRINT1("Cleanup: Ending transaction on source volume %u ...",
1884                 afromvol);
1885         code = AFSVolEndTrans(fromconn, fromtid, &rcode);
1886         if (code || rcode) {
1887             VPRINT("\n");
1888             fprintf(STDERR,
1889                     "Could not end transaction on the source volume %lu\n",
1890                     (unsigned long)afromvol);
1891             if (!error)
1892                 error = (code ? code : rcode);
1893         }
1894         VDONE;
1895     }
1896
1897     if (clonetid) {
1898         VPRINT1("Cleanup: Ending transaction on clone volume %u ...", newVol);
1899         code = AFSVolEndTrans(fromconn, clonetid, &rcode);
1900         if (code || rcode) {
1901             VPRINT("\n");
1902             fprintf(STDERR,
1903                     "Could not end transaction on the source's clone volume %lu\n",
1904                     (unsigned long)newVol);
1905             if (!error)
1906                 error = (code ? code : rcode);
1907         }
1908         VDONE;
1909     }
1910
1911     if (totid) {
1912         VPRINT1("Cleanup: Ending transaction on destination volume %u ...",
1913                 afromvol);
1914         code = AFSVolEndTrans(toconn, totid, &rcode);
1915         if (code) {
1916             VPRINT("\n");
1917             fprintf(STDERR,
1918                     "Could not end transaction on destination volume %lu\n",
1919                     (unsigned long)afromvol);
1920             if (!error)
1921                 error = (code ? code : rcode);
1922         }
1923         VDONE;
1924     }
1925     if (volName)
1926         free(volName);
1927 #ifdef  ENABLE_BUGFIX_1165
1928     if (infop)
1929         free(infop);
1930 #endif
1931     if (fromconn)
1932         rx_DestroyConnection(fromconn);
1933     if (toconn)
1934         rx_DestroyConnection(toconn);
1935     PrintError("", error);
1936     return error;
1937
1938     /* come here only when the sky falls */
1939   mfail:
1940
1941     if (pntg) {
1942         fprintf(STDOUT,
1943                 "vos move: operation interrupted, cleanup in progress...\n");
1944         fprintf(STDOUT, "clear transaction contexts\n");
1945         fflush(STDOUT);
1946     }
1947
1948     /* unlock VLDB entry */
1949     if (islocked) {
1950         VPRINT1("Recovery: Releasing VLDB lock on volume %u ...", afromvol);
1951         ubik_VL_ReleaseLock(cstruct, 0, afromvol, -1,
1952                   (LOCKREL_OPCODE | LOCKREL_AFSID | LOCKREL_TIMESTAMP));
1953         VDONE;
1954         islocked = 0;
1955     }
1956
1957     if (clonetid) {
1958         VPRINT("Recovery: Ending transaction on clone volume ...");
1959         AFSVolEndTrans(fromconn, clonetid, &rcode);
1960         VDONE;
1961     }
1962     if (totid) {
1963         VPRINT("Recovery: Ending transaction on destination volume ...");
1964         AFSVolEndTrans(toconn, totid, &rcode);
1965         VDONE;
1966     }
1967     if (fromtid) {              /* put it on-line */
1968         VPRINT("Recovery: Setting volume flags on source volume ...");
1969         AFSVolSetFlags(fromconn, fromtid, 0);
1970         VDONE;
1971
1972         VPRINT("Recovery: Ending transaction on source volume ...");
1973         AFSVolEndTrans(fromconn, fromtid, &rcode);
1974         VDONE;
1975     }
1976
1977     VPRINT("Recovery: Accessing VLDB.\n");
1978     vcode = VLDB_GetEntryByID(afromvol, -1, &entry);
1979     if (vcode) {
1980         fprintf(STDOUT, "FATAL: VLDB access error: abort cleanup\n");
1981         fflush(STDOUT);
1982         goto done;
1983     }
1984     MapHostToNetwork(&entry);
1985
1986     /* Delete either the volume on the source location or the target location.
1987      * If the vldb entry still points to the source location, then we know the
1988      * volume move didn't finish so we remove the volume from the target
1989      * location. Otherwise, we remove the volume from the source location.
1990      */
1991     if (Lp_Match(afromserver, afrompart, &entry)) {     /* didn't move - delete target volume */
1992         if (pntg) {
1993             fprintf(STDOUT,
1994                     "move incomplete - attempt cleanup of target partition - no guarantee\n");
1995             fflush(STDOUT);
1996         }
1997
1998         if (volid && toconn) {
1999             VPRINT1
2000                 ("Recovery: Creating transaction for destination volume %u ...",
2001                  volid);
2002             tmp = totid;
2003             code =
2004                 AFSVolTransCreate_retry(toconn, volid, atopart, ITOffline, &tmp);
2005             totid = tmp;
2006
2007             if (!code) {
2008                 VDONE;
2009
2010                 VPRINT1
2011                     ("Recovery: Setting flags on destination volume %u ...",
2012                      volid);
2013                 AFSVolSetFlags(toconn, totid,
2014                                VTDeleteOnSalvage | VTOutOfService);
2015                 VDONE;
2016
2017                 VPRINT1("Recovery: Deleting destination volume %u ...",
2018                         volid);
2019                 AFSVolDeleteVolume(toconn, totid);
2020                 VDONE;
2021
2022                 VPRINT1
2023                     ("Recovery: Ending transaction on destination volume %u ...",
2024                      volid);
2025                 AFSVolEndTrans(toconn, totid, &rcode);
2026                 VDONE;
2027             } else {
2028                 VPRINT1
2029                     ("\nRecovery: Unable to start transaction on destination volume %u.\n",
2030                      afromvol);
2031             }
2032         }
2033
2034         /* put source volume on-line */
2035         if (fromconn) {
2036             VPRINT1("Recovery: Creating transaction on source volume %u ...",
2037                     afromvol);
2038             tmp = fromtid;
2039             code =
2040                 AFSVolTransCreate_retry(fromconn, afromvol, afrompart, ITBusy,
2041                                   &tmp);
2042             fromtid = tmp;
2043             if (!code) {
2044                 VDONE;
2045
2046                 VPRINT1("Recovery: Setting flags on source volume %u ...",
2047                         afromvol);
2048                 AFSVolSetFlags(fromconn, fromtid, 0);
2049                 VDONE;
2050
2051                 VPRINT1
2052                     ("Recovery: Ending transaction on source volume %u ...",
2053                      afromvol);
2054                 AFSVolEndTrans(fromconn, fromtid, &rcode);
2055                 VDONE;
2056             } else {
2057                 VPRINT1
2058                     ("\nRecovery: Unable to start transaction on source volume %u.\n",
2059                      afromvol);
2060             }
2061         }
2062     } else {                    /* yep, move complete */
2063         if (pntg) {
2064             fprintf(STDOUT,
2065                     "move complete - attempt cleanup of source partition - no guarantee\n");
2066             fflush(STDOUT);
2067         }
2068
2069         /* delete backup volume */
2070         if (fromconn) {
2071             VPRINT1("Recovery: Creating transaction on backup volume %u ...",
2072                     backupId);
2073             tmp = fromtid;
2074             code =
2075                 AFSVolTransCreate_retry(fromconn, backupId, afrompart, ITOffline,
2076                                   &tmp);
2077             fromtid = tmp;
2078             if (!code) {
2079                 VDONE;
2080
2081                 VPRINT1("Recovery: Setting flags on backup volume %u ...",
2082                         backupId);
2083                 AFSVolSetFlags(fromconn, fromtid,
2084                                VTDeleteOnSalvage | VTOutOfService);
2085                 VDONE;
2086
2087                 VPRINT1("Recovery: Deleting backup volume %u ...", backupId);
2088                 AFSVolDeleteVolume(fromconn, fromtid);
2089                 VDONE;
2090
2091                 VPRINT1
2092                     ("Recovery: Ending transaction on backup volume %u ...",
2093                      backupId);
2094                 AFSVolEndTrans(fromconn, fromtid, &rcode);
2095                 VDONE;
2096             } else {
2097                 VPRINT1
2098                     ("\nRecovery: Unable to start transaction on backup volume %u.\n",
2099                      backupId);
2100             }
2101
2102             /* delete source volume */
2103             VPRINT1("Recovery: Creating transaction on source volume %u ...",
2104                     afromvol);
2105             tmp = fromtid;
2106             code =
2107                 AFSVolTransCreate_retry(fromconn, afromvol, afrompart, ITBusy,
2108                                   &tmp);
2109             fromtid = tmp;
2110             if (!code) {
2111                 VDONE;
2112
2113                 VPRINT1("Recovery: Setting flags on backup volume %u ...",
2114                         afromvol);
2115                 AFSVolSetFlags(fromconn, fromtid,
2116                                VTDeleteOnSalvage | VTOutOfService);
2117                 VDONE;
2118
2119                 if (atoserver != afromserver) {
2120                     VPRINT("Recovery: Setting volume forwarding pointer ...");
2121                     AFSVolSetForwarding(fromconn, fromtid, atoserver);
2122                     VDONE;
2123                 }
2124
2125                 VPRINT1("Recovery: Deleting source volume %u ...", afromvol);
2126                 AFSVolDeleteVolume(fromconn, fromtid);
2127                 VDONE;
2128
2129                 VPRINT1
2130                     ("Recovery: Ending transaction on source volume %u ...",
2131                      afromvol);
2132                 AFSVolEndTrans(fromconn, fromtid, &rcode);
2133                 VDONE;
2134             } else {
2135                 VPRINT1
2136                     ("\nRecovery: Unable to start transaction on source volume %u.\n",
2137                      afromvol);
2138             }
2139         }
2140     }
2141
2142     /* common cleanup - delete local clone */
2143     if (newVol) {
2144         VPRINT1("Recovery: Creating transaction on clone volume %u ...",
2145                 newVol);
2146         tmp = clonetid;
2147         code =
2148             AFSVolTransCreate_retry(fromconn, newVol, afrompart, ITOffline,
2149                               &tmp);
2150         clonetid = tmp;
2151         if (!code) {
2152             VDONE;
2153
2154             VPRINT1("Recovery: Deleting clone volume %u ...", newVol);
2155             AFSVolDeleteVolume(fromconn, clonetid);
2156             VDONE;
2157
2158             VPRINT1("Recovery: Ending transaction on clone volume %u ...",
2159                     newVol);
2160             AFSVolEndTrans(fromconn, clonetid, &rcode);
2161             VDONE;
2162         } else {
2163             VPRINT1
2164                 ("\nRecovery: Unable to start transaction on source volume %u.\n",
2165                  afromvol);
2166         }
2167     }
2168
2169     /* unlock VLDB entry */
2170     if (islocked) {
2171         VPRINT1("Recovery: Releasing lock on VLDB entry for volume %u ...",
2172                 afromvol);
2173         ubik_VL_ReleaseLock(cstruct, 0, afromvol, -1,
2174                             (LOCKREL_OPCODE | LOCKREL_AFSID | LOCKREL_TIMESTAMP));
2175         VDONE;
2176         islocked = 0;
2177     }
2178   done:                 /* routine cleanup */
2179     if (volName)
2180         free(volName);
2181 #ifdef  ENABLE_BUGFIX_1165
2182     if (infop)
2183         free(infop);
2184 #endif
2185     if (fromconn)
2186         rx_DestroyConnection(fromconn);
2187     if (toconn)
2188         rx_DestroyConnection(toconn);
2189
2190     if (pntg) {
2191         fprintf(STDOUT, "cleanup complete - user verify desired result\n");
2192         fflush(STDOUT);
2193     }
2194     exit(1);
2195 }
2196
2197
2198 int
2199 UV_MoveVolume(afs_uint32 afromvol, afs_uint32 afromserver, afs_int32 afrompart,
2200               afs_uint32 atoserver, afs_int32 atopart)
2201 {
2202     return UV_MoveVolume2(afromvol, afromserver, afrompart,
2203                           atoserver, atopart, 0);
2204 }
2205
2206
2207 /* Copy volume <afromvol> from <afromserver> <afrompart> to <atoserver>
2208  * <atopart>.  The new volume is named by <atovolname>.  The new volume
2209  * has ID <atovolid> if that is nonzero; otherwise a new ID is allocated
2210  * from the VLDB.  the following flags are supported:
2211  *
2212  *     RV_RDONLY  - target volume is RO
2213  *     RV_OFFLINE - leave target volume offline
2214  *     RV_CPINCR  - do incremental dump if target exists
2215  *     RV_NOVLDB  - don't create/update VLDB entry
2216  *     RV_NOCLONE - don't use a copy clone
2217  */
2218 int
2219 UV_CopyVolume2(afs_uint32 afromvol, afs_uint32 afromserver, afs_int32 afrompart,
2220                char *atovolname, afs_uint32 atoserver, afs_int32 atopart,
2221                afs_uint32 atovolid, int flags)
2222 {
2223     /* declare stuff 'volatile' that may be used from setjmp/longjmp and may
2224      * be changing during the copy */
2225     int volatile pntg;
2226     afs_int32 volatile clonetid;
2227     afs_int32 volatile totid;
2228     afs_int32 volatile fromtid;
2229     struct rx_connection * volatile fromconn;
2230     struct rx_connection * volatile toconn;
2231     afs_uint32 volatile cloneVol;
2232
2233     char vname[64];
2234     afs_int32 rcode;
2235     afs_int32 fromDate, cloneFromDate;
2236     struct restoreCookie cookie;
2237     afs_int32 vcode, code;
2238     afs_uint32 newVol;
2239     afs_int32 volflag;
2240     struct volser_status tstatus;
2241     struct destServer destination;
2242     struct nvldbentry entry, newentry, storeEntry;
2243     afs_int32 error;
2244     afs_int32 tmp;
2245     afs_uint32 tmpVol;
2246
2247     fromconn = (struct rx_connection *)0;
2248     toconn = (struct rx_connection *)0;
2249     fromtid = 0;
2250     totid = 0;
2251     clonetid = 0;
2252     error = 0;
2253     pntg = 0;
2254     newVol = 0;
2255
2256     /* support control-c processing */
2257     if (setjmp(env))
2258         goto mfail;
2259     (void)signal(SIGINT, sigint_handler);
2260
2261     vcode = VLDB_GetEntryByID(afromvol, -1, &entry);
2262     EGOTO1(mfail, vcode,
2263            "Could not fetch the entry for the volume  %u from the VLDB \n",
2264            afromvol);
2265     MapHostToNetwork(&entry);
2266
2267     pntg = 1;
2268     toconn = UV_Bind(atoserver, AFSCONF_VOLUMEPORT);    /* get connections to the servers */
2269     fromconn = UV_Bind(afromserver, AFSCONF_VOLUMEPORT);
2270     fromtid = totid = 0;        /* initialize to uncreated */
2271
2272     /* ***
2273      * clone the read/write volume locally.
2274      * ***/
2275
2276     cloneVol = 0;
2277     if (!(flags & RV_NOCLONE)) {
2278         VPRINT1("Starting transaction on source volume %u ...", afromvol);
2279         tmp = fromtid;
2280         code = AFSVolTransCreate_retry(fromconn, afromvol, afrompart, ITBusy,
2281                                  &tmp);
2282         fromtid = tmp;
2283         EGOTO1(mfail, code, "Failed to create transaction on the volume %u\n",
2284                afromvol);
2285         VDONE;
2286
2287         /* Get a clone id */
2288         VPRINT1("Allocating new volume id for clone of volume %u ...",
2289                 afromvol);
2290         cloneVol = 0;
2291         tmpVol = cloneVol;
2292         vcode = ubik_VL_GetNewVolumeId(cstruct, 0, 1, &tmpVol);
2293         cloneVol = tmpVol;
2294         EGOTO1(mfail, vcode,
2295            "Could not get an ID for the clone of volume %u from the VLDB\n",
2296            afromvol);
2297         VDONE;
2298     }
2299
2300     if (atovolid) {
2301         newVol = atovolid;
2302     } else {
2303         /* Get a new volume id */
2304         VPRINT1("Allocating new volume id for copy of volume %u ...", afromvol);
2305         newVol = 0;
2306         vcode = ubik_VL_GetNewVolumeId(cstruct, 0, 1, &newVol);
2307         EGOTO1(mfail, vcode,
2308                "Could not get an ID for the copy of volume %u from the VLDB\n",
2309                afromvol);
2310         VDONE;
2311     }
2312
2313     if (!(flags & RV_NOCLONE)) {
2314         /* Do the clone. Default flags on clone are set to delete on salvage and out of service */
2315         VPRINT1("Cloning source volume %u ...", afromvol);
2316         strcpy(vname, "copy-clone-temp");
2317         tmpVol = cloneVol;
2318         code =
2319             AFSVolClone(fromconn, fromtid, 0, readonlyVolume, vname,
2320                         &tmpVol);
2321         cloneVol = tmpVol;
2322         EGOTO1(mfail, code, "Failed to clone the source volume %u\n",
2323                afromvol);
2324         VDONE;
2325
2326         VPRINT1("Ending the transaction on the source volume %u ...", afromvol);
2327         rcode = 0;
2328         code = AFSVolEndTrans(fromconn, fromtid, &rcode);
2329         fromtid = 0;
2330         if (!code)
2331             code = rcode;
2332         EGOTO1(mfail, code,
2333                "Failed to end the transaction on the source volume %u\n",
2334                afromvol);
2335         VDONE;
2336     }
2337
2338     /* ***
2339      * Create the destination volume
2340      * ***/
2341
2342     if (!(flags & RV_NOCLONE)) {
2343         VPRINT1("Starting transaction on the cloned volume %u ...", cloneVol);
2344         tmp = clonetid;
2345         code =
2346             AFSVolTransCreate_retry(fromconn, cloneVol, afrompart, ITOffline,
2347                           &tmp);
2348         clonetid = tmp;
2349         EGOTO1(mfail, code,
2350                "Failed to start a transaction on the cloned volume%u\n",
2351                cloneVol);
2352         VDONE;
2353
2354         VPRINT1("Setting flags on cloned volume %u ...", cloneVol);
2355         code =
2356             AFSVolSetFlags(fromconn, clonetid,
2357                            VTDeleteOnSalvage | VTOutOfService); /*redundant */
2358         EGOTO1(mfail, code, "Could not set flags on the cloned volume %u\n",
2359                cloneVol);
2360         VDONE;
2361
2362         /* remember time from which we've dumped the volume */
2363         VPRINT1("Getting status of cloned volume %u ...", cloneVol);
2364         code = AFSVolGetStatus(fromconn, clonetid, &tstatus);
2365         EGOTO1(mfail, code,
2366                "Failed to get the status of the cloned volume %u\n",
2367                cloneVol);
2368         VDONE;
2369
2370         fromDate = CLOCKADJ(tstatus.creationDate);
2371     } else {
2372         fromDate = 0;
2373     }
2374
2375     /* create a volume on the target machine */
2376     cloneFromDate = 0;
2377     tmp = totid;
2378     code = AFSVolTransCreate_retry(toconn, newVol, atopart, ITOffline, &tmp);
2379     totid = tmp;
2380     if (!code) {
2381         if ((flags & RV_CPINCR)) {
2382             VPRINT1("Getting status of pre-existing volume %u ...", newVol);
2383             code = AFSVolGetStatus(toconn, totid, &tstatus);
2384             EGOTO1(mfail, code,
2385                    "Failed to get the status of the pre-existing volume %u\n",
2386                    newVol);
2387             VDONE;
2388
2389             /* Using the update date should be OK here, but add some fudge */
2390             cloneFromDate = CLOCKADJ(tstatus.updateDate);
2391             if ((flags & RV_NOCLONE))
2392                 fromDate = cloneFromDate;
2393
2394             /* XXX We should check that the source volume's creationDate is
2395              * XXX not newer than the existing target volume, and if not,
2396              * XXX throw away the existing target and do a full dump. */
2397
2398             goto cpincr;
2399         }
2400
2401         /* Delete the existing volume.
2402          * While we are deleting the volume in these steps, the transaction
2403          * we started against the cloned volume (clonetid above) will be
2404          * sitting idle. It will get cleaned up after 600 seconds
2405          */
2406         VPRINT1("Deleting pre-existing volume %u on destination ...", newVol);
2407         code = AFSVolDeleteVolume(toconn, totid);
2408         EGOTO1(mfail, code,
2409                "Could not delete the pre-existing volume %u on destination\n",
2410                newVol);
2411         VDONE;
2412
2413         VPRINT1
2414             ("Ending transaction on pre-existing volume %u on destination ...",
2415              newVol);
2416         code = AFSVolEndTrans(toconn, totid, &rcode);
2417         totid = 0;
2418         if (!code)
2419             code = rcode;
2420         EGOTO1(mfail, code,
2421                "Could not end the transaction on pre-existing volume %u on destination\n",
2422                newVol);
2423         VDONE;
2424     }
2425
2426     VPRINT1("Creating the destination volume %u ...", newVol);
2427     tmp = totid;
2428     code =
2429         AFSVolCreateVolume(toconn, atopart, atovolname,
2430                            (flags & RV_RDONLY) ? volser_RO : volser_RW,
2431                            newVol, &newVol, &tmp);
2432     totid = tmp;
2433     EGOTO1(mfail, code, "Failed to create the destination volume %u\n",
2434            newVol);
2435     VDONE;
2436
2437     VPRINT1("Setting volume flags on destination volume %u ...", newVol);
2438     code =
2439         AFSVolSetFlags(toconn, totid, (VTDeleteOnSalvage | VTOutOfService));
2440     EGOTO1(mfail, code,
2441            "Failed to set the flags on the destination volume %u\n", newVol);
2442     VDONE;
2443
2444 cpincr:
2445
2446     destination.destHost = ntohl(atoserver);
2447     destination.destPort = AFSCONF_VOLUMEPORT;
2448     destination.destSSID = 1;
2449
2450     strncpy(cookie.name, atovolname, VOLSER_OLDMAXVOLNAME);
2451     cookie.type = (flags & RV_RDONLY) ? ROVOL : RWVOL;
2452     cookie.parent = 0;
2453     cookie.clone = 0;
2454
2455     /***
2456      * Now dump the clone to the new volume
2457      ***/
2458
2459     if (!(flags & RV_NOCLONE)) {
2460         /* XXX probably should have some code here that checks to see if
2461          * XXX we are copying to same server and partition - if so, just
2462          * XXX use a clone to save disk space */
2463
2464         /* Copy the clone to the new volume */
2465         VPRINT2("Dumping from clone %u on source to volume %u on destination ...",
2466             cloneVol, newVol);
2467         code =
2468             AFSVolForward(fromconn, clonetid, cloneFromDate, &destination,
2469                           totid, &cookie);
2470         EGOTO1(mfail, code, "Failed to move data for the volume %u\n",
2471                newVol);
2472         VDONE;
2473
2474         VPRINT1("Ending transaction on cloned volume %u ...", cloneVol);
2475         code = AFSVolEndTrans(fromconn, clonetid, &rcode);
2476         if (!code)
2477             code = rcode;
2478         clonetid = 0;
2479         EGOTO1(mfail, code,
2480                "Failed to end the transaction on the cloned volume %u\n",
2481                cloneVol);
2482         VDONE;
2483     }
2484
2485     /* ***
2486      * reattach to the main-line volume, and incrementally dump it.
2487      * ***/
2488
2489     VPRINT1("Starting transaction on source volume %u ...", afromvol);
2490     tmp = fromtid;
2491     code = AFSVolTransCreate_retry(fromconn, afromvol, afrompart, ITBusy, &tmp);
2492     fromtid = tmp;
2493     EGOTO1(mfail, code,
2494            "Failed to create a transaction on the source volume %u\n",
2495            afromvol);
2496     VDONE;
2497
2498     /* now do the incremental */
2499     VPRINT2
2500         ("Doing the%s dump from source to destination for volume %u ... ",
2501          (flags & RV_NOCLONE) ? "" : " incremental",
2502          afromvol);
2503     code =
2504         AFSVolForward(fromconn, fromtid, fromDate, &destination, totid,
2505                       &cookie);
2506     EGOTO1(mfail, code,
2507            "Failed to do the%s dump from old site to new site\n",
2508            (flags & RV_NOCLONE) ? "" : " incremental");
2509     VDONE;
2510
2511     VPRINT1("Setting volume flags on destination volume %u ...", newVol);
2512     volflag = ((flags & RV_OFFLINE) ? VTOutOfService : 0);      /* off or on-line */
2513     code = AFSVolSetFlags(toconn, totid, volflag);
2514     EGOTO(mfail, code,
2515           "Failed to set the flags to make destination volume online\n");
2516     VDONE;
2517
2518     /* put new volume online */
2519     VPRINT1("Ending transaction on destination volume %u ...", newVol);
2520     code = AFSVolEndTrans(toconn, totid, &rcode);
2521     totid = 0;
2522     if (!code)
2523         code = rcode;
2524     EGOTO1(mfail, code,
2525            "Failed to end the transaction on the destination volume %u\n",
2526            newVol);
2527     VDONE;
2528
2529     VPRINT1("Ending transaction on source volume %u ...", afromvol);
2530     code = AFSVolEndTrans(fromconn, fromtid, &rcode);
2531     fromtid = 0;
2532     if (!code)
2533         code = rcode;
2534     EGOTO1(mfail, code,
2535            "Failed to end the transaction on the source volume %u\n",
2536            afromvol);
2537     VDONE;
2538
2539     fromtid = 0;
2540
2541     if (!(flags & RV_NOCLONE)) {
2542         VPRINT1("Starting transaction on the cloned volume %u ...", cloneVol);
2543         tmp = clonetid;
2544         code =
2545             AFSVolTransCreate_retry(fromconn, cloneVol, afrompart, ITOffline,
2546                               &tmp);
2547         clonetid = tmp;
2548         EGOTO1(mfail, code,
2549                "Failed to start a transaction on the cloned volume%u\n",
2550                cloneVol);
2551         VDONE;
2552
2553         /* now delete the clone */
2554         VPRINT1("Deleting the cloned volume %u ...", cloneVol);
2555         code = AFSVolDeleteVolume(fromconn, clonetid);
2556         EGOTO1(mfail, code, "Failed to delete the cloned volume %u\n",
2557                cloneVol);
2558         VDONE;
2559
2560         VPRINT1("Ending transaction on cloned volume %u ...", cloneVol);
2561         code = AFSVolEndTrans(fromconn, clonetid, &rcode);
2562         if (!code)
2563             code = rcode;
2564         clonetid = 0;
2565         EGOTO1(mfail, code,
2566                "Failed to end the transaction on the cloned volume %u\n",
2567                cloneVol);
2568         VDONE;
2569     }
2570
2571     if (!(flags & RV_NOVLDB)) {
2572         /* create the vldb entry for the copied volume */
2573         strncpy(newentry.name, atovolname, VOLSER_OLDMAXVOLNAME);
2574         newentry.nServers = 1;
2575         newentry.serverNumber[0] = atoserver;
2576         newentry.serverPartition[0] = atopart;
2577         newentry.flags = (flags & RV_RDONLY) ? RO_EXISTS : RW_EXISTS;
2578         newentry.serverFlags[0] = (flags & RV_RDONLY) ? ITSROVOL : ITSRWVOL;
2579         newentry.volumeId[RWVOL] = newVol;
2580         newentry.volumeId[ROVOL] = (flags & RV_RDONLY) ? newVol : 0;
2581         newentry.volumeId[BACKVOL] = 0;
2582         newentry.cloneId = 0;
2583         /*map into right byte order, before passing to xdr, the stuff has to be in host
2584          * byte order. Xdr converts it into network order */
2585         MapNetworkToHost(&newentry, &storeEntry);
2586         /* create the vldb entry */
2587         vcode = VLDB_CreateEntry(&storeEntry);
2588         if (vcode) {
2589             fprintf(STDERR,
2590                     "Could not create a VLDB entry for the volume %s %lu\n",
2591                     atovolname, (unsigned long)newVol);
2592             /*destroy the created volume */
2593             VPRINT1("Deleting the newly created volume %u\n", newVol);
2594             AFSVolDeleteVolume(toconn, totid);
2595             error = vcode;
2596             goto mfail;
2597         }
2598         VPRINT2("Created the VLDB entry for the volume %s %u\n", atovolname,
2599                 newVol);
2600     }
2601
2602     /* normal cleanup code */
2603
2604     if (fromtid) {
2605         VPRINT1("Cleanup: Ending transaction on source volume %u ...",
2606                 afromvol);
2607         code = AFSVolEndTrans(fromconn, fromtid, &rcode);
2608         if (code || rcode) {
2609             VPRINT("\n");
2610             fprintf(STDERR,
2611                     "Could not end transaction on the source volume %lu\n",
2612                     (unsigned long)afromvol);
2613             if (!error)
2614                 error = (code ? code : rcode);
2615         }
2616         VDONE;
2617     }
2618
2619     if (clonetid) {
2620         VPRINT1("Cleanup: Ending transaction on clone volume %u ...",
2621                 cloneVol);
2622         code = AFSVolEndTrans(fromconn, clonetid, &rcode);
2623         if (code || rcode) {
2624             VPRINT("\n");
2625             fprintf(STDERR,
2626                     "Could not end transaction on the source's clone volume %lu\n",
2627                     (unsigned long)cloneVol);
2628             if (!error)
2629                 error = (code ? code : rcode);
2630         }
2631         VDONE;
2632     }
2633
2634     if (totid) {
2635         VPRINT1("Cleanup: Ending transaction on destination volume %u ...",
2636                 newVol);
2637         code = AFSVolEndTrans(toconn, totid, &rcode);
2638         if (code) {
2639             VPRINT("\n");
2640             fprintf(STDERR,
2641                     "Could not end transaction on destination volume %lu\n",
2642                     (unsigned long)newVol);
2643             if (!error)
2644                 error = (code ? code : rcode);
2645         }
2646         VDONE;
2647     }
2648     if (fromconn)
2649         rx_DestroyConnection(fromconn);
2650     if (toconn)
2651         rx_DestroyConnection(toconn);
2652     PrintError("", error);
2653     return error;
2654
2655     /* come here only when the sky falls */
2656   mfail:
2657
2658     if (pntg) {
2659         fprintf(STDOUT,
2660                 "vos copy: operation interrupted, cleanup in progress...\n");
2661         fprintf(STDOUT, "clear transaction contexts\n");
2662         fflush(STDOUT);
2663     }
2664
2665     if (clonetid) {
2666         VPRINT("Recovery: Ending transaction on clone volume ...");
2667         AFSVolEndTrans(fromconn, clonetid, &rcode);
2668         VDONE;
2669     }
2670     if (totid) {
2671         VPRINT("Recovery: Ending transaction on destination volume ...");
2672         AFSVolEndTrans(toconn, totid, &rcode);
2673         VDONE;
2674     }
2675     if (fromtid) {              /* put it on-line */
2676         VPRINT("Recovery: Ending transaction on source volume ...");
2677         AFSVolEndTrans(fromconn, fromtid, &rcode);
2678         VDONE;
2679     }
2680
2681     VPRINT("Recovery: Accessing VLDB.\n");
2682     vcode = VLDB_GetEntryByID(afromvol, -1, &entry);
2683     if (vcode) {
2684         fprintf(STDOUT, "FATAL: VLDB access error: abort cleanup\n");
2685         fflush(STDOUT);
2686         goto done;
2687     }
2688     MapHostToNetwork(&entry);
2689
2690     /* common cleanup - delete local clone */
2691     if (cloneVol) {
2692         VPRINT1("Recovery: Creating transaction on clone volume %u ...",
2693                 cloneVol);
2694         tmp = clonetid;
2695         code =
2696             AFSVolTransCreate_retry(fromconn, cloneVol, afrompart, ITOffline,
2697                               &tmp);
2698         clonetid = tmp;
2699         if (!code) {
2700             VDONE;
2701
2702             VPRINT1("Recovery: Deleting clone volume %u ...", cloneVol);
2703             AFSVolDeleteVolume(fromconn, clonetid);
2704             VDONE;
2705
2706             VPRINT1("Recovery: Ending transaction on clone volume %u ...",
2707                     cloneVol);
2708             AFSVolEndTrans(fromconn, clonetid, &rcode);
2709             VDONE;
2710         } else {
2711             VPRINT1
2712                 ("\nRecovery: Unable to start transaction on clone volume %u.\n",
2713                  cloneVol);
2714         }
2715     }
2716
2717   done:                 /* routine cleanup */
2718     if (fromconn)
2719         rx_DestroyConnection(fromconn);
2720     if (toconn)
2721         rx_DestroyConnection(toconn);
2722
2723     if (pntg) {
2724         fprintf(STDOUT, "cleanup complete - user verify desired result\n");
2725         fflush(STDOUT);
2726     }
2727     exit(1);
2728 }
2729
2730
2731 int
2732 UV_CopyVolume(afs_uint32 afromvol, afs_uint32 afromserver, afs_int32 afrompart,
2733               char *atovolname, afs_uint32 atoserver, afs_int32 atopart)
2734 {
2735     return UV_CopyVolume2(afromvol, afromserver, afrompart,
2736                           atovolname, atoserver, atopart, 0, 0);
2737 }
2738
2739
2740
2741 /* Make a new backup of volume <avolid> on <aserver> and <apart>
2742  * if one already exists, update it
2743  */
2744
2745 int
2746 UV_BackupVolume(afs_uint32 aserver, afs_int32 apart, afs_uint32 avolid)
2747 {
2748     struct rx_connection *aconn = (struct rx_connection *)0;
2749     afs_int32 ttid = 0, btid = 0;
2750     afs_uint32 backupID;
2751     afs_int32 code = 0, rcode = 0;
2752     char vname[VOLSER_MAXVOLNAME + 1];
2753     struct nvldbentry entry, storeEntry;
2754     afs_int32 error = 0;
2755     int vldblocked = 0, vldbmod = 0, backexists = 1;
2756
2757     aconn = UV_Bind(aserver, AFSCONF_VOLUMEPORT);
2758
2759     /* the calls to VLDB will succeed only if avolid is a RW volume,
2760      * since we are following the RW hash chain for searching */
2761     code = VLDB_GetEntryByID(avolid, RWVOL, &entry);
2762     if (code) {
2763         fprintf(STDERR,
2764                 "Could not fetch the entry for the volume %lu from the VLDB \n",
2765                 (unsigned long)avolid);
2766         error = code;
2767         goto bfail;
2768     }
2769     MapHostToNetwork(&entry);
2770
2771     /* These operations require the VLDB be locked since it means the VLDB
2772      * will change or the vldb is already locked.
2773      */
2774     if (!(entry.flags & BACK_EXISTS) || /* backup volume doesnt exist */
2775         (entry.flags & VLOP_ALLOPERS) ||        /* vldb lock already held */
2776         (entry.volumeId[BACKVOL] == INVALID_BID)) {     /* no assigned backup volume id */
2777
2778         code = ubik_VL_SetLock(cstruct, 0, avolid, RWVOL, VLOP_BACKUP);
2779         if (code) {
2780             fprintf(STDERR,
2781                     "Could not lock the VLDB entry for the volume %lu\n",
2782                     (unsigned long)avolid);
2783             error = code;
2784             goto bfail;
2785         }
2786         vldblocked = 1;
2787
2788         /* Reread the vldb entry */
2789         code = VLDB_GetEntryByID(avolid, RWVOL, &entry);
2790         if (code) {
2791             fprintf(STDERR,
2792                     "Could not fetch the entry for the volume %lu from the VLDB \n",
2793                     (unsigned long)avolid);
2794             error = code;
2795             goto bfail;
2796         }
2797         MapHostToNetwork(&entry);
2798     }
2799
2800     if (!ISNAMEVALID(entry.name)) {
2801         fprintf(STDERR, "Name of the volume %s exceeds the size limit\n",
2802                 entry.name);
2803         error = VOLSERBADNAME;
2804         goto bfail;
2805     }
2806
2807     backupID = entry.volumeId[BACKVOL];
2808     if (backupID == INVALID_BID) {
2809         /* Get a backup volume id from the VLDB and update the vldb
2810          * entry with it.
2811          */
2812         code = ubik_VL_GetNewVolumeId(cstruct, 0, 1, &backupID);
2813         if (code) {
2814             fprintf(STDERR,
2815                     "Could not allocate ID for the backup volume of  %lu from the VLDB\n",
2816                     (unsigned long)avolid);
2817             error = code;
2818             goto bfail;
2819         }
2820         entry.volumeId[BACKVOL] = backupID;
2821         vldbmod = 1;
2822     }
2823
2824     /* Test to see if the backup volume exists by trying to create
2825      * a transaction on the backup volume. We've assumed the backup exists.
2826      */
2827     code = AFSVolTransCreate_retry(aconn, backupID, apart, ITOffline, &btid);
2828     if (code) {
2829         if (code != VNOVOL) {
2830             fprintf(STDERR, "Could not reach the backup volume %lu\n",
2831                     (unsigned long)backupID);
2832             error = code;
2833             goto bfail;
2834         }
2835         backexists = 0;         /* backup volume does not exist */
2836     }
2837     if (btid) {
2838         code = AFSVolEndTrans(aconn, btid, &rcode);
2839         btid = 0;
2840         if (code || rcode) {
2841             fprintf(STDERR,
2842                     "Could not end transaction on the previous backup volume %lu\n",
2843                     (unsigned long)backupID);
2844             error = (code ? code : rcode);
2845             goto bfail;
2846         }
2847     }
2848
2849     /* Now go ahead and try to clone the RW volume.
2850      * First start a transaction on the RW volume
2851      */
2852     code = AFSVolTransCreate_retry(aconn, avolid, apart, ITBusy, &ttid);
2853     if (code) {
2854         fprintf(STDERR, "Could not start a transaction on the volume %lu\n",
2855                 (unsigned long)avolid);
2856         error = code;
2857         goto bfail;
2858     }
2859
2860     /* Clone or reclone the volume, depending on whether the backup
2861      * volume exists or not
2862      */
2863     if (backexists) {
2864         VPRINT1("Re-cloning backup volume %u ...", backupID);
2865
2866         code = AFSVolReClone(aconn, ttid, backupID);
2867         if (code) {
2868             fprintf(STDERR, "Could not re-clone backup volume %lu\n",
2869                     (unsigned long)backupID);
2870             error = code;
2871             goto bfail;
2872         }
2873     } else {
2874         VPRINT1("Creating a new backup clone %u ...", backupID);
2875
2876         strcpy(vname, entry.name);
2877         strcat(vname, ".backup");
2878
2879         code = AFSVolClone(aconn, ttid, 0, backupVolume, vname, &backupID);
2880         if (code) {
2881             fprintf(STDERR, "Failed to clone the volume %lu\n",
2882                     (unsigned long)avolid);
2883             error = code;
2884             goto bfail;
2885         }
2886     }
2887
2888     /* End the transaction on the RW volume */
2889     code = AFSVolEndTrans(aconn, ttid, &rcode);
2890     ttid = 0;
2891     if (code || rcode) {
2892         fprintf(STDERR,
2893                 "Failed to end the transaction on the rw volume %lu\n",
2894                 (unsigned long)avolid);
2895         error = (code ? code : rcode);
2896         goto bfail;
2897     }
2898
2899     /* Mork vldb as backup exists */
2900     if (!(entry.flags & BACK_EXISTS)) {
2901         entry.flags |= BACK_EXISTS;
2902         vldbmod = 1;
2903     }
2904
2905     /* Now go back to the backup volume and bring it on line */
2906     code = AFSVolTransCreate_retry(aconn, backupID, apart, ITOffline, &btid);
2907     if (code) {
2908         fprintf(STDERR,
2909                 "Failed to start a transaction on the backup volume %lu\n",
2910                 (unsigned long)backupID);
2911         error = code;
2912         goto bfail;
2913     }
2914
2915     code = AFSVolSetFlags(aconn, btid, 0);
2916     if (code) {
2917         fprintf(STDERR, "Could not mark the backup volume %lu on line \n",
2918                 (unsigned long)backupID);
2919         error = code;
2920         goto bfail;
2921     }
2922
2923     code = AFSVolEndTrans(aconn, btid, &rcode);
2924     btid = 0;
2925     if (code || rcode) {
2926         fprintf(STDERR,
2927                 "Failed to end the transaction on the backup volume %lu\n",
2928                 (unsigned long)backupID);
2929         error = (code ? code : rcode);
2930         goto bfail;
2931     }
2932
2933     VDONE;
2934
2935     /* Will update the vldb below */
2936
2937   bfail:
2938     if (ttid) {
2939         code = AFSVolEndTrans(aconn, ttid, &rcode);
2940         if (code || rcode) {
2941             fprintf(STDERR, "Could not end transaction on the volume %lu\n",
2942                     (unsigned long)avolid);
2943             if (!error)
2944                 error = (code ? code : rcode);
2945         }
2946     }
2947
2948     if (btid) {
2949         code = AFSVolEndTrans(aconn, btid, &rcode);
2950         if (code || rcode) {
2951             fprintf(STDERR,
2952                     "Could not end transaction the backup volume %lu\n",
2953                     (unsigned long)backupID);
2954             if (!error)
2955                 error = (code ? code : rcode);
2956         }
2957     }
2958
2959     /* Now update the vldb - if modified */
2960     if (vldblocked) {
2961         if (vldbmod) {
2962             MapNetworkToHost(&entry, &storeEntry);
2963             code =
2964                 VLDB_ReplaceEntry(avolid, RWVOL, &storeEntry,
2965                                   (LOCKREL_OPCODE | LOCKREL_AFSID |
2966                                    LOCKREL_TIMESTAMP));
2967             if (code) {
2968                 fprintf(STDERR,
2969                         "Could not update the VLDB entry for the volume %lu \n",
2970                         (unsigned long)avolid);
2971                 if (!error)
2972                     error = code;
2973             }
2974         } else {
2975             code =
2976                 ubik_VL_ReleaseLock(cstruct, 0, avolid, RWVOL,
2977                           (LOCKREL_OPCODE | LOCKREL_AFSID |
2978                            LOCKREL_TIMESTAMP));
2979             if (code) {
2980                 fprintf(STDERR,
2981                         "Could not unlock the VLDB entry for the volume %lu \n",
2982                         (unsigned long)avolid);
2983                 if (!error)
2984                     error = code;
2985             }
2986         }
2987     }
2988
2989     if (aconn)
2990         rx_DestroyConnection(aconn);
2991
2992     PrintError("", error);
2993     return error;
2994 }
2995
2996 /* Make a new clone of volume <avolid> on <aserver> and <apart>
2997  * using volume ID <acloneid>, or a new ID allocated from the VLDB.
2998  * The new volume is named by <aname>, or by appending ".clone" to
2999  * the existing name if <aname> is NULL.  The following flags are
3000  * supported:
3001  *
3002  *     RV_RDONLY  - target volume is RO
3003  *     RV_OFFLINE - leave target volume offline
3004  */
3005
3006 int
3007 UV_CloneVolume(afs_uint32 aserver, afs_int32 apart, afs_uint32 avolid,
3008                afs_uint32 acloneid, char *aname, int flags)
3009 {
3010     struct rx_connection *aconn = (struct rx_connection *)0;
3011     afs_int32 ttid = 0, btid = 0;
3012     afs_int32 code = 0, rcode = 0;
3013     char vname[VOLSER_MAXVOLNAME + 1];
3014     afs_int32 error = 0;
3015     int backexists = 1;
3016     volEntries volumeInfo;
3017
3018     aconn = UV_Bind(aserver, AFSCONF_VOLUMEPORT);
3019
3020     if (!aname) {
3021         volumeInfo.volEntries_val = (volintInfo *) 0;
3022         volumeInfo.volEntries_len = 0;
3023         code = AFSVolListOneVolume(aconn, apart, avolid, &volumeInfo);
3024         if (code) {
3025             fprintf(stderr, "Could not get info for volume %lu\n",
3026                     (unsigned long)avolid);
3027             error = code;
3028             goto bfail;
3029         }
3030         strncpy(vname, volumeInfo.volEntries_val[0].name,
3031                 VOLSER_OLDMAXVOLNAME - 7);
3032         vname[VOLSER_OLDMAXVOLNAME - 7] = 0;
3033         strcat(vname, ".clone");
3034         aname = vname;
3035         if (volumeInfo.volEntries_val)
3036             free(volumeInfo.volEntries_val);
3037     }
3038
3039     if (!acloneid) {
3040         /* Get a clone id */
3041         VPRINT1("Allocating new volume id for clone of volume %u ...",
3042                 avolid);
3043         code = ubik_VL_GetNewVolumeId(cstruct, 0, 1, &acloneid);
3044         EGOTO1(bfail, code,
3045            "Could not get an ID for the clone of volume %u from the VLDB\n",
3046            avolid);
3047         VDONE;
3048     }
3049
3050     /* Test to see if the clone volume exists by trying to create
3051      * a transaction on the clone volume. We've assumed the clone exists.
3052      */
3053     /* XXX I wonder what happens if the clone has some other parent... */
3054     code = AFSVolTransCreate_retry(aconn, acloneid, apart, ITOffline, &btid);
3055     if (code) {
3056         if (code != VNOVOL) {
3057             fprintf(STDERR, "Could not reach the clone volume %lu\n",
3058                     (unsigned long)acloneid);
3059             error = code;
3060             goto bfail;
3061         }
3062         backexists = 0;         /* backup volume does not exist */
3063     }
3064     if (btid) {
3065         code = AFSVolEndTrans(aconn, btid, &rcode);
3066         btid = 0;
3067         if (code || rcode) {
3068             fprintf(STDERR,
3069                     "Could not end transaction on the previous clone volume %lu\n",
3070                     (unsigned long)acloneid);
3071             error = (code ? code : rcode);
3072             goto bfail;
3073         }
3074     }
3075
3076     /* Now go ahead and try to clone the RW volume.
3077      * First start a transaction on the RW volume
3078      */
3079     code = AFSVolTransCreate_retry(aconn, avolid, apart, ITBusy, &ttid);
3080     if (code) {
3081         fprintf(STDERR, "Could not start a transaction on the volume %lu\n",
3082                 (unsigned long)avolid);
3083         error = code;
3084         goto bfail;
3085     }
3086
3087     /* Clone or reclone the volume, depending on whether the backup
3088      * volume exists or not
3089      */
3090     if (backexists) {
3091         VPRINT1("Re-cloning clone volume %u ...", acloneid);
3092
3093         code = AFSVolReClone(aconn, ttid, acloneid);
3094         if (code) {
3095             fprintf(STDERR, "Could not re-clone backup volume %lu\n",
3096                     (unsigned long)acloneid);
3097             error = code;
3098             goto bfail;
3099         }
3100     } else {
3101         VPRINT1("Creating a new clone %u ...", acloneid);
3102
3103         code = AFSVolClone(aconn, ttid, 0,
3104                            (flags & RV_RDONLY) ? readonlyVolume : backupVolume,
3105                            aname, &acloneid);
3106         if (code) {
3107             fprintf(STDERR, "Failed to clone the volume %lu\n",
3108                     (unsigned long)avolid);
3109             error = code;
3110             goto bfail;
3111         }
3112     }
3113
3114     /* End the transaction on the RW volume */
3115     code = AFSVolEndTrans(aconn, ttid, &rcode);
3116     ttid = 0;
3117     if (code || rcode) {
3118         fprintf(STDERR,
3119                 "Failed to end the transaction on the rw volume %lu\n",
3120                 (unsigned long)avolid);
3121         error = (code ? code : rcode);
3122         goto bfail;
3123     }
3124
3125     /* Now go back to the backup volume and bring it on line */
3126     if (!(flags & RV_OFFLINE)) {
3127         code = AFSVolTransCreate_retry(aconn, acloneid, apart, ITOffline, &btid);
3128         if (code) {
3129             fprintf(STDERR,
3130                     "Failed to start a transaction on the clone volume %lu\n",
3131                     (unsigned long)acloneid);
3132             error = code;
3133             goto bfail;
3134         }
3135
3136         code = AFSVolSetFlags(aconn, btid, 0);
3137         if (code) {
3138             fprintf(STDERR, "Could not mark the clone volume %lu on line \n",
3139                     (unsigned long)acloneid);
3140             error = code;
3141             goto bfail;
3142         }
3143
3144         code = AFSVolEndTrans(aconn, btid, &rcode);
3145         btid = 0;
3146         if (code || rcode) {
3147             fprintf(STDERR,
3148                     "Failed to end the transaction on the clone volume %lu\n",
3149                     (unsigned long)acloneid);
3150             error = (code ? code : rcode);
3151             goto bfail;
3152         }
3153     }
3154
3155     VDONE;
3156
3157   bfail:
3158     if (ttid) {
3159         code = AFSVolEndTrans(aconn, ttid, &rcode);
3160         if (code || rcode) {
3161             fprintf(STDERR, "Could not end transaction on the volume %lu\n",
3162                     (unsigned long)avolid);
3163             if (!error)
3164                 error = (code ? code : rcode);
3165         }
3166     }
3167
3168     if (btid) {
3169         code = AFSVolEndTrans(aconn, btid, &rcode);
3170         if (code || rcode) {
3171             fprintf(STDERR,
3172                     "Could not end transaction on the clone volume %lu\n",
3173                     (unsigned long)acloneid);
3174             if (!error)
3175                 error = (code ? code : rcode);
3176         }
3177     }
3178
3179     if (aconn)
3180         rx_DestroyConnection(aconn);
3181
3182     PrintError("", error);
3183     return error;
3184 }
3185
3186 static int
3187 DelVol(struct rx_connection *conn, afs_uint32 vid, afs_int32 part,
3188        afs_int32 flags)
3189 {
3190     afs_int32 acode, ccode, rcode, tid;
3191     ccode = rcode = tid = 0;
3192
3193     acode = AFSVolTransCreate_retry(conn, vid, part, flags, &tid);
3194     if (!acode) {               /* It really was there */
3195         acode = AFSVolDeleteVolume(conn, tid);
3196         if (acode) {
3197             fprintf(STDERR, "Failed to delete volume %lu.\n",
3198                     (unsigned long)vid);
3199             PrintError("", acode);
3200         }
3201         ccode = AFSVolEndTrans(conn, tid, &rcode);
3202         if (!ccode)
3203             ccode = rcode;
3204         if (ccode) {
3205             fprintf(STDERR, "Failed to end transaction on volume %lu.\n",
3206                     (unsigned long)vid);
3207             PrintError("", ccode);
3208         }
3209     }
3210
3211     return acode;
3212 }
3213
3214 #define ONERROR(ec, ep, es) if (ec) { fprintf(STDERR, (es), (ep)); error = (ec); goto rfail; }
3215 #define ONERROR0(ec, es) if (ec) { fprintf(STDERR, (es)); error = (ec); goto rfail; }
3216 #define ERROREXIT(ec) { error = (ec); goto rfail; }
3217
3218 /* Get a "transaction" on this replica.  Create the volume
3219  * if necessary.  Return the time from which a dump should
3220  * be made (0 if it's a new volume)
3221  */
3222 static int
3223 GetTrans(struct nvldbentry *vldbEntryPtr, afs_int32 index,
3224          struct rx_connection **connPtr, afs_int32 * transPtr,
3225          afs_uint32 * crtimePtr, afs_uint32 * uptimePtr)
3226 {
3227     afs_uint32 volid;
3228     struct volser_status tstatus;
3229     int code = 0;
3230     int rcode, tcode;
3231     char hoststr[16];
3232
3233     *connPtr = (struct rx_connection *)0;
3234     *transPtr = 0;
3235     *crtimePtr = 0;
3236     *uptimePtr = 0;
3237
3238     /* get connection to the replication site */
3239     *connPtr = UV_Bind(vldbEntryPtr->serverNumber[index], AFSCONF_VOLUMEPORT);
3240     if (!*connPtr)
3241         goto fail;              /* server is down */
3242
3243     volid = vldbEntryPtr->volumeId[ROVOL];
3244     if (volid)
3245         code =
3246             AFSVolTransCreate_retry(*connPtr, volid,
3247                               vldbEntryPtr->serverPartition[index], ITOffline,
3248                               transPtr);
3249
3250     /* If the volume does not exist, create it */
3251     if (!volid || code) {
3252         char volname[64];
3253         char hoststr[16];
3254
3255         if (volid && (code != VNOVOL)) {
3256             PrintError("Failed to start a transaction on the RO volume.\n",
3257                        code);
3258             goto fail;
3259         }
3260
3261         strcpy(volname, vldbEntryPtr->name);
3262         strcat(volname, ".readonly");
3263
3264         if (verbose) {
3265             fprintf(STDOUT,
3266                     "Creating new volume %lu on replication site %s: ",
3267                     (unsigned long)volid,
3268                     noresolve ? afs_inet_ntoa_r(vldbEntryPtr->
3269                                                 serverNumber[index], hoststr) :
3270                     hostutil_GetNameByINet(vldbEntryPtr->
3271                                            serverNumber[index]));
3272             fflush(STDOUT);
3273         }
3274
3275         code =
3276             AFSVolCreateVolume(*connPtr, vldbEntryPtr->serverPartition[index],
3277                                volname, volser_RO,
3278                                vldbEntryPtr->volumeId[RWVOL], &volid,
3279                                transPtr);
3280         if (code) {
3281             PrintError("Failed to create the ro volume: ", code);
3282             goto fail;
3283         }
3284         vldbEntryPtr->volumeId[ROVOL] = volid;
3285
3286         VDONE;
3287
3288         /* The following is a bit redundant, since create sets these flags by default */
3289         code =
3290             AFSVolSetFlags(*connPtr, *transPtr,
3291                            VTDeleteOnSalvage | VTOutOfService);
3292         if (code) {
3293             PrintError("Failed to set flags on the ro volume: ", code);
3294             goto fail;
3295         }
3296     }
3297
3298     /* Otherwise, the transaction did succeed, so get the creation date of the
3299      * latest RO volume on the replication site
3300      */
3301     else {
3302         VPRINT2("Updating existing ro volume %u on %s ...\n", volid,
3303                 noresolve ? afs_inet_ntoa_r(vldbEntryPtr->
3304                                             serverNumber[index], hoststr) :
3305                 hostutil_GetNameByINet(vldbEntryPtr->serverNumber[index]));
3306
3307         code = AFSVolGetStatus(*connPtr, *transPtr, &tstatus);
3308         if (code) {
3309             PrintError("Failed to get status of volume on destination: ",
3310                        code);
3311             goto fail;
3312         }
3313         *crtimePtr = CLOCKADJ(tstatus.creationDate);
3314         *uptimePtr = CLOCKADJ(tstatus.updateDate);
3315     }
3316
3317     return 0;
3318
3319   fail:
3320     if (*transPtr) {
3321         tcode = AFSVolEndTrans(*connPtr, *transPtr, &rcode);
3322         *transPtr = 0;
3323         if (!tcode)
3324             tcode = rcode;
3325         if (tcode)
3326             PrintError("Could not end transaction on a ro volume: ", tcode);
3327     }
3328
3329     return code;
3330 }
3331
3332 static int
3333 SimulateForwardMultiple(struct rx_connection *fromconn, afs_int32 fromtid,
3334                         afs_int32 fromdate, manyDests * tr, afs_int32 flags,
3335                         void *cookie, manyResults * results)
3336 {
3337     unsigned int i;
3338
3339     for (i = 0; i < tr->manyDests_len; i++) {
3340         results->manyResults_val[i] =
3341             AFSVolForward(fromconn, fromtid, fromdate,
3342                           &(tr->manyDests_val[i].server),
3343                           tr->manyDests_val[i].trans, cookie);
3344     }
3345     return 0;
3346 }
3347
3348
3349 /* UV_ReleaseVolume()
3350  *    Release volume <afromvol> on <afromserver> <afrompart> to all
3351  *    its RO sites (full release). Unless the previous release was
3352  *    incomplete: in which case we bring the remaining incomplete
3353  *    volumes up to date with the volumes that were released
3354  *    successfully.
3355  *    forceflag: Performs a full release.
3356  *
3357  *    Will create a clone from the RW, then dump the clone out to
3358  *    the remaining replicas. If there is more than 1 RO sites,
3359  *    ensure that the VLDB says at least one RO is available all
3360  *    the time: Influences when we write back the VLDB entry.
3361  */
3362
3363 int
3364 UV_ReleaseVolume(afs_uint32 afromvol, afs_uint32 afromserver,
3365                  afs_int32 afrompart, int forceflag)
3366 {
3367     char vname[64];
3368     afs_int32 code = 0;
3369     afs_int32 vcode, rcode, tcode;
3370     afs_uint32 cloneVolId, roVolId;
3371     struct replica *replicas = 0;
3372     struct nvldbentry entry, storeEntry;
3373     int i, volcount, m, fullrelease, vldbindex;
3374     int failure;
3375     struct restoreCookie cookie;
3376     struct rx_connection **toconns = 0;
3377     struct release *times = 0;
3378     int nservers = 0;
3379     struct rx_connection *fromconn = (struct rx_connection *)0;
3380     afs_int32 error = 0;
3381     int islocked = 0;
3382     afs_int32 clonetid = 0, onlinetid;
3383     afs_int32 fromtid = 0;
3384     afs_uint32 fromdate = 0;
3385     afs_uint32 thisdate;
3386     time_t tmv;
3387     int s;
3388     manyDests tr;
3389     manyResults results;
3390     int rwindex, roindex, roclone, roexists;
3391     afs_uint32 rwcrdate = 0;
3392     afs_uint32 clcrdate;
3393     struct rtime {
3394         int validtime;
3395         afs_uint32 uptime;
3396     } remembertime[NMAXNSERVERS];
3397     int releasecount = 0;
3398     struct volser_status volstatus;
3399     char hoststr[16];
3400
3401     memset(remembertime, 0, sizeof(remembertime));
3402     memset(&results, 0, sizeof(results));
3403
3404     vcode = ubik_VL_SetLock(cstruct, 0, afromvol, RWVOL, VLOP_RELEASE);
3405     if (vcode != VL_RERELEASE)
3406         ONERROR(vcode, afromvol,
3407                 "Could not lock the VLDB entry for the volume %u.\n");
3408     islocked = 1;
3409
3410     /* Get the vldb entry in readable format */
3411     vcode = VLDB_GetEntryByID(afromvol, RWVOL, &entry);
3412     ONERROR(vcode, afromvol,
3413             "Could not fetch the entry for the volume %u from the VLDB.\n");
3414     MapHostToNetwork(&entry);
3415
3416     if (verbose)
3417         EnumerateEntry(&entry);
3418
3419     if (!ISNAMEVALID(entry.name))
3420         ONERROR(VOLSERBADOP, entry.name,
3421                 "Volume name %s is too long, rename before releasing.\n");
3422     if (entry.volumeId[RWVOL] != afromvol)
3423         ONERROR(VOLSERBADOP, afromvol,
3424                 "The volume %u being released is not a read-write volume.\n");
3425     if (entry.nServers <= 1)
3426         ONERROR(VOLSERBADOP, afromvol,
3427                 "Volume %u has no replicas - release operation is meaningless!\n");
3428     if (strlen(entry.name) > (VOLSER_OLDMAXVOLNAME - 10))
3429         ONERROR(VOLSERBADOP, entry.name,
3430                 "RO volume name %s exceeds (VOLSER_OLDMAXVOLNAME - 10) character limit\n");
3431
3432     /* roclone is true if one of the RO volumes is on the same
3433      * partition as the RW volume. In this case, we make the RO volume
3434      * on the same partition a clone instead of a complete copy.
3435      */
3436
3437     roindex = Lp_ROMatch(afromserver, afrompart, &entry) - 1;
3438     roclone = ((roindex == -1) ? 0 : 1);
3439     rwindex = Lp_GetRwIndex(&entry);
3440     if (rwindex < 0)
3441         ONERROR0(VOLSERNOVOL, "There is no RW volume \n");
3442
3443     /* Make sure we have a RO volume id to work with */
3444     if (entry.volumeId[ROVOL] == INVALID_BID) {
3445         /* need to get a new RO volume id */
3446         vcode = ubik_VL_GetNewVolumeId(cstruct, 0, 1, &roVolId);
3447         ONERROR(vcode, entry.name, "Cant allocate ID for RO volume of %s\n");
3448
3449         entry.volumeId[ROVOL] = roVolId;
3450         MapNetworkToHost(&entry, &storeEntry);
3451         vcode = VLDB_ReplaceEntry(afromvol, RWVOL, &storeEntry, 0);
3452         ONERROR(vcode, entry.name, "Could not update vldb entry for %s.\n");
3453     }
3454
3455     /* Will we be completing a previously unfinished release. -force overrides */
3456     for (s = 0, m = 0, fullrelease=0, i=0; (i<entry.nServers); i++) {
3457         if (entry.serverFlags[i] & ITSROVOL) {
3458             m++;
3459             if (entry.serverFlags[i] & NEW_REPSITE) s++;
3460         }
3461     }
3462     if ((forceflag && !fullrelease) || (s == m) || (s == 0))
3463         fullrelease = 1;
3464
3465     /* Determine which volume id to use and see if it exists */
3466     cloneVolId =
3467         ((fullrelease
3468           || (entry.cloneId == 0)) ? entry.volumeId[ROVOL] : entry.cloneId);
3469     code = VolumeExists(afromserver, afrompart, cloneVolId);
3470     roexists = ((code == ENODEV) ? 0 : 1);
3471
3472     fromconn = UV_Bind(afromserver, AFSCONF_VOLUMEPORT);
3473     if (!fromconn)
3474         ONERROR(-1, afromserver,
3475                 "Cannot establish connection with server 0x%x\n");
3476
3477     if (!fullrelease) {
3478         if (!roexists)
3479             fullrelease = 1;    /* Do a full release if RO clone does not exist */
3480         else {
3481             /* Begin transaction on RW and mark it busy while we query it */
3482             code = AFSVolTransCreate_retry(
3483                         fromconn, afromvol, afrompart, ITBusy, &fromtid
3484                    );
3485             ONERROR(code, afromvol,
3486                     "Failed to start transaction on RW volume %u\n");
3487
3488             /* Query the creation date for the RW */
3489             code = AFSVolGetStatus(fromconn, fromtid, &volstatus);
3490             ONERROR(code, afromvol,
3491                     "Failed to get the status of RW volume %u\n");
3492             rwcrdate = volstatus.creationDate;
3493
3494             /* End transaction on RW */
3495             code = AFSVolEndTrans(fromconn, fromtid, &rcode);
3496             fromtid = 0;
3497             ONERROR((code ? code : rcode), afromvol,
3498                     "Failed to end transaction on RW volume %u\n");
3499
3500             /* Begin transaction on clone and mark it busy while we query it */
3501             code = AFSVolTransCreate_retry(
3502                         fromconn, cloneVolId, afrompart, ITBusy, &clonetid
3503                    );
3504             ONERROR(code, cloneVolId,
3505                     "Failed to start transaction on RW clone %u\n");
3506
3507             /* Query the creation date for the clone */
3508             code = AFSVolGetStatus(fromconn, clonetid, &volstatus);
3509             ONERROR(code, cloneVolId,
3510                     "Failed to get the status of RW clone %u\n");
3511             clcrdate = volstatus.creationDate;
3512
3513             /* End transaction on clone */
3514             code = AFSVolEndTrans(fromconn, clonetid, &rcode);
3515             clonetid = 0;
3516             ONERROR((code ? code : rcode), cloneVolId,
3517                     "Failed to end transaction on RW clone %u\n");
3518
3519             if (rwcrdate > clcrdate)
3520                 fullrelease = 2;/* Do a full release if RO clone older than RW */
3521         }
3522     }
3523
3524     if (verbose) {
3525         switch (fullrelease) {
3526             case 2:
3527                 fprintf(STDOUT, "RW %lu changed, doing a complete release\n",
3528                         (unsigned long)afromvol);
3529                 break;
3530             case 1:
3531                 fprintf(STDOUT, "This is a complete release of volume %lu\n",
3532                         (unsigned long)afromvol);
3533                 break;
3534             case 0:
3535                 fprintf(STDOUT, "This is a completion of a previous release\n");
3536                 break;
3537         }
3538     }
3539
3540     if (fullrelease) {
3541         /* If the RO clone exists, then if the clone is a temporary
3542          * clone, delete it. Or if the RO clone is marked RO_DONTUSE
3543          * (it was recently added), then also delete it. We do not
3544          * want to "reclone" a temporary RO clone.
3545          */
3546         if (roexists
3547             && (!roclone || (entry.serverFlags[roindex] & RO_DONTUSE))) {
3548             code = DelVol(fromconn, cloneVolId, afrompart, ITOffline);
3549             if (code && (code != VNOVOL))
3550                 ERROREXIT(code);
3551             roexists = 0;
3552         }
3553
3554         /* Mark all the ROs in the VLDB entry as RO_DONTUSE. We don't
3555          * write this entry out to the vlserver until after the first
3556          * RO volume is released (temp RO clones don't count).
3557          */
3558         for (i = 0; i < entry.nServers; i++) {
3559             entry.serverFlags[i] &= ~NEW_REPSITE;
3560             entry.serverFlags[i] |= RO_DONTUSE;
3561         }