static afs_int32 SALVSYNC_com_Link(SALVSYNC_command * com, SALVSYNC_response * res);
-extern int LogLevel;
extern int VInit;
extern pthread_mutex_t vol_salvsync_mutex;
static struct QueueHead SalvageHashTable[VSHASH_SIZE];
static struct SalvageQueueNode *
-LookupNode(afs_uint32 vid, char * partName,
+LookupNode(VolumeId vid, char * partName,
struct SalvageQueueNode ** parent)
{
struct rx_queue *qp, *nqp;
SalvageHashTable[idx].len++;
}
-#if 0
-static void
-DeleteNodeFromHash(struct SalvageQueueNode * node)
-{
- int idx = VSHASH(node->command.sop.volume);
-
- if (queue_IsNotOnQueue(&node->hash_chain)) {
- return;
- }
-
- queue_Remove(&node->hash_chain);
- SalvageHashTable[idx].len--;
-}
-#endif
-
void
SALVSYNC_salvInit(void)
{
CallHandler(&SALVSYNC_readfds);
}
- return NULL;
+ AFS_UNREACHED(return(NULL));
}
static void
}
ReleaseReadLock(&SALVSYNC_handler_lock); /* just in case */
osi_Panic("Failed to find handler\n");
- return -1; /* satisfy compiler */
+ AFS_UNREACHED(return -1);
}
static int
return i;
}
osi_Panic("Failed to find handler\n");
- return -1; /* satisfy compiler */
+ AFS_UNREACHED(return -1);
}
static int
switch (clone->state) {
case SALVSYNC_STATE_QUEUED:
DeleteFromSalvageQueue(clone);
-
+ AFS_FALLTHROUGH;
case SALVSYNC_STATE_SALVAGING:
switch (parent->state) {
case SALVSYNC_STATE_UNKNOWN:
}
}
-#if 0
-static struct SalvageQueueNode *
-LookupPendingCommand(SALVSYNC_command_hdr * qry)
-{
- struct SalvageQueueNode * np, * nnp;
-
- for (queue_Scan(&pendingQueue, np, nnp, SalvageQueueNode)) {
- if ((np->command.sop.volume == qry->volume) &&
- !strncmp(np->command.sop.partName, qry->partName,
- sizeof(qry->partName)))
- break;
- }
-
- if (queue_IsEnd(&pendingQueue, np))
- np = NULL;
- return np;
-}
-#endif
-
static struct SalvageQueueNode *
LookupPendingCommandByPid(int pid)
{
{
struct SalvageQueueNode * node;
char partName[16];
- afs_uint32 volids[VOLMAXTYPES+1];
+ VolumeId volids[VOLMAXTYPES+1];
unsigned int idx;
memset(volids, 0, sizeof(volids));