dev

分支 (7)

标签 (101)

管理

管理

dev

2.5.x

2.4.x

2.3.x

2.2.x

2.1.x

next

2.5.20

2.4.11client

2.4.8client

2.4.9

2.3.7

2.3.6

2.2.4client

2.2.7

2.2.6

2.1.20

2.2.3client

2.2.5

2.2.4

2.2.1client

2.2.2

2.1.15client

2.1.14client

2.1.18

2.1.13client

2.1.17

urbackup_backend
/
OpenSSLPipe.h

#pragma once

#ifdef WITH_OPENSSL
#include <openssl/opensslv.h>
#if OPENSSL_VERSION_NUMBER < 0x10002000L
#warning "OpenSSL version too old (<1.0.2). Not supported. Compiling without OpenSSL"
#undef WITH_OPENSSL
#endif
#endif //WITH_OPENSSL

#ifdef WITH_OPENSSL

#include "Interface/Pipe.h"
#include "StreamPipe.h"
#include <memory>
#include <openssl/bio.h>

class OpenSSLPipe : public IPipe
{
public:
	OpenSSLPipe(CStreamPipe* bpipe);

	~OpenSSLPipe();

	static void init();

	bool ssl_connect(const std::string& p_hostname, int timeoutms);

	// Inherited via IPipe
	virtual size_t Read(char * buffer, size_t bsize, int timeoutms = -1);

	virtual bool Write(const char * buffer, size_t bsize, int timeoutms = -1, bool flush = true);

	virtual size_t Read(std::string * ret, int timeoutms = -1);

	virtual bool Write(const std::string & str, int timeoutms = -1, bool flush = true);

	virtual bool Flush(int timeoutms = -1);

	virtual bool isWritable(int timeoutms = 0);

	virtual bool isReadable(int timeoutms = 0);

	virtual bool hasError(void);

	virtual void shutdown(void);

	virtual size_t getNumWaiters();

	virtual size_t getNumElements(void);

	virtual void addThrottler(IPipeThrottler * throttler);

	virtual void addOutgoingThrottler(IPipeThrottler * throttler);

	virtual void addIncomingThrottler(IPipeThrottler * throttler);

	virtual _i64 getTransferedBytes(void);

	virtual void resetTransferedBytes(void);

private:

	std::unique_ptr<CStreamPipe> bpipe;

	BIO* bbio;
	SSL_CTX* ctx;

	bool has_error;
};

#endif //WITH_OPENSSL