Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 16 additions & 0 deletions embuilder.py
Original file line number Diff line number Diff line change
Expand Up @@ -54,11 +54,13 @@
'gl-webgl2',
'html5',
'libc',
'libc-sockets',
'libc++',
'libc++_noexcept',
'libc++abi',
'libc-extras',
'libc-mt',
'libc-sockets-proxy',
'pthreads',
'pthreads_stub',
]
Expand Down Expand Up @@ -354,6 +356,20 @@ def is_flag(arg):
build_port('cocos2d', 'cocos2d.bc', ['-s', 'USE_COCOS2D=3', '-s', 'USE_ZLIB=1', '-s', 'USE_LIBPNG=1', '-s', 'ERROR_ON_UNDEFINED_SYMBOLS=0'])
elif what == 'regal':
build_port('regal', 'regal.bc', ['-s', 'USE_REGAL=1'])
elif what == 'libc-sockets':
build('''
#include <sys/socket.h>
int main() {
return socket(0,0,0);
}
''', [static_library_name('libc-sockets')])
elif what == 'libc-sockets-proxy':
build('''
#include <sys/socket.h>
int main() {
return socket(0,0,0);
}
''', [static_library_name('libc-sockets-proxy')], ['-s', 'PROXY_POSIX_SOCKETS=1', '-s', 'USE_PTHREADS=1', '-s', 'PROXY_TO_PTHREAD=1'])
else:
logger.error('unfamiliar build target: ' + what)
return 1
Expand Down
1 change: 1 addition & 0 deletions site/source/docs/porting/index.rst
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@ The topics in this section cover the main integration points that you need to co
Audio
Debugging
pthreads
networking
simd
asyncify
emterpreter
Expand Down
44 changes: 44 additions & 0 deletions site/source/docs/porting/networking.rst
Original file line number Diff line number Diff line change
@@ -0,0 +1,44 @@
.. Networking:

==============================
Networking
==============================

Emscripten compiled applications have a number of ways to connect with online servers. Check the subtopics here to learn about the different strategies that are available.

If you are familiar with networking concepts provided by different web APIs, such as XmlHttpRequest, Fetch, WebSockets and WebRTC, you can quickly get started by leveraging what you already know: by calling out from C/C++ code to JavaScript (see the "Connecting C++ and JavaScript" section), you can establish networked connections by writing regular JavaScript. For C/C++ developers, Emscripten provides a few approaches, described here.

Emscripten WebSockets API
=========================

WebSockets API provides connection-oriented message-framed bidirectional asynchronous networking communication to the browser. It is the closest to TCP on the web that web sites can access, direct access to TCP sockets is not possible from web browsers.

Emscripten provides a passthrough API for accessing the WebSockets API from C/C++ code. This is useful for developers who would prefer not to write any JavaScript code, or deal with the C/C++ and JavaScript language interop. See the system include file <emscripten/websocket.h> for details. One benefit that the Emscripten WebSockets API provides over manual WebSockets access in JavaScript is the ability to share access to a WebSocket handle across multiple threads, something that can be time consuming to develop from scratch.

To target Emscripten WebSockets API, you must link it in with a "-lwebsocket.js" linker directive.

Emulated POSIX TCP Sockets over WebSockets
==========================================

If you have existing TCP networking code written in C/C++ that utilizes the Posix Sockets API, by default Emscripten attempts to emulate such connections to take place over the WebSocket protocol instead. For this to work, you will need to use something like WebSockify on the server side to enable the TCP server stack to receive incoming WebSocket connections. This emulation is not very complete at the moment, it is likely that you will run into problems out of the box and need to adapt the code to work within the limitations that this emulation provides.

This is the default build mode for POSIX sockets, no linker flags or option settings are needed to enable it.

Full POSIX Sockets over WebSocket Proxy Server
==============================================

Emscripten provides a native POSIX Sockets proxy server program, located in directory tools/websocket_to_posix_proxy/, that allows full POSIX Sockets API access from a web browser. This support works by proxying all POSIX Sockets API calls from the browser to the Emscripten POSIX Sockets proxy server (via transparent use of WebSockets API), and the proxy server then performs the native TCP/UDP calls on behalf of the page. This allows a web browser page to run full TCP & UDP connections, act as a server to accept incoming connections, and perform host name lookups and reverse lookups. Because all API calls are individually proxied, this support can be slow. This support is mostly useful for developing testing infrastructure and debugging.

To use POSIX sockets proxying, link the application with flags "-lwebsocket.js -s PROXY_POSIX_SOCKETS=1 -s USE_PTHREADS=1 -s PROXY_TO_PTHREAD=1 -s FORCE_FILESYSTEM=1". That is, POSIX sockets proxying builds on top of the Emscripten WebSockets library, and requires multithreading and proxying the application main() to a pthread. Without FORCE_FILESYSTEM=1, required syscalls may be optimized out, giving the runtime error "SYSCALLS.getStreamFromFD is not a function".
Copy link
Owner

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Hmm, it is not intended to use -s FORCE_FILESYSTEM=1 with sockets proxying - any code in the SYSCALLS.* will not be compatible with sockets proxying, but rather if you are getting such an error, I think it's due to some bits missing in the sockets proxying PR. Let's revert this doc piece back and look at the runtime error in more detail?


