caafd4df2e
This change includes four changes: 1) moved IOStream.h into host/include/libOpenGLRender, this directory will include the api interface into the libOpenGLRender which will be used later by the emulator and we need this interface to use IOStream.h 2) Updated Andorid.mk files to include the new directory location of IOStream.h in the LOCAL_C_INCLUDE. 3) Added new function "read" to IOStream which reads a message without a givven size. 4) Updated TcpStream to use "cutils/sockets.h" instead of using directly the socket api for portability reasons. (It now compiles on windows as well). Change-Id: I30eb40c8dcd5aacf0d993aff9cdb90b283b12dde
52 lines
1.5 KiB
C++
52 lines
1.5 KiB
C++
/*
|
|
* Copyright (C) 2011 The Android Open Source Project
|
|
*
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
#ifndef __TCP_STREAM_H
|
|
#define __TCP_STREAM_H
|
|
|
|
#include <stdlib.h>
|
|
#include "IOStream.h"
|
|
|
|
|
|
class TcpStream : public IOStream {
|
|
public:
|
|
typedef enum { ERR_INVALID_SOCKET = -1000 } TcpStreamError;
|
|
|
|
explicit TcpStream(size_t bufsize = 10000);
|
|
~TcpStream();
|
|
int listen(unsigned short port, bool localhost_only = true);
|
|
TcpStream *accept();
|
|
int connect(const char *hostname, unsigned short port);
|
|
|
|
virtual void *allocBuffer(size_t minSize);
|
|
virtual int commitBuffer(size_t size);
|
|
virtual const unsigned char *readFully( void *buf, size_t len);
|
|
virtual const unsigned char *read( void *buf, size_t *inout_len);
|
|
|
|
bool valid() { return m_sock >= 0; }
|
|
int recv(void *buf, size_t len);
|
|
|
|
private:
|
|
int writeFully(const void *buf, size_t len);
|
|
|
|
private:
|
|
int m_sock;
|
|
size_t m_bufsize;
|
|
unsigned char *m_buf;
|
|
TcpStream(int sock, size_t bufSize);
|
|
};
|
|
|
|
#endif
|