This adds win32 build compatability to libwebsockets.
The patch is from Peter Hinz, Andy Green has cleaned it up a bit and
possibly broken win32 compatability since I can't test it, so there
may be followup patches. It compiles fine under Linux after this
patch anyway.
Much of the patch is changing a reserved keyword for Visual C compiler
"this" to "context", but there is no real C99 support in the MSFT
compiler even though it is 2011 so C99 style array declarations
have been mangled back into "ancient C" style.
Some windows-isms are also added like closesocket() but these are
quite localized. Win32 random is just using C library random() call
at the moment vs Linux /dev/urandom. canonical hostname detection is
broken in win32 at the moment.
Signed-off-by: Peter Hinz <cerebusrc@gmail.com>
Signed-off-by: Andy Green <andy@warmcat.com>
/**
* libwebsocket_client_connect() - Connect to another websocket server
- * @this: Websocket context
+ * @context: Websocket context
* @address: Remote server address, eg, "myserver.com"
* @port: Port to connect to on the remote server, eg, 80
* @ssl_connection: 0 = ws://, 1 = wss:// encrypted, 2 = wss:// allow self
*/
struct libwebsocket *
-libwebsocket_client_connect(struct libwebsocket_context *this,
+libwebsocket_client_connect(struct libwebsocket_context *context,
const char *address,
int port,
int ssl_connection,
/* force no mask if he asks for that though */
- if (this->options & LWS_SERVER_OPTION_DEFEAT_CLIENT_MASK)
+ if (context->options & LWS_SERVER_OPTION_DEFEAT_CLIENT_MASK)
wsi->xor_mask = xor_no_mask;
for (n = 0; n < WSI_TOKEN_COUNT; n++) {
* proxy?
*/
- if (this->http_proxy_port) {
+ if (context->http_proxy_port) {
plen = sprintf(pkt, "CONNECT %s:%u HTTP/1.0\x0d\x0a"
"User-agent: libwebsockets\x0d\x0a"
/*Proxy-authorization: basic aGVsbG86d29ybGQ= */
/* OK from now on we talk via the proxy */
- address = this->http_proxy_address;
- port = this->http_proxy_port;
+ address = context->http_proxy_address;
+ port = context->http_proxy_port;
}
/*
/* into fd -> wsi hashtable */
- insert_wsi(this, wsi);
+ insert_wsi(context, wsi);
/* into internal poll list */
- this->fds[this->fds_count].fd = wsi->sock;
- this->fds[this->fds_count].revents = 0;
- this->fds[this->fds_count++].events = POLLIN;
+ context->fds[context->fds_count].fd = wsi->sock;
+ context->fds[context->fds_count].revents = 0;
+ context->fds[context->fds_count++].events = POLLIN;
/* external POLL support via protocol 0 */
- this->protocols[0].callback(this, wsi,
+ context->protocols[0].callback(context, wsi,
LWS_CALLBACK_ADD_POLL_FD,
(void *)(long)wsi->sock, NULL, POLLIN);
/* we are connected to server, or proxy */
- if (this->http_proxy_port) {
+ if (context->http_proxy_port) {
n = send(wsi->sock, pkt, plen, 0);
if (n < 0) {
+#ifdef WIN32
+ closesocket(wsi->sock);
+#else
close(wsi->sock);
+#endif
fprintf(stderr, "ERROR writing to proxy socket\n");
goto bail1;
}
wsi->mode = LWS_CONNMODE_WS_CLIENT_ISSUE_HANDSHAKE;
pfd.fd = wsi->sock;
pfd.revents = POLLIN;
- libwebsocket_service_fd(this, &pfd);
+ libwebsocket_service_fd(context, &pfd);
return wsi;
/* select the nonce */
- n = read(wsi->protocol->owning_server->fd_random, hash, 16);
+ n = libwebsockets_get_random(wsi->protocol->owning_server,
+ hash, 16);
if (n != 16) {
fprintf(stderr, "Unable to read random device %s %d\n",
SYSTEM_RANDOM_FILEPATH, n);
*/
int
-libwebsocket_read(struct libwebsocket_context *this, struct libwebsocket *wsi,
+libwebsocket_read(struct libwebsocket_context *context, struct libwebsocket *wsi,
unsigned char * buf, size_t len)
{
size_t n;
if (!wsi->utf8_token[WSI_TOKEN_UPGRADE].token_len ||
!wsi->utf8_token[WSI_TOKEN_CONNECTION].token_len) {
if (wsi->protocol->callback)
- (wsi->protocol->callback)(this, wsi,
+ (wsi->protocol->callback)(context, wsi,
LWS_CALLBACK_HTTP, wsi->user_space,
wsi->utf8_token[WSI_TOKEN_GET_URI].token, 0);
wsi->state = WSI_STATE_HTTP;
return 0;
bail:
- libwebsocket_close_and_free_session(this, wsi,
+ libwebsocket_close_and_free_session(context, wsi,
LWS_CLOSE_STATUS_NOSTATUS);
return -1;
-/*
+/*
* libwebsockets - small server side websockets and web server implementation
*
* Copyright (C) 2010 Andy Green <andy@warmcat.com>
*/
#include "private-libwebsockets.h"
-#include <ifaddrs.h>
+#ifdef WIN32
+
+#else
+#include <ifaddrs.h>
+#endif
/*
* In-place str to lower case
*/
/* file descriptor hash management */
struct libwebsocket *
-wsi_from_fd(struct libwebsocket_context *this, int fd)
+wsi_from_fd(struct libwebsocket_context *context, int fd)
{
int h = LWS_FD_HASH(fd);
int n = 0;
- for (n = 0; n < this->fd_hashtable[h].length; n++)
- if (this->fd_hashtable[h].wsi[n]->sock == fd)
- return this->fd_hashtable[h].wsi[n];
+ for (n = 0; n < context->fd_hashtable[h].length; n++)
+ if (context->fd_hashtable[h].wsi[n]->sock == fd)
+ return context->fd_hashtable[h].wsi[n];
return NULL;
}
int
-insert_wsi(struct libwebsocket_context *this, struct libwebsocket *wsi)
+insert_wsi(struct libwebsocket_context *context, struct libwebsocket *wsi)
{
int h = LWS_FD_HASH(wsi->sock);
- if (this->fd_hashtable[h].length == MAX_CLIENTS - 1) {
+ if (context->fd_hashtable[h].length == MAX_CLIENTS - 1) {
fprintf(stderr, "hash table overflow\n");
return 1;
}
- this->fd_hashtable[h].wsi[this->fd_hashtable[h].length++] = wsi;
+ context->fd_hashtable[h].wsi[context->fd_hashtable[h].length++] = wsi;
return 0;
}
int
-delete_from_fd(struct libwebsocket_context *this, int fd)
+delete_from_fd(struct libwebsocket_context *context, int fd)
{
int h = LWS_FD_HASH(fd);
int n = 0;
- for (n = 0; n < this->fd_hashtable[h].length; n++)
- if (this->fd_hashtable[h].wsi[n]->sock == fd) {
- while (n < this->fd_hashtable[h].length) {
- this->fd_hashtable[h].wsi[n] =
- this->fd_hashtable[h].wsi[n + 1];
+ for (n = 0; n < context->fd_hashtable[h].length; n++)
+ if (context->fd_hashtable[h].wsi[n]->sock == fd) {
+ while (n < context->fd_hashtable[h].length) {
+ context->fd_hashtable[h].wsi[n] =
+ context->fd_hashtable[h].wsi[n + 1];
n++;
}
- this->fd_hashtable[h].length--;
+ context->fd_hashtable[h].length--;
return 0;
}
interface_to_sa(const char* ifname, struct sockaddr_in *addr, size_t addrlen)
{
int rc = -1;
+#ifdef WIN32
+ // TODO
+#else
struct ifaddrs *ifr;
struct ifaddrs *ifc;
struct sockaddr_in *sin;
}
freeifaddrs(ifr);
-
+#endif
return rc;
}
void
-libwebsocket_close_and_free_session(struct libwebsocket_context *this,
+libwebsocket_close_and_free_session(struct libwebsocket_context *context,
struct libwebsocket *wsi, enum lws_close_status reason)
{
int n;
/* remove this fd from wsi mapping hashtable */
- delete_from_fd(this, wsi->sock);
+ delete_from_fd(context, wsi->sock);
/* delete it from the internal poll list if still present */
- for (n = 0; n < this->fds_count; n++) {
- if (this->fds[n].fd != wsi->sock)
+ for (n = 0; n < context->fds_count; n++) {
+ if (context->fds[n].fd != wsi->sock)
continue;
- while (n < this->fds_count - 1) {
- this->fds[n] = this->fds[n + 1];
+ while (n < context->fds_count - 1) {
+ context->fds[n] = context->fds[n + 1];
n++;
}
- this->fds_count--;
+ context->fds_count--;
/* we only have to deal with one */
- n = this->fds_count;
+ n = context->fds_count;
}
/* remove also from external POLL support via protocol 0 */
- this->protocols[0].callback(this, wsi,
+ context->protocols[0].callback(context, wsi,
LWS_CALLBACK_DEL_POLL_FD, (void *)(long)wsi->sock, NULL, 0);
wsi->close_reason = reason;
if (wsi->protocol && wsi->protocol->callback &&
old_state == WSI_STATE_ESTABLISHED)
- wsi->protocol->callback(this, wsi, LWS_CALLBACK_CLOSED,
+ wsi->protocol->callback(context, wsi, LWS_CALLBACK_CLOSED,
wsi->user_space, NULL, 0);
/* free up his allocations */
if (wsi->ssl) {
n = SSL_get_fd(wsi->ssl);
SSL_shutdown(wsi->ssl);
+#ifdef WIN32
+ closesocket(n);
+#else
close(n);
+#endif
SSL_free(wsi->ssl);
} else {
#endif
shutdown(wsi->sock, SHUT_RDWR);
+#ifdef WIN32
+ closesocket(wsi->sock);
+#else
close(wsi->sock);
+#endif
#ifdef LWS_OPENSSL_SUPPORT
}
#endif
/**
* libwebsockets_hangup_on_client() - Server calls to terminate client
* connection
- * @this: libwebsockets context
+ * @context: libwebsockets context
* @fd: Connection socket descriptor
*/
void
-libwebsockets_hangup_on_client(struct libwebsocket_context *this, int fd)
+libwebsockets_hangup_on_client(struct libwebsocket_context *context, int fd)
{
- struct libwebsocket *wsi = wsi_from_fd(this, fd);
+ struct libwebsocket *wsi = wsi_from_fd(context, fd);
if (wsi == NULL)
return;
- libwebsocket_close_and_free_session(this, wsi,
+ libwebsocket_close_and_free_session(context, wsi,
LWS_CLOSE_STATUS_NOSTATUS);
}
}
}
+int libwebsockets_get_random(struct libwebsocket_context *context,
+ void *buf, int len)
+{
+ int n;
+ char *p = buf;
+
+#ifdef WIN32
+ for (n = 0; n < len; n++)
+ p[n] = (unsigned char)rand();
+#else
+ n = read(context->fd_random, p, len);
+#endif
+
+ return n;
+}
+
void libwebsockets_00_spaceout(char *key, int spaces, int seed)
{
char *p;
-
+
key++;
while (spaces--) {
if (*key && (seed & 1))
key++;
seed >>= 1;
-
+
p = key + strlen(key);
while (p >= key) {
p[1] = p[0];
/**
* libwebsocket_service_fd() - Service polled socket with something waiting
- * @this: Websocket context
+ * @context: Websocket context
* @pollfd: The pollfd entry describing the socket fd and which events
* happened.
*
*/
int
-libwebsocket_service_fd(struct libwebsocket_context *this,
+libwebsocket_service_fd(struct libwebsocket_context *context,
struct pollfd *pollfd)
{
unsigned char buf[LWS_SEND_BUFFER_PRE_PADDING + MAX_BROADCAST_PAYLOAD +
gettimeofday(&tv, NULL);
- if (this->last_timeout_check_s != tv.tv_sec) {
- this->last_timeout_check_s = tv.tv_sec;
+ if (context->last_timeout_check_s != tv.tv_sec) {
+ context->last_timeout_check_s = tv.tv_sec;
/* global timeout check once per second */
- for (n = 0; n < this->fds_count; n++) {
- wsi = wsi_from_fd(this, this->fds[n].fd);
+ for (n = 0; n < context->fds_count; n++) {
+ wsi = wsi_from_fd(context, context->fds[n].fd);
if (!wsi->pending_timeout)
continue;
*/
if (tv.tv_sec > wsi->pending_timeout_limit)
- libwebsocket_close_and_free_session(this, wsi,
- LWS_CLOSE_STATUS_NOSTATUS);
+ libwebsocket_close_and_free_session(context,
+ wsi, LWS_CLOSE_STATUS_NOSTATUS);
}
}
/* no, here to service a socket descriptor */
- wsi = wsi_from_fd(this, pollfd->fd);
+ wsi = wsi_from_fd(context, pollfd->fd);
if (wsi == NULL)
return 1;
break;
}
- if (this->fds_count >= MAX_CLIENTS) {
+ if (context->fds_count >= MAX_CLIENTS) {
fprintf(stderr, "too busy to accept new client\n");
+#ifdef WIN32
+ closesocket(accept_fd);
+#else
close(accept_fd);
+#endif
break;
}
* yet so we issue this to protocols[0]
*/
- if ((this->protocols[0].callback)(this, wsi,
+ if ((context->protocols[0].callback)(context, wsi,
LWS_CALLBACK_FILTER_NETWORK_CONNECTION,
(void*)(long)accept_fd, NULL, 0)) {
fprintf(stderr, "Callback denied network connection\n");
+#ifdef WIN32
+ closesocket(accept_fd);
+#else
close(accept_fd);
+#endif
break;
}
#ifdef LWS_OPENSSL_SUPPORT
new_wsi->ssl = NULL;
- if (this->use_ssl) {
+ if (context->use_ssl) {
- new_wsi->ssl = SSL_new(this->ssl_ctx);
+ new_wsi->ssl = SSL_new(context->ssl_ctx);
if (new_wsi->ssl == NULL) {
fprintf(stderr, "SSL_new failed: %s\n",
ERR_error_string(SSL_get_error(
* to the start of the supported list, so it can look
* for matching ones during the handshake
*/
- new_wsi->protocol = this->protocols;
+ new_wsi->protocol = context->protocols;
new_wsi->user_space = NULL;
/*
*/
new_wsi->ietf_spec_revision = 0;
- insert_wsi(this, new_wsi);
+ insert_wsi(context, new_wsi);
/*
* make sure NO events are seen yet on this new socket
* (otherwise we inherit old fds[client].revents from
* previous socket there and die mysteriously! )
*/
- this->fds[this->fds_count].revents = 0;
+ context->fds[context->fds_count].revents = 0;
- this->fds[this->fds_count].events = POLLIN;
- this->fds[this->fds_count++].fd = accept_fd;
+ context->fds[context->fds_count].events = POLLIN;
+ context->fds[context->fds_count++].fd = accept_fd;
/* external POLL support via protocol 0 */
- this->protocols[0].callback(this, new_wsi,
+ context->protocols[0].callback(context, new_wsi,
LWS_CALLBACK_ADD_POLL_FD,
(void *)(long)accept_fd, NULL, POLLIN);
break;
}
- if (this->fds_count >= MAX_CLIENTS) {
+ if (context->fds_count >= MAX_CLIENTS) {
fprintf(stderr, "too busy to accept new broadcast "
"proxy client\n");
+#ifdef WIN32
+ closesocket(accept_fd);
+#else
close(accept_fd);
+#endif
break;
}
/* note which protocol we are proxying */
new_wsi->protocol_index_for_broadcast_proxy =
wsi->protocol_index_for_broadcast_proxy;
- insert_wsi(this, new_wsi);
+ insert_wsi(context, new_wsi);
/* add connected socket to internal poll array */
- this->fds[this->fds_count].revents = 0;
- this->fds[this->fds_count].events = POLLIN;
- this->fds[this->fds_count++].fd = accept_fd;
+ context->fds[context->fds_count].revents = 0;
+ context->fds[context->fds_count].events = POLLIN;
+ context->fds[context->fds_count++].fd = accept_fd;
/* external POLL support via protocol 0 */
- this->protocols[0].callback(this, new_wsi,
+ context->protocols[0].callback(context, new_wsi,
LWS_CALLBACK_ADD_POLL_FD,
(void *)(long)accept_fd, NULL, POLLIN);
debug("Session Socket %p (fd=%d) dead\n",
(void *)wsi, pollfd->fd);
- libwebsocket_close_and_free_session(this, wsi,
+ libwebsocket_close_and_free_session(context, wsi,
LWS_CLOSE_STATUS_NORMAL);
return 1;
}
pollfd->events &= ~POLLOUT;
/* external POLL support via protocol 0 */
- this->protocols[0].callback(this, wsi,
+ context->protocols[0].callback(context, wsi,
LWS_CALLBACK_CLEAR_MODE_POLL_FD,
(void *)(long)wsi->sock, NULL, POLLOUT);
- wsi->protocol->callback(this, wsi,
+ wsi->protocol->callback(context, wsi,
LWS_CALLBACK_CLIENT_WRITEABLE,
wsi->user_space,
NULL, 0);
for (n = 0; n < FD_HASHTABLE_MODULUS; n++) {
- for (m = 0; m < this->fd_hashtable[n].length; m++) {
+ for (m = 0; m < context->fd_hashtable[n].length; m++) {
- new_wsi = this->fd_hashtable[n].wsi[m];
+ new_wsi = context->fd_hashtable[n].wsi[m];
/* only to clients we are serving to */
/* broadcast it to this connection */
- new_wsi->protocol->callback(this, new_wsi,
+ new_wsi->protocol->callback(context, new_wsi,
LWS_CALLBACK_BROADCAST,
new_wsi->user_space,
buf + LWS_SEND_BUFFER_PRE_PADDING, len);
fprintf(stderr, "Proxy connection %p (fd=%d) dead\n",
(void *)wsi, pollfd->fd);
- libwebsocket_close_and_free_session(this, wsi,
+ libwebsocket_close_and_free_session(context, wsi,
LWS_CLOSE_STATUS_NOSTATUS);
return 1;
}
n = recv(wsi->sock, pkt, sizeof pkt, 0);
if (n < 0) {
- libwebsocket_close_and_free_session(this, wsi,
+ libwebsocket_close_and_free_session(context, wsi,
LWS_CLOSE_STATUS_NOSTATUS);
fprintf(stderr, "ERROR reading from proxy socket\n");
return 1;
pkt[13] = '\0';
if (strcmp(pkt, "HTTP/1.0 200 ") != 0) {
- libwebsocket_close_and_free_session(this, wsi,
+ libwebsocket_close_and_free_session(context, wsi,
LWS_CLOSE_STATUS_NOSTATUS);
fprintf(stderr, "ERROR from proxy: %s\n", pkt);
return 1;
#ifdef LWS_OPENSSL_SUPPORT
if (wsi->use_ssl) {
- wsi->ssl = SSL_new(this->ssl_client_ctx);
- wsi->client_bio = BIO_new_socket(wsi->sock, BIO_NOCLOSE);
+ wsi->ssl = SSL_new(context->ssl_client_ctx);
+ wsi->client_bio = BIO_new_socket(wsi->sock,
+ BIO_NOCLOSE);
SSL_set_bio(wsi->ssl, wsi->client_bio, wsi->client_bio);
SSL_set_ex_data(wsi->ssl,
- this->openssl_websocket_private_data_index, this);
+ context->openssl_websocket_private_data_index,
+ context);
if (SSL_connect(wsi->ssl) <= 0) {
fprintf(stderr, "SSL connect error %s\n",
ERR_error_string(ERR_get_error(),
ssl_err_buf));
- libwebsocket_close_and_free_session(this, wsi,
+ libwebsocket_close_and_free_session(context, wsi,
LWS_CLOSE_STATUS_NOSTATUS);
return 1;
}
fprintf(stderr, "server's cert didn't "
"look good %d\n", n);
- libwebsocket_close_and_free_session(this, wsi,
- LWS_CLOSE_STATUS_NOSTATUS);
+ libwebsocket_close_and_free_session(context,
+ wsi, LWS_CLOSE_STATUS_NOSTATUS);
return 1;
}
} else {
* create the random key
*/
- n = read(this->fd_random, hash, 16);
+ n = libwebsockets_get_random(context, hash, 16);
if (n != 16) {
fprintf(stderr, "Unable to read from random dev %s\n",
SYSTEM_RANDOM_FILEPATH);
free(wsi->c_origin);
if (wsi->c_protocol)
free(wsi->c_protocol);
- libwebsocket_close_and_free_session(this, wsi,
+ libwebsocket_close_and_free_session(context, wsi,
LWS_CLOSE_STATUS_NOSTATUS);
return 1;
}
unsigned int count;
char challenge[16];
- read(this->fd_random, &spaces_1, sizeof(char));
- read(this->fd_random, &spaces_2, sizeof(char));
-
+ libwebsockets_get_random(context, &spaces_1,
+ sizeof(char));
+ libwebsockets_get_random(context, &spaces_2,
+ sizeof(char));
+
spaces_1 = (spaces_1 % 12) + 1;
spaces_2 = (spaces_2 % 12) + 1;
-
+
max_1 = 4294967295 / spaces_1;
max_2 = 4294967295 / spaces_2;
- read(this->fd_random, &num_1, sizeof(int));
- read(this->fd_random, &num_2, sizeof(int));
-
+ libwebsockets_get_random(context, &num_1, sizeof(int));
+ libwebsockets_get_random(context, &num_2, sizeof(int));
+
num_1 = (num_1 % max_1);
num_2 = (num_2 % max_2);
-
+
challenge[0] = num_1 >> 24;
challenge[1] = num_1 >> 16;
challenge[2] = num_1 >> 8;
challenge[5] = num_2 >> 16;
challenge[6] = num_2 >> 8;
challenge[7] = num_2;
-
+
product_1 = num_1 * spaces_1;
product_2 = num_2 * spaces_2;
-
+
sprintf(key_1, "%lu", product_1);
sprintf(key_2, "%lu", product_2);
- read(this->fd_random, &seed, sizeof(int));
- read(this->fd_random, &count, sizeof(int));
-
+ libwebsockets_get_random(context, &seed, sizeof(int));
+ libwebsockets_get_random(context, &count, sizeof(int));
+
libwebsockets_00_spam(key_1, (count % 12) + 1, seed);
-
- read(this->fd_random, &seed, sizeof(int));
- read(this->fd_random, &count, sizeof(int));
-
+
+ libwebsockets_get_random(context, &seed, sizeof(int));
+ libwebsockets_get_random(context, &count, sizeof(int));
+
libwebsockets_00_spam(key_2, (count % 12) + 1, seed);
-
- read(this->fd_random, &seed, sizeof(int));
-
+
+ libwebsockets_get_random(context, &seed, sizeof(int));
+
libwebsockets_00_spaceout(key_1, spaces_1, seed);
libwebsockets_00_spaceout(key_2, spaces_2, seed >> 16);
-
+
p += sprintf(p, "Upgrade: websocket\x0d\x0a"
"Connection: Upgrade\x0d\x0aHost: %s\x0d\x0a",
- wsi->c_host);
+ wsi->c_host);
if (wsi->c_origin)
p += sprintf(p, "Origin: %s\x0d\x0a",
- wsi->c_origin);
-
+ wsi->c_origin);
+
if (wsi->c_protocol)
- p += sprintf(p, "Sec-WebSocket-Protocol: %s\x0d\x0a",
- wsi->c_protocol);
-
+ p += sprintf(p, "Sec-WebSocket-Protocol: %s"
+ "\x0d\x0a", wsi->c_protocol);
+
p += sprintf(p, "Sec-WebSocket-Key1: %s\x0d\x0a",
- key_1);
+ key_1);
p += sprintf(p, "Sec-WebSocket-Key2: %s\x0d\x0a",
- key_2);
+ key_2);
/* give userland a chance to append, eg, cookies */
-
- this->protocols[0].callback(this, wsi,
- LWS_CALLBACK_CLIENT_APPEND_HANDSHAKE_HEADER,
+
+ context->protocols[0].callback(context, wsi,
+ LWS_CALLBACK_CLIENT_APPEND_HANDSHAKE_HEADER,
NULL, &p, (pkt + sizeof(pkt)) - p - 12);
p += sprintf(p, "\x0d\x0a");
-
- read(this->fd_random, p, 8);
+
+ read(context->fd_random, p, 8);
memcpy(&challenge[8], p, 8);
p += 8;
-
+
/* precompute what we want to see from the server */
-
+
MD5((unsigned char *)challenge, 16,
(unsigned char *)wsi->initial_handshake_hash_base64);
-
+
goto issue_hdr;
}
p += sprintf(p, "Sec-WebSocket-Protocol: %s\x0d\x0a",
wsi->c_protocol);
p += sprintf(p, "Sec-WebSocket-Version: %d\x0d\x0a",
- wsi->ietf_spec_revision);
-
+ wsi->ietf_spec_revision);
/* give userland a chance to append, eg, cookies */
-
- this->protocols[0].callback(this, wsi,
- LWS_CALLBACK_CLIENT_APPEND_HANDSHAKE_HEADER,
- NULL, &p, (pkt + sizeof(pkt)) - p - 12);
-
+
+ context->protocols[0].callback(context, wsi,
+ LWS_CALLBACK_CLIENT_APPEND_HANDSHAKE_HEADER,
+ NULL, &p, (pkt + sizeof(pkt)) - p - 12);
+
p += sprintf(p, "\x0d\x0a");
/* prepare the expected server accept response */
lws_b64_encode_string(hash, 20,
wsi->initial_handshake_hash_base64,
sizeof wsi->initial_handshake_hash_base64);
-issue_hdr:
+issue_hdr:
+
/* done with these now */
-
+
free(wsi->c_path);
free(wsi->c_host);
if (wsi->c_origin)
free(wsi->c_origin);
-
/* send our request to the server */
#ifdef LWS_OPENSSL_SUPPORT
if (n < 0) {
fprintf(stderr, "ERROR writing to client socket\n");
- libwebsocket_close_and_free_session(this, wsi,
+ libwebsocket_close_and_free_session(context, wsi,
LWS_CLOSE_STATUS_NOSTATUS);
return 1;
}
if (wsi->parser_state != WSI_PARSING_COMPLETE) {
fprintf(stderr, "libwebsocket_client_handshake "
- "server response ailed parsing\n");
+ "server response failed parsing\n");
goto bail3;
}
*
* xxxxxxxxxxxxxxxx
*/
-
+
if (wsi->ietf_spec_revision == 0) {
if (!wsi->utf8_token[WSI_TOKEN_HTTP].token_len ||
- !wsi->utf8_token[WSI_TOKEN_UPGRADE].token_len ||
- !wsi->utf8_token[WSI_TOKEN_CHALLENGE].token_len ||
- !wsi->utf8_token[WSI_TOKEN_CONNECTION].token_len ||
- (!wsi->utf8_token[WSI_TOKEN_PROTOCOL].token_len &&
- wsi->c_protocol != NULL)) {
+ !wsi->utf8_token[WSI_TOKEN_UPGRADE].token_len ||
+ !wsi->utf8_token[WSI_TOKEN_CHALLENGE].token_len ||
+ !wsi->utf8_token[WSI_TOKEN_CONNECTION].token_len ||
+ (!wsi->utf8_token[WSI_TOKEN_PROTOCOL].token_len &&
+ wsi->c_protocol != NULL)) {
fprintf(stderr, "libwebsocket_client_handshake "
- "missing required header(s)\n");
+ "missing required header(s)\n");
pkt[len] = '\0';
fprintf(stderr, "%s", pkt);
goto bail3;
}
-
+
strtolower(wsi->utf8_token[WSI_TOKEN_HTTP].token);
if (strcmp(wsi->utf8_token[WSI_TOKEN_HTTP].token,
- "101 websocket protocol handshake")) {
+ "101 websocket protocol handshake")) {
fprintf(stderr, "libwebsocket_client_handshake "
- "server sent bad HTTP response '%s'\n",
- wsi->utf8_token[WSI_TOKEN_HTTP].token);
+ "server sent bad HTTP response '%s'\n",
+ wsi->utf8_token[WSI_TOKEN_HTTP].token);
goto bail3;
}
- if (wsi->utf8_token[WSI_TOKEN_CHALLENGE].token_len < 16) {
+ if (wsi->utf8_token[WSI_TOKEN_CHALLENGE].token_len <
+ 16) {
fprintf(stderr, "libwebsocket_client_handshake "
- "challenge reply too short %d\n",
- wsi->utf8_token[WSI_TOKEN_CHALLENGE].token_len);
+ "challenge reply too short %d\n",
+ wsi->utf8_token[
+ WSI_TOKEN_CHALLENGE].token_len);
pkt[len] = '\0';
fprintf(stderr, "%s", pkt);
goto bail3;
-
+
}
-
+
goto select_protocol;
}
-
+
/*
* well, what the server sent looked reasonable for syntax.
* Now let's confirm it sent all the necessary headers
}
select_protocol:
-
pc = wsi->c_protocol;
/*
* no protocol name to work from,
* default to first protocol
*/
- wsi->protocol = &this->protocols[0];
+ wsi->protocol = &context->protocols[0];
free(wsi->c_protocol);
*/
n = 0;
wsi->protocol = NULL;
- while (this->protocols[n].callback) {
+ while (context->protocols[n].callback) {
if (strcmp(wsi->utf8_token[WSI_TOKEN_PROTOCOL].token,
- this->protocols[n].name) == 0)
- wsi->protocol = &this->protocols[n];
+ context->protocols[n].name) == 0)
+ wsi->protocol = &context->protocols[n];
n++;
}
check_accept:
if (wsi->ietf_spec_revision == 0) {
-
+
if (memcmp(wsi->initial_handshake_hash_base64,
- wsi->utf8_token[WSI_TOKEN_CHALLENGE].token, 16)) {
+ wsi->utf8_token[WSI_TOKEN_CHALLENGE].token, 16)) {
fprintf(stderr, "libwebsocket_client_handshake "
- "failed 00 challenge compare\n");
-
- pkt[len] = '\0';
- fprintf(stderr, "%s", pkt);
- goto bail2;
+ "failed 00 challenge compare\n");
+ pkt[len] = '\0';
+ fprintf(stderr, "%s", pkt);
+ goto bail2;
}
-
+
goto accept_ok;
}
-
+
/*
* Confirm his accept token is the one we precomputed
*/
strcpy(p, magic_websocket_04_masking_guid);
SHA1(buf, strlen((char *)buf), wsi->masking_key_04);
}
-
accept_ok:
/* allocate the per-connection user memory (if any) */
/* call him back to inform him he is up */
- wsi->protocol->callback(this, wsi,
+ wsi->protocol->callback(context, wsi,
LWS_CALLBACK_CLIENT_ESTABLISHED,
wsi->user_space,
NULL, 0);
free(wsi->c_protocol);
bail2:
- libwebsocket_close_and_free_session(this, wsi,
+ libwebsocket_close_and_free_session(context, wsi,
LWS_CLOSE_STATUS_NOSTATUS);
return 1;
fprintf(stderr, "Session Socket %p (fd=%d) dead\n",
(void *)wsi, pollfd->fd);
- libwebsocket_close_and_free_session(this, wsi,
+ libwebsocket_close_and_free_session(context, wsi,
LWS_CLOSE_STATUS_NOSTATUS);
return 1;
}
pollfd->events &= ~POLLOUT;
/* external POLL support via protocol 0 */
- this->protocols[0].callback(this, wsi,
+ context->protocols[0].callback(context, wsi,
LWS_CALLBACK_CLEAR_MODE_POLL_FD,
(void *)(long)wsi->sock, NULL, POLLOUT);
- wsi->protocol->callback(this, wsi,
+ wsi->protocol->callback(context, wsi,
LWS_CALLBACK_CLIENT_WRITEABLE,
wsi->user_space,
NULL, 0);
break;
}
if (!n) {
- libwebsocket_close_and_free_session(this, wsi,
+ libwebsocket_close_and_free_session(context, wsi,
LWS_CLOSE_STATUS_NOSTATUS);
return 1;
}
/* service incoming data */
- n = libwebsocket_read(this, wsi, buf, n);
+ n = libwebsocket_read(context, wsi, buf, n);
if (n >= 0)
break;
/**
* libwebsocket_context_destroy() - Destroy the websocket context
- * @this: Websocket context
+ * @context: Websocket context
*
* This function closes any active connections and then frees the
* context. After calling this, any further use of the context is
* undefined.
*/
void
-libwebsocket_context_destroy(struct libwebsocket_context *this)
+libwebsocket_context_destroy(struct libwebsocket_context *context)
{
int n;
int m;
struct libwebsocket *wsi;
for (n = 0; n < FD_HASHTABLE_MODULUS; n++)
- for (m = 0; m < this->fd_hashtable[n].length; m++) {
- wsi = this->fd_hashtable[n].wsi[m];
- libwebsocket_close_and_free_session(this, wsi,
+ for (m = 0; m < context->fd_hashtable[n].length; m++) {
+ wsi = context->fd_hashtable[n].wsi[m];
+ libwebsocket_close_and_free_session(context, wsi,
LWS_CLOSE_STATUS_GOINGAWAY);
}
- close(this->fd_random);
+#ifdef WIN32
+#else
+ close(context->fd_random);
+#endif
#ifdef LWS_OPENSSL_SUPPORT
- if (this->ssl_ctx)
- SSL_CTX_free(this->ssl_ctx);
- if (this->ssl_client_ctx)
- SSL_CTX_free(this->ssl_client_ctx);
+ if (context->ssl_ctx)
+ SSL_CTX_free(context->ssl_ctx);
+ if (context->ssl_client_ctx)
+ SSL_CTX_free(context->ssl_client_ctx);
#endif
- free(this);
+ free(context);
+
+#ifdef WIN32
+ WSACleanup();
+#endif
}
/**
* libwebsocket_service() - Service any pending websocket activity
- * @this: Websocket context
+ * @context: Websocket context
* @timeout_ms: Timeout for poll; 0 means return immediately if nothing needed
* service otherwise block and service immediately, returning
* after the timeout if nothing needed service.
int
-libwebsocket_service(struct libwebsocket_context *this, int timeout_ms)
+libwebsocket_service(struct libwebsocket_context *context, int timeout_ms)
{
int n;
/* stay dead once we are dead */
- if (this == NULL)
+ if (context == NULL)
return 1;
/* wait for something to need service */
- n = poll(this->fds, this->fds_count, timeout_ms);
+ n = poll(context->fds, context->fds_count, timeout_ms);
if (n == 0) /* poll timeout */
return 0;
/* handle accept on listening socket? */
- for (n = 0; n < this->fds_count; n++)
- if (this->fds[n].revents)
- libwebsocket_service_fd(this, &this->fds[n]);
+ for (n = 0; n < context->fds_count; n++)
+ if (context->fds[n].revents)
+ libwebsocket_service_fd(context, &context->fds[n]);
return 0;
}
* becomes able to be written to without
* blocking
*
- * @this: libwebsockets context
+ * @context: libwebsockets context
* @wsi: Websocket connection instance to get callback for
*/
int
-libwebsocket_callback_on_writable(struct libwebsocket_context *this,
+libwebsocket_callback_on_writable(struct libwebsocket_context *context,
struct libwebsocket *wsi)
{
int n;
- for (n = 0; n < this->fds_count; n++)
- if (this->fds[n].fd == wsi->sock) {
- this->fds[n].events |= POLLOUT;
- n = this->fds_count;
+ for (n = 0; n < context->fds_count; n++)
+ if (context->fds[n].fd == wsi->sock) {
+ context->fds[n].events |= POLLOUT;
+ n = context->fds_count;
}
/* external POLL support via protocol 0 */
- this->protocols[0].callback(this, wsi,
+ context->protocols[0].callback(context, wsi,
LWS_CALLBACK_SET_MODE_POLL_FD,
(void *)(long)wsi->sock, NULL, POLLOUT);
libwebsocket_callback_on_writable_all_protocol(
const struct libwebsocket_protocols *protocol)
{
- struct libwebsocket_context *this = protocol->owning_server;
+ struct libwebsocket_context *context = protocol->owning_server;
int n;
int m;
struct libwebsocket *wsi;
for (n = 0; n < FD_HASHTABLE_MODULUS; n++) {
- for (m = 0; m < this->fd_hashtable[n].length; m++) {
+ for (m = 0; m < context->fd_hashtable[n].length; m++) {
- wsi = this->fd_hashtable[n].wsi[m];
+ wsi = context->fd_hashtable[n].wsi[m];
if (wsi->protocol == protocol)
- libwebsocket_callback_on_writable(this, wsi);
+ libwebsocket_callback_on_writable(context, wsi);
}
}
int
libwebsocket_rx_flow_control(struct libwebsocket *wsi, int enable)
{
- struct libwebsocket_context *this = wsi->protocol->owning_server;
+ struct libwebsocket_context *context = wsi->protocol->owning_server;
int n;
- for (n = 0; n < this->fds_count; n++)
- if (this->fds[n].fd == wsi->sock) {
+ for (n = 0; n < context->fds_count; n++)
+ if (context->fds[n].fd == wsi->sock) {
if (enable)
- this->fds[n].events |= POLLIN;
+ context->fds[n].events |= POLLIN;
else
- this->fds[n].events &= ~POLLIN;
+ context->fds[n].events &= ~POLLIN;
return 0;
}
if (enable)
/* external POLL support via protocol 0 */
- this->protocols[0].callback(this, wsi,
+ context->protocols[0].callback(context, wsi,
LWS_CALLBACK_SET_MODE_POLL_FD,
(void *)(long)wsi->sock, NULL, POLLIN);
else
/* external POLL support via protocol 0 */
- this->protocols[0].callback(this, wsi,
+ context->protocols[0].callback(context, wsi,
LWS_CALLBACK_CLEAR_MODE_POLL_FD,
(void *)(long)wsi->sock, NULL, POLLIN);
* when making a client connection. You can only call it after the context
* has been created.
*
- * @this: Websocket context
+ * @context: Websocket context
*/
extern const char *
-libwebsocket_canonical_hostname(struct libwebsocket_context *this)
+libwebsocket_canonical_hostname(struct libwebsocket_context *context)
{
- return (const char *)this->canonical_hostname;
+ return (const char *)context->canonical_hostname;
}
SSL *ssl;
int n;
-// struct libwebsocket_context *this;
+// struct libwebsocket_context *context;
ssl = X509_STORE_CTX_get_ex_data(x509_ctx,
SSL_get_ex_data_X509_STORE_CTX_idx());
/*
- * !!! can't get this->openssl_websocket_private_data_index
+ * !!! can't get context->openssl_websocket_private_data_index
* can't store as a static either
*/
-// this = SSL_get_ex_data(ssl, this->openssl_websocket_private_data_index);
+// context = SSL_get_ex_data(ssl,
+// context->openssl_websocket_private_data_index);
- n = this->protocols[0].callback(NULL, NULL,
+ n = context->protocols[0].callback(NULL, NULL,
LWS_CALLBACK_OPENSSL_PERFORM_CLIENT_CERT_VERIFICATION,
x509_ctx, ssl, preverify_ok);
* @port: Port to listen on... you can use 0 to suppress listening on
* any port, that's what you want if you are not running a
* websocket server at all but just using it as a client
- * @interface: NULL to bind the listen socket to all interfaces, or the
+ * @interf: NULL to bind the listen socket to all interfaces, or the
* interface name, eg, "eth2"
* @protocols: Array of structures listing supported protocols and a protocol-
* specific callback for each one. The list is ended with an
*/
struct libwebsocket_context *
-libwebsocket_create_context(int port, const char *interface,
+libwebsocket_create_context(int port, const char *interf,
struct libwebsocket_protocols *protocols,
const char *ssl_cert_filepath,
const char *ssl_private_key_filepath,
int fd;
struct sockaddr_in serv_addr, cli_addr;
int opt = 1;
- struct libwebsocket_context *this = NULL;
+ struct libwebsocket_context *context = NULL;
unsigned int slen;
char *p;
char hostname[1024];
char ssl_err_buf[512];
#endif
- this = malloc(sizeof(struct libwebsocket_context));
- if (!this) {
+#ifdef _WIN32
+ {
+ WORD wVersionRequested;
+ WSADATA wsaData;
+ int err;
+
+ /* Use the MAKEWORD(lowbyte, highbyte) macro from Windef.h */
+ wVersionRequested = MAKEWORD(2, 2);
+
+ err = WSAStartup(wVersionRequested, &wsaData);
+ if (err != 0) {
+ /* Tell the user that we could not find a usable */
+ /* Winsock DLL. */
+ fprintf(stderr, "WSAStartup failed with error: %d\n",
+ err);
+ return NULL;
+ }
+ }
+#endif
+
+
+ context = malloc(sizeof(struct libwebsocket_context));
+ if (!context) {
fprintf(stderr, "No memory for websocket context\n");
return NULL;
}
- this->protocols = protocols;
- this->listen_port = port;
- this->http_proxy_port = 0;
- this->http_proxy_address[0] = '\0';
- this->options = options;
- this->fds_count = 0;
-
- this->fd_random = open(SYSTEM_RANDOM_FILEPATH, O_RDONLY);
- if (this->fd_random < 0) {
+ context->protocols = protocols;
+ context->listen_port = port;
+ context->http_proxy_port = 0;
+ context->http_proxy_address[0] = '\0';
+ context->options = options;
+ context->fds_count = 0;
+
+#ifdef WIN32
+ context->fd_random = 0;
+#else
+ context->fd_random = open(SYSTEM_RANDOM_FILEPATH, O_RDONLY);
+ if (context->fd_random < 0) {
fprintf(stderr, "Unable to open random device %s %d\n",
- SYSTEM_RANDOM_FILEPATH, this->fd_random);
+ SYSTEM_RANDOM_FILEPATH, context->fd_random);
return NULL;
}
+#endif
+#ifdef LWS_OPENSSL_SUPPORT
+ context->use_ssl = 0;
+ context->ssl_ctx = NULL;
+ context->ssl_client_ctx = NULL;
+ context->openssl_websocket_private_data_index = 0;
+#endif
/* find canonical hostname */
hostname[(sizeof hostname) - 1] = '\0';
gethostname(hostname, (sizeof hostname) - 1);
he = gethostbyname(hostname);
if (he) {
- strncpy(this->canonical_hostname, he->h_name,
- sizeof this->canonical_hostname - 1);
- this->canonical_hostname[sizeof this->canonical_hostname - 1] =
- '\0';
+ strncpy(context->canonical_hostname, he->h_name,
+ sizeof context->canonical_hostname - 1);
+ context->canonical_hostname[
+ sizeof context->canonical_hostname - 1] = '\0';
} else
- strncpy(this->canonical_hostname, hostname,
- sizeof this->canonical_hostname - 1);
+ strncpy(context->canonical_hostname, hostname,
+ sizeof context->canonical_hostname - 1);
/* split the proxy ads:port if given */
p = getenv("http_proxy");
if (p) {
- strncpy(this->http_proxy_address, p,
- sizeof this->http_proxy_address - 1);
- this->http_proxy_address[
- sizeof this->http_proxy_address - 1] = '\0';
+ strncpy(context->http_proxy_address, p,
+ sizeof context->http_proxy_address - 1);
+ context->http_proxy_address[
+ sizeof context->http_proxy_address - 1] = '\0';
- p = strchr(this->http_proxy_address, ':');
+ p = strchr(context->http_proxy_address, ':');
if (p == NULL) {
fprintf(stderr, "http_proxy needs to be ads:port\n");
return NULL;
}
*p = '\0';
- this->http_proxy_port = atoi(p + 1);
+ context->http_proxy_port = atoi(p + 1);
fprintf(stderr, "Using proxy %s:%u\n",
- this->http_proxy_address,
- this->http_proxy_port);
+ context->http_proxy_address,
+ context->http_proxy_port);
}
if (port) {
#ifdef LWS_OPENSSL_SUPPORT
- this->use_ssl = ssl_cert_filepath != NULL &&
+ context->use_ssl = ssl_cert_filepath != NULL &&
ssl_private_key_filepath != NULL;
- if (this->use_ssl)
+ if (context->use_ssl)
fprintf(stderr, " Compiled with SSL support, "
"using it\n");
else
}
/* ignore SIGPIPE */
-
+#ifdef WIN32
+#else
signal(SIGPIPE, sigpipe_handler);
+#endif
#ifdef LWS_OPENSSL_SUPPORT
OpenSSL_add_all_algorithms();
SSL_load_error_strings();
- this->openssl_websocket_private_data_index =
+ context->openssl_websocket_private_data_index =
SSL_get_ex_new_index(0, "libwebsockets", NULL, NULL, NULL);
/*
ERR_error_string(ERR_get_error(), ssl_err_buf));
return NULL;
}
- this->ssl_ctx = SSL_CTX_new(method); /* create context */
- if (!this->ssl_ctx) {
+ context->ssl_ctx = SSL_CTX_new(method); /* create context */
+ if (!context->ssl_ctx) {
fprintf(stderr, "problem creating ssl context: %s\n",
ERR_error_string(ERR_get_error(), ssl_err_buf));
return NULL;
}
/* client context */
+ if (port == CONTEXT_PORT_NO_LISTEN)
+ {
+ method = (SSL_METHOD *)SSLv23_client_method();
+ if (!method) {
+ fprintf(stderr, "problem creating ssl method: %s\n",
+ ERR_error_string(ERR_get_error(), ssl_err_buf));
+ return NULL;
+ }
+ /* create context */
+ context->ssl_client_ctx = SSL_CTX_new(method);
+ if (!context->ssl_client_ctx) {
+ fprintf(stderr, "problem creating ssl context: %s\n",
+ ERR_error_string(ERR_get_error(), ssl_err_buf));
+ return NULL;
+ }
- method = (SSL_METHOD *)SSLv23_client_method();
- if (!method) {
- fprintf(stderr, "problem creating ssl method: %s\n",
- ERR_error_string(ERR_get_error(), ssl_err_buf));
- return NULL;
- }
- this->ssl_client_ctx = SSL_CTX_new(method); /* create context */
- if (!this->ssl_client_ctx) {
- fprintf(stderr, "problem creating ssl context: %s\n",
- ERR_error_string(ERR_get_error(), ssl_err_buf));
- return NULL;
- }
-
-
- /* openssl init for cert verification (used with client sockets) */
+ /* openssl init for cert verification (for client sockets) */
- if (!SSL_CTX_load_verify_locations(this->ssl_client_ctx, NULL,
- LWS_OPENSSL_CLIENT_CERTS)) {
- fprintf(stderr, "Unable to load SSL Client certs from %s "
- "(set by --with-client-cert-dir= in configure) -- "
- " client ssl isn't going to work",
+ if (!SSL_CTX_load_verify_locations(
+ context->ssl_client_ctx, NULL,
+ LWS_OPENSSL_CLIENT_CERTS))
+ fprintf(stderr,
+ "Unable to load SSL Client certs from %s "
+ "(set by --with-client-cert-dir= in configure) -- "
+ " client ssl isn't going to work",
LWS_OPENSSL_CLIENT_CERTS);
- }
- /*
- * callback allowing user code to load extra verification certs
- * helping the client to verify server identity
- */
-
- this->protocols[0].callback(this, NULL,
- LWS_CALLBACK_OPENSSL_LOAD_EXTRA_CLIENT_VERIFY_CERTS,
- this->ssl_client_ctx, NULL, 0);
+ /*
+ * callback allowing user code to load extra verification certs
+ * helping the client to verify server identity
+ */
+ context->protocols[0].callback(context, NULL,
+ LWS_CALLBACK_OPENSSL_LOAD_EXTRA_CLIENT_VERIFY_CERTS,
+ context->ssl_client_ctx, NULL, 0);
+ }
/* as a server, are we requiring clients to identify themselves? */
if (options & LWS_SERVER_OPTION_REQUIRE_VALID_OPENSSL_CLIENT_CERT) {
/* absolutely require the client cert */
- SSL_CTX_set_verify(this->ssl_ctx,
+ SSL_CTX_set_verify(context->ssl_ctx,
SSL_VERIFY_PEER | SSL_VERIFY_FAIL_IF_NO_PEER_CERT,
OpenSSL_verify_callback);
* allowing it to verify incoming client certs
*/
- this->protocols[0].callback(this, NULL,
+ context->protocols[0].callback(context, NULL,
LWS_CALLBACK_OPENSSL_LOAD_EXTRA_SERVER_VERIFY_CERTS,
- this->ssl_ctx, NULL, 0);
+ context->ssl_ctx, NULL, 0);
}
- if (this->use_ssl) {
+ if (context->use_ssl) {
/* openssl init for server sockets */
/* set the local certificate from CertFile */
- n = SSL_CTX_use_certificate_file(this->ssl_ctx,
+ n = SSL_CTX_use_certificate_file(context->ssl_ctx,
ssl_cert_filepath, SSL_FILETYPE_PEM);
if (n != 1) {
fprintf(stderr, "problem getting cert '%s': %s\n",
return NULL;
}
/* set the private key from KeyFile */
- if (SSL_CTX_use_PrivateKey_file(this->ssl_ctx,
- ssl_private_key_filepath,
- SSL_FILETYPE_PEM) != 1) {
+ if (SSL_CTX_use_PrivateKey_file(context->ssl_ctx,
+ ssl_private_key_filepath, SSL_FILETYPE_PEM) != 1) {
fprintf(stderr, "ssl problem getting key '%s': %s\n",
ssl_private_key_filepath,
ERR_error_string(ERR_get_error(), ssl_err_buf));
return NULL;
}
/* verify private key */
- if (!SSL_CTX_check_private_key(this->ssl_ctx)) {
+ if (!SSL_CTX_check_private_key(context->ssl_ctx)) {
fprintf(stderr, "Private SSL key doesn't match cert\n");
return NULL;
}
/* fd hashtable init */
for (n = 0; n < FD_HASHTABLE_MODULUS; n++)
- this->fd_hashtable[n].length = 0;
+ context->fd_hashtable[n].length = 0;
/* set up our external listening socket we serve on */
bzero((char *) &serv_addr, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
- if (interface == NULL)
+ if (interf == NULL)
serv_addr.sin_addr.s_addr = INADDR_ANY;
else
- interface_to_sa(interface, &serv_addr,
+ interface_to_sa(interf, &serv_addr,
sizeof(serv_addr));
serv_addr.sin_port = htons(port);
memset(wsi, 0, sizeof (struct libwebsocket));
wsi->sock = sockfd;
wsi->mode = LWS_CONNMODE_SERVER_LISTENER;
- insert_wsi(this, wsi);
+ insert_wsi(context, wsi);
listen(sockfd, 5);
fprintf(stderr, " Listening on port %d\n", port);
/* list in the internal poll array */
- this->fds[this->fds_count].fd = sockfd;
- this->fds[this->fds_count++].events = POLLIN;
+ context->fds[context->fds_count].fd = sockfd;
+ context->fds[context->fds_count++].events = POLLIN;
/* external POLL support via protocol 0 */
- this->protocols[0].callback(this, wsi,
+ context->protocols[0].callback(context, wsi,
LWS_CALLBACK_ADD_POLL_FD,
(void *)(long)sockfd, NULL, POLLIN);
}
/* drop any root privs for this process */
-
+#ifdef WIN32
+#else
if (gid != -1)
if (setgid(gid))
fprintf(stderr, "setgid: %s\n", strerror(errno));
if (uid != -1)
if (setuid(uid))
fprintf(stderr, "setuid: %s\n", strerror(errno));
-
+#endif
/* set up our internal broadcast trigger sockets per-protocol */
- for (this->count_protocols = 0;
- protocols[this->count_protocols].callback;
- this->count_protocols++) {
- protocols[this->count_protocols].owning_server = this;
- protocols[this->count_protocols].protocol_index =
- this->count_protocols;
+ for (context->count_protocols = 0;
+ protocols[context->count_protocols].callback;
+ context->count_protocols++) {
+ protocols[context->count_protocols].owning_server = context;
+ protocols[context->count_protocols].protocol_index =
+ context->count_protocols;
fd = socket(AF_INET, SOCK_STREAM, 0);
if (fd < 0) {
fprintf(stderr, "getsockname failed\n");
return NULL;
}
- protocols[this->count_protocols].broadcast_socket_port =
+ protocols[context->count_protocols].broadcast_socket_port =
ntohs(cli_addr.sin_port);
listen(fd, 5);
debug(" Protocol %s broadcast socket %d\n",
- protocols[this->count_protocols].name,
+ protocols[context->count_protocols].name,
ntohs(cli_addr.sin_port));
/* dummy wsi per broadcast proxy socket */
wsi->sock = fd;
wsi->mode = LWS_CONNMODE_BROADCAST_PROXY_LISTENER;
/* note which protocol we are proxying */
- wsi->protocol_index_for_broadcast_proxy = this->count_protocols;
- insert_wsi(this, wsi);
+ wsi->protocol_index_for_broadcast_proxy =
+ context->count_protocols;
+ insert_wsi(context, wsi);
/* list in internal poll array */
- this->fds[this->fds_count].fd = fd;
- this->fds[this->fds_count].events = POLLIN;
- this->fds[this->fds_count].revents = 0;
- this->fds_count++;
+ context->fds[context->fds_count].fd = fd;
+ context->fds[context->fds_count].events = POLLIN;
+ context->fds[context->fds_count].revents = 0;
+ context->fds_count++;
/* external POLL support via protocol 0 */
- this->protocols[0].callback(this, wsi,
+ context->protocols[0].callback(context, wsi,
LWS_CALLBACK_ADD_POLL_FD,
(void *)(long)fd, NULL, POLLIN);
}
- return this;
+ return context;
}
* have to make sure you are calling
* libwebsocket_service periodically to service
* the websocket traffic
- * @this: server context returned by creation function
+ * @context: server context returned by creation function
*/
int
-libwebsockets_fork_service_loop(struct libwebsocket_context *this)
+libwebsockets_fork_service_loop(struct libwebsocket_context *context)
{
int fd;
struct sockaddr_in cli_addr;
* service process context
*/
- for (p = 0; p < this->count_protocols; p++) {
+ for (p = 0; p < context->count_protocols; p++) {
fd = socket(AF_INET, SOCK_STREAM, 0);
if (fd < 0) {
fprintf(stderr, "Unable to create socket\n");
}
cli_addr.sin_family = AF_INET;
cli_addr.sin_port = htons(
- this->protocols[p].broadcast_socket_port);
+ context->protocols[p].broadcast_socket_port);
cli_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
n = connect(fd, (struct sockaddr *)&cli_addr,
sizeof cli_addr);
return -1;
}
- this->protocols[p].broadcast_socket_user_fd = fd;
+ context->protocols[p].broadcast_socket_user_fd = fd;
}
return 0;
/* in this forked process, sit and service websocket connections */
while (1)
- if (libwebsocket_service(this, 1000))
+ if (libwebsocket_service(context, 1000))
return -1;
return 0;
libwebsockets_broadcast(const struct libwebsocket_protocols *protocol,
unsigned char *buf, size_t len)
{
- struct libwebsocket_context *this = protocol->owning_server;
+ struct libwebsocket_context *context = protocol->owning_server;
int n;
int m;
struct libwebsocket * wsi;
for (n = 0; n < FD_HASHTABLE_MODULUS; n++) {
- for (m = 0; m < this->fd_hashtable[n].length; m++) {
+ for (m = 0; m < context->fd_hashtable[n].length; m++) {
- wsi = this->fd_hashtable[n].wsi[m];
+ wsi = context->fd_hashtable[n].wsi[m];
if (wsi->mode != LWS_CONNMODE_WS_SERVING)
continue;
if (wsi->protocol != protocol)
continue;
- wsi->protocol->callback(this, wsi,
+ wsi->protocol->callback(context, wsi,
LWS_CALLBACK_BROADCAST,
wsi->user_space,
buf, len);
#ifndef __LIBWEBSOCKET_H__
#define __LIBWEBSOCKET_H__
+#ifdef WIN32
+
+#ifndef WIN32_LEAN_AND_MEAN
+#define WIN32_LEAN_AND_MEAN
+#endif
+#include <winsock2.h>
+#include <ws2tcpip.h>
+#include "websock-w32.h"
+#include "gettimeofday.h"
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+#else
#include <poll.h>
+#endif
#define CONTEXT_PORT_NO_LISTEN 0
LWS_CALLBACK_OPENSSL_LOAD_EXTRA_SERVER_VERIFY_CERTS,
LWS_CALLBACK_OPENSSL_PERFORM_CLIENT_CERT_VERIFICATION,
LWS_CALLBACK_CLIENT_APPEND_HANDSHAKE_HEADER,
-
/* external poll() management support */
LWS_CALLBACK_ADD_POLL_FD,
LWS_CALLBACK_DEL_POLL_FD,
};
extern struct libwebsocket_context *
-libwebsocket_create_context(int port, const char * interface,
+libwebsocket_create_context(int port, const char * interf,
struct libwebsocket_protocols *protocols,
const char *ssl_cert_filepath,
const char *ssl_private_key_filepath, int gid, int uid,
libwebsocket_close_and_free_session(struct libwebsocket_context *context,
struct libwebsocket *wsi, enum lws_close_status);
+#ifdef WIN32
+#ifdef __cplusplus
+}
+#endif
+#endif
#endif
#include "private-libwebsockets.h"
const struct lws_tokens lws_tokens[WSI_TOKEN_COUNT] = {
- [WSI_TOKEN_GET_URI] = { "GET ", 4 },
- [WSI_TOKEN_HOST] = { "Host:", 5 },
- [WSI_TOKEN_CONNECTION] = { "Connection:", 11 },
- [WSI_TOKEN_KEY1] = { "Sec-WebSocket-Key1:", 19 },
- [WSI_TOKEN_KEY2] = { "Sec-WebSocket-Key2:", 19 },
- [WSI_TOKEN_PROTOCOL] = { "Sec-WebSocket-Protocol:", 23 },
- [WSI_TOKEN_UPGRADE] = { "Upgrade:", 8 },
- [WSI_TOKEN_EXTENSIONS] = { "Sec-WebSocket-Extensions:", 25 },
- [WSI_TOKEN_ORIGIN] = { "Origin:", 7 },
- [WSI_TOKEN_DRAFT] = { "Sec-WebSocket-Draft:", 20 },
- [WSI_TOKEN_CHALLENGE] = { "\x0d\x0a", 2 },
-
- [WSI_TOKEN_KEY] = { "Sec-WebSocket-Key:", 18 },
- [WSI_TOKEN_VERSION] = { "Sec-WebSocket-Version:", 22 },
-
- [WSI_TOKEN_ACCEPT] = { "Sec-WebSocket-Accept:", 21 },
- [WSI_TOKEN_NONCE] = { "Sec-WebSocket-Nonce:", 20 },
- [WSI_TOKEN_HTTP] = { "HTTP/1.1 ", 9 },
- [WSI_TOKEN_SWORIGIN] = { "Sec-WebSocket-Origin:", 21 },
+
+ /* win32 can't do C99 */
+
+/* [WSI_TOKEN_GET_URI] = */{ "GET ", 4 },
+/* [WSI_TOKEN_HOST] = */{ "Host:", 5 },
+/* [WSI_TOKEN_CONNECTION] = */{ "Connection:", 11 },
+/* [WSI_TOKEN_KEY1] = */{ "Sec-WebSocket-Key1:", 19 },
+/* [WSI_TOKEN_KEY2] = */{ "Sec-WebSocket-Key2:", 19 },
+/* [WSI_TOKEN_PROTOCOL] = */{ "Sec-WebSocket-Protocol:", 23 },
+/* [WSI_TOKEN_UPGRADE] = */{ "Upgrade:", 8 },
+/* [WSI_TOKEN_ORIGIN] = */{ "Origin:", 7 },
+/* [WSI_TOKEN_DRAFT] = */{ "Sec-WebSocket-Draft:", 20 },
+/* [WSI_TOKEN_CHALLENGE] = */{ "\x0d\x0a", 2 },
+
+/* [WSI_TOKEN_KEY] = */{ "Sec-WebSocket-Key:", 18 },
+/* [WSI_TOKEN_VERSION] = */{ "Sec-WebSocket-Version:", 22 },
+/* [WSI_TOKEN_SWORIGIN]= */{ "Sec-WebSocket-Origin:", 21 },
+
+/* [WSI_TOKEN_EXTENSIONS] = */{ "Sec-WebSocket-Extensions:", 25 },
+
+/* [WSI_TOKEN_ACCEPT] = */{ "Sec-WebSocket-Accept:", 21 },
+/* [WSI_TOKEN_NONCE] = */{ "Sec-WebSocket-Nonce:", 20 },
+/* [WSI_TOKEN_HTTP] = */{ "HTTP/1.1 ", 9 },
};
/* -76 has no version header ... server */
if (!wsi->utf8_token[WSI_TOKEN_VERSION].token_len &&
- wsi->mode != LWS_CONNMODE_WS_CLIENT_WAITING_SERVER_REPLY &&
+ wsi->mode != LWS_CONNMODE_WS_CLIENT_WAITING_SERVER_REPLY &&
wsi->utf8_token[wsi->parser_state].token_len != 8)
break;
/* -76 has no version header ... client */
if (!wsi->utf8_token[WSI_TOKEN_VERSION].token_len &&
- wsi->mode == LWS_CONNMODE_WS_CLIENT_WAITING_SERVER_REPLY &&
- wsi->utf8_token[wsi->parser_state].token_len != 16)
+ wsi->mode == LWS_CONNMODE_WS_CLIENT_WAITING_SERVER_REPLY &&
+ wsi->utf8_token[wsi->parser_state].token_len != 16)
break;
-
/* <= 03 has old handshake with version header needs 8 bytes */
if (wsi->utf8_token[WSI_TOKEN_VERSION].token_len &&
atoi(wsi->utf8_token[WSI_TOKEN_VERSION].token) < 4 &&
/* fetch the per-frame nonce */
- n = read(wsi->protocol->owning_server->fd_random,
+ n = libwebsockets_get_random(wsi->protocol->owning_server,
wsi->frame_masking_nonce_04, 4);
if (n != 4) {
fprintf(stderr, "Unable to read from random device %s %d\n",
const char *content_type)
{
int fd;
- struct stat stat;
+ struct stat stat_buf;
char buf[512];
char *p = buf;
int n;
return -1;
}
- fstat(fd, &stat);
+ fstat(fd, &stat_buf);
p += sprintf(p, "HTTP/1.0 200 OK\x0d\x0a"
"Server: libwebsockets\x0d\x0a"
"Content-Type: %s\x0d\x0a"
"Content-Length: %u\x0d\x0a"
- "\x0d\x0a", content_type, (unsigned int)stat.st_size);
+ "\x0d\x0a", content_type, (unsigned int)stat_buf.st_size);
libwebsocket_write(wsi, (unsigned char *)buf, p - buf, LWS_WRITE_HTTP);
#include <fcntl.h>
#include <signal.h>
#include <netdb.h>
+#include <stdarg.h>
-#include <sys/types.h>
#include <sys/stat.h>
+
+#ifdef WIN32
+
+#include <time.h >
+#include <winsock2.h>
+#include <ws2ipdef.h>
+#include <windows.h>
+
+#else
+
+#include <sys/types.h>
#include <sys/socket.h>
#ifndef LWS_NO_FORK
#include <sys/prctl.h>
#include <sys/mman.h>
#include <sys/time.h>
+#endif
+
#ifdef LWS_OPENSSL_SUPPORT
#include <openssl/ssl.h>
#include <openssl/evp.h>
#endif
#ifdef DEBUG
-static inline void debug(const char *format, ...)
+#ifdef WIN32
+static
+#else
+static inline
+#endif
+void debug(const char *format, ...)
{
va_list ap;
va_start(ap, format); vfprintf(stderr, format, ap); va_end(ap);
unsigned char *buf, size_t len);
extern int
-libwebsocket_read(struct libwebsocket_context *this, struct libwebsocket *wsi,
+libwebsocket_read(struct libwebsocket_context *context, struct libwebsocket *wsi,
unsigned char * buf, size_t len);
extern int
xor_mask_05(struct libwebsocket *wsi, unsigned char c);
extern struct libwebsocket *
-wsi_from_fd(struct libwebsocket_context *this, int fd);
+wsi_from_fd(struct libwebsocket_context *context, int fd);
extern int
-insert_wsi(struct libwebsocket_context *this, struct libwebsocket *wsi);
+insert_wsi(struct libwebsocket_context *context, struct libwebsocket *wsi);
extern int
-delete_from_fd(struct libwebsocket_context *this, int fd);
+delete_from_fd(struct libwebsocket_context *context, int fd);
extern void
libwebsocket_set_timeout(struct libwebsocket *wsi,
enum pending_timeout reason, int secs);
+extern int
+libwebsockets_get_random(struct libwebsocket_context *context,
+ void *buf, int len);
+
#ifndef LWS_OPENSSL_SUPPORT
unsigned char *
*/
#include <sys/types.h>
+#ifdef WIN32
+
+typedef unsigned char u_int8_t;
+typedef unsigned int u_int32_t;
+typedef unsigned __int64 u_int64_t;
+typedef void* caddr_t;
+
+#undef __P
+#ifndef __P
+#if __STDC__
+#define __P(protos) protos
+#else
+#define __P(protos) ()
+#endif
+#endif
+
+#define bzero(b,len) (memset((b), '\0', (len)), (void) 0)
+
+#else
#include <sys/cdefs.h>
#include <sys/time.h>
+#endif
+
#include <string.h>
struct sha1_ctxt {
<h2>libwebsockets_hangup_on_client - Server calls to terminate client connection</h2>
<i>void</i>
<b>libwebsockets_hangup_on_client</b>
-(<i>struct libwebsocket_context *</i> <b>this</b>,
+(<i>struct libwebsocket_context *</i> <b>context</b>,
<i>int</i> <b>fd</b>)
<h3>Arguments</h3>
<dl>
-<dt><b>this</b>
+<dt><b>context</b>
<dd>libwebsockets context
<dt><b>fd</b>
<dd>Connection socket descriptor
<h2>libwebsocket_service_fd - Service polled socket with something waiting</h2>
<i>int</i>
<b>libwebsocket_service_fd</b>
-(<i>struct libwebsocket_context *</i> <b>this</b>,
+(<i>struct libwebsocket_context *</i> <b>context</b>,
<i>struct pollfd *</i> <b>pollfd</b>)
<h3>Arguments</h3>
<dl>
-<dt><b>this</b>
+<dt><b>context</b>
<dd>Websocket context
<dt><b>pollfd</b>
<dd>The pollfd entry describing the socket fd and which events
<h2>libwebsocket_context_destroy - Destroy the websocket context</h2>
<i>void</i>
<b>libwebsocket_context_destroy</b>
-(<i>struct libwebsocket_context *</i> <b>this</b>)
+(<i>struct libwebsocket_context *</i> <b>context</b>)
<h3>Arguments</h3>
<dl>
-<dt><b>this</b>
+<dt><b>context</b>
<dd>Websocket context
</dl>
<h3>Description</h3>
<h2>libwebsocket_service - Service any pending websocket activity</h2>
<i>int</i>
<b>libwebsocket_service</b>
-(<i>struct libwebsocket_context *</i> <b>this</b>,
+(<i>struct libwebsocket_context *</i> <b>context</b>,
<i>int</i> <b>timeout_ms</b>)
<h3>Arguments</h3>
<dl>
-<dt><b>this</b>
+<dt><b>context</b>
<dd>Websocket context
<dt><b>timeout_ms</b>
<dd>Timeout for poll; 0 means return immediately if nothing needed
<h2>libwebsocket_callback_on_writable - Request a callback when this socket becomes able to be written to without blocking</h2>
<i>int</i>
<b>libwebsocket_callback_on_writable</b>
-(<i>struct libwebsocket_context *</i> <b>this</b>,
+(<i>struct libwebsocket_context *</i> <b>context</b>,
<i>struct libwebsocket *</i> <b>wsi</b>)
<h3>Arguments</h3>
<dl>
-<dt><b>this</b>
+<dt><b>context</b>
<dd>libwebsockets context
<dt><b>wsi</b>
<dd>Websocket connection instance to get callback for
<h2>libwebsocket_canonical_hostname - returns this host's hostname</h2>
<i>const char *</i>
<b>libwebsocket_canonical_hostname</b>
-(<i>struct libwebsocket_context *</i> <b>this</b>)
+(<i>struct libwebsocket_context *</i> <b>context</b>)
<h3>Arguments</h3>
<dl>
-<dt><b>this</b>
+<dt><b>context</b>
<dd>Websocket context
</dl>
<h3>Description</h3>
<i>struct libwebsocket_context *</i>
<b>libwebsocket_create_context</b>
(<i>int</i> <b>port</b>,
-<i>const char *</i> <b>interface</b>,
+<i>const char *</i> <b>interf</b>,
<i>struct libwebsocket_protocols *</i> <b>protocols</b>,
<i>const char *</i> <b>ssl_cert_filepath</b>,
<i>const char *</i> <b>ssl_private_key_filepath</b>,
<dd>Port to listen on... you can use 0 to suppress listening on
any port, that's what you want if you are not running a
websocket server at all but just using it as a client
-<dt><b>interface</b>
+<dt><b>interf</b>
<dd>NULL to bind the listen socket to all interfaces, or the
interface name, eg, "eth2"
<dt><b>protocols</b>
<h2>libwebsockets_fork_service_loop - Optional helper function forks off a process for the websocket server loop. You don't have to use this but if not, you have to make sure you are calling libwebsocket_service periodically to service the websocket traffic</h2>
<i>int</i>
<b>libwebsockets_fork_service_loop</b>
-(<i>struct libwebsocket_context *</i> <b>this</b>)
+(<i>struct libwebsocket_context *</i> <b>context</b>)
<h3>Arguments</h3>
<dl>
-<dt><b>this</b>
+<dt><b>context</b>
<dd>server context returned by creation function
</dl>
<hr>
<h2>libwebsocket_client_connect - Connect to another websocket server</h2>
<i>struct libwebsocket *</i>
<b>libwebsocket_client_connect</b>
-(<i>struct libwebsocket_context *</i> <b>this</b>,
+(<i>struct libwebsocket_context *</i> <b>context</b>,
<i>const char *</i> <b>address</b>,
<i>int</i> <b>port</b>,
<i>int</i> <b>ssl_connection</b>,
<i>int</i> <b>ietf_version_or_minus_one</b>)
<h3>Arguments</h3>
<dl>
-<dt><b>this</b>
+<dt><b>context</b>
<dd>Websocket context
<dt><b>address</b>
<dd>Remote server address, eg, "myserver.com"
#include <string.h>
#include "../lib/libwebsockets.h"
-#include <poll.h>
static unsigned int opts;
static int was_closed;
/* list of supported protocols and callbacks */
static struct libwebsocket_protocols protocols[] = {
-
- [PROTOCOL_DUMB_INCREMENT] = {
- .name = "dumb-increment-protocol",
- .callback = callback_dumb_increment,
+ {
+ "dumb-increment-protocol",
+ callback_dumb_increment,
+ 0,
},
- [PROTOCOL_LWS_MIRROR] = {
- .name = "lws-mirror-protocol",
- .callback = callback_lws_mirror,
+ {
+ "lws-mirror-protocol",
+ callback_lws_mirror,
+ 0,
},
- [DEMO_PROTOCOL_COUNT] = { /* end of list */
- .callback = NULL
+ { /* end of list */
+ NULL,
+ NULL,
+ 0
}
};
static struct libwebsocket_protocols protocols[] = {
/* first protocol must always be HTTP handler */
- [PROTOCOL_HTTP] = {
- .name = "http-only",
- .callback = callback_http,
+
+ {
+ "http-only", /* name */
+ callback_http, /* callback */
+ 0 /* per_session_data_size */
},
- [PROTOCOL_DUMB_INCREMENT] = {
- .name = "dumb-increment-protocol",
- .callback = callback_dumb_increment,
- .per_session_data_size =
- sizeof(struct per_session_data__dumb_increment),
+ {
+ "dumb-increment-protocol",
+ callback_dumb_increment,
+ sizeof(struct per_session_data__dumb_increment),
},
- [PROTOCOL_LWS_MIRROR] = {
- .name = "lws-mirror-protocol",
- .callback = callback_lws_mirror,
- .per_session_data_size =
- sizeof(struct per_session_data__lws_mirror),
+ {
+ "lws-mirror-protocol",
+ callback_lws_mirror,
+ sizeof(struct per_session_data__lws_mirror)
},
- [DEMO_PROTOCOL_COUNT] = { /* end of list */
- .callback = NULL
+ {
+ NULL, NULL, 0 /* End of list */
}
};
/* this protocol server (always the first one) just knows how to do HTTP */
-static int callback_http(struct libwebsocket_context * this,
+static int callback_http(struct libwebsocket_context * context,
struct libwebsocket *wsi,
enum libwebsocket_callback_reasons reason, void *user,
void *in, size_t len)
{
int n;
static const char *token_names[] = {
- [WSI_TOKEN_GET_URI] = "GET URI",
- [WSI_TOKEN_HOST] = "Host",
- [WSI_TOKEN_CONNECTION] = "Connection",
- [WSI_TOKEN_KEY1] = "key 1",
- [WSI_TOKEN_KEY2] = "key 2",
- [WSI_TOKEN_PROTOCOL] = "Protocol",
- [WSI_TOKEN_UPGRADE] = "Upgrade",
- [WSI_TOKEN_ORIGIN] = "Origin",
- [WSI_TOKEN_DRAFT] = "Draft",
- [WSI_TOKEN_CHALLENGE] = "Challenge",
+ /*[WSI_TOKEN_GET_URI] =*/ "GET URI",
+ /*[WSI_TOKEN_HOST] =*/ "Host",
+ /*[WSI_TOKEN_CONNECTION] =*/ "Connection",
+ /*[WSI_TOKEN_KEY1] =*/ "key 1",
+ /*[WSI_TOKEN_KEY2] =*/ "key 2",
+ /*[WSI_TOKEN_PROTOCOL] =*/ "Protocol",
+ /*[WSI_TOKEN_UPGRADE] =*/ "Upgrade",
+ /*[WSI_TOKEN_ORIGIN] =*/ "Origin",
+ /*[WSI_TOKEN_DRAFT] =*/ "Draft",
+ /*[WSI_TOKEN_CHALLENGE] =*/ "Challenge",
/* new for 04 */
- [WSI_TOKEN_KEY] = "Key",
- [WSI_TOKEN_VERSION] = "Version",
- [WSI_TOKEN_SWORIGIN] = "Sworigin",
+ /*[WSI_TOKEN_KEY] =*/ "Key",
+ /*[WSI_TOKEN_VERSION] =*/ "Version",
+ /*[WSI_TOKEN_SWORIGIN] =*/ "Sworigin",
/* new for 05 */
- [WSI_TOKEN_EXTENSIONS] = "Extensions",
+ /*[WSI_TOKEN_EXTENSIONS] =*/ "Extensions",
/* client receives these */
- [WSI_TOKEN_ACCEPT] = "Accept",
- [WSI_TOKEN_NONCE] = "Nonce",
- [WSI_TOKEN_HTTP] = "Http",
+ /*[WSI_TOKEN_ACCEPT] =*/ "Accept",
+ /*[WSI_TOKEN_NONCE] =*/ "Nonce",
+ /*[WSI_TOKEN_HTTP] =*/ "Http",
};
for (n = 0; n < WSI_TOKEN_COUNT; n++) {
};
static int
-callback_dumb_increment(struct libwebsocket_context * this,
+callback_dumb_increment(struct libwebsocket_context * context,
struct libwebsocket *wsi,
enum libwebsocket_callback_reasons reason,
void *user, void *in, size_t len)
static int
-callback_lws_mirror(struct libwebsocket_context * this,
+callback_lws_mirror(struct libwebsocket_context * context,
struct libwebsocket *wsi,
enum libwebsocket_callback_reasons reason,
void *user, void *in, size_t len)
MAX_MESSAGE_QUEUE) < (MAX_MESSAGE_QUEUE - 15))
libwebsocket_rx_flow_control(wsi, 1);
- libwebsocket_callback_on_writable(this, wsi);
+ libwebsocket_callback_on_writable(context, wsi);
}
break;
static struct libwebsocket_protocols protocols[] = {
/* first protocol must always be HTTP handler */
- [PROTOCOL_HTTP] = {
- .name = "http-only",
- .callback = callback_http,
+
+ {
+ "http-only", /* name */
+ callback_http, /* callback */
+ 0 /* per_session_data_size */
},
- [PROTOCOL_DUMB_INCREMENT] = {
- .name = "dumb-increment-protocol",
- .callback = callback_dumb_increment,
- .per_session_data_size =
- sizeof(struct per_session_data__dumb_increment),
+ {
+ "dumb-increment-protocol",
+ callback_dumb_increment,
+ sizeof(struct per_session_data__dumb_increment),
},
- [PROTOCOL_LWS_MIRROR] = {
- .name = "lws-mirror-protocol",
- .callback = callback_lws_mirror,
- .per_session_data_size =
- sizeof(struct per_session_data__lws_mirror),
+ {
+ "lws-mirror-protocol",
+ callback_lws_mirror,
+ sizeof(struct per_session_data__lws_mirror)
},
- [DEMO_PROTOCOL_COUNT] = { /* end of list */
- .callback = NULL
+ {
+ NULL, NULL, 0 /* End of list */
}
};
--- /dev/null
+<?xml version="1.0" encoding="utf-8"?>\r
+<Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">\r
+ <ItemGroup Label="ProjectConfigurations">\r
+ <ProjectConfiguration Include="Debug|Win32">\r
+ <Configuration>Debug</Configuration>\r
+ <Platform>Win32</Platform>\r
+ </ProjectConfiguration>\r
+ <ProjectConfiguration Include="Release|Win32">\r
+ <Configuration>Release</Configuration>\r
+ <Platform>Win32</Platform>\r
+ </ProjectConfiguration>\r
+ </ItemGroup>\r
+ <ItemGroup>\r
+ <ClCompile Include="..\..\test-server\test-client.c" />\r
+ <ClCompile Include="..\win32helpers\getopt.c" />\r
+ <ClCompile Include="..\win32helpers\getopt_long.c" />\r
+ <ClCompile Include="..\win32helpers\gettimeofday.c" />\r
+ </ItemGroup>\r
+ <ItemGroup>\r
+ <ProjectReference Include="..\libwebsocketswin32\libwebsocketswin32.vcxproj">\r
+ <Project>{332bf17e-fd30-4363-975a-aa731a827b4f}</Project>\r
+ </ProjectReference>\r
+ </ItemGroup>\r
+ <ItemGroup>\r
+ <ClInclude Include="..\win32helpers\getopt.h" />\r
+ <ClInclude Include="..\win32helpers\gettimeofday.h" />\r
+ </ItemGroup>\r
+ <PropertyGroup Label="Globals">\r
+ <ProjectGuid>{6265650C-4799-451C-A687-94DE48759A8B}</ProjectGuid>\r
+ <Keyword>Win32Proj</Keyword>\r
+ <RootNamespace>client</RootNamespace>\r
+ </PropertyGroup>\r
+ <Import Project="$(VCTargetsPath)\Microsoft.Cpp.Default.props" />\r
+ <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|Win32'" Label="Configuration">\r
+ <ConfigurationType>Application</ConfigurationType>\r
+ <UseDebugLibraries>true</UseDebugLibraries>\r
+ <CharacterSet>Unicode</CharacterSet>\r
+ </PropertyGroup>\r
+ <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Release|Win32'" Label="Configuration">\r
+ <ConfigurationType>Application</ConfigurationType>\r
+ <UseDebugLibraries>false</UseDebugLibraries>\r
+ <WholeProgramOptimization>true</WholeProgramOptimization>\r
+ <CharacterSet>Unicode</CharacterSet>\r
+ </PropertyGroup>\r
+ <Import Project="$(VCTargetsPath)\Microsoft.Cpp.props" />\r
+ <ImportGroup Label="ExtensionSettings">\r
+ </ImportGroup>\r
+ <ImportGroup Label="PropertySheets" Condition="'$(Configuration)|$(Platform)'=='Debug|Win32'">\r
+ <Import Project="$(UserRootDir)\Microsoft.Cpp.$(Platform).user.props" Condition="exists('$(UserRootDir)\Microsoft.Cpp.$(Platform).user.props')" Label="LocalAppDataPlatform" />\r
+ </ImportGroup>\r
+ <ImportGroup Label="PropertySheets" Condition="'$(Configuration)|$(Platform)'=='Release|Win32'">\r
+ <Import Project="$(UserRootDir)\Microsoft.Cpp.$(Platform).user.props" Condition="exists('$(UserRootDir)\Microsoft.Cpp.$(Platform).user.props')" Label="LocalAppDataPlatform" />\r
+ </ImportGroup>\r
+ <PropertyGroup Label="UserMacros" />\r
+ <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|Win32'">\r
+ <LinkIncremental>true</LinkIncremental>\r
+ </PropertyGroup>\r
+ <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Release|Win32'">\r
+ <LinkIncremental>false</LinkIncremental>\r
+ </PropertyGroup>\r
+ <ItemDefinitionGroup Condition="'$(Configuration)|$(Platform)'=='Debug|Win32'">\r
+ <ClCompile>\r
+ <PrecompiledHeader>\r
+ </PrecompiledHeader>\r
+ <WarningLevel>Level3</WarningLevel>\r
+ <Optimization>Disabled</Optimization>\r
+ <PreprocessorDefinitions>WIN32;_DEBUG;_CONSOLE;%(PreprocessorDefinitions)</PreprocessorDefinitions>\r
+ <AdditionalIncludeDirectories>../win32helpers</AdditionalIncludeDirectories>\r
+ </ClCompile>\r
+ <Link>\r
+ <SubSystem>Console</SubSystem>\r
+ <GenerateDebugInformation>true</GenerateDebugInformation>\r
+ <AdditionalDependencies>ws2_32.lib;kernel32.lib;user32.lib;gdi32.lib;winspool.lib;comdlg32.lib;advapi32.lib;shell32.lib;ole32.lib;oleaut32.lib;uuid.lib;odbc32.lib;odbccp32.lib;%(AdditionalDependencies)</AdditionalDependencies>\r
+ </Link>\r
+ </ItemDefinitionGroup>\r
+ <ItemDefinitionGroup Condition="'$(Configuration)|$(Platform)'=='Release|Win32'">\r
+ <ClCompile>\r
+ <WarningLevel>Level3</WarningLevel>\r
+ <PrecompiledHeader>\r
+ </PrecompiledHeader>\r
+ <Optimization>MaxSpeed</Optimization>\r
+ <FunctionLevelLinking>true</FunctionLevelLinking>\r
+ <IntrinsicFunctions>true</IntrinsicFunctions>\r
+ <PreprocessorDefinitions>WIN32;NDEBUG;_CONSOLE;%(PreprocessorDefinitions)</PreprocessorDefinitions>\r
+ <AdditionalIncludeDirectories>../win32helpers</AdditionalIncludeDirectories>\r
+ </ClCompile>\r
+ <Link>\r
+ <SubSystem>Console</SubSystem>\r
+ <GenerateDebugInformation>true</GenerateDebugInformation>\r
+ <EnableCOMDATFolding>true</EnableCOMDATFolding>\r
+ <OptimizeReferences>true</OptimizeReferences>\r
+ <AdditionalDependencies>ws2_32.lib;kernel32.lib;user32.lib;gdi32.lib;winspool.lib;comdlg32.lib;advapi32.lib;shell32.lib;ole32.lib;oleaut32.lib;uuid.lib;odbc32.lib;odbccp32.lib;%(AdditionalDependencies)</AdditionalDependencies>\r
+ </Link>\r
+ </ItemDefinitionGroup>\r
+ <Import Project="$(VCTargetsPath)\Microsoft.Cpp.targets" />\r
+ <ImportGroup Label="ExtensionTargets">\r
+ </ImportGroup>\r
+</Project>
\ No newline at end of file
--- /dev/null
+<?xml version="1.0" encoding="utf-8"?>\r
+<Project ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">\r
+ <ItemGroup>\r
+ <Filter Include="Source Files">\r
+ <UniqueIdentifier>{4FC737F1-C7A5-4376-A066-2A32D752A2FF}</UniqueIdentifier>\r
+ <Extensions>cpp;c;cc;cxx;def;odl;idl;hpj;bat;asm;asmx</Extensions>\r
+ </Filter>\r
+ <Filter Include="Header Files">\r
+ <UniqueIdentifier>{93995380-89BD-4b04-88EB-625FBE52EBFB}</UniqueIdentifier>\r
+ <Extensions>h;hpp;hxx;hm;inl;inc;xsd</Extensions>\r
+ </Filter>\r
+ <Filter Include="Resource Files">\r
+ <UniqueIdentifier>{67DA6AB6-F800-4c08-8B7A-83BB121AAD01}</UniqueIdentifier>\r
+ <Extensions>rc;ico;cur;bmp;dlg;rc2;rct;bin;rgs;gif;jpg;jpeg;jpe;resx;tiff;tif;png;wav;mfcribbon-ms</Extensions>\r
+ </Filter>\r
+ </ItemGroup>\r
+ <ItemGroup>\r
+ <ClCompile Include="..\..\test-server\test-client.c">\r
+ <Filter>Source Files</Filter>\r
+ </ClCompile>\r
+ <ClCompile Include="..\win32helpers\getopt.c">\r
+ <Filter>Source Files</Filter>\r
+ </ClCompile>\r
+ <ClCompile Include="..\win32helpers\getopt_long.c">\r
+ <Filter>Source Files</Filter>\r
+ </ClCompile>\r
+ <ClCompile Include="..\win32helpers\gettimeofday.c">\r
+ <Filter>Source Files</Filter>\r
+ </ClCompile>\r
+ </ItemGroup>\r
+ <ItemGroup>\r
+ <ClInclude Include="..\win32helpers\getopt.h">\r
+ <Filter>Source Files</Filter>\r
+ </ClInclude>\r
+ <ClInclude Include="..\win32helpers\gettimeofday.h">\r
+ <Filter>Source Files</Filter>\r
+ </ClInclude>\r
+ </ItemGroup>\r
+</Project>
\ No newline at end of file
--- /dev/null
+<?xml version="1.0" encoding="utf-8"?>\r
+<Project ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">\r
+ <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|Win32'">\r
+ <LocalDebuggerCommandArguments>127.0.0.1</LocalDebuggerCommandArguments>\r
+ <DebuggerFlavor>WindowsLocalDebugger</DebuggerFlavor>\r
+ </PropertyGroup>\r
+</Project>
\ No newline at end of file
--- /dev/null
+<?xml version="1.0" encoding="utf-8"?>\r
+<Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">\r
+ <ItemGroup Label="ProjectConfigurations">\r
+ <ProjectConfiguration Include="Debug|Win32">\r
+ <Configuration>Debug</Configuration>\r
+ <Platform>Win32</Platform>\r
+ </ProjectConfiguration>\r
+ <ProjectConfiguration Include="Release|Win32">\r
+ <Configuration>Release</Configuration>\r
+ <Platform>Win32</Platform>\r
+ </ProjectConfiguration>\r
+ </ItemGroup>\r
+ <PropertyGroup Label="Globals">\r
+ <ProjectGuid>{332BF17E-FD30-4363-975A-AA731A827B4F}</ProjectGuid>\r
+ <Keyword>Win32Proj</Keyword>\r
+ <RootNamespace>libwebsocketswin32</RootNamespace>\r
+ </PropertyGroup>\r
+ <Import Project="$(VCTargetsPath)\Microsoft.Cpp.Default.props" />\r
+ <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|Win32'" Label="Configuration">\r
+ <ConfigurationType>StaticLibrary</ConfigurationType>\r
+ <UseDebugLibraries>true</UseDebugLibraries>\r
+ <CharacterSet>Unicode</CharacterSet>\r
+ </PropertyGroup>\r
+ <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Release|Win32'" Label="Configuration">\r
+ <ConfigurationType>StaticLibrary</ConfigurationType>\r
+ <UseDebugLibraries>false</UseDebugLibraries>\r
+ <WholeProgramOptimization>true</WholeProgramOptimization>\r
+ <CharacterSet>Unicode</CharacterSet>\r
+ </PropertyGroup>\r
+ <Import Project="$(VCTargetsPath)\Microsoft.Cpp.props" />\r
+ <ImportGroup Label="ExtensionSettings">\r
+ </ImportGroup>\r
+ <ImportGroup Label="PropertySheets" Condition="'$(Configuration)|$(Platform)'=='Debug|Win32'">\r
+ <Import Project="$(UserRootDir)\Microsoft.Cpp.$(Platform).user.props" Condition="exists('$(UserRootDir)\Microsoft.Cpp.$(Platform).user.props')" Label="LocalAppDataPlatform" />\r
+ </ImportGroup>\r
+ <ImportGroup Label="PropertySheets" Condition="'$(Configuration)|$(Platform)'=='Release|Win32'">\r
+ <Import Project="$(UserRootDir)\Microsoft.Cpp.$(Platform).user.props" Condition="exists('$(UserRootDir)\Microsoft.Cpp.$(Platform).user.props')" Label="LocalAppDataPlatform" />\r
+ </ImportGroup>\r
+ <PropertyGroup Label="UserMacros" />\r
+ <PropertyGroup />\r
+ <ItemDefinitionGroup Condition="'$(Configuration)|$(Platform)'=='Debug|Win32'">\r
+ <ClCompile>\r
+ <PrecompiledHeader>\r
+ </PrecompiledHeader>\r
+ <WarningLevel>Level3</WarningLevel>\r
+ <Optimization>Disabled</Optimization>\r
+ <PreprocessorDefinitions>WIN32;_DEBUG;_LIB;%(PreprocessorDefinitions)</PreprocessorDefinitions>\r
+ <AdditionalIncludeDirectories>../win32helpers</AdditionalIncludeDirectories>\r
+ </ClCompile>\r
+ <Link>\r
+ <SubSystem>Windows</SubSystem>\r
+ <GenerateDebugInformation>true</GenerateDebugInformation>\r
+ </Link>\r
+ </ItemDefinitionGroup>\r
+ <ItemDefinitionGroup Condition="'$(Configuration)|$(Platform)'=='Release|Win32'">\r
+ <ClCompile>\r
+ <WarningLevel>Level3</WarningLevel>\r
+ <PrecompiledHeader>\r
+ </PrecompiledHeader>\r
+ <Optimization>MaxSpeed</Optimization>\r
+ <FunctionLevelLinking>true</FunctionLevelLinking>\r
+ <IntrinsicFunctions>true</IntrinsicFunctions>\r
+ <PreprocessorDefinitions>WIN32;NDEBUG;_LIB;%(PreprocessorDefinitions)</PreprocessorDefinitions>\r
+ <AdditionalIncludeDirectories>../win32helpers</AdditionalIncludeDirectories>\r
+ </ClCompile>\r
+ <Link>\r
+ <SubSystem>Windows</SubSystem>\r
+ <GenerateDebugInformation>true</GenerateDebugInformation>\r
+ <EnableCOMDATFolding>true</EnableCOMDATFolding>\r
+ <OptimizeReferences>true</OptimizeReferences>\r
+ </Link>\r
+ </ItemDefinitionGroup>\r
+ <ItemGroup>\r
+ <ClCompile Include="..\..\lib\base64-decode.c" />\r
+ <ClCompile Include="..\..\lib\client-handshake.c" />\r
+ <ClCompile Include="..\..\lib\handshake.c" />\r
+ <ClCompile Include="..\..\lib\libwebsockets.c" />\r
+ <ClCompile Include="..\..\lib\md5.c" />\r
+ <ClCompile Include="..\..\lib\parsers.c" />\r
+ <ClCompile Include="..\..\lib\sha-1.c" />\r
+ </ItemGroup>\r
+ <ItemGroup>\r
+ <ClInclude Include="..\..\lib\libwebsockets.h" />\r
+ <ClInclude Include="..\..\lib\private-libwebsockets.h" />\r
+ </ItemGroup>\r
+ <Import Project="$(VCTargetsPath)\Microsoft.Cpp.targets" />\r
+ <ImportGroup Label="ExtensionTargets">\r
+ </ImportGroup>\r
+</Project>
\ No newline at end of file
--- /dev/null
+<?xml version="1.0" encoding="utf-8"?>\r
+<Project ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">\r
+ <ItemGroup>\r
+ <Filter Include="Source Files">\r
+ <UniqueIdentifier>{4FC737F1-C7A5-4376-A066-2A32D752A2FF}</UniqueIdentifier>\r
+ <Extensions>cpp;c;cc;cxx;def;odl;idl;hpj;bat;asm;asmx</Extensions>\r
+ </Filter>\r
+ <Filter Include="Header Files">\r
+ <UniqueIdentifier>{93995380-89BD-4b04-88EB-625FBE52EBFB}</UniqueIdentifier>\r
+ <Extensions>h;hpp;hxx;hm;inl;inc;xsd</Extensions>\r
+ </Filter>\r
+ <Filter Include="Resource Files">\r
+ <UniqueIdentifier>{67DA6AB6-F800-4c08-8B7A-83BB121AAD01}</UniqueIdentifier>\r
+ <Extensions>rc;ico;cur;bmp;dlg;rc2;rct;bin;rgs;gif;jpg;jpeg;jpe;resx;tiff;tif;png;wav;mfcribbon-ms</Extensions>\r
+ </Filter>\r
+ </ItemGroup>\r
+ <ItemGroup>\r
+ <ClCompile Include="..\..\lib\base64-decode.c">\r
+ <Filter>Source Files</Filter>\r
+ </ClCompile>\r
+ <ClCompile Include="..\..\lib\client-handshake.c">\r
+ <Filter>Source Files</Filter>\r
+ </ClCompile>\r
+ <ClCompile Include="..\..\lib\handshake.c">\r
+ <Filter>Source Files</Filter>\r
+ </ClCompile>\r
+ <ClCompile Include="..\..\lib\libwebsockets.c">\r
+ <Filter>Source Files</Filter>\r
+ </ClCompile>\r
+ <ClCompile Include="..\..\lib\md5.c">\r
+ <Filter>Source Files</Filter>\r
+ </ClCompile>\r
+ <ClCompile Include="..\..\lib\parsers.c">\r
+ <Filter>Source Files</Filter>\r
+ </ClCompile>\r
+ <ClCompile Include="..\..\lib\sha-1.c">\r
+ <Filter>Source Files</Filter>\r
+ </ClCompile>\r
+ </ItemGroup>\r
+ <ItemGroup>\r
+ <ClInclude Include="..\..\lib\libwebsockets.h">\r
+ <Filter>Header Files</Filter>\r
+ </ClInclude>\r
+ <ClInclude Include="..\..\lib\private-libwebsockets.h">\r
+ <Filter>Header Files</Filter>\r
+ </ClInclude>\r
+ </ItemGroup>\r
+</Project>
\ No newline at end of file
--- /dev/null
+<?xml version="1.0" encoding="utf-8"?>\r
+<Project ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">\r
+</Project>
\ No newline at end of file
--- /dev/null
+<?xml version="1.0" encoding="utf-8"?>\r
+<Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">\r
+ <ItemGroup Label="ProjectConfigurations">\r
+ <ProjectConfiguration Include="Debug|Win32">\r
+ <Configuration>Debug</Configuration>\r
+ <Platform>Win32</Platform>\r
+ </ProjectConfiguration>\r
+ <ProjectConfiguration Include="Release|Win32">\r
+ <Configuration>Release</Configuration>\r
+ <Platform>Win32</Platform>\r
+ </ProjectConfiguration>\r
+ </ItemGroup>\r
+ <ItemGroup>\r
+ <ClCompile Include="..\..\test-server\test-server.c">\r
+ <AdditionalIncludeDirectories Condition="'$(Configuration)|$(Platform)'=='Debug|Win32'">../win32helpers</AdditionalIncludeDirectories>\r
+ </ClCompile>\r
+ <ClCompile Include="..\win32helpers\getopt.c" />\r
+ <ClCompile Include="..\win32helpers\getopt_long.c" />\r
+ <ClCompile Include="..\win32helpers\gettimeofday.c" />\r
+ </ItemGroup>\r
+ <ItemGroup>\r
+ <ClInclude Include="..\win32helpers\getopt.h" />\r
+ <ClInclude Include="..\win32helpers\gettimeofday.h" />\r
+ <ClInclude Include="..\win32helpers\netdb.h" />\r
+ <ClInclude Include="..\win32helpers\strings.h" />\r
+ <ClInclude Include="..\win32helpers\unistd.h" />\r
+ <ClInclude Include="..\win32helpers\websock-w32.h" />\r
+ </ItemGroup>\r
+ <ItemGroup>\r
+ <ProjectReference Include="..\libwebsocketswin32\libwebsocketswin32.vcxproj">\r
+ <Project>{332bf17e-fd30-4363-975a-aa731a827b4f}</Project>\r
+ </ProjectReference>\r
+ </ItemGroup>\r
+ <PropertyGroup Label="Globals">\r
+ <ProjectGuid>{E585B64F-9365-4C58-9EF8-56393EB27F8B}</ProjectGuid>\r
+ <Keyword>Win32Proj</Keyword>\r
+ <RootNamespace>server</RootNamespace>\r
+ </PropertyGroup>\r
+ <Import Project="$(VCTargetsPath)\Microsoft.Cpp.Default.props" />\r
+ <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|Win32'" Label="Configuration">\r
+ <ConfigurationType>Application</ConfigurationType>\r
+ <UseDebugLibraries>true</UseDebugLibraries>\r
+ <CharacterSet>Unicode</CharacterSet>\r
+ </PropertyGroup>\r
+ <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Release|Win32'" Label="Configuration">\r
+ <ConfigurationType>Application</ConfigurationType>\r
+ <UseDebugLibraries>false</UseDebugLibraries>\r
+ <WholeProgramOptimization>true</WholeProgramOptimization>\r
+ <CharacterSet>Unicode</CharacterSet>\r
+ </PropertyGroup>\r
+ <Import Project="$(VCTargetsPath)\Microsoft.Cpp.props" />\r
+ <ImportGroup Label="ExtensionSettings">\r
+ </ImportGroup>\r
+ <ImportGroup Label="PropertySheets" Condition="'$(Configuration)|$(Platform)'=='Debug|Win32'">\r
+ <Import Project="$(UserRootDir)\Microsoft.Cpp.$(Platform).user.props" Condition="exists('$(UserRootDir)\Microsoft.Cpp.$(Platform).user.props')" Label="LocalAppDataPlatform" />\r
+ </ImportGroup>\r
+ <ImportGroup Label="PropertySheets" Condition="'$(Configuration)|$(Platform)'=='Release|Win32'">\r
+ <Import Project="$(UserRootDir)\Microsoft.Cpp.$(Platform).user.props" Condition="exists('$(UserRootDir)\Microsoft.Cpp.$(Platform).user.props')" Label="LocalAppDataPlatform" />\r
+ </ImportGroup>\r
+ <PropertyGroup Label="UserMacros" />\r
+ <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|Win32'">\r
+ <LinkIncremental>true</LinkIncremental>\r
+ </PropertyGroup>\r
+ <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Release|Win32'">\r
+ <LinkIncremental>false</LinkIncremental>\r
+ </PropertyGroup>\r
+ <ItemDefinitionGroup Condition="'$(Configuration)|$(Platform)'=='Debug|Win32'">\r
+ <ClCompile>\r
+ <PrecompiledHeader>\r
+ </PrecompiledHeader>\r
+ <WarningLevel>Level3</WarningLevel>\r
+ <Optimization>Disabled</Optimization>\r
+ <PreprocessorDefinitions>WIN32;_DEBUG;_CONSOLE;%(PreprocessorDefinitions)</PreprocessorDefinitions>\r
+ <AdditionalIncludeDirectories>../win32helpers</AdditionalIncludeDirectories>\r
+ </ClCompile>\r
+ <Link>\r
+ <SubSystem>Console</SubSystem>\r
+ <GenerateDebugInformation>true</GenerateDebugInformation>\r
+ <IgnoreSpecificDefaultLibraries>\r
+ </IgnoreSpecificDefaultLibraries>\r
+ <AdditionalDependencies>ws2_32.lib;kernel32.lib;user32.lib;gdi32.lib;winspool.lib;comdlg32.lib;advapi32.lib;shell32.lib;ole32.lib;oleaut32.lib;uuid.lib;odbc32.lib;odbccp32.lib;%(AdditionalDependencies)</AdditionalDependencies>\r
+ </Link>\r
+ </ItemDefinitionGroup>\r
+ <ItemDefinitionGroup Condition="'$(Configuration)|$(Platform)'=='Release|Win32'">\r
+ <ClCompile>\r
+ <WarningLevel>Level3</WarningLevel>\r
+ <PrecompiledHeader>\r
+ </PrecompiledHeader>\r
+ <Optimization>MaxSpeed</Optimization>\r
+ <FunctionLevelLinking>true</FunctionLevelLinking>\r
+ <IntrinsicFunctions>true</IntrinsicFunctions>\r
+ <PreprocessorDefinitions>WIN32;NDEBUG;_CONSOLE;%(PreprocessorDefinitions)</PreprocessorDefinitions>\r
+ <AdditionalIncludeDirectories>../win32helpers</AdditionalIncludeDirectories>\r
+ </ClCompile>\r
+ <Link>\r
+ <SubSystem>Console</SubSystem>\r
+ <GenerateDebugInformation>true</GenerateDebugInformation>\r
+ <EnableCOMDATFolding>true</EnableCOMDATFolding>\r
+ <OptimizeReferences>true</OptimizeReferences>\r
+ <AdditionalDependencies>ws2_32.lib;kernel32.lib;user32.lib;gdi32.lib;winspool.lib;comdlg32.lib;advapi32.lib;shell32.lib;ole32.lib;oleaut32.lib;uuid.lib;odbc32.lib;odbccp32.lib;%(AdditionalDependencies)</AdditionalDependencies>\r
+ </Link>\r
+ </ItemDefinitionGroup>\r
+ <Import Project="$(VCTargetsPath)\Microsoft.Cpp.targets" />\r
+ <ImportGroup Label="ExtensionTargets">\r
+ </ImportGroup>\r
+</Project>
\ No newline at end of file
--- /dev/null
+<?xml version="1.0" encoding="utf-8"?>\r
+<Project ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">\r
+ <ItemGroup>\r
+ <Filter Include="Source Files">\r
+ <UniqueIdentifier>{4FC737F1-C7A5-4376-A066-2A32D752A2FF}</UniqueIdentifier>\r
+ <Extensions>cpp;c;cc;cxx;def;odl;idl;hpj;bat;asm;asmx</Extensions>\r
+ </Filter>\r
+ <Filter Include="Header Files">\r
+ <UniqueIdentifier>{93995380-89BD-4b04-88EB-625FBE52EBFB}</UniqueIdentifier>\r
+ <Extensions>h;hpp;hxx;hm;inl;inc;xsd</Extensions>\r
+ </Filter>\r
+ <Filter Include="Resource Files">\r
+ <UniqueIdentifier>{67DA6AB6-F800-4c08-8B7A-83BB121AAD01}</UniqueIdentifier>\r
+ <Extensions>rc;ico;cur;bmp;dlg;rc2;rct;bin;rgs;gif;jpg;jpeg;jpe;resx;tiff;tif;png;wav;mfcribbon-ms</Extensions>\r
+ </Filter>\r
+ </ItemGroup>\r
+ <ItemGroup>\r
+ <ClCompile Include="..\..\test-server\test-server.c">\r
+ <Filter>Source Files</Filter>\r
+ </ClCompile>\r
+ <ClCompile Include="..\win32helpers\getopt.c">\r
+ <Filter>Source Files</Filter>\r
+ </ClCompile>\r
+ <ClCompile Include="..\win32helpers\getopt_long.c">\r
+ <Filter>Source Files</Filter>\r
+ </ClCompile>\r
+ <ClCompile Include="..\win32helpers\gettimeofday.c">\r
+ <Filter>Source Files</Filter>\r
+ </ClCompile>\r
+ </ItemGroup>\r
+ <ItemGroup>\r
+ <ClInclude Include="..\win32helpers\getopt.h">\r
+ <Filter>Source Files</Filter>\r
+ </ClInclude>\r
+ <ClInclude Include="..\win32helpers\netdb.h">\r
+ <Filter>Source Files</Filter>\r
+ </ClInclude>\r
+ <ClInclude Include="..\win32helpers\strings.h">\r
+ <Filter>Source Files</Filter>\r
+ </ClInclude>\r
+ <ClInclude Include="..\win32helpers\unistd.h">\r
+ <Filter>Source Files</Filter>\r
+ </ClInclude>\r
+ <ClInclude Include="..\win32helpers\websock-w32.h">\r
+ <Filter>Source Files</Filter>\r
+ </ClInclude>\r
+ <ClInclude Include="..\win32helpers\gettimeofday.h">\r
+ <Filter>Source Files</Filter>\r
+ </ClInclude>\r
+ </ItemGroup>\r
+</Project>
\ No newline at end of file
--- /dev/null
+<?xml version="1.0" encoding="utf-8"?>\r
+<Project ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">\r
+</Project>
\ No newline at end of file
--- /dev/null
+/* $NetBSD: getopt.c,v 1.16 1999/12/02 13:15:56 kleink Exp $ */
+
+/*
+ * Copyright (c) 1987, 1993, 1994
+ * The Regents of the University of California. All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * 3. All advertising materials mentioning features or use of this software
+ * must display the following acknowledgement:
+ * This product includes software developed by the University of
+ * California, Berkeley and its contributors.
+ * 4. Neither the name of the University nor the names of its contributors
+ * may be used to endorse or promote products derived from this software
+ * without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+ * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+ * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ */
+
+#if 0
+static char sccsid[] = "@(#)getopt.c 8.3 (Berkeley) 4/27/95";
+#endif
+
+#include <assert.h>
+#include <errno.h>
+#include <stdio.h>
+#include <string.h>
+
+#define __P(x) x
+#define _DIAGASSERT(x) assert(x)
+
+#ifdef __weak_alias
+__weak_alias(getopt,_getopt);
+#endif
+
+
+int opterr = 1, /* if error message should be printed */
+ optind = 1, /* index into parent argv vector */
+ optopt, /* character checked for validity */
+ optreset; /* reset getopt */
+char *optarg; /* argument associated with option */
+
+static char * _progname __P((char *));
+int getopt_internal __P((int, char * const *, const char *));
+
+static char *
+_progname(nargv0)
+ char * nargv0;
+{
+ char * tmp;
+
+ _DIAGASSERT(nargv0 != NULL);
+
+ tmp = strrchr(nargv0, '/');
+ if (tmp)
+ tmp++;
+ else
+ tmp = nargv0;
+ return(tmp);
+}
+
+#define BADCH (int)'?'
+#define BADARG (int)':'
+#define EMSG ""
+
+/*
+ * getopt --
+ * Parse argc/argv argument vector.
+ */
+int
+getopt(nargc, nargv, ostr)
+ int nargc;
+ char * const nargv[];
+ const char *ostr;
+{
+ static char *__progname = 0;
+ static char *place = EMSG; /* option letter processing */
+ char *oli; /* option letter list index */
+ __progname = __progname?__progname:_progname(*nargv);
+
+ _DIAGASSERT(nargv != NULL);
+ _DIAGASSERT(ostr != NULL);
+
+ if (optreset || !*place) { /* update scanning pointer */
+ optreset = 0;
+ if (optind >= nargc || *(place = nargv[optind]) != '-') {
+ place = EMSG;
+ return (-1);
+ }
+ if (place[1] && *++place == '-' /* found "--" */
+ && place[1] == '\0') {
+ ++optind;
+ place = EMSG;
+ return (-1);
+ }
+ } /* option letter okay? */
+ if ((optopt = (int)*place++) == (int)':' ||
+ !(oli = strchr(ostr, optopt))) {
+ /*
+ * if the user didn't specify '-' as an option,
+ * assume it means -1.
+ */
+ if (optopt == (int)'-')
+ return (-1);
+ if (!*place)
+ ++optind;
+ if (opterr && *ostr != ':')
+ (void)fprintf(stderr,
+ "%s: illegal option -- %c\n", __progname, optopt);
+ return (BADCH);
+ }
+ if (*++oli != ':') { /* don't need argument */
+ optarg = NULL;
+ if (!*place)
+ ++optind;
+ }
+ else { /* need an argument */
+ if (*place) /* no white space */
+ optarg = place;
+ else if (nargc <= ++optind) { /* no arg */
+ place = EMSG;
+ if (*ostr == ':')
+ return (BADARG);
+ if (opterr)
+ (void)fprintf(stderr,
+ "%s: option requires an argument -- %c\n",
+ __progname, optopt);
+ return (BADCH);
+ }
+ else /* white space */
+ optarg = nargv[optind];
+ place = EMSG;
+ ++optind;
+ }
+ return (optopt); /* dump back option letter */
+}
+
--- /dev/null
+#ifndef __GETOPT_H__
+#define __GETOPT_H__
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+extern int opterr; /* if error message should be printed */
+extern int optind; /* index into parent argv vector */
+extern int optopt; /* character checked for validity */
+extern int optreset; /* reset getopt */
+extern char *optarg; /* argument associated with option */
+
+struct option
+{
+ const char *name;
+ int has_arg;
+ int *flag;
+ int val;
+};
+
+#define no_argument 0
+#define required_argument 1
+#define optional_argument 2
+
+int getopt(int, char**, char*);
+int getopt_long(int, char**, char*, struct option*, int*);
+
+#ifdef __cplusplus
+}
+#endif
+
+#endif /* __GETOPT_H__ */
--- /dev/null
+
+/*
+ * Copyright (c) 1987, 1993, 1994, 1996
+ * The Regents of the University of California. All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * 3. All advertising materials mentioning features or use of this software
+ * must display the following acknowledgement:
+ * This product includes software developed by the University of
+ * California, Berkeley and its contributors.
+ * 4. Neither the name of the University nor the names of its contributors
+ * may be used to endorse or promote products derived from this software
+ * without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+ * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+ * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ */
+#include <assert.h>
+#include <errno.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include "getopt.h"
+
+extern int opterr; /* if error message should be printed */
+extern int optind; /* index into parent argv vector */
+extern int optopt; /* character checked for validity */
+extern int optreset; /* reset getopt */
+extern char *optarg; /* argument associated with option */
+
+#define __P(x) x
+#define _DIAGASSERT(x) assert(x)
+
+static char * __progname __P((char *));
+int getopt_internal __P((int, char * const *, const char *));
+
+static char *
+__progname(nargv0)
+ char * nargv0;
+{
+ char * tmp;
+
+ _DIAGASSERT(nargv0 != NULL);
+
+ tmp = strrchr(nargv0, '/');
+ if (tmp)
+ tmp++;
+ else
+ tmp = nargv0;
+ return(tmp);
+}
+
+#define BADCH (int)'?'
+#define BADARG (int)':'
+#define EMSG ""
+
+/*
+ * getopt --
+ * Parse argc/argv argument vector.
+ */
+int
+getopt_internal(nargc, nargv, ostr)
+ int nargc;
+ char * const *nargv;
+ const char *ostr;
+{
+ static char *place = EMSG; /* option letter processing */
+ char *oli; /* option letter list index */
+
+ _DIAGASSERT(nargv != NULL);
+ _DIAGASSERT(ostr != NULL);
+
+ if (optreset || !*place) { /* update scanning pointer */
+ optreset = 0;
+ if (optind >= nargc || *(place = nargv[optind]) != '-') {
+ place = EMSG;
+ return (-1);
+ }
+ if (place[1] && *++place == '-') { /* found "--" */
+ /* ++optind; */
+ place = EMSG;
+ return (-2);
+ }
+ } /* option letter okay? */
+ if ((optopt = (int)*place++) == (int)':' ||
+ !(oli = strchr(ostr, optopt))) {
+ /*
+ * if the user didn't specify '-' as an option,
+ * assume it means -1.
+ */
+ if (optopt == (int)'-')
+ return (-1);
+ if (!*place)
+ ++optind;
+ if (opterr && *ostr != ':')
+ (void)fprintf(stderr,
+ "%s: illegal option -- %c\n", __progname(nargv[0]), optopt);
+ return (BADCH);
+ }
+ if (*++oli != ':') { /* don't need argument */
+ optarg = NULL;
+ if (!*place)
+ ++optind;
+ } else { /* need an argument */
+ if (*place) /* no white space */
+ optarg = place;
+ else if (nargc <= ++optind) { /* no arg */
+ place = EMSG;
+ if ((opterr) && (*ostr != ':'))
+ (void)fprintf(stderr,
+ "%s: option requires an argument -- %c\n",
+ __progname(nargv[0]), optopt);
+ return (BADARG);
+ } else /* white space */
+ optarg = nargv[optind];
+ place = EMSG;
+ ++optind;
+ }
+ return (optopt); /* dump back option letter */
+}
+
+#if 0
+/*
+ * getopt --
+ * Parse argc/argv argument vector.
+ */
+int
+getopt2(nargc, nargv, ostr)
+ int nargc;
+ char * const *nargv;
+ const char *ostr;
+{
+ int retval;
+
+ if ((retval = getopt_internal(nargc, nargv, ostr)) == -2) {
+ retval = -1;
+ ++optind;
+ }
+ return(retval);
+}
+#endif
+
+/*
+ * getopt_long --
+ * Parse argc/argv argument vector.
+ */
+int
+getopt_long(nargc, nargv, options, long_options, index)
+ int nargc;
+ char ** nargv;
+ char * options;
+ struct option * long_options;
+ int * index;
+{
+ int retval;
+
+ _DIAGASSERT(nargv != NULL);
+ _DIAGASSERT(options != NULL);
+ _DIAGASSERT(long_options != NULL);
+ /* index may be NULL */
+
+ if ((retval = getopt_internal(nargc, nargv, options)) == -2) {
+ char *current_argv = nargv[optind++] + 2, *has_equal;
+ int i, current_argv_len, match = -1;
+
+ if (*current_argv == '\0') {
+ return(-1);
+ }
+ if ((has_equal = strchr(current_argv, '=')) != NULL) {
+ current_argv_len = has_equal - current_argv;
+ has_equal++;
+ } else
+ current_argv_len = strlen(current_argv);
+
+ for (i = 0; long_options[i].name; i++) {
+ if (strncmp(current_argv, long_options[i].name, current_argv_len))
+ continue;
+
+ if (strlen(long_options[i].name) == (unsigned)current_argv_len) {
+ match = i;
+ break;
+ }
+ if (match == -1)
+ match = i;
+ }
+ if (match != -1) {
+ if (long_options[match].has_arg == required_argument ||
+ long_options[match].has_arg == optional_argument) {
+ if (has_equal)
+ optarg = has_equal;
+ else
+ optarg = nargv[optind++];
+ }
+ if ((long_options[match].has_arg == required_argument)
+ && (optarg == NULL)) {
+ /*
+ * Missing argument, leading :
+ * indicates no error should be generated
+ */
+ if ((opterr) && (*options != ':'))
+ (void)fprintf(stderr,
+ "%s: option requires an argument -- %s\n",
+ __progname(nargv[0]), current_argv);
+ return (BADARG);
+ }
+ } else { /* No matching argument */
+ if ((opterr) && (*options != ':'))
+ (void)fprintf(stderr,
+ "%s: illegal option -- %s\n", __progname(nargv[0]), current_argv);
+ return (BADCH);
+ }
+ if (long_options[match].flag) {
+ *long_options[match].flag = long_options[match].val;
+ retval = 0;
+ } else
+ retval = long_options[match].val;
+ if (index)
+ *index = match;
+ }
+ return(retval);
+}
--- /dev/null
+#include < time.h >
+#include <windows.h> //I've ommited context line.
+#if defined(_MSC_VER) || defined(_MSC_EXTENSIONS)
+ #define DELTA_EPOCH_IN_MICROSECS 11644473600000000Ui64
+#else
+ #define DELTA_EPOCH_IN_MICROSECS 11644473600000000ULL
+#endif
+
+struct timezone
+{
+ int tz_minuteswest; /* minutes W of Greenwich */
+ int tz_dsttime; /* type of dst correction */
+};
+
+int gettimeofday(struct timeval *tv, struct timezone *tz)
+{
+ FILETIME ft;
+ unsigned __int64 tmpres = 0;
+ static int tzflag;
+
+ if (NULL != tv)
+ {
+ GetSystemTimeAsFileTime(&ft);
+
+ tmpres |= ft.dwHighDateTime;
+ tmpres <<= 32;
+ tmpres |= ft.dwLowDateTime;
+
+ /*converting file time to unix epoch*/
+ tmpres -= DELTA_EPOCH_IN_MICROSECS;
+ tmpres /= 10; /*convert into microseconds*/
+ tv->tv_sec = (long)(tmpres / 1000000UL);
+ tv->tv_usec = (long)(tmpres % 1000000UL);
+ }
+
+ if (NULL != tz)
+ {
+ if (!tzflag)
+ {
+ _tzset();
+ tzflag++;
+ }
+ tz->tz_minuteswest = _timezone / 60;
+ tz->tz_dsttime = _daylight;
+ }
+
+ return 0;
+}
--- /dev/null
+#ifndef _GET_TIME_OF_DAY_H
+#define _GET_TIME_OF_DAY_H
+
+#include < time.h >
+#include <windows.h> //I've ommited context line.
+#if defined(_MSC_VER) || defined(_MSC_EXTENSIONS)
+ #define DELTA_EPOCH_IN_MICROSECS 11644473600000000Ui64
+#else
+ #define DELTA_EPOCH_IN_MICROSECS 11644473600000000ULL
+#endif
+
+struct timezone
+{
+ int tz_minuteswest; /* minutes W of Greenwich */
+ int tz_dsttime; /* type of dst correction */
+};
+
+int gettimeofday(struct timeval *tv, struct timezone *tz);
+
+
+#endif
\ No newline at end of file
--- /dev/null
+// Left blank for win32
\ No newline at end of file
--- /dev/null
+// left blank
\ No newline at end of file
--- /dev/null
+#ifndef __WEB_SOCK_W32_H__
+#define __WEB_SOCK_W32_H__
+
+// Windows uses _DEBUG and NDEBUG
+#ifdef _DEBUG
+#undef DEBUG
+#define DEBUG 1
+#endif
+
+#define bzero(b,len) (memset((b), '\0', (len)), (void) 0)
+
+#define MSG_NOSIGNAL 0
+#define SHUT_RDWR SD_BOTH
+
+#define poll WSAPoll
+
+#define LWS_NO_FORK
+
+#define DATADIR "."
+
+#endif
\ No newline at end of file
--- /dev/null
+\r
+Microsoft Visual Studio Solution File, Format Version 11.00\r
+# Visual Studio 2010\r
+Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "server", "server\server.vcxproj", "{E585B64F-9365-4C58-9EF8-56393EB27F8B}"\r
+ ProjectSection(ProjectDependencies) = postProject\r
+ {332BF17E-FD30-4363-975A-AA731A827B4F} = {332BF17E-FD30-4363-975A-AA731A827B4F}\r
+ EndProjectSection\r
+EndProject\r
+Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "libwebsocketswin32", "libwebsocketswin32\libwebsocketswin32.vcxproj", "{332BF17E-FD30-4363-975A-AA731A827B4F}"\r
+EndProject\r
+Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "client", "client\client.vcxproj", "{6265650C-4799-451C-A687-94DE48759A8B}"\r
+EndProject\r
+Global\r
+ GlobalSection(SolutionConfigurationPlatforms) = preSolution\r
+ Debug|Win32 = Debug|Win32\r
+ Release|Win32 = Release|Win32\r
+ EndGlobalSection\r
+ GlobalSection(ProjectConfigurationPlatforms) = postSolution\r
+ {E585B64F-9365-4C58-9EF8-56393EB27F8B}.Debug|Win32.ActiveCfg = Debug|Win32\r
+ {E585B64F-9365-4C58-9EF8-56393EB27F8B}.Debug|Win32.Build.0 = Debug|Win32\r
+ {E585B64F-9365-4C58-9EF8-56393EB27F8B}.Release|Win32.ActiveCfg = Release|Win32\r
+ {E585B64F-9365-4C58-9EF8-56393EB27F8B}.Release|Win32.Build.0 = Release|Win32\r
+ {332BF17E-FD30-4363-975A-AA731A827B4F}.Debug|Win32.ActiveCfg = Debug|Win32\r
+ {332BF17E-FD30-4363-975A-AA731A827B4F}.Debug|Win32.Build.0 = Debug|Win32\r
+ {332BF17E-FD30-4363-975A-AA731A827B4F}.Release|Win32.ActiveCfg = Release|Win32\r
+ {332BF17E-FD30-4363-975A-AA731A827B4F}.Release|Win32.Build.0 = Release|Win32\r
+ {6265650C-4799-451C-A687-94DE48759A8B}.Debug|Win32.ActiveCfg = Debug|Win32\r
+ {6265650C-4799-451C-A687-94DE48759A8B}.Debug|Win32.Build.0 = Debug|Win32\r
+ {6265650C-4799-451C-A687-94DE48759A8B}.Release|Win32.ActiveCfg = Release|Win32\r
+ {6265650C-4799-451C-A687-94DE48759A8B}.Release|Win32.Build.0 = Release|Win32\r
+ EndGlobalSection\r
+ GlobalSection(SolutionProperties) = preSolution\r
+ HideSolutionNode = FALSE\r
+ EndGlobalSection\r
+EndGlobal\r
projects / platform / upstream / libwebsockets.git / commitdiff