переписал как договаривались, без единого потока, и с запуском следующей операции записи по завершению предыдущей.
работает значительно дольше, но все равно валится(только при запуске клиента и сервера локально):
исходники + логи, тут: http://rghost.ru/5141178
выложу в тему исходники. может я в коде что-то намудрил.. сам не замечаю..
клиент:
| Код |
#include <iostream>
#include <boost/bind.hpp>
#include <boost/asio.hpp>
#include <boost/lexical_cast.hpp>
#include "header.hpp"
/***************************************************************************/
void readed(
boost::asio::ip::tcp::socket&,
char*,
FILE*,
const boost::system::error_code&
);
void start_read(
boost::asio::ip::tcp::socket& sock,
FILE* out
) {
char* buf = new char[recv_buffer_size];
boost::asio::async_read(
sock,
boost::asio::buffer(buf, recv_buffer_size),
boost::bind(
&readed,
boost::ref(sock),
buf,
out,
boost::asio::placeholders::error
)
);
}
void readed(
boost::asio::ip::tcp::socket& sock,
char* buf,
FILE* out,
const boost::system::error_code& e
) {
if ( e ) {
std::cout << "read handler: " << e.message() << std::endl;
return;
}
// fwrite(buf, recv_buffer_size, 1, out);
static size_t idx = 0;
size_t tmp = 0;
char* p = strchr(buf, ':');
if ( p ) {
sscanf(p+1, "%8d", &tmp);
} else {
throw std::runtime_error("input data error!");
}
delete[] buf;
if ( idx != tmp ) {
std::ostringstream os;
os << "read error. expected " << idx << " get " << tmp;
throw std::runtime_error(os.str());
}
idx++;
start_read(sock, out);
}
/***************************************************************************/
void writen(
boost::asio::ip::tcp::socket&,
char*,
FILE*,
const boost::system::error_code&
);
void start_write(
boost::asio::ip::tcp::socket& sock,
FILE* out
) {
static size_t idx = 0;
char* buf = new char[send_buffer_size];
sprintf(buf, "cs:%8d\n", idx);
idx++;
boost::asio::async_write(
sock,
boost::asio::buffer(buf, send_buffer_size),
boost::bind(
&writen,
boost::ref(sock),
buf,
out,
boost::asio::placeholders::error
)
);
}
void writen(
boost::asio::ip::tcp::socket& sock,
char* buf,
FILE* out,
const boost::system::error_code& e
) {
// fwrite(buf, send_buffer_size, 1, out);
delete[] buf;
if ( e ) {
std::cout << "writen(): " << e.message() << std::endl;
}
start_write(sock, out);
}
/***************************************************************************/
int main(int argc, char** argv) {
if ( argc != 4 ) {
std::cout << "client ip port 0/1 - sleed disabled/enabled" << std::endl;
return 0;
}
if (init_wrappers())
{
return -1;
}
std::string ip = argv[1];
boost::uint16_t port = boost::lexical_cast<boost::uint16_t>(argv[2]);
bool wsleep = (argv[3][0] == '1');
std::cout << "sleep " << (wsleep?"enabled":"disabled") << std::endl;
FILE* in = fopen("client_in.log", "wb");
FILE* out= fopen("client_out.log", "wb");
dbg::in = in;
dbg::out = out;
if ( !out || !in ) {
std::cout << "can`t open file!" << std::endl;
return 1;
}
boost::asio::ip::tcp::endpoint endpoint(
boost::asio::ip::address::from_string(ip), port
);
boost::asio::io_service ios;
boost::asio::ip::tcp::socket socket(ios);
socket.connect(endpoint);
boost::asio::socket_base::non_blocking_io non_blocking_io(true);
socket.io_control(non_blocking_io);
start_write(socket, out);
start_read(socket, in);
ios.run();
fclose(in);
fclose(out);
}
/***************************************************************************/
|
сервер:
| Код |
#include <iostream>
#include <boost/bind.hpp>
#include <boost/asio.hpp>
#include <boost/lexical_cast.hpp>
#include "header.hpp"
/***************************************************************************/
void writen(
boost::asio::ip::tcp::socket& sock,
char* buf,
FILE* out,
const boost::system::error_code& e
);
void start_write(
boost::asio::ip::tcp::socket& sock,
char* buf,
FILE* out
) {
boost::asio::async_write(
sock,
boost::asio::buffer(buf, send_buffer_size),
boost::bind(
&writen,
boost::ref(sock),
buf,
out,
boost::asio::placeholders::error
)
);
}
void writen(
boost::asio::ip::tcp::socket& sock,
char* buf,
FILE* out,
const boost::system::error_code& e
) {
// fwrite(buf, send_buffer_size, 1, out);
delete[] buf;
if ( e ) {
std::cout << "writen(): " << e.message() << std::endl;
}
}
void readed(
boost::asio::ip::tcp::socket&,
char*,
FILE*,
FILE*,
const boost::system::error_code&
);
void start_read(
boost::asio::ip::tcp::socket& sock,
FILE* in,
FILE* out
) {
char* buf = new char[recv_buffer_size];
boost::asio::async_read(
sock,
boost::asio::buffer(buf, recv_buffer_size),
boost::bind(
&readed,
boost::ref(sock),
buf,
in,
out,
boost::asio::placeholders::error
)
);
}
void readed(
boost::asio::ip::tcp::socket& sock,
char* buf,
FILE* in,
FILE* out,
const boost::system::error_code& e
) {
if ( e ) {
std::cout << "read handler: " << e.message() << std::endl;
return;
}
#ifdef _my_debug_
printf("server_readed(): %s", buf);
#endif
// fwrite(buf, recv_buffer_size, 1, in);
static const char* ptr = "sc:";
memcpy(buf, ptr, strlen(ptr));
start_write(sock, buf, out);
start_read(sock, in, out);
}
/***************************************************************************/
int main(int argc, char** argv) {
if ( argc != 3 ) {
std::cout << "server ip port" << std::endl;
return 0;
}
if (init_wrappers())
{
return -1;
}
std::string ip = argv[1];
boost::uint16_t port = boost::lexical_cast<boost::uint16_t>(argv[2]);
FILE* in = fopen("server_in.log", "wb");
FILE* out= fopen("server_out.log", "wb");
dbg::in = in;
dbg::out = out;
if ( !out || !in ) {
std::cout << "can`t open file!" << std::endl;
return 1;
}
boost::asio::ip::tcp::endpoint endpoint(
boost::asio::ip::address::from_string(ip), port
);
boost::asio::io_service ios;
boost::asio::ip::tcp::acceptor acceptor(ios, endpoint);
boost::asio::ip::tcp::socket socket(ios);
acceptor.accept(socket);
std::cout << "new connection from: " << socket.remote_endpoint().address().to_string() << std::endl;
boost::asio::socket_base::non_blocking_io non_blocking_io(true);
socket.io_control(non_blocking_io);
start_read(socket, in, out);
ios.run();
fclose(in);
fclose(out);
}
/***************************************************************************/
|
общий хидер:
| Код |
#ifndef _header_hpp_included_
#define _header_hpp_included_
#include <cstdio>
enum { recv_buffer_size = 13 };
enum { send_buffer_size = 13 };
namespace dbg {
extern FILE *in;
extern FILE *out;
};
extern int init_wrappers();
#endif // _header_hpp_included_
|
на клиент, в один прекрасный, приходит это:
тут две ошибки:
1. склеились две части "sc".
2. клиент ожидает 3574549, а пришло 3574550.
Добавлено @ 17:32
вот что еще странно.
в server_out.log есть такое:
т.е. одно и то же значение повторяется дважды.
хотя, в server_in.log этого нет:
странно.. |
