![]() |
Multiscale Universal Interface
2.0
A Concurrent Framework for Coupling Heterogeneous Solvers
|
File containing class definition of base TCP communicator. More...
#include <cstdio>#include <cstdlib>#include <cstring>#include <sys/stat.h>#include <sys/types.h>#include <sys/socket.h>#include <netdb.h>#include <netinet/in.h>#include <arpa/inet.h>#include <unistd.h>#include <sys/epoll.h>#include <sys/eventfd.h>#include <fcntl.h>#include <thread>#include <mutex>#include <condition_variable>#include <vector>#include <deque>#include <list>#include <exception>#include <atomic>#include "message.h"#include "comm.h"#include "lib_uri.h"#include "comm_factory.h"
Go to the source code of this file.
Classes | |
| struct | mui::smalluint |
| struct | mui::mutex_timeout |
| class | mui::unique_fd_ |
| class | mui::poll_scheduler |
| class | mui::read_que |
| class | mui::write_que |
| class | mui::comm_fd |
Namespaces | |
| mui | |
Functions | |
| istream & | mui::operator>> (istream &stream, smalluint &sml) |
| ostream & | mui::operator<< (ostream &stream, const smalluint &sml) |
| communicator * | mui::create_comm_tcp (const char *str) |
| communicator * | mui::create_comm_shm (const char *str) |
File containing class definition of base TCP communicator.
| char buf[BUFSIZE] |
| unsigned ccur_ = 0u |
| unsigned head_ = 0u |
| std::deque<node_t> nodes_ |
| std::size_t pcur_ = 0u |
| std::size_t psize_ = 0u |
| std::size_t size_ = 0u |
| unsigned tail_ = 0u |