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 |