Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
21 changes: 11 additions & 10 deletions src/client.h
Original file line number Diff line number Diff line change
Expand Up @@ -10,23 +10,24 @@

typedef struct client_t {
#define BUFFER_SIZE 655365
int fd;
unsigned char buffer[65536]; // adjust if we expect larger frames
size_t buf_used; // bytes currently in buffer
ssize_t
frame_need; // -1 until we know; else total frame size (2 + core_len)
char ip_str[INET6_ADDRSTRLEN]; // TODO: Remove this in the future
char *command_type;
char *config_file_path;
char *command;
char *uds_socket_path; // Unix domain socket path
char *ip_address;
size_t buf_used; // bytes currently in buffer
ssize_t frame_need; // -1 until we know; else total frame size (2 + core_len)
int port;
char *uds_socket_path; // Unix domain socket path
int fd;
enum socket_domain
socket_domain; // The socket domain we are using (Unix Domain or TCP/IP)

unsigned char buffer[65536]; // adjust if we expect larger frames
char ip_str[INET6_ADDRSTRLEN]; // TODO: Remove this in the future
bool benchmark_mode;
char *command_type;
char *config_file_path;
bool interactive_mode;
bool verbose; // print additional information during runtime
} client_t;
} client_t __attribute__((aligned(64)));

client_t *init_client(int client_fd, struct sockaddr_storage ss,
enum socket_domain socket_domain);
Expand Down
27 changes: 14 additions & 13 deletions src/server.h
Original file line number Diff line number Diff line change
Expand Up @@ -16,25 +16,26 @@ typedef struct {
} db_t;

typedef struct server_t {
bool daemonize;
list_t *clients;
char *config_file_path;
db_t *database;
char *uds_socket_path; // Unix domain socket path
counter_t metrics;
int port;
int fd;
int event_loop_fd;
int event_loop_max_events;
int32_t num_disconnected_clients;
pid_t pid;
bool is_logging_enabled;
bool verbose;
bool show_logo;
list_t *clients;
u_int32_t num_clients;
int32_t num_disconnected_clients;
int event_loop_max_events;
char *uds_socket_path; // Unix domain socket path
enum socket_domain socket_domain;
bool use_io_uring;
char *config_file_path;
db_t *database;
counter_t metrics;
event_loop_dispatcher_kind event_dispatcher_kind;
} server_t;
bool use_io_uring;
bool is_logging_enabled;
bool verbose;
bool show_logo;
bool daemonize;
} server_t __attribute__((aligned(128)));
;

#endif // SERVER_H
Loading