/* $Id$ */
#include "bbs.h"
static int semid = -1;
#ifndef SEM_R
#define SEM_R 0400
#endif
#ifndef SEM_A
#define SEM_A 0200
#endif
#ifndef __FreeBSD__
union semun {
int val; /* value for SETVAL */
struct semid_ds *buf; /* buffer for IPC_STAT & IPC_SET */
u_short *array; /* array for GETALL & SETALL */
struct seminfo *__buf; /* buffer for IPC_INFO */
};
#endif
int
passwd_init()
{
semid = semget(PASSWDSEM_KEY, 1, SEM_R | SEM_A | IPC_CREAT | IPC_EXCL);
if (semid == -1) {
if (errno == EEXIST) {
semid = semget(PASSWDSEM_KEY, 1, SEM_R | SEM_A);
if (semid == -1) {
perror("semget");
exit(1);
}
} else {
perror("semget");
exit(1);
}
} else {
union semun s;
s.val = 1;
if (semctl(semid, 0, SETVAL, s) == -1) {
perror("semctl");
exit(1);
}
}
return 0;
}
int
passwd_update_money(int num) /* update money only */
{
userec_t user;
int pwdfd, money = moneyof(num);
char path[256];
if (num < 1 || num > MAX_USERS)
return -1;
sethomefile(path, getuserid(num), ".passwd");
if ((pwdfd = open(path, O_WRONLY)) < 0)
{
if(passwd_index_query(num, &user)<0) // tempory code, will be removed
exit(1);
user.money=money;
passwd_update(num, &user);
return 0;
}
if(lseek(pwdfd, (off_t)((int)&user.money - (int)&user), SEEK_SET) >= 0)
write(pwdfd, &money, sizeof(int));
close(pwdfd);
return 0;
}
int
passwd_index_update(int num, userec_t * buf)
{
int pwdfd;
if (num < 1 || num > MAX_USERS)
return -1;
buf->money = moneyof(num);
if ((pwdfd = open(fn_passwd, O_WRONLY)) < 0)
exit(1);
lseek(pwdfd, sizeof(userec_t) * (num - 1), SEEK_SET);
write(pwdfd, buf, sizeof(userec_t));
close(pwdfd);
return 0;
}
int
passwd_update(int num, userec_t * buf)
{
int pwdfd;
char path[256];
if(!buf->userid[0]) return -1;
sethomefile(path, buf->userid, ".passwd");
buf->money = moneyof(num);
if ((pwdfd = open(path, O_WRONLY|O_CREAT, 0600)) < 0)
return -1;
write(pwdfd, buf, sizeof(userec_t));
close(pwdfd);
return 0;
}
int
passwd_index_query(int num, userec_t * buf)
{
int pwdfd;
if (num < 1 || num > MAX_USERS)
return -1;
if ((pwdfd = open(fn_passwd, O_RDONLY)) < 0)
exit(1);
lseek(pwdfd, sizeof(userec_t) * (num - 1), SEEK_SET);
read(pwdfd, buf, sizeof(userec_t));
close(pwdfd);
return 0;
}
userec_t userecbuf;
int initcuser(char *userid)
{
// Ptt: setup cuser and usernum here
if(userid[0]=='\0' ||
!(usernum = searchuser(userid)) || usernum > MAX_USERS)
return -1;
passwd_query(usernum, &userecbuf);
cuser = &userecbuf;
return usernum;
}
int
passwd_query(int num, userec_t * buf)
{
int pwdfd;
char path[256], *userid;
if (num < 1 || num > MAX_USERS)
return -1;
userid = getuserid(num);
if(userid[0]=='\0') return -1;
sethomefile(path, userid, ".passwd");
if((pwdfd = open(path, O_RDONLY)) < 0)
{ // copy from index // tempory code, will be removed
if(passwd_index_query(num, buf)<0)
exit(1);
passwd_update(num, buf);
return 0;
}
read(pwdfd, buf, sizeof(userec_t));
close(pwdfd);
return 0;
}
int
passwd_apply(int (*fptr) (int, userec_t *))
{
int i;
userec_t user;
for (i = 0; i < MAX_USERS; i++) {
passwd_query(i + 1, &user);
if ((*fptr) (i, &user) == QUIT)
return QUIT;
}
return 0;
}
void
passwd_lock()
{
struct sembuf buf = {0, -1, SEM_UNDO};
if (semop(semid, &buf, 1)) {
perror("semop");
exit(1);
}
}
void
passwd_unlock()
{
struct sembuf buf = {0, 1, SEM_UNDO};
if (semop(semid, &buf, 1)) {
perror("semop");
exit(1);
}
}