Searched defs:conn (Results 1 - 25 of 32) sorted by relevance

12

/vbox/src/VBox/HostServices/SharedOpenGL/expando/
H A Dexpandospu_config.c28 CRConnection *conn; local
34 conn = crMothershipConnect( );
35 if (!conn)
42 crMothershipIdentifySPU( conn, expando_spu.id );
44 crSPUGetMothershipParams( conn, &expando_spu, expandoSPUOptions );
46 crMothershipDisconnect( conn );
/vbox/src/VBox/GuestHost/OpenGL/include/
H A Dcr_netserver.h21 CRConnection *conn; member in struct:__anon16106
H A Dcr_net.h72 typedef int (*CRNetReceiveFunc)( CRConnection *conn, CRMessage *msg, unsigned int len );
73 typedef int (*CRNetConnectFunc)( CRConnection *conn );
89 CRConnection *conn; /* some messages are assoc. with specific connections*/ member in struct:__messageListNode
150 /* To allocate a data buffer of size conn->buffer_size bytes */
151 void *(*Alloc)( CRConnection *conn );
153 void (*Free)( CRConnection *conn, void *buf );
157 void (*Send)( CRConnection *conn, void **buf, const void *start, unsigned int len );
159 void (*Barf)( CRConnection *conn, void **buf, const void *start, unsigned int len );
161 void (*SendExact)( CRConnection *conn, const void *start, unsigned int len );
163 void (*Recv)( CRConnection *conn, voi
270 extern DECLEXPORT(void) *crNetAlloc( CRConnection *conn ); variable
274 extern DECLEXPORT(int) crNetConnect( CRConnection *conn ); variable
275 extern DECLEXPORT(void) crNetDisconnect( CRConnection *conn ); variable
276 extern DECLEXPORT(void) crNetFreeConnection( CRConnection *conn ); variable
285 extern DECLEXPORT(int) crNetNumMessages(CRConnection *conn); variable
289 CRConnection *conn variable
[all...]
/vbox/src/VBox/GuestHost/OpenGL/util/
H A Ddevnull.c13 crDevnullWriteExact( CRConnection *conn, const void *buf, unsigned int len ) argument
15 (void) conn;
21 crDevnullAlloc( CRConnection *conn )
23 return crAlloc( conn->buffer_size );
27 crDevnullSingleRecv( CRConnection *conn, void *buf, unsigned int len ) argument
30 (void) conn;
36 crDevnullFree( CRConnection *conn, void *buf ) argument
39 (void) conn;
43 crDevnullSend( CRConnection *conn, void **bufp, argument
55 crDevnullFree( conn, *buf
79 crDevnullAccept( CRConnection *conn, const char *hostname, unsigned short port ) argument
[all...]
H A Dfilenet.c59 crFileReadExact( CRConnection *conn, void *buf, unsigned int len ) argument
65 int num_read = read( conn->fd, buf, len );
82 crFileWriteExact( CRConnection *conn, const void *buf, unsigned int len ) argument
84 int retval = write( conn->fd, buf, len );
87 crError( "crFileWriteExact: %s (tried to write %d bytes, actually wrote %d)", conn->filename, len, retval );
92 crFileAccept( CRConnection *conn, const char *hostname, unsigned short port ) argument
94 conn->file_direction = CR_FILE_READ;
95 conn->fd = open( conn->filename, O_RDONLY | O_BINARY );
96 if (conn
134 crFileSingleRecv( CRConnection *conn, void *buf, unsigned int len ) argument
140 crFileSend( CRConnection *conn, void **bufp, const void *start, unsigned int len ) argument
185 crFileFree( CRConnection *conn, void *buf ) argument
227 CRConnection *conn = cr_file.conns[i]; local
269 crFileHandleNewMessage( CRConnection *conn, CRMessage *msg, unsigned int len ) argument
284 crFileInstantReclaim( CRConnection *conn, CRMessage *mess ) argument
[all...]
H A Dudptcpip.c83 crUDPIPWriteExact( CRConnection *conn, const void *buf, unsigned int len ) argument
86 if ( len > conn->mtu + sizeof(conn->seq) )
88 crWarning( "crUDPIPWriteExact(%d): too big a packet for mtu %d, dropping !", len, (int)(conn->mtu + sizeof(conn->seq)) );
91 retval = sendto( conn->udp_socket, buf, len, 0,
92 (struct sockaddr *) &(conn->remoteaddr), sizeof(conn->remoteaddr));
103 if ( getsockopt( conn->udp_socket, SOL_IP, IP_MTU_DISCOVER, &opt, &leno) == -1)
119 if ( getsockopt( conn
146 crUDPTCPIPAccept( CRConnection *conn, const char *hostname, unsigned short port ) argument
240 crUDPTCPIPSend( CRConnection *conn, void **bufp, const void *start, unsigned int len ) argument
313 crUDPTCPIPBarf( CRConnection *conn, void **bufp, const void *start, unsigned int len) argument
387 crUDPTCPIPReceive( CRConnection *conn, CRTCPIPBuffer *buf, int len ) argument
436 CRConnection *conn = cr_tcpip.conns[i]; local
489 CRConnection *conn = cr_tcpip.conns[i]; local
[all...]
H A Dnet.c75 InitConnection(CRConnection *conn, const char *protocol, unsigned int mtu argument
84 crDevnullConnection(conn);
90 crFileConnection(conn);
97 crFileConnection(conn);
98 conn->swap = 1;
104 crTCPIPConnection(conn);
110 crUDPTCPIPConnection(conn);
117 crVBoxHGCMConnection(conn
129 crGmConnection(conn);
137 crTeacConnection(conn);
202 CRConnection *conn; local
349 CRConnection *conn; local
415 crNetFreeConnection(CRConnection *conn) argument
608 crNetFree( CRConnection *conn, void *buf ) argument
634 crEnqueueMessage(CRMessageList *list, CRMessage *msg, unsigned int len, CRConnection *conn) argument
671 crDequeueMessageNoBlock(CRMessageList *list, CRMessage **msg, unsigned int *len, CRConnection **conn) argument
722 crDequeueMessage(CRMessageList *list, CRMessage **msg, unsigned int *len, CRConnection **conn) argument
779 crNetSend(CRConnection *conn, void **bufp, const void *start, unsigned int len) argument
814 crNetBarf( CRConnection *conn, void **bufp, const void *start, unsigned int len ) argument
850 crNetSendExact( CRConnection *conn, const void *buf, unsigned int len ) argument
904 crNetAccept( CRConnection *conn, const char *hostname, unsigned short port ) argument
916 crNetSingleRecv( CRConnection *conn, void *buf, unsigned int len ) argument
933 crNetRecvMulti( CRConnection *conn, CRMessageMulti *msg, unsigned int len ) argument
985 crNetRecvFlowControl( CRConnection *conn, CRMessageFlowControl *msg, unsigned int len ) argument
1078 crNetDefaultRecv( CRConnection *conn, CRMessage *msg, unsigned int len ) argument
1157 crNetDispatchMessage( CRNetReceiveFuncList *rfl, CRConnection *conn, CRMessage *msg, unsigned int len ) argument
1183 crNetNumMessages(CRConnection *conn) argument
1201 crNetPeekMessage( CRConnection *conn, CRMessage **message ) argument
1221 crNetGetMessage( CRConnection *conn, CRMessage **message ) argument
1251 crNetReadline( CRConnection *conn, void *buf ) argument
[all...]
H A Dtcpip.c260 crTCPIPReadExact( CRConnection *conn, void *buf, unsigned int len ) argument
262 if ( __tcpip_read_exact( conn->tcp_socket, buf, len ) <= 0 )
264 __tcpip_dead_connection( conn );
307 crTCPIPWriteExact( CRConnection *conn, const void *buf, unsigned int len ) argument
309 if ( __tcpip_write_exact( conn->tcp_socket, buf, len) <= 0 )
311 __tcpip_dead_connection( conn );
505 crTCPIPAccept( CRConnection *conn, const char *hostname, unsigned short port ) argument
524 if (conn->broker) {
529 conn->tcp_socket = accept( cr_tcpip.server_sock, (struct sockaddr *) &addr, &addr_length );
530 if (conn
624 crTCPIPSingleRecv( CRConnection *conn, void *buf, unsigned int len ) argument
631 crTCPIPSend( CRConnection *conn, void **bufp, const void *start, unsigned int len ) argument
736 crTCPIPFree( CRConnection *conn, void *buf ) argument
775 crTCPIPUserbufRecv(CRConnection *conn, CRMessage *msg) argument
815 crTCPIPReceiveMessage(CRConnection *conn) argument
972 CRConnection *conn = cr_tcpip.conns[i]; local
1102 CRConnection *conn = cr_tcpip.conns[i]; local
1131 crTCPIPHandleNewMessage( CRConnection *conn, CRMessage *msg, unsigned int len ) argument
1146 crTCPIPInstantReclaim( CRConnection *conn, CRMessage *mess ) argument
[all...]
H A Dvboxhgsmi.c225 static void _crVBoxHGSMIReceiveMessage(CRConnection *conn, PCRVBOXHGSMI_CLIENT pClient);
542 static void *crVBoxHGSMIAlloc(CRConnection *conn) argument
550 pvBuf = _crVBoxHGSMIDoAlloc(pClient, conn->buffer_size);
583 static void _crVBoxHGSMIWriteExact(CRConnection *conn, PCRVBOXHGSMI_CLIENT pClient, PVBOXUHGSMI_BUFFER pBuf, uint32_t offStart, unsigned int len) argument
590 if (conn->u32InjectClientID)
600 parms->hdr.u32ClientID = conn->u32ClientID;
604 parms->u32ClientID = conn->u32InjectClientID;
636 parms->hdr.u32ClientID = conn->u32ClientID;
671 static void crVBoxHGSMIWriteExact(CRConnection *conn, const void *buf, unsigned int len) argument
682 // _crVBoxHGSMIWriteExact(conn, pClien
687 _crVBoxHGSMIPollHost(CRConnection *conn, PCRVBOXHGSMI_CLIENT pClient) argument
758 _crVBoxHGSMIReadExact(CRConnection *conn, PCRVBOXHGSMI_CLIENT pClient) argument
771 _crVBoxHGSMIWriteReadExact(CRConnection *conn, PCRVBOXHGSMI_CLIENT pClient, void *buf, uint32_t offBuffer, unsigned int len, bool bIsBuffer) argument
916 crVBoxHGSMISend(CRConnection *conn, void **bufp, const void *start, unsigned int len) argument
980 crVBoxHGSMISingleRecv(CRConnection *conn, void *buf, unsigned int len) argument
999 _crVBoxHGSMIFree(CRConnection *conn, void *buf) argument
1026 crVBoxHGSMIFree(CRConnection *conn, void *buf) argument
1033 _crVBoxHGSMIReceiveMessage(CRConnection *conn, PCRVBOXHGSMI_CLIENT pClient) argument
1114 crVBoxHGSMIReceiveMessage(CRConnection *conn) argument
1130 crVBoxHGSMIAccept( CRConnection *conn, const char *hostname, unsigned short port ) argument
1142 crVBoxHGSMISetVersion(CRConnection *conn, unsigned int vMajor, unsigned int vMinor) argument
1174 crVBoxHGSMISetPID(CRConnection *conn, unsigned long long pid) argument
1412 crVBoxHGSMIInstantReclaim(CRConnection *conn, CRMessage *mess) argument
1423 crVBoxHGSMIHandleNewMessage( CRConnection *conn, CRMessage *msg, unsigned int len ) argument
1574 crVBoxHGSMIConnection(CRConnection *conn) argument
1636 CRConnection *conn = g_crvboxhgsmi.conns[i]; local
1651 CRConnection *conn = g_crvboxhgsmi.conns[i]; local
[all...]
/vbox/src/VBox/Additions/common/crOpenGL/pack/
H A Dpackspu_net.c54 packspuReceiveData( CRConnection *conn, CRMessage *msg, unsigned int len ) argument
161 CRASSERT( thread->netServer.conn );
166 crNetBarf( thread->netServer.conn, &(buf->pack), hdr, len );
171 crNetSend( thread->netServer.conn, &(buf->pack), hdr, len );
174 buf->pack = crNetAlloc( thread->netServer.conn );
177 buf->mtu = thread->netServer.conn->mtu;
233 CRASSERT( thread->netServer.conn );
234 crNetSend( thread->netServer.conn, NULL, src, len );
249 if (server->conn)
268 if (!server->conn) {
[all...]
/vbox/src/VBox/Devices/Network/lwip/src/api/
H A Dapi_msg.c46 struct netconn *conn; local
48 conn = arg;
49 if (!conn) return 0;
51 if (conn->recvmbox != SYS_MBOX_NULL) {
61 conn->recv_avail += p->tot_len;
63 if (conn->callback)
64 (*conn->callback)(conn, NETCONN_EVT_RCVPLUS, p->tot_len);
65 sys_mbox_post(conn->recvmbox, buf);
77 struct netconn *conn; local
110 struct netconn *conn; local
141 struct netconn *conn; local
155 struct netconn *conn; local
172 struct netconn *conn; local
201 setup_tcp(struct netconn *conn) argument
218 struct netconn *conn; local
456 struct netconn *conn; local
[all...]
H A Dapi_lib.c200 struct netconn *conn; local
203 conn = memp_malloc(MEMP_NETCONN);
204 if (conn == NULL) {
208 conn->err = ERR_OK;
209 conn->type = t;
210 conn->pcb.tcp = NULL;
212 if ((conn->mbox = sys_mbox_new()) == SYS_MBOX_NULL) {
213 memp_free(MEMP_NETCONN, conn);
216 conn->recvmbox = SYS_MBOX_NULL;
217 conn
264 netconn_delete(struct netconn *conn) argument
319 netconn_type(struct netconn *conn) argument
325 netconn_peer(struct netconn *conn, struct ip_addr *addr, u16_t *port) argument
352 netconn_addr(struct netconn *conn, struct ip_addr **addr, u16_t *port) argument
375 netconn_bind(struct netconn *conn, struct ip_addr *addr, u16_t port) argument
406 netconn_connect(struct netconn *conn, struct ip_addr *addr, u16_t port) argument
436 netconn_disconnect(struct netconn *conn) argument
457 netconn_listen(struct netconn *conn) argument
484 netconn_accept(struct netconn *conn) argument
501 netconn_recv(struct netconn *conn) argument
597 netconn_send(struct netconn *conn, struct netbuf *buf) argument
625 netconn_write(struct netconn *conn, void *dataptr, u16_t size, u8_t copy) argument
690 netconn_close(struct netconn *conn) argument
718 netconn_err(struct netconn *conn) argument
[all...]
H A Dsockets.c50 struct netconn *conn; member in struct:lwip_socket
76 event_callback(struct netconn *conn, enum netconn_evt evt, u16_t len);
127 if (!sock->conn) {
149 if (!sockets[i].conn) {
150 sockets[i].conn = newconn;
182 newconn = netconn_accept(sock->conn);
241 err = netconn_bind(sock->conn, &local_addr, ntohs(local_port));
273 netconn_delete(sock->conn);
279 sock->conn = NULL;
299 err = netconn_disconnect(sock->conn);
567 struct netconn *conn; local
810 event_callback(struct netconn *conn, enum netconn_evt evt, u16_t len) argument
[all...]
/vbox/src/VBox/Devices/Network/lwip/src/include/lwip/
H A Dapi_msg.h67 struct netconn *conn; member in struct:api_msg_msg
/vbox/src/VBox/Devices/Network/lwip-new/src/include/lwip/
H A Dapi_msg.h65 struct netconn *conn; member in struct:api_msg_msg
169 void netconn_free(struct netconn *conn);
/vbox/src/VBox/Devices/PC/ipxe/src/net/infiniband/
H A Dib_cm.c46 * @ret conn Connection, or NULL
49 struct ib_connection *conn; local
51 list_for_each_entry ( conn, &ib_cm_conns, list ) {
52 if ( conn->local_id == local_id )
53 return conn;
110 struct ib_connection *conn; local
115 conn = ib_cm_find ( local_id );
116 if ( conn ) {
118 if ( ( rc = ib_cm_send_rtu ( ibdev, mi, av, conn->local_id,
119 conn
176 struct ib_connection *conn; local
249 struct ib_connection *conn = ib_madx_get_ownerdata ( madx ); local
341 struct ib_connection *conn = ib_path_get_ownerdata ( path ); local
438 struct ib_connection *conn; local
[all...]
H A Dib_cmrc.c81 struct ib_connection *conn; member in struct:ib_cmrc_connection
115 ib_destroy_conn ( cmrc->ibdev, cmrc->qp, cmrc->conn );
144 * @v conn Connection
151 struct ib_connection *conn __unused, int rc_cm,
279 if ( cmrc->conn ) {
287 cmrc->conn = ib_create_conn ( cmrc->ibdev, cmrc->qp,
291 if ( ! cmrc->conn ) {
/vbox/src/VBox/Additions/x11/VBoxClient/
H A Dhostversion.cpp44 DBusConnection *conn; local
46 conn = dbus_bus_get (DBUS_BUS_SESSON, NULL);
47 if (conn == NULL)
102 reply = dbus_connection_send_with_reply_and_block(conn, msg,
110 dbus_connection_flush(conn);
/vbox/src/VBox/Devices/Network/lwip-new/src/api/
H A Dapi_lib.c70 struct netconn *conn; local
73 conn = netconn_alloc(t, callback);
74 if (conn != NULL) {
77 msg.msg.conn = conn;
80 LWIP_ASSERT("freeing conn without freeing pcb", conn->pcb.tcp == NULL);
81 LWIP_ASSERT("conn has no op_completed", sys_sem_valid(&conn->op_completed));
82 LWIP_ASSERT("conn ha
104 netconn_delete(struct netconn *conn) argument
136 netconn_getaddr(struct netconn *conn, ip_addr_t *addr, u16_t *port, u8_t local) argument
166 netconn_bind(struct netconn *conn, ip_addr_t *addr, u16_t port) argument
191 netconn_connect(struct netconn *conn, ip_addr_t *addr, u16_t port) argument
233 netconn_disconnect(struct netconn *conn) argument
256 netconn_listen_with_backlog(struct netconn *conn, u8_t backlog) argument
291 netconn_accept(struct netconn *conn, struct netconn **new_conn) argument
355 netconn_recv_data(struct netconn *conn, void **new_buf) argument
449 netconn_recv_tcp_pbuf(struct netconn *conn, struct pbuf **new_buf) argument
466 netconn_recv(struct netconn *conn, struct netbuf **new_buf) argument
529 netconn_recved(struct netconn *conn, u32_t length) argument
560 netconn_sendto(struct netconn *conn, struct netbuf *buf, ip_addr_t *addr, u16_t port) argument
578 netconn_send(struct netconn *conn, struct netbuf *buf) argument
608 netconn_write_partly(struct netconn *conn, const void *dataptr, size_t size, u8_t apiflags, size_t *bytes_written) argument
672 netconn_close_shutdown(struct netconn *conn, u8_t how) argument
698 netconn_close(struct netconn *conn) argument
711 netconn_shutdown(struct netconn *conn, u8_t shut_rx, u8_t shut_tx) argument
728 netconn_join_leave_group(struct netconn *conn, ip_addr_t *multiaddr, ip_addr_t *netif_addr, enum netconn_igmp join_or_leave) argument
[all...]
H A Dapi_msg.c58 #define SET_NONBLOCKING_CONNECT(conn, val) do { if(val) { \
59 (conn)->flags |= NETCONN_FLAG_IN_NONBLOCKING_CONNECT; \
61 (conn)->flags &= ~ NETCONN_FLAG_IN_NONBLOCKING_CONNECT; }} while(0)
62 #define IN_NONBLOCKING_CONNECT(conn) (((conn)->flags & NETCONN_FLAG_IN_NONBLOCKING_CONNECT) != 0)
66 static err_t lwip_netconn_do_writemore(struct netconn *conn);
67 static void lwip_netconn_do_close_internal(struct netconn *conn);
74 * conn->recvmbox
84 struct netconn *conn; local
87 conn
149 struct netconn *conn; local
218 struct netconn *conn; local
280 struct netconn *conn = (struct netconn *)arg; local
316 struct netconn *conn = (struct netconn *)arg; local
350 struct netconn *conn; local
414 setup_tcp(struct netconn *conn) argument
436 struct netconn *conn = (struct netconn *)arg; local
579 struct netconn *conn; local
658 netconn_free(struct netconn *conn) argument
683 netconn_drain(struct netconn *conn) argument
748 lwip_netconn_do_close_internal(struct netconn *conn) argument
941 struct netconn *conn; local
1231 lwip_netconn_do_writemore(struct netconn *conn) argument
[all...]
H A Dsockets.c77 ((((name)->sa_family == AF_INET) && !(NETCONNTYPE_ISIPV6((sock)->conn->type))) || \
78 (((name)->sa_family == AF_INET6) && (NETCONNTYPE_ISIPV6((sock)->conn->type))))
126 struct netconn *conn; member in struct:lwip_sock
247 static void event_callback(struct netconn *conn, enum netconn_evt evt, u16_t len);
279 if (!sock->conn) {
300 if (!sockets[s].conn) {
324 if (!sockets[i].conn) {
325 sockets[i].conn = newconn;
364 sock->conn = NULL;
400 if (netconn_is_nonblocking(sock->conn)
1020 struct netconn *conn; local
1319 event_callback(struct netconn *conn, enum netconn_evt evt, u16_t len) argument
[all...]
/vbox/src/VBox/HostServices/SharedOpenGL/crserverlib/
H A Dserver_stream.c24 newClient->conn = crNetAcceptClient( cr_server.protocol, NULL,
81 client->conn->pClient = client;
82 CRVBOXHGSMI_CMDDATA_CLEANUP(&client->conn->CmdData);
87 client->number = client->conn->u32ClientID;
185 crDebug("Deleting client %p (%d msgs left)", client, crNetNumMessages(client->conn));
188 if (crNetNumMessages(client->conn) > 0) {
260 crNetFreeConnection(client->conn);
261 client->conn = NULL;
350 if (!cr_server.run_queue->client->conn
351 || (cr_server.run_queue->client->conn
425 crServerPendMsg(CRConnection *conn, const CRMessage *msg, int cbMsg) argument
550 crServerPendProcess(CRConnection *conn) argument
588 crServerDispatchMessage(CRConnection *conn, CRMessage *msg, int cbMsg) argument
720 CRConnection *conn; local
911 crServerRecv( CRConnection *conn, CRMessage *msg, unsigned int len ) argument
[all...]
/vbox/src/VBox/Devices/USB/testcase/
H A DtstPalmOne.c207 static int usb_set_connected(int ifnum, int conn) argument
211 io.ioctl_code = (conn) ? USBDEVFS_CONNECT : USBDEVFS_DISCONNECT;
H A DtstTrekStorGo.c207 static int usb_set_connected(int ifnum, int conn) argument
211 io.ioctl_code = (conn) ? USBDEVFS_CONNECT : USBDEVFS_DISCONNECT;
/vbox/src/VBox/Additions/solaris/SharedFolders/
H A Dvboxfs_prov.c118 sfprov_disconnect(sfp_connection_t *conn) argument
120 if (conn != (sfp_connection_t *)&vbox_client)
128 sfprov_mount(sfp_connection_t *conn, char *path, sfp_mount_t **mnt) argument

Completed in 75 milliseconds

12