#define MAXHANDLERS 4 /* Up to 4 clients; must be at least 2, so that
* move = dump+restore can run on single server */
-#define MAXOFFLINEVOLUMES 30 /* This needs to be as big as the maximum
+#define MAXOFFLINEVOLUMES 128 /* This needs to be as big as the maximum
* number that would be offline for 1 operation.
* Current winner is salvage, which needs all
* cloned read-only copies offline when salvaging
else
command.partName[0] = 0;
assert(FS_sd != -1);
- VFSYNC_LOCK
+ VFSYNC_LOCK;
#ifdef AFS_NT40_ENV
if (send(FS_sd, (char *)&command, sizeof(command), 0) != sizeof(command)) {
printf("FSYNC_askfs: write to file server failed\n");
("FSYNC_askfs: negative response from file server; volume %u, command %d\n",
command.volume, (int)command.command);
}
- done:
- VFSYNC_UNLOCK
-
+ done:
+ VFSYNC_UNLOCK;
return response;
}
FSYNC_Drop(fd);
return;
}
- VATTACH_LOCK VOL_LOCK volumes = OfflineVolumes[FindHandler(fd)];
+ VATTACH_LOCK;
+ VOL_LOCK;
+ volumes = OfflineVolumes[FindHandler(fd)];
for (v = 0, i = 0; i < MAXOFFLINEVOLUMES; i++) {
if (volumes[i].volumeID == command.volume
&& strcmp(volumes[i].partName, command.partName) == 0) {
if (V_BreakVolumeCallbacks) {
Log("fssync: volume %u moved to %x; breaking all call backs\n",
command.volume, command.reason);
- VOL_UNLOCK VATTACH_UNLOCK(*V_BreakVolumeCallbacks) (command.
- volume);
- VATTACH_LOCK VOL_LOCK}
+ VOL_UNLOCK;
+ VATTACH_UNLOCK;
+ (*V_BreakVolumeCallbacks) (command.volume);
+ VATTACH_LOCK;
+ VOL_LOCK;
+ }
break;
case FSYNC_RESTOREVOLUME:
/* if the volume is being restored, break all callbacks on it */
if (V_BreakVolumeCallbacks) {
Log("fssync: volume %u restored; breaking all call backs\n",
command.volume);
- VOL_UNLOCK VATTACH_UNLOCK(*V_BreakVolumeCallbacks) (command.
- volume);
- VATTACH_LOCK VOL_LOCK}
+ VOL_UNLOCK;
+ VATTACH_UNLOCK;
+ (*V_BreakVolumeCallbacks) (command.volume);
+ VATTACH_LOCK;
+ VOL_LOCK;
+ }
break;
default:
rc = FSYNC_DENIED;
break;
}
- VOL_UNLOCK VATTACH_UNLOCK
+ VOL_UNLOCK;
+ VATTACH_UNLOCK;
#ifdef AFS_NT40_ENV
- (void) send(fd, &rc, 1, 0);
+ (void)send(fd, &rc, 1, 0);
#else
- (void) write(fd, &rc, 1);
+ (void)write(fd, &rc, 1);
#endif
}
Error error;
char tvolName[VMAXPATHLEN];
- VATTACH_LOCK VOL_LOCK p = OfflineVolumes[FindHandler(fd)];
+ VATTACH_LOCK;
+ VOL_LOCK;
+ p = OfflineVolumes[FindHandler(fd)];
for (i = 0; i < MAXOFFLINEVOLUMES; i++) {
if (p[i].volumeID) {
Volume *vp;
p[i].volumeID = 0;
}
}
- VOL_UNLOCK VATTACH_UNLOCK RemoveHandler(fd);
+ VOL_UNLOCK;
+ VATTACH_UNLOCK;
+ RemoveHandler(fd);
#ifdef AFS_NT40_ENV
closesocket(fd);
#else