Lines Matching refs:pipe
17 /* This file implements the 'tcp:' goldfish pipe type which allows
30 /* Implement the OpenGL fast-pipe */
75 netPipe_free( NetPipe* pipe )
80 fd = pipe->io->fd;
81 loopIo_done(pipe->io);
84 /* Release the pipe object */
85 AFREE(pipe);
90 netPipe_resetState( NetPipe* pipe )
92 if ((pipe->wakeWanted & PIPE_WAKE_WRITE) != 0) {
93 loopIo_wantWrite(pipe->io);
95 loopIo_dontWantWrite(pipe->io);
98 if (pipe->state == STATE_CONNECTED && (pipe->wakeWanted & PIPE_WAKE_READ) != 0) {
99 loopIo_wantRead(pipe->io);
101 loopIo_dontWantRead(pipe->io);
112 NetPipe* pipe = opaque;
116 /* If the guest already ordered the pipe to be closed, delete immediately */
117 if (pipe->state == STATE_CLOSING_GUEST) {
118 netPipe_free(pipe);
124 if (pipe->hwpipe != NULL) {
125 goldfish_pipe_close(pipe->hwpipe);
126 pipe->hwpipe = NULL;
129 pipe->state = STATE_CLOSING_SOCKET;
130 netPipe_resetState(pipe);
135 * event on the network pipe.
140 NetPipe* pipe = opaque;
146 if (pipe->state == STATE_CONNECTING) {
147 AsyncStatus status = asyncConnector_run(pipe->connector);
154 netPipe_closeFromSocket(pipe);
157 pipe->state = STATE_CONNECTED;
158 netPipe_resetState(pipe);
164 if ((pipe->wakeWanted & PIPE_WAKE_READ) != 0) {
170 if ((pipe->wakeWanted & PIPE_WAKE_WRITE) != 0) {
177 goldfish_pipe_wake(pipe->hwpipe, wakeFlags);
178 pipe->wakeWanted &= ~wakeFlags;
182 netPipe_resetState(pipe);
189 NetPipe* pipe;
191 ANEW0(pipe);
193 pipe->hwpipe = hwpipe;
194 pipe->state = STATE_INIT;
202 netPipe_free(pipe);
206 loopIo_init(pipe->io, looper, fd, netPipe_io_func, pipe);
207 status = asyncConnector_init(pipe->connector, address, pipe->io);
208 pipe->state = STATE_CONNECTING;
213 netPipe_free(pipe);
217 pipe->state = STATE_CONNECTED;
218 netPipe_resetState(pipe);
222 return pipe;
232 NetPipe* pipe = opaque;
233 netPipe_free(pipe);
236 static int netPipeReadySend(NetPipe *pipe)
238 if (pipe->state == STATE_CONNECTED)
240 else if (pipe->state == STATE_CONNECTING)
242 else if (pipe->hwpipe == NULL)
251 NetPipe* pipe = opaque;
258 ret = netPipeReadySend(pipe);
268 int len = socket_send(pipe->io->fd, buff->data + buffStart, avail);
309 NetPipe* pipe = opaque;
322 int len = socket_recv(pipe->io->fd, buff->data + buffStart, avail);
362 NetPipe* pipe = opaque;
363 unsigned mask = loopIo_poll(pipe->io);
377 NetPipe* pipe = opaque;
381 pipe->wakeWanted |= flags;
382 netPipe_resetState(pipe);
477 * by openglesPipe_init() to refuse a pipe connection if the function
486 NetPipe *pipe;
491 D("Trying to open the OpenGLES pipe without GPU emulation!");
499 pipe = (NetPipe *)netPipe_initUnix(hwpipe, _looper, server_addr);
500 D("Creating Unix OpenGLES pipe for GPU emulation: %s", server_addr);
506 pipe = (NetPipe *)netPipe_initTcp(hwpipe, _looper, server_addr);
507 D("Creating TCP OpenGLES pipe for GPU emulation!");
509 if (pipe != NULL) {
511 socket_set_nodelay(pipe->io->fd);
518 if (setsockopt(pipe->io->fd, SOL_SOCKET, SO_SNDBUF,
527 return pipe;
