236 lines
4.3 KiB
C
236 lines
4.3 KiB
C
#include "private-libwebsockets.h"
|
|
|
|
/*
|
|
* included from libwebsockets.c for MBED3 builds
|
|
* MBED3 is an "OS" for very small embedded systems.
|
|
* He doesn't have Posix semantics or apis.
|
|
* But he has things like TCP sockets.
|
|
*/
|
|
|
|
unsigned long long time_in_microseconds(void)
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
LWS_VISIBLE int lws_get_random(struct lws_context *context, void *buf, int len)
|
|
{
|
|
int n = len;
|
|
unsigned char *b = (unsigned char *)buf;
|
|
|
|
(void)context;
|
|
|
|
while (n--)
|
|
b[n]= rand();
|
|
return len;
|
|
}
|
|
|
|
/*
|
|
* MBED3 does not have a 'kernel' which takes copies of what userland wants
|
|
* to send. The user application must hold the tx buffer until it is informed
|
|
* that send of the user buffer was complete.
|
|
*
|
|
* So as soon as you send something the pipe is globally choked.
|
|
*
|
|
* There is no concept of additional sent things being maybe acceptable.
|
|
* You can send one thing up to 64KB at a time and may not try to send
|
|
* anything else until that is completed.
|
|
*
|
|
* You can send things on other sockets, but they cannot complete until they
|
|
* get their turn at the network device.
|
|
*/
|
|
|
|
LWS_VISIBLE int lws_send_pipe_choked(struct lws *wsi)
|
|
{
|
|
#if 0
|
|
struct lws_pollfd fds;
|
|
|
|
/* treat the fact we got a truncated send pending as if we're choked */
|
|
if (wsi->trunc_len)
|
|
return 1;
|
|
|
|
fds.fd = wsi->sock;
|
|
fds.events = POLLOUT;
|
|
fds.revents = 0;
|
|
|
|
if (poll(&fds, 1, 0) != 1)
|
|
return 1;
|
|
|
|
if ((fds.revents & POLLOUT) == 0)
|
|
return 1;
|
|
|
|
/* okay to send another packet without blocking */
|
|
#endif
|
|
(void)wsi;
|
|
return 0;
|
|
}
|
|
|
|
LWS_VISIBLE int
|
|
lws_poll_listen_fd(struct lws_pollfd *fd)
|
|
{
|
|
(void)fd;
|
|
return -1;
|
|
}
|
|
|
|
/**
|
|
* lws_cancel_service() - Cancel servicing of pending websocket activity
|
|
* @context: Websocket context
|
|
*
|
|
* This function let a call to lws_service() waiting for a timeout
|
|
* immediately return.
|
|
*
|
|
* There is no poll() in MBED3, he will fire callbacks when he feels like
|
|
* it.
|
|
*/
|
|
LWS_VISIBLE void
|
|
lws_cancel_service(struct lws_context *context)
|
|
{
|
|
(void)context;
|
|
}
|
|
|
|
LWS_VISIBLE void
|
|
lws_cancel_service_pt(struct lws *wsi)
|
|
{
|
|
(void)wsi;
|
|
}
|
|
|
|
LWS_VISIBLE void lwsl_emit_syslog(int level, const char *line)
|
|
{
|
|
printf("%d: %s", level, line);
|
|
}
|
|
|
|
LWS_VISIBLE int
|
|
lws_plat_set_socket_options(struct lws_context *context, lws_sockfd_type fd)
|
|
{
|
|
(void)context;
|
|
(void)fd;
|
|
return 0;
|
|
}
|
|
|
|
LWS_VISIBLE void
|
|
lws_plat_drop_app_privileges(struct lws_context_creation_info *info)
|
|
{
|
|
(void)info;
|
|
}
|
|
|
|
LWS_VISIBLE int
|
|
lws_plat_context_early_init(void)
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
LWS_VISIBLE void
|
|
lws_plat_context_early_destroy(struct lws_context *context)
|
|
{
|
|
(void)context;
|
|
}
|
|
|
|
LWS_VISIBLE void
|
|
lws_plat_context_late_destroy(struct lws_context *context)
|
|
{
|
|
(void)context;
|
|
}
|
|
|
|
|
|
LWS_VISIBLE void
|
|
lws_plat_service_periodic(struct lws_context *context)
|
|
{
|
|
(void)context;
|
|
}
|
|
|
|
LWS_VISIBLE const char *
|
|
lws_plat_inet_ntop(int af, const void *src, char *dst, int cnt)
|
|
{
|
|
(void)af;
|
|
(void)src;
|
|
(void)dst;
|
|
(void)cnt;
|
|
return "unsupported";
|
|
}
|
|
|
|
LWS_VISIBLE int
|
|
insert_wsi(struct lws_context *context, struct lws *wsi)
|
|
{
|
|
(void)context;
|
|
(void)wsi;
|
|
|
|
return 0;
|
|
}
|
|
|
|
LWS_VISIBLE int
|
|
delete_from_fd(struct lws_context *context, lws_sockfd_type fd)
|
|
{
|
|
(void)context;
|
|
(void)fd;
|
|
|
|
return 1;
|
|
}
|
|
|
|
static lws_filefd_type
|
|
_lws_plat_file_open(struct lws *wsi, const char *filename,
|
|
unsigned long *filelen, int flags)
|
|
{
|
|
(void)wsi;
|
|
(void)filename;
|
|
(void)filelen;
|
|
(void)flags;
|
|
return NULL;
|
|
}
|
|
|
|
static int
|
|
_lws_plat_file_close(struct lws *wsi, lws_filefd_type fd)
|
|
{
|
|
(void)wsi;
|
|
(void)fd;
|
|
return -1;
|
|
}
|
|
|
|
unsigned long
|
|
_lws_plat_file_seek_cur(struct lws *wsi, lws_filefd_type fd, long offset)
|
|
{
|
|
(void)wsi;
|
|
(void)fd;
|
|
(void)offset;
|
|
|
|
return -1;
|
|
}
|
|
|
|
static int
|
|
_lws_plat_file_read(struct lws *wsi, lws_filefd_type fd, unsigned long *amount,
|
|
unsigned char *buf, unsigned long len)
|
|
{
|
|
(void)wsi;
|
|
(void)amount;
|
|
(void)fd;
|
|
(void)buf;
|
|
(void)len;
|
|
|
|
return -1;
|
|
}
|
|
|
|
static int
|
|
_lws_plat_file_write(struct lws *wsi, lws_filefd_type fd, unsigned long *amount,
|
|
unsigned char *buf, unsigned long len)
|
|
{
|
|
(void)wsi;
|
|
(void)amount;
|
|
(void)fd;
|
|
(void)buf;
|
|
(void)len;
|
|
|
|
return -1;
|
|
}
|
|
|
|
LWS_VISIBLE int
|
|
lws_plat_init(struct lws_context *context,
|
|
struct lws_context_creation_info *info)
|
|
{
|
|
(void)info;
|
|
|
|
context->fops.open = _lws_plat_file_open;
|
|
context->fops.close = _lws_plat_file_close;
|
|
context->fops.seek_cur = _lws_plat_file_seek_cur;
|
|
context->fops.read = _lws_plat_file_read;
|
|
context->fops.write = _lws_plat_file_write;
|
|
|
|
return 0;
|
|
}
|