@@ -598,11 +598,11 @@ STATIC mp_obj_t lwip_socket_make_new(const mp_obj_type_t *type, mp_uint_t n_args
598
598
case MOD_NETWORK_SOCK_STREAM : socket -> pcb .tcp = tcp_new (); break ;
599
599
case MOD_NETWORK_SOCK_DGRAM : socket -> pcb .udp = udp_new (); break ;
600
600
//case MOD_NETWORK_SOCK_RAW: socket->pcb.raw = raw_new(); break;
601
- default : nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( MP_EINVAL )) );
601
+ default : mp_raise_OSError ( MP_EINVAL );
602
602
}
603
603
604
604
if (socket -> pcb .tcp == NULL ) {
605
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( MP_ENOMEM )) );
605
+ mp_raise_OSError ( MP_ENOMEM );
606
606
}
607
607
608
608
switch (socket -> type ) {
@@ -686,7 +686,7 @@ STATIC mp_obj_t lwip_socket_bind(mp_obj_t self_in, mp_obj_t addr_in) {
686
686
}
687
687
688
688
if (err != ERR_OK ) {
689
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( error_lookup_table [- err ])) );
689
+ mp_raise_OSError ( error_lookup_table [- err ]);
690
690
}
691
691
692
692
return mp_const_none ;
@@ -698,15 +698,15 @@ STATIC mp_obj_t lwip_socket_listen(mp_obj_t self_in, mp_obj_t backlog_in) {
698
698
mp_int_t backlog = mp_obj_get_int (backlog_in );
699
699
700
700
if (socket -> pcb .tcp == NULL ) {
701
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( MP_EBADF )) );
701
+ mp_raise_OSError ( MP_EBADF );
702
702
}
703
703
if (socket -> type != MOD_NETWORK_SOCK_STREAM ) {
704
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( MP_EOPNOTSUPP )) );
704
+ mp_raise_OSError ( MP_EOPNOTSUPP );
705
705
}
706
706
707
707
struct tcp_pcb * new_pcb = tcp_listen_with_backlog (socket -> pcb .tcp , (u8_t )backlog );
708
708
if (new_pcb == NULL ) {
709
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( MP_ENOMEM )) );
709
+ mp_raise_OSError ( MP_ENOMEM );
710
710
}
711
711
socket -> pcb .tcp = new_pcb ;
712
712
tcp_accept (new_pcb , _lwip_tcp_accept );
@@ -719,15 +719,15 @@ STATIC mp_obj_t lwip_socket_accept(mp_obj_t self_in) {
719
719
lwip_socket_obj_t * socket = self_in ;
720
720
721
721
if (socket -> pcb .tcp == NULL ) {
722
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( MP_EBADF )) );
722
+ mp_raise_OSError ( MP_EBADF );
723
723
}
724
724
if (socket -> type != MOD_NETWORK_SOCK_STREAM ) {
725
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( MP_EOPNOTSUPP )) );
725
+ mp_raise_OSError ( MP_EOPNOTSUPP );
726
726
}
727
727
// I need to do this because "tcp_accepted", later, is a macro.
728
728
struct tcp_pcb * listener = socket -> pcb .tcp ;
729
729
if (listener -> state != LISTEN ) {
730
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( MP_EINVAL )) );
730
+ mp_raise_OSError ( MP_EINVAL );
731
731
}
732
732
733
733
// accept incoming connection
@@ -738,7 +738,7 @@ STATIC mp_obj_t lwip_socket_accept(mp_obj_t self_in) {
738
738
if (socket -> incoming .connection != NULL ) break ;
739
739
}
740
740
if (socket -> incoming .connection == NULL ) {
741
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( MP_ETIMEDOUT )) );
741
+ mp_raise_OSError ( MP_ETIMEDOUT );
742
742
}
743
743
} else {
744
744
while (socket -> incoming .connection == NULL ) {
@@ -785,7 +785,7 @@ STATIC mp_obj_t lwip_socket_connect(mp_obj_t self_in, mp_obj_t addr_in) {
785
785
lwip_socket_obj_t * socket = self_in ;
786
786
787
787
if (socket -> pcb .tcp == NULL ) {
788
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( MP_EBADF )) );
788
+ mp_raise_OSError ( MP_EBADF );
789
789
}
790
790
791
791
// get address
@@ -800,9 +800,9 @@ STATIC mp_obj_t lwip_socket_connect(mp_obj_t self_in, mp_obj_t addr_in) {
800
800
case MOD_NETWORK_SOCK_STREAM : {
801
801
if (socket -> state != STATE_NEW ) {
802
802
if (socket -> state == STATE_CONNECTED ) {
803
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( MP_EALREADY )) );
803
+ mp_raise_OSError ( MP_EALREADY );
804
804
} else {
805
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( MP_EINPROGRESS )) );
805
+ mp_raise_OSError ( MP_EINPROGRESS );
806
806
}
807
807
}
808
808
// Register our recieve callback.
@@ -811,7 +811,7 @@ STATIC mp_obj_t lwip_socket_connect(mp_obj_t self_in, mp_obj_t addr_in) {
811
811
err = tcp_connect (socket -> pcb .tcp , & dest , port , _lwip_tcp_connected );
812
812
if (err != ERR_OK ) {
813
813
socket -> state = STATE_NEW ;
814
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( error_lookup_table [- err ])) );
814
+ mp_raise_OSError ( error_lookup_table [- err ]);
815
815
}
816
816
socket -> peer_port = (mp_uint_t )port ;
817
817
memcpy (socket -> peer , & dest , sizeof (socket -> peer ));
@@ -822,7 +822,7 @@ STATIC mp_obj_t lwip_socket_connect(mp_obj_t self_in, mp_obj_t addr_in) {
822
822
if (socket -> state != STATE_CONNECTING ) break ;
823
823
}
824
824
if (socket -> state == STATE_CONNECTING ) {
825
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( MP_ETIMEDOUT )) );
825
+ mp_raise_OSError ( MP_ETIMEDOUT );
826
826
}
827
827
} else {
828
828
while (socket -> state == STATE_CONNECTING ) {
@@ -843,7 +843,7 @@ STATIC mp_obj_t lwip_socket_connect(mp_obj_t self_in, mp_obj_t addr_in) {
843
843
}
844
844
845
845
if (err != ERR_OK ) {
846
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( error_lookup_table [- err ])) );
846
+ mp_raise_OSError ( error_lookup_table [- err ]);
847
847
}
848
848
849
849
return mp_const_none ;
@@ -855,7 +855,7 @@ STATIC void lwip_socket_check_connected(lwip_socket_obj_t *socket) {
855
855
// not connected
856
856
int _errno = error_lookup_table [- socket -> state ];
857
857
socket -> state = _ERR_BADF ;
858
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( _errno )) );
858
+ mp_raise_OSError ( _errno );
859
859
}
860
860
}
861
861
@@ -880,7 +880,7 @@ STATIC mp_obj_t lwip_socket_send(mp_obj_t self_in, mp_obj_t buf_in) {
880
880
}
881
881
}
882
882
if (ret == -1 ) {
883
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( _errno )) );
883
+ mp_raise_OSError ( _errno );
884
884
}
885
885
886
886
return mp_obj_new_int_from_uint (ret );
@@ -909,7 +909,7 @@ STATIC mp_obj_t lwip_socket_recv(mp_obj_t self_in, mp_obj_t len_in) {
909
909
}
910
910
}
911
911
if (ret == -1 ) {
912
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( _errno )) );
912
+ mp_raise_OSError ( _errno );
913
913
}
914
914
915
915
if (ret == 0 ) {
@@ -944,7 +944,7 @@ STATIC mp_obj_t lwip_socket_sendto(mp_obj_t self_in, mp_obj_t data_in, mp_obj_t
944
944
}
945
945
}
946
946
if (ret == -1 ) {
947
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( _errno )) );
947
+ mp_raise_OSError ( _errno );
948
948
}
949
949
950
950
return mp_obj_new_int_from_uint (ret );
@@ -977,7 +977,7 @@ STATIC mp_obj_t lwip_socket_recvfrom(mp_obj_t self_in, mp_obj_t len_in) {
977
977
}
978
978
}
979
979
if (ret == -1 ) {
980
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( _errno )) );
980
+ mp_raise_OSError ( _errno );
981
981
}
982
982
983
983
mp_obj_t tuple [2 ];
@@ -1010,15 +1010,15 @@ STATIC mp_obj_t lwip_socket_sendall(mp_obj_t self_in, mp_obj_t buf_in) {
1010
1010
// most useful behavior is: check whether we will be able to send all of input
1011
1011
// data without EAGAIN, and if won't be, raise it without sending any.
1012
1012
if (bufinfo .len > tcp_sndbuf (socket -> pcb .tcp )) {
1013
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( MP_EAGAIN )) );
1013
+ mp_raise_OSError ( MP_EAGAIN );
1014
1014
}
1015
1015
}
1016
1016
// TODO: In CPython3.5, socket timeout should apply to the
1017
1017
// entire sendall() operation, not to individual send() chunks.
1018
1018
while (bufinfo .len != 0 ) {
1019
1019
ret =
93F9
lwip_tcp_send (socket , bufinfo .buf , bufinfo .len , & _errno );
1020
1020
if (ret == -1 ) {
1021
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( _errno )) );
1021
+ mp_raise_OSError ( _errno );
1022
1022
}
1023
1023
bufinfo .len -= ret ;
1024
1024
bufinfo .buf = (char * )bufinfo .buf + ret ;
@@ -1259,7 +1259,7 @@ STATIC mp_obj_t lwip_getaddrinfo(mp_obj_t host_in, mp_obj_t port_in) {
1259
1259
if (state .status < 0 ) {
1260
1260
// TODO: CPython raises gaierror, we raise with native lwIP negative error
1261
1261
// values, to differentiate from normal errno's at least in such way.
1262
- nlr_raise ( mp_obj_new_exception_arg1 ( & mp_type_OSError , MP_OBJ_NEW_SMALL_INT ( state .status )) );
1262
+ mp_raise_OSError ( state .status );
1263
1263
}
1264
1264
1265
1265
mp_obj_tuple_t * tuple = mp_obj_new_tuple (5 , NULL );
0 commit comments