Boost.Asio
# Makefile for top dir
# $(call makever,1.2.3)
# major.minor.patch
# libtool manual: -version-number
define makever
? @ $(MAKE) -C $@ soname=lib$@.so.$(word 1,$(subst ., ,$(1)))
? @ cp $(OBJDIR)/$@/$@ $(OBJDIR)/$@/lib$@.so.$(1)
? @ cd $(OBJDIR)/$@ ; \
? ? ln -f -s lib$@.so.$(1) lib$@.so.$(word 1,$(subst ., ,$(1))) ; \
? ? cd - >/dev/null 2>&1 ;
? @ cd $(OBJDIR)/$@ ; \
? ? ln -f -s lib$@.so.$(1) lib$@.so ; \
? ? cd - >/dev/null 2>&1 ;
endef
# make # BUILD_DIR=build
ifdef BUILD_DIR
export OBJDIR = $(abspath $(BUILD_DIR))
else
export OBJDIR = $(abspath build)
endif
SUBDIRS = main # foo
all : $(SUBDIRS)
install : $(SUBDIRS)
$(SUBDIRS) : | $(OBJDIR)
$(OBJDIR) : ; @ mkdir $@
# main : foo
main : ; @ $(MAKE) -C $@
# foo : ; $(call makever,1.2.3)
# make DESTDIR=~/foo install
# Alexandre Duret-Lutz's Autotools Tutorial (without animations):
# "is ready to be uncompressed in / on many hosts"
install :
? install -d $(DESTDIR)/usr/local/bin
? install -d $(DESTDIR)/usr/local/lib
? install -m 0755 $(OBJDIR)/main/server $(DESTDIR)/usr/local/bin
? install -m 0755 $(OBJDIR)/main/client $(DESTDIR)/usr/local/bin
? # cp -P $(OBJDIR)/foo/*.so* $(DESTDIR)/usr/local/lib
clean :
? @ for dir in $(SUBDIRS); do \
? ? $(MAKE) -C $$dir $@; \
? done
? -rm -fr $(OBJDIR)
.PHONY : $(SUBDIRS) all install clean
---
# Makefile for subdir
# build shared library with -fPIC, -shared
CXXFLAGS ?= # -g -O3 -fPIC # CXXFLAGS for .cpp
CPPFLAGS ?= -MMD -MP -I/home/ljh/Downloads/boost_1_81_0/ # -I../foo
LDFLAGS ? = -L/home/ljh/Downloads/boost_1_81_0/stage/lib # -L$(OBJDIR)/foo # -shared
LDLIBS ? ?= -lpthread
# CC ? ? ?= $(CXX) # link with CXX for .cpp
LDFLAGS ?+= -Wl,-rpath,'$$ORIGIN/../foo'
LDFLAGS ?+= -Wl,-rpath,'$$ORIGIN/../lib'
#LDFLAGS += -Wl,-soname,$(soname)
# make # NDEBUG=1
ifdef NDEBUG
CXXFLAGS += -O3 # .cpp
CPPFLAGS += -DNDEBUG
else
CXXFLAGS += -g # .cpp
LDFLAGS ?+= -fsanitize=address
endif
SUBDIR ? ?= $(OBJDIR)/$(lastword $(subst /, ,$(CURDIR)))
all : $(SUBDIR)/server $(SUBDIR)/client
# https://make.mad-scientist.net/papers/how-not-to-use-vpath/
# $(SUBDIR)/main : $(addprefix $(SUBDIR)/,$(patsubst %.c,%.o,$(wildcard *.c))) # .cpp
# ? $(CC) $(LDFLAGS) $^ $(LDLIBS) -o $@
$(SUBDIR)/server : $(addprefix $(SUBDIR)/,$(patsubst %.cpp,%.o,server.cpp)) # .cpp
? $(CXX) $(LDFLAGS) $^ $(LDLIBS) -o $@
$(SUBDIR)/client : $(addprefix $(SUBDIR)/,$(patsubst %.cpp,%.o,client.cpp)) # .cpp
? $(CXX) $(LDFLAGS) $^ $(LDLIBS) -o $@
$(SUBDIR)/%.o : %.cpp | $(SUBDIR) # .cpp
? $(CXX) $(CXXFLAGS) $(CPPFLAGS) -c -o $@ $<
$(SUBDIR) : ; @ mkdir $@
-include $(SUBDIR)/*.d
clean : ; -rm -fr $(SUBDIR)
.PHONY : all clean
---
// ./boost_1_81_0/doc/html/boost_asio/example/cpp11/echo/async_tcp_echo_server.cpp
#include <cstdlib>
#include <iostream>
#include <memory>
#include <utility>
#include <boost/asio.hpp>
#ifndef NDEBUG
#include <sanitizer/lsan_interface.h>
#endif
struct session
? : public std::enable_shared_from_this<session>
{
? session(boost::asio::ip::tcp::socket socket)
? ? : socket(std::move(socket))
? { }
? void start() {
? ? start_read();
? ? start_write();
? }
? void start_read() {
? ? auto self(shared_from_this());
? ? memset(input_data, 0, sizeof(input_data));
? ? socket.async_read_some(
? ? ? boost::asio::buffer(input_data, sizeof(input_data)),
? ? ? [&, self](boost::system::error_code ec, std::size_t length) {
? ? ? ? if (!ec) {
? ? ? ? ? std::cout << input_data;
? ? ? ? ? start_read();
? ? ? ? } else {
? ? ? ? ? std::cout << ec.message() << "\n";
? ? ? ? }
? ? ? }
? ? );
? }
? void start_write() {
? ? auto self(shared_from_this());
? ? memset(output_data, 0, sizeof(output_data));
? ? snprintf(output_data, sizeof(output_data) - 1,
? ? ? "hello client %zu\n", cnt++);
? ? boost::asio::async_write(
? ? ? socket,
? ? ? boost::asio::buffer(output_data, sizeof(input_data)),
? ? ? [&, self](boost::system::error_code ec, std::size_t length)
? ? ? {
? ? ? ? if (!ec) {
? ? ? ? ? // sleep(1); //test
? ? ? ? ? start_write();
? ? ? ? } else {
? ? ? ? ? std::cout << ec.message() << "\n";
? ? ? ? }
? ? ? }
? ? );
? }
? boost::asio::ip::tcp::socket socket;
? enum { LEN = 1024 };
? char input_data[LEN];
? char output_data[LEN];
? size_t cnt = 0;
};
struct server {
? server(boost::asio::io_context& io_context, short port)
? ? : acceptor(io_context, boost::asio::ip::tcp::endpoint(
? ? ? ? boost::asio::ip::tcp::v4(), port))
? {
? ? std::cout << "Listen on port: " << port << " \n";
? ? do_accept();
? }
? void do_accept() {
? ? acceptor.async_accept(
? ? ? [&](boost::system::error_code ec,
? ? ? ? boost::asio::ip::tcp::socket socket)
? ? ? {
? ? ? ? if (!ec) {
? ? ? ? ? std::cout << "Accept connection: "
? ? ? ? ? ? << socket.remote_endpoint() << "\n";
? ? ? ? ? std::make_shared<session>(std::move(socket))->start();
? ? ? ? } else {
? ? ? ? ? std::cout << ec.message() << "\n";
? ? ? ? }
? ? ? ? do_accept();
? ? ? }
? ? );
? }
? boost::asio::ip::tcp::acceptor acceptor;
};
void handlerCont(int signum) {
? printf("SIGCONT %d\n", signum);
#ifndef NDEBUG
? __lsan_do_recoverable_leak_check();
#endif
}
int main(int argc, char* argv[]) {
? if (argc != 2) {
? ? std::cerr << "Usage: server <port>\n";
? ? return 1;
? }
? signal(SIGCONT, handlerCont); // kill -CONT 123 # pid
? boost::asio::io_context io_context;
? server s(io_context, std::atoi(argv[1]));
? io_context.run();
? return 0;
}
---
// ./boost_1_81_0/doc/html/boost_asio/example/cpp11/timeouts/async_tcp_client.cpp
#include <boost/asio/buffer.hpp>
#include <boost/asio/io_context.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <boost/asio/write.hpp>
#include <iostream>
#include <string>
#ifndef NDEBUG
#include <sanitizer/lsan_interface.h>
#endif
std::string client_tag; //test
struct session
? : public std::enable_shared_from_this<session>
{
? session(boost::asio::ip::tcp::socket socket)
? ? : socket(std::move(socket))
? { }
? void start() {
? ? start_read();
? ? start_write();
? }
? void start_read() {
? ? auto self(shared_from_this());
? ? memset(input_data, 0, sizeof(input_data));
? ? socket.async_read_some(
? ? ? boost::asio::buffer(input_data, sizeof(input_data)),
? ? ? [&, self](boost::system::error_code ec, std::size_t length) {
? ? ? ? if (!ec) {
? ? ? ? ? std::cout << input_data;
? ? ? ? ? start_read();
? ? ? ? } else {
? ? ? ? ? std::cout << ec.message() << "\n";
? ? ? ? }
? ? ? }
? ? );
? }
? void start_write() {
? ? auto self(shared_from_this());
? ? memset(output_data, 0, sizeof(output_data));
? ? snprintf(output_data, sizeof(output_data) - 1,
? ? ? "hello server %s %zu\n", client_tag.c_str(), cnt++);
? ? boost::asio::async_write(
? ? ? socket,
? ? ? boost::asio::buffer(output_data, sizeof(input_data)),
? ? ? [&, self](boost::system::error_code ec, std::size_t length)
? ? ? {
? ? ? ? if (!ec) {
? ? ? ? ? // sleep(1); //test
? ? ? ? ? start_write();
? ? ? ? } else {
? ? ? ? ? std::cout << ec.message() << "\n";
? ? ? ? }
? ? ? }
? ? );
? }
? boost::asio::ip::tcp::socket socket;
? enum { LEN = 1024 };
? char input_data[LEN];
? char output_data[LEN];
? size_t cnt = 0;
};
struct client {
? client(boost::asio::io_context& io_context,
? ? boost::asio::ip::tcp::resolver::results_type endpoints)
? ? ? : socket(io_context), endpoints(endpoints)
? {
? ? do_connect(endpoints.begin());
? }
? void do_connect (
? ? boost::asio::ip::tcp::resolver::results_type::iterator
? ? endpoint_iter)
? {
? ? if (endpoint_iter != endpoints.end()) {
? ? ? socket.async_connect(
? ? ? ? endpoint_iter->endpoint(),
? ? ? ? [&](const boost::system::error_code ec)
? ? ? ? {
? ? ? ? ? if (!socket.is_open()) {
? ? ? ? ? ? std::cout << "Connect timed out\n";
? ? ? ? ? ? do_connect(++endpoint_iter);
? ? ? ? ? } else if (ec) {
? ? ? ? ? ? std::cout << "Connect error: " << ec.message() << "\n";
? ? ? ? ? ? socket.close();
? ? ? ? ? } else {
? ? ? ? ? ? std::cout << "Connected to " <<
? ? ? ? ? ? ? socket.remote_endpoint() << "\n";
? ? ? ? ? ? std::make_shared<session>(std::move(socket))->start();
? ? ? ? ? }
? ? ? ? }
? ? ? );
? ? }
? }
? boost::asio::ip::tcp::resolver::results_type endpoints;
? boost::asio::ip::tcp::socket socket;
};
void handlerCont(int signum){
? printf("SIGCONT %d\n", signum);
#ifndef NDEBUG
? __lsan_do_recoverable_leak_check();
#endif
}
int main(int argc, char* argv[]) {
? if (argc != 4) {
? ? std::cerr << "Usage: client <host> <port> <tag>\n";
? ? return 1;
? }
? signal(SIGCONT, handlerCont); // kill -CONT 123 # pid
? client_tag = argv[3];
? boost::asio::io_context io_context;
? boost::asio::ip::tcp::resolver r(io_context);
? client c(io_context, r.resolve(argv[1], argv[2]));
? io_context.run();
? return 0;
}
