blob: bf9a58aad7c0a25e5fa5274276098694ecf78422 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
/*
* This file is part of the LibreOffice project.
*
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/
#ifndef _SD_IMPRESSREMOTE_BUFFEREDSTREAMSOCKET_HXX
#define _SD_IMPRESSREMOTE_BUFFEREDSTREAMSOCKET_HXX
#include <boost/noncopyable.hpp>
#include <osl/socket.hxx>
#include <vector>
#define CHARSET RTL_TEXTENCODING_UTF8
#define MAX_LINE_LENGTH 20000
namespace sd
{
/**
* [A wrapper for an osl StreamSocket to allow reading lines.]
*
* Currently wraps either an osl StreamSocket or a standard c socket,
* allowing reading and writing for our purposes. Should eventually be
* returned to being a StreamSocket wrapper if/when Bluetooth is
* integrated into osl Sockets.
*/
class BufferedStreamSocket :
private ::osl::StreamSocket,
private ::boost::noncopyable
{
public:
/**
* Create a BufferedStreamSocket on top of an
* osl::StreamSocket.
*/
BufferedStreamSocket( const osl::StreamSocket &aSocket );
/**
* Create a BufferedStreamSocket on top of a standard c socket.
*/
BufferedStreamSocket( int aSocket );
BufferedStreamSocket( const BufferedStreamSocket &aSocket );
/**
* Blocks until a line is read.
* Returns whatever the last call of recv returned, i.e. 0 or less
* if there was a problem in communications.
*/
sal_Int32 readLine(OString& aLine);
sal_Int32 write( const void* pBuffer, sal_uInt32 n );
void getPeerAddr(osl::SocketAddr&);
private:
sal_Int32 aRet, aRead;
std::vector<char> aBuffer;
int mSocket;
bool usingCSocket;
};
}
#endif // _SD_IMPRESSREMOTE_BUFFEREDSTREAMSOCKET_HXX
/* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|
