Green-Sky/crdt_tests
1
0
Fork 0
mirror of https://github.com/Green-Sky/crdt_tests.git synced 2024-12-22 23:53:24 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix bug where event where wired to the wrong callback

Browse Source 
begin crdt
This commit is contained in:
Green Sky 2022-12-16 23:18:39 +01:00
parent c94e2e68a7
commit bbb93040d0
No known key found for this signature in database
1 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
vim_research/test1.cpp
View File

@ -10,8 +10,8 @@
// single letter agent, for testing only // single letter agent, for testing only
using Agent = char; using Agent = char;
using DocType = GreenCRDT::TextDocument<Agent>; using Doc = GreenCRDT::TextDocument<Agent>;
using ListType = DocType::ListType; using ListType = Doc::ListType;
static bool send_command(zed_net_socket_t* remote_socket, const std::string_view mode, const std::string_view command) { static bool send_command(zed_net_socket_t* remote_socket, const std::string_view mode, const std::string_view command) {
auto j = nlohmann::json::array(); auto j = nlohmann::json::array();
@ -28,9 +28,6 @@ static bool send_command(zed_net_socket_t* remote_socket, const std::string_view
static bool send_setup(zed_net_socket_t* remote_socket) { static bool send_setup(zed_net_socket_t* remote_socket) {
return send_command(remote_socket, "ex", return send_command(remote_socket, "ex",
//"function! GreenCRDT_CheckTimeAndSendState()",
//"endfunction",
//"function! GreenCRDT_CheckTimeAndSendState() | endfunction",
// vars // vars
R"( R"(
@ -39,7 +36,7 @@ let b:green_crdt_dirty = v:true
)" )"
R"( R"(
function! GreenCRDTTimerCallback(timer) function! GreenCRDTTimerCallback(timer) abort
let b:green_crdt_timer_can_send = v:true let b:green_crdt_timer_can_send = v:true
call GreenCRDTCheckTimeAndSendState() call GreenCRDTCheckTimeAndSendState()
endfunction endfunction
@ -59,7 +56,7 @@ endfunction
R"( R"(
function! GreenCRDTChangeEvent() function! GreenCRDTChangeEvent()
let b:green_crdt_dirty = v:true let b:green_crdt_dirty = v:true
GreenCRDTCheckTimeAndSendState() call GreenCRDTCheckTimeAndSendState()
endfunction endfunction
)" )"
@ -74,7 +71,10 @@ function! GreenCRDTStop()
augroup END augroup END
call ch_close(b:channel) call ch_close(b:channel)
delfunction GreenCRDTCheckTimeAndSendState delfunction GreenCRDTCheckTimeAndSendState
delfunction GreenCRDTTimerCallback
delfunction GreenCRDTChangeEvent
"delfunction GreenCRDTStop "delfunction GreenCRDTStop
let b:green_crdt_timer_can_send = v:true
endfunction endfunction
)" )"
@ -83,8 +83,8 @@ R"(
function! GreenCRDTSetupEvents() abort function! GreenCRDTSetupEvents() abort
augroup green_crdt augroup green_crdt
au! au!
au TextChanged <buffer> call GreenCRDTCheckTimeAndSendState() au TextChanged <buffer> call GreenCRDTChangeEvent()
au TextChangedI <buffer> call GreenCRDTCheckTimeAndSendState() au TextChangedI <buffer> call GreenCRDTChangeEvent()
augroup END augroup END
endfunction endfunction
call GreenCRDTSetupEvents() call GreenCRDTSetupEvents()
@ -141,6 +141,7 @@ int main(void) {
send_setup(&remote_socket); send_setup(&remote_socket);
// send doauto text changed for inital buffer // send doauto text changed for inital buffer
Doc doc;
while (true) { while (true) {
// 10MiB // 10MiB
auto buffer = std::make_unique<std::array<uint8_t, 1024*1024*10>>(); auto buffer = std::make_unique<std::array<uint8_t, 1024*1024*10>>();
@ -231,7 +232,10 @@ int main(void) {
new_text += '\n'; new_text += '\n';
} }
//std::cout << "new_text: " << new_text << "\n"; const auto ops = doc.merge(new_text);
if (!ops.empty()) {
std::cout << "ops.size: " << ops.size() << "\n";
}
} else { } else {
std::cout << "unknown command '" << command << "'\n"; std::cout << "unknown command '" << command << "'\n";
} }