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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
/*
* Copyright 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 __GLTRACE_TRANSPORT_H_
#define __GLTRACE_TRANSPORT_H_
#include <pthread.h>
#include "frameworks/native/opengl/libs/GLES_trace/proto/gltrace.pb.h"
namespace android {
namespace gltrace {
/**
* TCPStream provides a TCP based communication channel from the device to
* the host for transferring GLMessages.
*/
class TCPStream {
int mSocket;
pthread_mutex_t mSocketWriteMutex;
public:
/** Create a TCP based communication channel over @socket */
TCPStream(int socket);
~TCPStream();
/** Close the channel. */
void closeStream();
/** Send @data of size @len to host. . Returns -1 on error, 0 on success. */
int send(void *data, size_t len);
/**
* Receive @len bytes of data into @buf from the remote end. This is a blocking call.
* Returns -1 on failure, 0 on success.
*/
int receive(void *buf, size_t len);
};
/**
* BufferedOutputStream provides buffering of data sent to the underlying
* unbuffered channel.
*/
class BufferedOutputStream {
TCPStream *mStream;
size_t mBufferSize;
std::string mStringBuffer;
/** Enqueue message into internal buffer. */
void enqueueMessage(GLMessage *msg);
public:
/**
* Construct a Buffered stream of size @bufferSize, using @stream as
* its underlying channel for transport.
*/
BufferedOutputStream(TCPStream *stream, size_t bufferSize);
/**
* Send @msg. The message could be buffered and sent later with a
* subsequent message. Returns -1 on error, 0 on success.
*/
int send(GLMessage *msg);
/** Send any buffered messages, returns -1 on error, 0 on success. */
int flush();
};
/**
* Utility method: start a server listening at @sockName (unix domain socket,
* abstract namespace path), and wait for a client connection.
* Returns the connected client socket on success, or -1 on failure.
*/
int acceptClientConnection(char *sockName);
};
};
#endif
|