For an example of how the POSIX Sockets proxy server works in an Emscripten client program, see the file tests/websocket/tcp_echo_client.cpp.

XmlHttpRequests and Fetch API
=============================

For HTTP transfers, one can use the browser built-in XmlHttpRequest (XHR) API and the newer Fetch API. These can be accessed directly from JavaScript. Emscripten also provides passthrough APIs to perform HTTP requests. For more information, see the emscripten_async_wget*() C API and the Emscripten Fetch API.

WebRTC and UDP
==============

Direct UDP communication is not available in browsers, but as a close alternative, the WebRTC specification provides a mechanism to perform UDP-like communication with WebRTC Data Channels. Currently Emscripten does not provide a C/C++ API for interacting with WebRTC.
3 changes: 3 additions & 0 deletions src/library.js
Original file line number Diff line number Diff line change
Expand Up @@ -3608,6 +3608,7 @@ LibraryManager.library = {
// arpa/inet.h
// ==========================================================================

#if PROXY_POSIX_SOCKETS == 0
// old ipv4 only functions
inet_addr__deps: ['_inet_pton4_raw'],
inet_addr: function(ptr) {
Expand Down Expand Up @@ -4350,6 +4351,8 @@ LibraryManager.library = {
0x0b00000a, 0x0c00000a, 0x0d00000a, 0x0e00000a] /* 0x0100000a is reserved */
},

#endif // PROXY_POSIX_SOCKETS == 0

// pwd.h

getpwnam: function() { throw 'getpwnam: TODO' },
Expand Down
2 changes: 2 additions & 0 deletions src/library_syscall.js
Original file line number Diff line number Diff line change
Expand Up @@ -484,6 +484,7 @@ var SyscallsLibrary = {
__syscall97: function(which, varargs) { // setpriority
return -ERRNO_CODES.EPERM;
},
#if PROXY_POSIX_SOCKETS == 0
__syscall102__deps: ['$SOCKFS', '$DNS', '_read_sockaddr', '_write_sockaddr'],
__syscall102: function(which, varargs) { // socketcall
var call = SYSCALLS.get(), socketvararg = SYSCALLS.get();
Expand Down Expand Up @@ -674,6 +675,7 @@ var SyscallsLibrary = {
default: abort('unsupported socketcall syscall ' + call);
}
},
#endif // ~PROXY_POSIX_SOCKETS==0
__syscall104: function(which, varargs) { // setitimer
return -ERRNO_CODES.ENOSYS; // unsupported feature
},
Expand Down
1 change: 1 addition & 0 deletions src/library_websocket.js
Original file line number Diff line number Diff line change
Expand Up @@ -109,6 +109,7 @@ var LibraryWebSocket = {
#endif
return {{{ cDefine('EMSCRIPTEN_RESULT_INVALID_TARGET') }}};
}
HEAPU32[urlLength>>2] = lengthBytesUTF8(socket.url);
return {{{ cDefine('EMSCRIPTEN_RESULT_SUCCESS') }}};
},

Expand Down
3 changes: 3 additions & 0 deletions src/settings.js
Original file line number Diff line number Diff line change
Expand Up @@ -364,6 +364,9 @@ var SOCKET_WEBRTC = 0;
// where addr and port are derived from the socket connect/bind/accept calls.
var WEBSOCKET_URL = 'ws://';

// If 1, the POSIX sockets API uses a proxy bridge to proxy sockets calls
var PROXY_POSIX_SOCKETS = 0;

// A string containing a comma separated list of WebSocket subprotocols
// as would be present in the Sec-WebSocket-Protocol header.
var WEBSOCKET_SUBPROTOCOL = 'binary';
Expand Down
13 changes: 13 additions & 0 deletions system/include/emscripten/posix_socket.h
Original file line number Diff line number Diff line change
@@ -0,0 +1,13 @@
#pragma once

#include "websocket.h"

#ifdef __cplusplus
extern "C" {
#endif

extern EMSCRIPTEN_RESULT emscripten_init_websocket_to_posix_socket_bridge(const char *bridgeUrl);

#ifdef __cplusplus
}
#endif
4 changes: 4 additions & 0 deletions system/include/emscripten/websocket.h
Original file line number Diff line number Diff line change
Expand Up @@ -113,3 +113,7 @@ EMSCRIPTEN_RESULT emscripten_websocket_delete(EMSCRIPTEN_WEBSOCKET_T socket);
// even after the pthread quits, although be warned that if the target thread that was registered to handle events for a given WebSocket quits, then those
// events will stop from being delivered altogether.
void emscripten_websocket_deinitialize(void);

#ifdef __cplusplus
}
#endif
23 changes: 23 additions & 0 deletions system/lib/libc-sockets.symbols
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
U __errno_location
U __syscall102
U __syscall221
U __syscall_ret
U free
-------- T accept
-------- T bind
-------- T connect
-------- T freeaddrinfo
-------- T getpeername
-------- T getsockname
-------- T getsockopt
-------- T listen
-------- T recv
-------- T recvfrom
-------- T recvmsg
-------- T send
-------- T sendmsg
-------- T sendto
-------- T setsockopt
-------- T shutdown
-------- T socket
-------- T socketpair
Loading