ClickHouse/dbms/include/DB/IO/copyData.h

31 lines
937 B
C
Raw Normal View History

2014-04-08 06:51:53 +00:00
#pragma once
#include <atomic>
2016-03-01 17:47:53 +00:00
#include <functional>
namespace DB
{
class ReadBuffer;
class WriteBuffer;
/** Копирует данные из ReadBuffer в WriteBuffer, все что есть.
*/
void copyData(ReadBuffer & from, WriteBuffer & to);
/** Копирует bytes байт из ReadBuffer в WriteBuffer. Если нет bytes байт, то кидает исключение.
2014-04-02 13:45:39 +00:00
*/
void copyData(ReadBuffer & from, WriteBuffer & to, size_t bytes);
/** То же самое, с условием на остановку.
*/
void copyData(ReadBuffer & from, WriteBuffer & to, std::atomic<bool> & is_cancelled);
void copyData(ReadBuffer & from, WriteBuffer & to, size_t bytes, std::atomic<bool> & is_cancelled);
2016-03-01 17:47:53 +00:00
void copyData(ReadBuffer & from, WriteBuffer & to, std::function<void()> cancellation_hook);
void copyData(ReadBuffer & from, WriteBuffer & to, size_t bytes, std::function<void()> cancellation_hook);
}