diff --git a/kirill/rgz/Makefile b/kirill/rgz/Makefile new file mode 100644 index 0000000..6c1591b --- /dev/null +++ b/kirill/rgz/Makefile @@ -0,0 +1,19 @@ +CC = gcc +CFLAGS = -Wall -Wextra -O2 +LDFLAGS = + +SERVER = daemon +CLIENT = client + +.PHONY: all clean + +all: daemon client + +daemon: daemon.c + $(CC) $(CFLAGS) -o $(SERVER) daemon.c $(LDFLAGS) + +client: client.c + $(CC) $(CFLAGS) -o $(CLIENT) client.c $(LDFLAGS) + +clean: + rm -f daemon client diff --git a/kirill/rgz/bad_service.sh b/kirill/rgz/bad_service.sh new file mode 100644 index 0000000..df0d6bf --- /dev/null +++ b/kirill/rgz/bad_service.sh @@ -0,0 +1,38 @@ +#!/usr/bin/env bash + +set -euo pipefail + +target=/etc/systemd/system/fifo.service + +USER="pajjilykk" +GROUP="pajjilykk" +WORKDIR="/home/pajjilykk/CLionProjects/CS-LABS/vlad/rgz" +EXECUTABLE="$WORKDIR/daemon" +tmp=$(mktemp) + +trap 'rm -f "$tmp"' EXIT + +cat > "$tmp" <\n", +// пишет обработанный текст в выходной файл и печатает количество замен. + +#include +#include +#include +#include // read, write, close, getpid +#include // open +#include +#include +#include + +#define FIFO_REQUEST "/tmp/fifo_request" +#define FIFO_RESPONSE "/tmp/fifo_response" +#define BUFFER_SIZE 4096 + +void print_usage(const char *progname) { + fprintf(stderr, "Usage: %s \n", progname); + fprintf(stderr, "Example: %s input.txt output.txt\n", progname); +} + +int main(int argc, char *argv[]) { + if (argc != 3) { + fprintf(stderr, "ERROR: Неверное количество аргументов\n"); + print_usage(argv[0]); + return 1; + } + + const char *input_file = argv[1]; + const char *output_file = argv[2]; + + printf("=== FIFO Client ===\n"); + printf("Client PID: %d\n", getpid()); + printf("Входной файл: %s\n", input_file); + printf("Выходной файл: %s\n", output_file); + + int in_fd = open(input_file, O_RDONLY); + if (in_fd < 0) { + fprintf(stderr, "ERROR: Не удалось открыть входной файл %s: %s\n", + input_file, strerror(errno)); + return 1; + } + + char *buffer = malloc(BUFFER_SIZE); + if (!buffer) { + fprintf(stderr, "ERROR: Не удалось выделить память\n"); + close(in_fd); + return 1; + } + + ssize_t bytes_read = read(in_fd, buffer, BUFFER_SIZE - 1); + close(in_fd); + if (bytes_read < 0) { + fprintf(stderr, "ERROR: Не удалось прочитать файл: %s\n", strerror(errno)); + free(buffer); + return 1; + } + + buffer[bytes_read] = '\0'; + printf("Прочитано байт из файла: %zd\n", bytes_read); + + printf("Отправка запроса серверу...\n"); + int fd_req = open(FIFO_REQUEST, O_WRONLY); + if (fd_req == -1) { + fprintf(stderr, "ERROR: Не удалось открыть FIFO запроса: %s\n", strerror(errno)); + fprintf(stderr, "Убедитесь, что сервер (демон) запущен!\n"); + free(buffer); + return 1; + } + + ssize_t bytes_written = write(fd_req, buffer, bytes_read); + close(fd_req); + if (bytes_written != bytes_read) { + fprintf(stderr, "ERROR: Ошибка отправки данных\n"); + free(buffer); + return 1; + } + + printf("Отправлено байт: %zd\n", bytes_written); + printf("Ожидание ответа от сервера...\n"); + + int fd_resp = open(FIFO_RESPONSE, O_RDONLY); + if (fd_resp == -1) { + fprintf(stderr, "ERROR: Не удалось открыть FIFO ответа: %s\n", strerror(errno)); + free(buffer); + return 1; + } + + ssize_t response_bytes = read(fd_resp, buffer, BUFFER_SIZE - 1); + close(fd_resp); + if (response_bytes < 0) { + fprintf(stderr, "ERROR: Ошибка чтения ответа: %s\n", strerror(errno)); + free(buffer); + return 1; + } + + buffer[response_bytes] = '\0'; + printf("Получено байт от сервера: %zd\n", response_bytes); + + char *replacements_info = strstr(buffer, "\nREPLACEMENTS:"); + long long replacements = 0; + if (replacements_info) { + sscanf(replacements_info, "\nREPLACEMENTS:%lld", &replacements); + *replacements_info = '\0'; + response_bytes = replacements_info - buffer; + } + + int out_fd = open(output_file, O_CREAT | O_WRONLY | O_TRUNC, + S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP | S_IROTH | S_IWOTH); + if (out_fd < 0) { + fprintf(stderr, "ERROR: Не удалось открыть выходной файл %s: %s\n", + output_file, strerror(errno)); + free(buffer); + return 1; + } + + ssize_t written = write(out_fd, buffer, response_bytes); + close(out_fd); + if (written != response_bytes) { + fprintf(stderr, "ERROR: Ошибка записи в выходной файл\n"); + free(buffer); + return 1; + } + + printf("Записано байт в выходной файл: %zd\n", written); + printf("Количество выполненных замен: %lld\n", replacements); + printf("\nОбработка завершена успешно!\n"); + + free(buffer); + return 0; +} diff --git a/kirill/rgz/daemon.c b/kirill/rgz/daemon.c new file mode 100644 index 0000000..b43a735 --- /dev/null +++ b/kirill/rgz/daemon.c @@ -0,0 +1,194 @@ +// fifo_server_daemon.c +// Демон: читает из FIFO_REQUEST, обрабатывает текст, +// В КАЖДОЙ СТРОКЕ заменяет пробелом каждый 3-й байт, который НЕ '\n'. +// '\n' сохраняется и сбрасывает счётчик позиции внутри строки. +// Пишет результат в FIFO_RESPONSE и дописывает "\nREPLACEMENTS:\n". +// Логирует ошибки в syslog, игнорирует SIGPIPE (чтобы write() не убивал процесс). [web:21][web:28] + +#include // fprintf, snprintf +#include // malloc, free, strtoll +#include // strlen, strerror, memset +#include // read, write, close, unlink +#include // open, O_RDONLY, O_WRONLY +#include // типы +#include // mkfifo +#include // errno +#include // sigaction, SIGINT, SIGTERM, SIGPIPE +#include // syslog, openlog, closelog + +#define FIFO_REQUEST "/tmp/fifo_request" +#define FIFO_RESPONSE "/tmp/fifo_response" +#define BUFFER_SIZE 4096 + +static volatile sig_atomic_t running = 1; + +static void signal_handler(int sig) { + (void) sig; + running = 0; +} + +// разбор неотрицательного long long +static long long parse_ll(const char *s) { + char *end = NULL; + errno = 0; + long long v = strtoll(s, &end, 10); + if (errno != 0 || end == s || *end != '\0' || v < 0) return -1; + return v; +} + +// В каждой строке: заменить каждый 3-й НЕ '\n' байт на пробел. +// Возвращает количество замен. +static long long process_data(const char *input, size_t input_len, + char *output, size_t output_size) { + if (!input || !output || input_len == 0 || output_size == 0) { + return 0; + } + + long long replacements = 0; + size_t out_pos = 0; + size_t pos_in_line = 0; // считает только не-'\n' байты в текущей строке + + for (size_t i = 0; i < input_len && out_pos < output_size - 1; i++) { + unsigned char c = (unsigned char) input[i]; + + if (c == '\n') { + output[out_pos++] = '\n'; + pos_in_line = 0; + continue; + } + + pos_in_line++; + + if (pos_in_line % 3 == 0) { + output[out_pos++] = ' '; + replacements++; + } else { + output[out_pos++] = (char) c; + } + } + + output[out_pos] = '\0'; + return replacements; +} + +int main(int argc, char *argv[]) { + // Аргумент оставлен для совместимости с вашим запуском, но больше не влияет на обработку. + if (argc != 2) { + fprintf(stderr, "Usage: %s \n", argv[0]); + return 1; + } + + long long ignored = parse_ll(argv[1]); + if (ignored < 0) { + fprintf(stderr, "ERROR: Invalid argument (must be non-negative integer)\n"); + return 1; + } + + openlog("fifo_server_daemon", LOG_PID | LOG_NDELAY, LOG_DAEMON); + syslog(LOG_INFO, "Server started (systemd), arg(ignored)=%lld", ignored); // syslog via openlog/syslog [web:28] + + struct sigaction sa; + memset(&sa, 0, sizeof(sa)); + sa.sa_handler = signal_handler; + sigemptyset(&sa.sa_mask); + sigaction(SIGINT, &sa, NULL); + sigaction(SIGTERM, &sa, NULL); + signal(SIGPIPE, SIG_IGN); // игнор SIGPIPE, обработка ошибок через write() [web:21] + + unlink(FIFO_REQUEST); + unlink(FIFO_RESPONSE); + + if (mkfifo(FIFO_REQUEST, 0666) == -1) { + syslog(LOG_ERR, "mkfifo request failed: %s", strerror(errno)); // mkfifo creates FIFO special file [web:37] + closelog(); + return 1; + } + + if (mkfifo(FIFO_RESPONSE, 0666) == -1) { + syslog(LOG_ERR, "mkfifo response failed: %s", strerror(errno)); // mkfifo creates FIFO special file [web:37] + unlink(FIFO_REQUEST); + closelog(); + return 1; + } + + syslog(LOG_INFO, "FIFO created: request=%s, response=%s", FIFO_REQUEST, FIFO_RESPONSE); + + while (running) { + int fd_req = open(FIFO_REQUEST, O_RDONLY); + // open FIFO for reading can block until writer connects [web:26][web:35] + if (!running) { + if (fd_req != -1) close(fd_req); + break; + } + if (fd_req == -1) { + if (errno == EINTR) continue; + syslog(LOG_ERR, "open request FIFO failed: %s", strerror(errno)); + break; + } + + char *input_buffer = (char *) malloc(BUFFER_SIZE); + char *output_buffer = (char *) malloc(BUFFER_SIZE); + if (!input_buffer || !output_buffer) { + syslog(LOG_ERR, "Memory allocation failed"); + close(fd_req); + free(input_buffer); + free(output_buffer); + break; + } + + ssize_t bytes_read = read(fd_req, input_buffer, BUFFER_SIZE - 1); + close(fd_req); + + if (!running) { + free(input_buffer); + free(output_buffer); + break; + } + + if (bytes_read <= 0) { + free(input_buffer); + free(output_buffer); + if (!running) break; + continue; + } + + input_buffer[bytes_read] = '\0'; + syslog(LOG_INFO, "Request received: %zd bytes", bytes_read); + + long long replacements = + process_data(input_buffer, (size_t) bytes_read, output_buffer, BUFFER_SIZE); + + int fd_resp = open(FIFO_RESPONSE, O_WRONLY); + // open FIFO for writing can block until reader connects [web:26][web:35] + if (fd_resp == -1) { + syslog(LOG_ERR, "open response FIFO failed: %s", strerror(errno)); + free(input_buffer); + free(output_buffer); + if (!running) break; + continue; + } + + size_t output_len = strlen(output_buffer); + ssize_t bytes_written = write(fd_resp, output_buffer, output_len); + + char trailer[64]; + snprintf(trailer, sizeof(trailer), "\nREPLACEMENTS:%lld\n", replacements); + if (write(fd_resp, trailer, strlen(trailer)) < 0) { + syslog(LOG_WARNING, "write replacements trailer failed: %s", strerror(errno)); + } + + close(fd_resp); + + syslog(LOG_INFO, "Response sent: %zd bytes; replacements=%lld", + bytes_written, replacements); + + free(input_buffer); + free(output_buffer); + } + + syslog(LOG_INFO, "Server stopping, cleaning up"); + unlink(FIFO_REQUEST); + unlink(FIFO_RESPONSE); + closelog(); + return 0; +} diff --git a/kirill/rgz/input.txt b/kirill/rgz/input.txt new file mode 100644 index 0000000..da7ca42 --- /dev/null +++ b/kirill/rgz/input.txt @@ -0,0 +1,4 @@ +abacaba +hello +abcaa +aaaaa diff --git a/kirill/rgz/service.sh b/kirill/rgz/service.sh new file mode 100644 index 0000000..a04bf43 --- /dev/null +++ b/kirill/rgz/service.sh @@ -0,0 +1,38 @@ +#!/usr/bin/env bash + +set -euo pipefail + +target=/etc/systemd/system/fifo.service + +USER="pajjilykk" +GROUP="pajjilykk" +WORKDIR="/home/pajjilykk/CLionProjects/CS-LABS/vlad/rgz" +EXECUTABLE="$WORKDIR/daemon" +tmp=$(mktemp) + +trap 'rm -f "$tmp"' EXIT + +cat > "$tmp" <