blackbeard420/kore
1
0
Fork 0
mirror of https://github.com/jorisvink/kore synced 2025-03-09 20:49:01 -04:00
Code Issues Projects Releases Wiki Activity

add python sendto recvfrom abstract socket support

Browse Source
This commit is contained in:
Erik Karlsson 2019-03-14 08:37:02 +01:00 committed by Joris Vink
parent 9caa45a050
commit d60994abb5
1 changed files with 28 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/python.c
View File

@ -2267,6 +2267,26 @@ pysocket_async_recv(struct pysocket_op *op)
return (NULL); return (NULL);
break; break;
case AF_UNIX: case AF_UNIX:
if (socklen < sizeof(sa_family_t)) {
if ((tuple = Py_BuildValue("(ON)",
Py_None, bytes)) == NULL)
return (NULL);
break;
}
if (socklen > sizeof(struct sockaddr_un)) {
PyErr_SetString(PyExc_RuntimeError,
"Socklen longer than sockaddr_un");
return (NULL);
}
#if defined(__linux__)
if (op->sendaddr.sun.sun_path[0] == '\0') {
op->sendaddr.sun.sun_path[0] = '@';
op->sendaddr.sun.sun_path[socklen - sizeof(sa_family_t)] = '\0';
}
#endif
if ((tuple = Py_BuildValue("(sN)", if ((tuple = Py_BuildValue("(sN)",
op->sendaddr.sun.sun_path, bytes)) == NULL) op->sendaddr.sun.sun_path, bytes)) == NULL)
return (NULL); return (NULL);
@ -2313,6 +2333,14 @@ pysocket_async_send(struct pysocket_op *op)
break; break;
case AF_UNIX: case AF_UNIX:
socklen = sizeof(op->sendaddr.sun); socklen = sizeof(op->sendaddr.sun);
#if defined(__linux__)
if (op->sendaddr.sun.sun_path[0] == '@') {
socklen = sizeof(sa_family_t) +
strlen(op->sendaddr.sun.sun_path);
op->sendaddr.sun.sun_path[0] = '\0';
}
#endif
break; break;
default: default:
fatal("non AF_INET/AF_UNIX in %s", __func__); fatal("non AF_INET/AF_UNIX in %s", __func__);