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
17 /* This program uses a QEMUD pipe to exchange data with a test
18 * server. It's very simple:
19 *
20 * for count in range(0,100):
21 * msg = "Hello Word " + count
22 * qemud_pipe_send(msg)
23 * qemud_pipe_recv(msg2)
24 * if (msg != msg2):
25 * error()
26 *
27 *
28 * See test_host_1.c for the corresponding server code, which simply
29 * sends back anything it receives from the client.
30 */
31 #include "test_util.h"
32 #include <errno.h>
33 #include <string.h>
34 #include <stddef.h>
35 #include <stdio.h>
36
37 #define PIPE_NAME "pingpong"
38
39
main(void)40 int main(void)
41 {
42 Pipe pipe[1];
43 const int maxCount = 100;
44 int port = 8012;
45
46 #if 0
47 if (pipe_openSocket(pipe, port) < 0) {
48 fprintf(stderr, "Could not open tcp socket!\n");
49 return 1;
50 }
51 printf("Connected to tcp:host:%d\n", port);
52 #else
53 if (pipe_openQemuPipe(pipe, PIPE_NAME) < 0) {
54 fprintf(stderr, "Could not open '%s' pipe: %s\n", PIPE_NAME, strerror(errno));
55 return 1;
56 }
57 printf("Connected to '%s' pipe\n", PIPE_NAME);
58 #endif
59
60 char buff[64];
61 char buff2[64];
62 int count;
63 double time0 = now_secs();
64 size_t total = 0;
65
66 for (count = 0; count < maxCount; count++) {
67 /* First, send a small message */
68 int len = snprintf(buff, sizeof(buff), "Hello World %d\n", count);
69 printf("%4d: Sending %d bytes\n", count, len);
70 int ret = pipe_send(pipe, buff, len);
71 if (ret < 0) {
72 fprintf(stderr,"Sending %d bytes failed: %s\n", len, strerror(errno));
73 return 1;
74 }
75
76 total += len;
77
78 /* The server is supposed to send the message back */
79 ret = pipe_recv(pipe, buff2, len);
80 if (ret < 0) {
81 fprintf(stderr, "Receiving failed (ret=%d): %s\n", ret, strerror(errno));
82 return 3;
83 }
84 printf("%4d: Received %d bytes\n", count, ret);
85 /* Check the message's content */
86 if (ret != len) {
87 fprintf(stderr, "Message size mismatch sent=%d received=%d\n", len, ret);
88 return 5;
89 }
90 if (memcmp(buff, buff2, len) != 0) {
91 fprintf(stderr, "Message content mismatch!\n");
92 return 6;
93 }
94 }
95
96 double time1 = now_secs();
97
98 printf("Closing pipe\n");
99 pipe_close(pipe);
100
101 printf("Bandwidth: %g MB/s, %g bytes in %g seconds.\n",
102 total*1.0 / (1024.*1024.*(time1-time0)), 1.0*total, time1-time0);
103
104 return 0;
105 }
106