5 #include <websocketpp/config/asio_no_tls_client.hpp> 6 #include <websocketpp/client.hpp> 7 #include <websocketpp/common/thread.hpp> 8 #include <websocketpp/common/functional.hpp> 11 #include <glibmm/spawn.h> 13 typedef websocketpp::client<websocketpp::config::asio_client>
WSClient;
14 typedef websocketpp::config::asio_client::message_type::ptr
message_ptr;
15 typedef websocketpp::lib::lock_guard<websocketpp::lib::mutex>
scoped_lock;
41 ComputeThread(
int server_port=0, std::string token=
"", std::string ip_address=
"127.0.0.1");
86 bool complete(DTree::iterator,
int pos,
int alternative);
124 void on_open(websocketpp::connection_hdl hdl);
125 void on_fail(websocketpp::connection_hdl hdl);
126 void on_close(websocketpp::connection_hdl hdl);
void try_spawn_server()
Definition: ComputeThread.cc:169
std::string forced_server_token
Definition: ComputeThread.hh:143
void set_master(GUIBase *, DocumentThread *)
Determine the objects that this compute thread should be talking to.
Definition: ComputeThread.cc:43
void on_fail(websocketpp::connection_hdl hdl)
Definition: ComputeThread.cc:147
Abstract base class with methods that need to be implemented by any GUI.
Definition: GUIBase.hh:16
void on_message(websocketpp::connection_hdl hdl, message_ptr msg)
Definition: ComputeThread.cc:274
websocketpp::lib::lock_guard< websocketpp::lib::mutex > scoped_lock
Definition: ComputeThread.hh:15
WSClient::connection_ptr connection
Definition: ComputeThread.hh:119
void cell_finished_running(DataCell::id_t)
Definition: ComputeThread.cc:263
int number_of_cells_executing(void) const
Definition: ComputeThread.cc:550
unsigned short port
Definition: ComputeThread.hh:140
void execute_cell(DTree::iterator)
In order to execute code on the server, call the following from the GUI thread.
Definition: ComputeThread.cc:477
websocketpp::connection_hdl our_connection_hdl
Definition: ComputeThread.hh:120
DocumentThread * docthread
Definition: ComputeThread.hh:102
A base class with all the logic to manipulate a Cadabra notebook document.
Definition: DocumentThread.hh:40
bool complete(DTree::iterator, int pos, int alternative)
Request completion of a string.
Definition: ComputeThread.cc:604
void try_connect()
Definition: ComputeThread.cc:57
void stop()
Stop the current cell execution on the server and remove all other cells from the run queue as well...
Definition: ComputeThread.cc:555
void run()
Main entry point, which will connect to the server and then start an event loop to handle communicati...
Definition: ComputeThread.cc:96
std::thread::id gui_thread_id
Definition: ComputeThread.hh:107
std::string authentication_token
Definition: ComputeThread.hh:141
GUIBase * gui
Definition: ComputeThread.hh:101
void on_close(websocketpp::connection_hdl hdl)
Definition: ComputeThread.cc:249
bool restarting_kernel
Definition: ComputeThread.hh:118
int server_stdout
Definition: ComputeThread.hh:139
Functions to handle the exchange properties of two or more symbols in a product.
Definition: Adjform.cc:83
std::string forced_server_ip_address
Definition: ComputeThread.hh:144
int server_stderr
Definition: ComputeThread.hh:139
void terminate()
Terminate the compute thread, in preparation for shutting down the client altogether.
Definition: ComputeThread.cc:108
int forced_server_port
Definition: ComputeThread.hh:142
std::map< DataCell::id_t, DTree::iterator > running_cells
Definition: ComputeThread.hh:114
Glib::Pid server_pid
Definition: ComputeThread.hh:138
~ComputeThread()
Definition: ComputeThread.cc:31
websocketpp::client< websocketpp::config::asio_client > WSClient
Definition: ComputeThread.hh:13
ComputeThread(int server_port=0, std::string token="", std::string ip_address="127.0.0.1")
If the ComputeThread is constructed with a null pointer to the gui, there will be no gui updates...
Definition: ComputeThread.cc:19
void restart_kernel()
Restart the kernel.
Definition: ComputeThread.cc:575
void execute_interactive(uint64_t id, const std::string &code)
Definition: ComputeThread.cc:450
void all_cells_nonrunning()
Set all cells to be non-running (e.g.
Definition: ComputeThread.cc:133
Base class which talks to the server and sends Action objects back to the DocumentThread.
Definition: ComputeThread.hh:36
void init()
Definition: ComputeThread.cc:49
bool connection_is_open
Definition: ComputeThread.hh:118
Each cell is identified by a serial number 'id' which is used to keep track of it across network call...
Definition: DataCell.hh:51
WSClient wsclient
Definition: ComputeThread.hh:117
websocketpp::config::asio_client::message_type::ptr message_ptr
Definition: ComputeThread.hh:14
std::set< uint64_t > interactive_cells
Definition: ComputeThread.hh:135
void on_open(websocketpp::connection_hdl hdl)
Definition: ComputeThread.cc:222