djsundog/circuitpython
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

zephyr/modusocket: send: Switch to native sockets.

Browse Source
This commit is contained in:
Paul Sokolovsky 2017-08-09 10:17:15 +03:00
parent 600f5afed3
commit 675ceb2dd9
1 changed files with 4 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
zephyr/modusocket.c
View File

@ -344,28 +344,15 @@ STATIC MP_DEFINE_CONST_FUN_OBJ_1(socket_accept_obj, socket_accept);
STATIC mp_uint_t sock_write(mp_obj_t self_in, const void *buf, mp_uint_t size, int *errcode) { STATIC mp_uint_t sock_write(mp_obj_t self_in, const void *buf, mp_uint_t size, int *errcode) {
socket_obj_t *socket = self_in; socket_obj_t *socket = self_in;
if (socket->ctx == NULL) { if (socket->ctx == -1) {
// already closed // already closed
*errcode = EBADF; *errcode = EBADF;
return MP_STREAM_ERROR; return MP_STREAM_ERROR;
} }
struct net_pkt *send_pkt = net_pkt_get_tx(socket->ctx, K_FOREVER); ssize_t len = zsock_send(socket->ctx, buf, size, 0);
if (len == -1) {
unsigned len = net_if_get_mtu(net_context_get_iface(socket->ctx)); *errcode = errno;
// Arbitrary value to account for protocol headers
len -= 64;
if (len > size) {
len = size;
}
// TODO: Return value of 0 is a hard case (as we wait forever, should
// not happen).
len = net_pkt_append(send_pkt, len, buf, K_FOREVER);
int err = net_context_send(send_pkt, /*cb*/NULL, K_FOREVER, NULL, NULL);
if (err < 0) {
*errcode = -err;
return MP_STREAM_ERROR; return MP_STREAM_ERROR;
} }