| /external/clearsilver/util/ |
| neo_net.h | 38 NEOERR *ne_net_accept(NSOCK **sock, int fd, int data_timeout);
39 NEOERR *ne_net_connect(NSOCK **sock, const char *host, int port,
41 NEOERR *ne_net_close(NSOCK **sock);
42 NEOERR *ne_net_read(NSOCK *sock, UINT8 *buf, int buflen);
43 NEOERR *ne_net_read_line(NSOCK *sock, char **buf);
44 NEOERR *ne_net_read_binary(NSOCK *sock, UINT8 **b, int *blen);
45 NEOERR *ne_net_read_str_alloc(NSOCK *sock, char **s, int *len);
46 NEOERR *ne_net_read_int(NSOCK *sock, int *i);
47 NEOERR *ne_net_write(NSOCK *sock, const char *b, int blen);
48 NEOERR *ne_net_write_line(NSOCK *sock, const char *s)
[all...] |
| neo_net.c | 110 NEOERR *ne_net_accept(NSOCK **sock, int sfd, int data_timeout)
143 *sock = my_sock;
149 NEOERR *ne_net_connect(NSOCK **sock, const char *host, int port,
277 *sock = my_sock;
282 NEOERR *ne_net_close(NSOCK **sock)
286 if (sock == NULL || *sock == NULL) return STATUS_OK;
287 err = ne_net_flush(*sock);
288 close((*sock)->fd);
289 free((*sock));
[all...] |
| /external/quake/quake/src/WinQuake/ |
| net_loop.cpp | 127 int Loop_GetMessage (qsocket_t *sock)
132 if (sock->receiveMessageLength == 0)
135 ret = sock->receiveMessage[0];
136 length = sock->receiveMessage[1] + (sock->receiveMessage[2] << 8);
139 SZ_Write (&net_message, &sock->receiveMessage[4], length);
142 sock->receiveMessageLength -= length;
144 if (sock->receiveMessageLength)
145 Q_memcpy(sock->receiveMessage, &sock->receiveMessage[length], sock->receiveMessageLength)
[all...] |
| net_dgrm.h | 28 int Datagram_GetMessage (qsocket_t *sock);
29 int Datagram_SendMessage (qsocket_t *sock, sizebuf_t *data);
30 int Datagram_SendUnreliableMessage (qsocket_t *sock, sizebuf_t *data);
31 qboolean Datagram_CanSendMessage (qsocket_t *sock);
32 qboolean Datagram_CanSendUnreliableMessage (qsocket_t *sock);
33 void Datagram_Close (qsocket_t *sock);
|
| net_loop.h | 27 int Loop_GetMessage (qsocket_t *sock);
28 int Loop_SendMessage (qsocket_t *sock, sizebuf_t *data);
29 int Loop_SendUnreliableMessage (qsocket_t *sock, sizebuf_t *data);
30 qboolean Loop_CanSendMessage (qsocket_t *sock);
31 qboolean Loop_CanSendUnreliableMessage (qsocket_t *sock);
32 void Loop_Close (qsocket_t *sock);
|
| net_ser.h | 27 int Serial_GetMessage (qsocket_t *sock);
28 int Serial_SendMessage (qsocket_t *sock, sizebuf_t *data);
29 int Serial_SendUnreliableMessage (qsocket_t *sock, sizebuf_t *data);
30 qboolean Serial_CanSendMessage (qsocket_t *sock);
31 qboolean Serial_CanSendUnreliableMessage (qsocket_t *sock);
32 void Serial_Close (qsocket_t *sock);
|
| net_vcr.cpp | 77 static long getDriverDataAsLong(qsocket_t *sock) {
79 memcpy(&driverDataAsLong, &sock->driverdata, sizeof(long));
83 int VCR_GetMessage (qsocket_t *sock)
87 if (host_time != next.time || next.op != VCR_OP_GETMESSAGE || next.session != getDriverDataAsLong(sock))
106 int VCR_SendMessage (qsocket_t *sock, sizebuf_t *data)
110 if (host_time != next.time || next.op != VCR_OP_SENDMESSAGE || next.session != getDriverDataAsLong(sock))
121 qboolean VCR_CanSendMessage (qsocket_t *sock)
125 if (host_time != next.time || next.op != VCR_OP_CANSENDMESSAGE || next.session != getDriverDataAsLong(sock))
136 void VCR_Close (qsocket_t *sock)
154 qsocket_t *sock; local
[all...] |
| net_ser.cpp | 75 qsocket_t *sock;
member in struct:SerialLine_s
172 if (p->sequence == p->sock->receiveSequence)
174 p->sock->receiveSequence = (p->sequence + 1) & 0xff;
175 p->sock->receiveMessageLength += p->lengthFound;
178 Con_DPrintf("Serial: reliable out of order; got %u wanted %u\n", p->sequence, p->sock->receiveSequence);
182 p->sock->unreliableReceiveSequence = (p->sequence + 1) & 0xff;
183 p->sock->receiveMessageLength += p->lengthFound;
188 if (p->sequence == p->sock->sendSequence)
190 p->sock->sendSequence = (p->sock->sendSequence + 1) & 0xff;
[all...] |
| net_dgrm.cpp | 44 #define sfunc net_landrivers[sock->landriver]
163 int Datagram_SendMessage (qsocket_t *sock, sizebuf_t *data)
176 if (sock->canSend == false)
180 Q_memcpy(sock->sendMessage, data->data, data->cursize);
181 sock->sendMessageLength = data->cursize;
196 packetBuffer.sequence = BigLong(sock->sendSequence++);
197 Q_memcpy (packetBuffer.data, sock->sendMessage, dataLen);
199 sock->canSend = false;
201 if (sfunc.Write (sock->socket, (byte *)&packetBuffer, packetLen, &sock->addr) == -1
838 qsocket_t *sock; local
1221 qsocket_t *sock; local
[all...] |
| net_main.cpp | 87 #define sfunc net_drivers[sock->driver]
112 qsocket_t *sock; local
121 sock = net_freeSockets;
122 net_freeSockets = sock->next;
125 sock->next = net_activeSockets;
126 net_activeSockets = sock;
128 sock->disconnected = false;
129 sock->connecttime = net_time;
130 Q_strcpy (sock->address,"UNSET ADDRESS");
131 sock->driver = net_driverlevel
898 qsocket_t *sock; local
[all...] |
| net_vcr.h | 33 int VCR_GetMessage (qsocket_t *sock);
34 int VCR_SendMessage (qsocket_t *sock, sizebuf_t *data);
35 qboolean VCR_CanSendMessage (qsocket_t *sock);
36 void VCR_Close (qsocket_t *sock);
|
| /external/kernel-headers/original/linux/ |
| net.h | 113 struct sock *sk;
128 int (*release) (struct socket *sock);
129 int (*bind) (struct socket *sock,
132 int (*connect) (struct socket *sock,
137 int (*accept) (struct socket *sock,
139 int (*getname) (struct socket *sock,
142 unsigned int (*poll) (struct file *file, struct socket *sock,
144 int (*ioctl) (struct socket *sock, unsigned int cmd,
146 int (*compat_ioctl) (struct socket *sock, unsigned int cmd,
148 int (*listen) (struct socket *sock, int len)
[all...] |
| /external/bluetooth/bluez/common/ |
| btio.c | 149 int err = 0, sock = g_io_channel_unix_get_fd(io); local
152 if (getsockopt(sock, SOL_SOCKET, SO_ERROR, &err, &len) < 0)
255 static int l2cap_bind(int sock, const bdaddr_t *src, uint16_t psm)
264 return bind(sock, (struct sockaddr *) &addr, sizeof(addr));
267 static int l2cap_connect(int sock, const bdaddr_t *dst, uint16_t psm)
277 err = connect(sock, (struct sockaddr *) &addr, sizeof(addr));
284 static int l2cap_set_master(int sock, int master)
290 if (getsockopt(sock, SOL_L2CAP, L2CAP_LM, &flags, &len) < 0)
303 if (setsockopt(sock, SOL_L2CAP, L2CAP_LM, &flags, sizeof(flags)) < 0)
309 static int rfcomm_set_master(int sock, int master
1003 int sock; local
1025 int sock; local
1056 int sock; local
1099 int sock; local
1178 int err, sock; local
1233 int sock; local
[all...] |
| /frameworks/base/cmds/keystore/ |
| keystore_get.h | 44 int sock; local
49 sock = socket_local_client("keystore", ANDROID_SOCKET_NAMESPACE_RESERVED,
51 if (sock == -1) {
54 if (send(sock, &code, 1, 0) == 1 && send(sock, bytes, 2, 0) == 2 &&
55 send(sock, key, length, 0) == length && shutdown(sock, SHUT_WR) == 0 &&
56 recv(sock, &code, 1, 0) == 1 && code == /* NO_ERROR */ 1 &&
57 recv(sock, &bytes[0], 1, 0) == 1 && recv(sock, &bytes[1], 1, 0) == 1)
[all...] |
| keystore_cli.c | 49 int sock, i; local
56 sock = socket_local_client("keystore", ANDROID_SOCKET_NAMESPACE_RESERVED,
58 if (sock == -1) {
63 send(sock, argv[1], 1, 0);
68 send(sock, &bytes, 2, 0);
69 send(sock, argv[i], length, 0);
71 shutdown(sock, SHUT_WR);
73 if (recv(sock, &code, 1, 0) != 1) {
78 while ((i = recv(sock, &bytes[0], 1, 0)) == 1) {
81 if ((i = recv(sock, &bytes[1], 1, 0)) != 1)
[all...] |
| /system/core/nexus/ |
| nexctl.c | 35 static int do_monitor(int sock, int stop_after_cmd);
36 static int do_cmd(int sock, int argc, char **argv);
39 int sock; local
44 if ((sock = socket_local_client("nexus",
52 exit(do_monitor(sock, 0));
53 exit(do_cmd(sock, argc, argv));
56 static int do_cmd(int sock, int argc, char **argv) {
72 if (write(sock, final_cmd, strlen(final_cmd) + 1) < 0) {
77 return do_monitor(sock, 1);
80 static int do_monitor(int sock, int stop_after_cmd)
[all...] |
| /system/netd/ |
| ndc.c | 35 static int do_monitor(int sock, int stop_after_cmd);
36 static int do_cmd(int sock, int argc, char **argv);
39 int sock; local
44 if ((sock = socket_local_client("netd",
52 exit(do_monitor(sock, 0));
53 exit(do_cmd(sock, argc, argv));
56 static int do_cmd(int sock, int argc, char **argv) {
72 if (write(sock, final_cmd, strlen(final_cmd) + 1) < 0) {
77 return do_monitor(sock, 1);
80 static int do_monitor(int sock, int stop_after_cmd)
[all...] |
| /system/vold/ |
| vdc.c | 35 static int do_monitor(int sock, int stop_after_cmd);
36 static int do_cmd(int sock, int argc, char **argv);
39 int sock; local
44 if ((sock = socket_local_client("vold",
52 exit(do_monitor(sock, 0));
53 exit(do_cmd(sock, argc, argv));
56 static int do_cmd(int sock, int argc, char **argv) {
72 if (write(sock, final_cmd, strlen(final_cmd) + 1) < 0) {
77 return do_monitor(sock, 1);
80 static int do_monitor(int sock, int stop_after_cmd)
[all...] |
| /device/htc/passion-common/tools/ |
| btconfig.c | 83 int sock = socket(AF_BLUETOOTH, SOCK_RAW, BTPROTO_HCI); local
87 if(sock < 0) {
94 if (setsockopt(sock, SOL_HCI, HCI_DATA_DIR, &opt, sizeof(opt)) < 0) {
103 if(bind(sock, (struct sockaddr *) &addr, sizeof(addr)) < 0) {
109 return sock;
152 int sock = get_hci_sock(); local
154 if (sock < 0)
155 return sock;
157 ret = vendor_sleep(sock);
158 close(sock);
165 int sock = get_hci_sock(); local
186 int sock = get_hci_sock(); local
[all...] |
| /external/wpa_supplicant/ |
| ctrl_iface_unix.c | 50 int sock; member in struct:ctrl_iface_priv
135 static void wpa_supplicant_ctrl_iface_receive(int sock, void *eloop_ctx,
148 res = recvfrom(sock, buf, sizeof(buf) - 1, 0,
180 sendto(sock, reply, reply_len, 0, (struct sockaddr *) &from,
184 sendto(sock, "FAIL\n", 5, 0, (struct sockaddr *) &from,
187 sendto(sock, "OK\n", 3, 0, (struct sockaddr *) &from,
269 priv->sock = -1;
280 priv->sock = android_get_control_socket(addr.sun_path);
281 if (priv->sock >= 0)
337 priv->sock = socket(PF_UNIX, SOCK_DGRAM, 0)
579 int sock; member in struct:ctrl_iface_global_priv
[all...] |
| /external/wpa_supplicant_6/wpa_supplicant/ |
| ctrl_iface_unix.c | 51 int sock; member in struct:ctrl_iface_priv
141 static void wpa_supplicant_ctrl_iface_receive(int sock, void *eloop_ctx,
154 res = recvfrom(sock, buf, sizeof(buf) - 1, 0,
186 sendto(sock, reply, reply_len, 0, (struct sockaddr *) &from,
190 sendto(sock, "FAIL\n", 5, 0, (struct sockaddr *) &from,
193 sendto(sock, "OK\n", 3, 0, (struct sockaddr *) &from,
281 priv->sock = -1;
292 priv->sock = android_get_control_socket(addr.sun_path);
293 if (priv->sock >= 0)
359 priv->sock = socket(PF_UNIX, SOCK_DGRAM, 0)
609 int sock; member in struct:ctrl_iface_global_priv
[all...] |
| /external/qemu/block/ |
| nbd.c | 37 int sock; member in struct:BDRVNBDState
47 int sock; local
63 sock = unix_socket_outgoing(unixpath);
82 sock = tcp_socket_outgoing(hostname, port);
85 if (sock == -1)
88 ret = nbd_receive_negotiate(sock, &size, &blocksize);
92 s->sock = sock;
111 if (nbd_send_request(s->sock, &request) == -1)
114 if (nbd_receive_reply(s->sock, &reply) == -1
[all...] |
| /system/core/include/sysutils/ |
| FrameworkClient.h | 13 FrameworkClient(int sock);
|
| SocketClient.h | 13 SocketClient(int sock);
|
| /external/apache-http/src/org/apache/http/impl/conn/ |
| DefaultClientConnectionOperator.java | 139 Socket sock = plain_sf.createSocket(); local
140 conn.opening(sock, target);
143 Socket connsock = plain_sf.connectSocket(sock,
147 if (sock != connsock) {
148 sock = connsock;
149 conn.opening(sock, target);
162 prepareSocket(sock, context, params);
164 Socket layeredsock = layered_sf.createSocket(sock,
168 if (layeredsock != sock) {
173 conn.openCompleted(sf.isSecure(sock), params)
223 final Socket sock; local
[all...] |
