-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathuser_controller.c
More file actions
77 lines (64 loc) · 1.89 KB
/
user_controller.c
File metadata and controls
77 lines (64 loc) · 1.89 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
#include "user_controller.h"
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/sem.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
static UserController *users = NULL;
static int sem_user; // Keep only user semaphore
#if defined(__linux__)
union semun { int val; };
#endif
static void sem_lock(int sem_id) {
struct sembuf op = {0, -1, SEM_UNDO};
semop(sem_id, &op, 1);
}
static void sem_unlock(int sem_id) {
struct sembuf op = {0, 1, SEM_UNDO};
semop(sem_id, &op, 1);
}
void init_user_controller() {
int shm_id = shmget(SHM_KEY_USERS, sizeof(UserController), IPC_CREAT | 0666);
users = (UserController*)shmat(shm_id, NULL, 0);
memset(users, 0, sizeof(UserController));
// Only create user semaphore (removed balance semaphore)
sem_user = semget(SHM_KEY_USERS + 1, 1, IPC_CREAT | 0666);
union semun arg;
arg.val = 1;
semctl(sem_user, 0, SETVAL, arg);
printf("✓ User controller initialized\n");
}
int check_and_register_login(int role, int user_id) {
sem_lock(sem_user);
for (int i = 0; i < MAX_USERS; i++) {
if (users->users[i].active &&
users->users[i].role == role &&
users->users[i].user_id == user_id) {
sem_unlock(sem_user);
return 0;
}
}
for (int i = 0; i < MAX_USERS; i++) {
if (!users->users[i].active) {
users->users[i].role = role;
users->users[i].user_id = user_id;
users->users[i].active = 1;
sem_unlock(sem_user);
return 1;
}
}
sem_unlock(sem_user);
return 0;
}
void register_logout(int role, int user_id) {
sem_lock(sem_user);
for (int i = 0; i < MAX_USERS; i++) {
if (users->users[i].role == role &&
users->users[i].user_id == user_id) {
users->users[i].active = 0;
break;
}
}
sem_unlock(sem_user);
}