added more protocol description
This commit is contained in:
parent
6a184c6d84
commit
0e1e55ffb1
10
README.md
10
README.md
@ -10,4 +10,12 @@
|
|||||||
| `response_size` | Размер ответа в байтах |
|
| `response_size` | Размер ответа в байтах |
|
||||||
| `response_ready` | Флаг: 0 (ожидание), 1 (ответ готов) |
|
| `response_ready` | Флаг: 0 (ожидание), 1 (ответ готов) |
|
||||||
|
|
||||||
---
|
---
|
||||||
|
|
||||||
|
### 🔥 Пошаговый обмен:
|
||||||
|
|
||||||
|
1. Клиент заполняет `Command` структуры (устанавливает поля, сбрасывает `response_ready = 0`).
|
||||||
|
2. Клиент `push_batch()` пачку команд в `SharedCommandQueue`.
|
||||||
|
3. Сервер `try_pop_batch()`, обрабатывает.
|
||||||
|
4. Сервер пишет результат обратно в поля `Command` (`response`, `response_size`, `response_ready=1`).
|
||||||
|
5. Клиент ждет готовности (`response_ready.load() == 1`) и читает результат.
|
||||||
|
11
core/UDB.cpp
11
core/UDB.cpp
@ -31,17 +31,6 @@ namespace usub::core
|
|||||||
compactor_.run();
|
compactor_.run();
|
||||||
}
|
}
|
||||||
|
|
||||||
// {
|
|
||||||
// if (create_new)
|
|
||||||
// new(this->shm_manager_.base_ptr()) SharedCommandQueue(this->shm_queue_capacity_);
|
|
||||||
// this->command_queue_ = reinterpret_cast<SharedCommandQueue*>(this->shm_manager_.base_ptr());
|
|
||||||
//
|
|
||||||
// recover_from_logs();
|
|
||||||
//
|
|
||||||
// this->background_flush_thread_ = std::thread(&UDB::background_flush_worker, this);
|
|
||||||
// compactor_.run();
|
|
||||||
// }
|
|
||||||
|
|
||||||
UDB::~UDB()
|
UDB::~UDB()
|
||||||
{
|
{
|
||||||
running_ = false;
|
running_ = false;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user