1 /*
2 * Copyright (C) 2011 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16 #include "HostConnection.h"
17 #include "TcpStream.h"
18 #include "QemuPipeStream.h"
19 #include "ThreadInfo.h"
20 #include <cutils/log.h>
21 #include "GLEncoder.h"
22 #include "GL2Encoder.h"
23 #include <memory>
24
25 #define STREAM_BUFFER_SIZE 4*1024*1024
26 #define STREAM_PORT_NUM 22468
27
28 /* Set to 1 to use a QEMU pipe, or 0 for a TCP connection */
29 #define USE_QEMU_PIPE 1
30
HostConnection()31 HostConnection::HostConnection() :
32 m_stream(NULL),
33 m_glEnc(NULL),
34 m_gl2Enc(NULL),
35 m_rcEnc(NULL),
36 m_checksumHelper()
37 {
38 }
39
~HostConnection()40 HostConnection::~HostConnection()
41 {
42 delete m_stream;
43 delete m_glEnc;
44 delete m_gl2Enc;
45 delete m_rcEnc;
46 }
47
get()48 HostConnection *HostConnection::get()
49 {
50 /* TODO: Make this configurable with a system property */
51 const int useQemuPipe = USE_QEMU_PIPE;
52
53 // Get thread info
54 EGLThreadInfo *tinfo = getEGLThreadInfo();
55 if (!tinfo) {
56 return NULL;
57 }
58
59 if (tinfo->hostConn == NULL) {
60 HostConnection *con = new HostConnection();
61 if (NULL == con) {
62 return NULL;
63 }
64
65 if (useQemuPipe) {
66 QemuPipeStream *stream = new QemuPipeStream(STREAM_BUFFER_SIZE);
67 if (!stream) {
68 ALOGE("Failed to create QemuPipeStream for host connection!!!\n");
69 delete con;
70 return NULL;
71 }
72 if (stream->connect() < 0) {
73 ALOGE("Failed to connect to host (QemuPipeStream)!!!\n");
74 delete stream;
75 delete con;
76 return NULL;
77 }
78 con->m_stream = stream;
79 }
80 else /* !useQemuPipe */
81 {
82 TcpStream *stream = new TcpStream(STREAM_BUFFER_SIZE);
83 if (!stream) {
84 ALOGE("Failed to create TcpStream for host connection!!!\n");
85 delete con;
86 return NULL;
87 }
88
89 if (stream->connect("10.0.2.2", STREAM_PORT_NUM) < 0) {
90 ALOGE("Failed to connect to host (TcpStream)!!!\n");
91 delete stream;
92 delete con;
93 return NULL;
94 }
95 con->m_stream = stream;
96 }
97
98 // send zero 'clientFlags' to the host.
99 unsigned int *pClientFlags =
100 (unsigned int *)con->m_stream->allocBuffer(sizeof(unsigned int));
101 *pClientFlags = 0;
102 con->m_stream->commitBuffer(sizeof(unsigned int));
103
104 ALOGD("HostConnection::get() New Host Connection established %p, tid %d\n", con, gettid());
105 tinfo->hostConn = con;
106 }
107
108 return tinfo->hostConn;
109 }
110
glEncoder()111 GLEncoder *HostConnection::glEncoder()
112 {
113 if (!m_glEnc) {
114 m_glEnc = new GLEncoder(m_stream, checksumHelper());
115 DBG("HostConnection::glEncoder new encoder %p, tid %d", m_glEnc, gettid());
116 m_glEnc->setContextAccessor(s_getGLContext);
117 }
118 return m_glEnc;
119 }
120
gl2Encoder()121 GL2Encoder *HostConnection::gl2Encoder()
122 {
123 if (!m_gl2Enc) {
124 m_gl2Enc = new GL2Encoder(m_stream, checksumHelper());
125 DBG("HostConnection::gl2Encoder new encoder %p, tid %d", m_gl2Enc, gettid());
126 m_gl2Enc->setContextAccessor(s_getGL2Context);
127 }
128 return m_gl2Enc;
129 }
130
rcEncoder()131 renderControl_encoder_context_t *HostConnection::rcEncoder()
132 {
133 if (!m_rcEnc) {
134 m_rcEnc = new renderControl_encoder_context_t(m_stream, checksumHelper());
135 // TODO: disable checksum as a workaround in a glTexSubImage2D problem
136 // Uncomment the following line when the root cause is solved
137 //setChecksumHelper(m_rcEnc);
138 }
139 return m_rcEnc;
140 }
141
s_getGLContext()142 gl_client_context_t *HostConnection::s_getGLContext()
143 {
144 EGLThreadInfo *ti = getEGLThreadInfo();
145 if (ti->hostConn) {
146 return ti->hostConn->m_glEnc;
147 }
148 return NULL;
149 }
150
s_getGL2Context()151 gl2_client_context_t *HostConnection::s_getGL2Context()
152 {
153 EGLThreadInfo *ti = getEGLThreadInfo();
154 if (ti->hostConn) {
155 return ti->hostConn->m_gl2Enc;
156 }
157 return NULL;
158 }
159
setChecksumHelper(renderControl_encoder_context_t * rcEnc)160 void HostConnection::setChecksumHelper(renderControl_encoder_context_t *rcEnc) {
161 std::unique_ptr<char[]> glExtensions;
162 int extensionSize = rcEnc->rcGetGLString(rcEnc, GL_EXTENSIONS, NULL, 0);
163 if (extensionSize < 0) {
164 glExtensions = std::unique_ptr<char[]>(new char[-extensionSize]);
165 extensionSize = rcEnc->rcGetGLString(rcEnc, GL_EXTENSIONS, glExtensions.get(), -extensionSize);
166 if (extensionSize <= 0) {
167 glExtensions.reset();
168 }
169 }
170 // check the host supported version
171 uint32_t checksumVersion = 0;
172 const char* checksumPrefix = ChecksumCalculator::getMaxVersionStrPrefix();
173 const char* glProtocolStr = glExtensions.get() ?
174 strstr(glExtensions.get(), checksumPrefix) : NULL;
175 if (glProtocolStr) {
176 uint32_t maxVersion = ChecksumCalculator::getMaxVersion();
177 sscanf(glProtocolStr+strlen(checksumPrefix), "%d", &checksumVersion);
178 if (maxVersion < checksumVersion) {
179 checksumVersion = maxVersion;
180 }
181 // The ordering of the following two commands matters!
182 // Must tell the host first before setting it in the guest
183 rcEnc->rcSelectChecksumHelper(rcEnc, checksumVersion, 0);
184 m_checksumHelper.setVersion(checksumVersion);
185 }
186 }
187