abc/lwip
1
0
Fork 0
mirror of https://git.savannah.nongnu.org/git/lwip.git synced 2025-08-04 13:34:38 +08:00
Code Issues Packages Projects Releases Wiki Activity

Port PPP API to new simple tcpip API call method

Browse Source
This commit is contained in:
Dirk Ziegelmeier 2016-03-08 21:55:07 +01:00
parent 8f71795844
commit f7a3d6cca5
2 changed files with 43 additions and 111 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

147
src/api/pppapi.c
View File

@ -42,64 +42,16 @@
#include "netif/ppp/pppos.h" #include "netif/ppp/pppos.h"
#if !LWIP_TCPIP_CORE_LOCKING
#define TCPIP_PPPAPI(m) tcpip_pppapi(m)
#define TCPIP_PPPAPI_ACK(m) sys_sem_signal(&m->sem)
/**
* Much like tcpip_apimsg, but calls the lower part of a pppapi_*
* function.
*
* @param pppapimsg a struct containing the function to call and its parameters
* @return error code given back by the function that was called
*/
static err_t
tcpip_pppapi(struct pppapi_msg* pppapimsg)
{
err_t err = sys_sem_new(&pppapimsg->msg.sem, 0);
if (err != ERR_OK) {
pppapimsg->msg.err = err;
return err;
}
if(tcpip_send_api_msg(pppapimsg->function, &pppapimsg->msg, &pppapimsg->msg.sem) == ERR_OK) {
sys_sem_free(&pppapimsg->msg.sem);
return pppapimsg->msg.err;
}
return ERR_VAL;
}
#else /* !LWIP_TCPIP_CORE_LOCKING */
#define TCPIP_PPPAPI(m) tcpip_pppapi_lock(m)
#define TCPIP_PPPAPI_ACK(m)
/**
* Call the lower part of a pppapi_* function
* This function has exclusive access to lwIP core code by locking it
* before the function is called.
*
* @param pppapimsg a struct containing the function to call and its parameters
* @return ERR_OK (only for compatibility fo tcpip_pppapi())
*/
static err_t
tcpip_pppapi_lock(struct pppapi_msg* pppapimsg)
{
LOCK_TCPIP_CORE();
pppapimsg->function(&(pppapimsg->msg));
UNLOCK_TCPIP_CORE();
return pppapimsg->msg.err;
}
#endif /* !LWIP_TCPIP_CORE_LOCKING */
/** /**
* Call ppp_set_default() inside the tcpip_thread context. * Call ppp_set_default() inside the tcpip_thread context.
*/ */
static void static err_t
pppapi_do_ppp_set_default(void *m) pppapi_do_ppp_set_default(struct tcpip_api_call *m)
{ {
struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m; struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m;
ppp_set_default(msg->ppp); ppp_set_default(msg->ppp);
TCPIP_PPPAPI_ACK(msg); return ERR_OK;
} }
/** /**
@ -110,23 +62,22 @@ void
pppapi_set_default(ppp_pcb *pcb) pppapi_set_default(ppp_pcb *pcb)
{ {
struct pppapi_msg msg; struct pppapi_msg msg;
msg.function = pppapi_do_ppp_set_default;
msg.msg.ppp = pcb; msg.msg.ppp = pcb;
TCPIP_PPPAPI(&msg); tcpip_api_call(pppapi_do_ppp_set_default, &msg.call);
} }
/** /**
* Call ppp_set_auth() inside the tcpip_thread context. * Call ppp_set_auth() inside the tcpip_thread context.
*/ */
static void static err_t
pppapi_do_ppp_set_auth(void *m) pppapi_do_ppp_set_auth(struct tcpip_api_call *m)
{ {
struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m; struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m;
ppp_set_auth(msg->ppp, msg->msg.setauth.authtype, ppp_set_auth(msg->ppp, msg->msg.setauth.authtype,
msg->msg.setauth.user, msg->msg.setauth.passwd); msg->msg.setauth.user, msg->msg.setauth.passwd);
TCPIP_PPPAPI_ACK(msg); return ERR_OK;
} }
/** /**
@ -137,12 +88,11 @@ void
pppapi_set_auth(ppp_pcb *pcb, u8_t authtype, const char *user, const char *passwd) pppapi_set_auth(ppp_pcb *pcb, u8_t authtype, const char *user, const char *passwd)
{ {
struct pppapi_msg msg; struct pppapi_msg msg;
msg.function = pppapi_do_ppp_set_auth;
msg.msg.ppp = pcb; msg.msg.ppp = pcb;
msg.msg.msg.setauth.authtype = authtype; msg.msg.msg.setauth.authtype = authtype;
msg.msg.msg.setauth.user = user; msg.msg.msg.setauth.user = user;
msg.msg.msg.setauth.passwd = passwd; msg.msg.msg.setauth.passwd = passwd;
TCPIP_PPPAPI(&msg); tcpip_api_call(pppapi_do_ppp_set_auth, &msg.call);
} }
@ -150,11 +100,12 @@ pppapi_set_auth(ppp_pcb *pcb, u8_t authtype, const char *user, const char *passw
/** /**
* Call ppp_set_notify_phase_callback() inside the tcpip_thread context. * Call ppp_set_notify_phase_callback() inside the tcpip_thread context.
*/ */
static void static err_t
pppapi_do_ppp_set_notify_phase_callback(struct pppapi_msg_msg *msg) pppapi_do_ppp_set_notify_phase_callback(struct tcpip_api_call *m)
{ {
struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m;
ppp_set_notify_phase_callback(msg->ppp, msg->msg.setnotifyphasecb.notify_phase_cb); ppp_set_notify_phase_callback(msg->ppp, msg->msg.setnotifyphasecb.notify_phase_cb);
TCPIP_PPPAPI_ACK(msg); return ERR_OK;
} }
/** /**
@ -168,7 +119,7 @@ pppapi_set_notify_phase_callback(ppp_pcb *pcb, ppp_notify_phase_cb_fn notify_pha
msg.function = pppapi_do_ppp_set_notify_phase_callback; msg.function = pppapi_do_ppp_set_notify_phase_callback;
msg.msg.ppp = pcb; msg.msg.ppp = pcb;
msg.msg.msg.setnotifyphasecb.notify_phase_cb = notify_phase_cb; msg.msg.msg.setnotifyphasecb.notify_phase_cb = notify_phase_cb;
TCPIP_PPPAPI(&msg); tcpip_api_call(pppapi_do_ppp_set_notify_phase_callback, &msg.call);
} }
#endif /* PPP_NOTIFY_PHASE */ #endif /* PPP_NOTIFY_PHASE */
@ -177,14 +128,14 @@ pppapi_set_notify_phase_callback(ppp_pcb *pcb, ppp_notify_phase_cb_fn notify_pha
/** /**
* Call pppos_create() inside the tcpip_thread context. * Call pppos_create() inside the tcpip_thread context.
*/ */
static void static err_t
pppapi_do_pppos_create(void *m) pppapi_do_pppos_create(struct tcpip_api_call *m)
{ {
struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m; struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m;
msg->ppp = pppos_create(msg->msg.serialcreate.pppif, msg->msg.serialcreate.output_cb, msg->ppp = pppos_create(msg->msg.serialcreate.pppif, msg->msg.serialcreate.output_cb,
msg->msg.serialcreate.link_status_cb, msg->msg.serialcreate.ctx_cb); msg->msg.serialcreate.link_status_cb, msg->msg.serialcreate.ctx_cb);
TCPIP_PPPAPI_ACK(msg); return ERR_OK;
} }
/** /**
@ -196,12 +147,11 @@ pppapi_pppos_create(struct netif *pppif, pppos_output_cb_fn output_cb,
ppp_link_status_cb_fn link_status_cb, void *ctx_cb) ppp_link_status_cb_fn link_status_cb, void *ctx_cb)
{ {
struct pppapi_msg msg; struct pppapi_msg msg;
msg.function = pppapi_do_pppos_create;
msg.msg.msg.serialcreate.pppif = pppif; msg.msg.msg.serialcreate.pppif = pppif;
msg.msg.msg.serialcreate.output_cb = output_cb; msg.msg.msg.serialcreate.output_cb = output_cb;
msg.msg.msg.serialcreate.link_status_cb = link_status_cb; msg.msg.msg.serialcreate.link_status_cb = link_status_cb;
msg.msg.msg.serialcreate.ctx_cb = ctx_cb; msg.msg.msg.serialcreate.ctx_cb = ctx_cb;
TCPIP_PPPAPI(&msg); tcpip_api_call(pppapi_do_pppos_create, &msg.call);
return msg.msg.ppp; return msg.msg.ppp;
} }
#endif /* PPPOS_SUPPORT */ #endif /* PPPOS_SUPPORT */
@ -211,15 +161,15 @@ pppapi_pppos_create(struct netif *pppif, pppos_output_cb_fn output_cb,
/** /**
* Call pppoe_create() inside the tcpip_thread context. * Call pppoe_create() inside the tcpip_thread context.
*/ */
static void static err_t
pppapi_do_pppoe_create(void *m) pppapi_do_pppoe_create(struct tcpip_api_call *m)
{ {
struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m; struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m;
msg->ppp = pppoe_create(msg->msg.ethernetcreate.pppif, msg->msg.ethernetcreate.ethif, msg->ppp = pppoe_create(msg->msg.ethernetcreate.pppif, msg->msg.ethernetcreate.ethif,
msg->msg.ethernetcreate.service_name, msg->msg.ethernetcreate.concentrator_name, msg->msg.ethernetcreate.service_name, msg->msg.ethernetcreate.concentrator_name,
msg->msg.ethernetcreate.link_status_cb, msg->msg.ethernetcreate.ctx_cb); msg->msg.ethernetcreate.link_status_cb, msg->msg.ethernetcreate.ctx_cb);
TCPIP_PPPAPI_ACK(msg); return ERR_OK;
} }
/** /**
@ -232,14 +182,13 @@ pppapi_pppoe_create(struct netif *pppif, struct netif *ethif, const char *servic
void *ctx_cb) void *ctx_cb)
{ {
struct pppapi_msg msg; struct pppapi_msg msg;
msg.function = pppapi_do_pppoe_create;
msg.msg.msg.ethernetcreate.pppif = pppif; msg.msg.msg.ethernetcreate.pppif = pppif;
msg.msg.msg.ethernetcreate.ethif = ethif; msg.msg.msg.ethernetcreate.ethif = ethif;
msg.msg.msg.ethernetcreate.service_name = service_name; msg.msg.msg.ethernetcreate.service_name = service_name;
msg.msg.msg.ethernetcreate.concentrator_name = concentrator_name; msg.msg.msg.ethernetcreate.concentrator_name = concentrator_name;
msg.msg.msg.ethernetcreate.link_status_cb = link_status_cb; msg.msg.msg.ethernetcreate.link_status_cb = link_status_cb;
msg.msg.msg.ethernetcreate.ctx_cb = ctx_cb; msg.msg.msg.ethernetcreate.ctx_cb = ctx_cb;
TCPIP_PPPAPI(&msg); tcpip_api_call(pppapi_do_pppoe_create, &msg.call);
return msg.msg.ppp; return msg.msg.ppp;
} }
#endif /* PPPOE_SUPPORT */ #endif /* PPPOE_SUPPORT */
@ -249,8 +198,8 @@ pppapi_pppoe_create(struct netif *pppif, struct netif *ethif, const char *servic
/** /**
* Call pppol2tp_create() inside the tcpip_thread context. * Call pppol2tp_create() inside the tcpip_thread context.
*/ */
static void static err_t
pppapi_do_pppol2tp_create(void *m) pppapi_do_pppol2tp_create(struct tcpip_api_call *m)
{ {
struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m; struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m;
@ -263,7 +212,7 @@ pppapi_do_pppol2tp_create(void *m)
NULL, NULL,
#endif /* PPPOL2TP_AUTH_SUPPORT */ #endif /* PPPOL2TP_AUTH_SUPPORT */
msg->msg.l2tpcreate.link_status_cb, msg->msg.l2tpcreate.ctx_cb); msg->msg.l2tpcreate.link_status_cb, msg->msg.l2tpcreate.ctx_cb);
TCPIP_PPPAPI_ACK(msg); return ERR_OK;
} }
/** /**
@ -276,7 +225,6 @@ pppapi_pppol2tp_create(struct netif *pppif, struct netif *netif, ip_addr_t *ipad
ppp_link_status_cb_fn link_status_cb, void *ctx_cb) ppp_link_status_cb_fn link_status_cb, void *ctx_cb)
{ {
struct pppapi_msg msg; struct pppapi_msg msg;
msg.function = pppapi_do_pppol2tp_create;
msg.msg.msg.l2tpcreate.pppif = pppif; msg.msg.msg.l2tpcreate.pppif = pppif;
msg.msg.msg.l2tpcreate.netif = netif; msg.msg.msg.l2tpcreate.netif = netif;
msg.msg.msg.l2tpcreate.ipaddr = ipaddr; msg.msg.msg.l2tpcreate.ipaddr = ipaddr;
@ -287,7 +235,7 @@ pppapi_pppol2tp_create(struct netif *pppif, struct netif *netif, ip_addr_t *ipad
#endif /* PPPOL2TP_AUTH_SUPPORT */ #endif /* PPPOL2TP_AUTH_SUPPORT */
msg.msg.msg.l2tpcreate.link_status_cb = link_status_cb; msg.msg.msg.l2tpcreate.link_status_cb = link_status_cb;
msg.msg.msg.l2tpcreate.ctx_cb = ctx_cb; msg.msg.msg.l2tpcreate.ctx_cb = ctx_cb;
TCPIP_PPPAPI(&msg); tcpip_api_call(pppapi_do_pppol2tp_create, &msg.call);
return msg.msg.ppp; return msg.msg.ppp;
} }
#endif /* PPPOL2TP_SUPPORT */ #endif /* PPPOL2TP_SUPPORT */
@ -296,13 +244,12 @@ pppapi_pppol2tp_create(struct netif *pppif, struct netif *netif, ip_addr_t *ipad
/** /**
* Call ppp_connect() inside the tcpip_thread context. * Call ppp_connect() inside the tcpip_thread context.
*/ */
static void static err_t
pppapi_do_ppp_connect(void *m) pppapi_do_ppp_connect(struct tcpip_api_call *m)
{ {
struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m; struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m;
msg->err = ppp_connect(msg->ppp, msg->msg.connect.holdoff); return ppp_connect(msg->ppp, msg->msg.connect.holdoff);
TCPIP_PPPAPI_ACK(msg);
} }
/** /**
@ -313,11 +260,9 @@ err_t
pppapi_connect(ppp_pcb *pcb, u16_t holdoff) pppapi_connect(ppp_pcb *pcb, u16_t holdoff)
{ {
struct pppapi_msg msg; struct pppapi_msg msg;
msg.function = pppapi_do_ppp_connect;
msg.msg.ppp = pcb; msg.msg.ppp = pcb;
msg.msg.msg.connect.holdoff = holdoff; msg.msg.msg.connect.holdoff = holdoff;
TCPIP_PPPAPI(&msg); return tcpip_api_call(pppapi_do_ppp_connect, &msg.call);
return msg.msg.err;
} }
@ -352,13 +297,12 @@ pppapi_listen(ppp_pcb *pcb, struct ppp_addrs *addrs)
/** /**
* Call ppp_close() inside the tcpip_thread context. * Call ppp_close() inside the tcpip_thread context.
*/ */
static void static err_t
pppapi_do_ppp_close(void *m) pppapi_do_ppp_close(struct tcpip_api_call *m)
{ {
struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m; struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m;
msg->err = ppp_close(msg->ppp, msg->msg.close.nocarrier); return ppp_close(msg->ppp, msg->msg.close.nocarrier);
TCPIP_PPPAPI_ACK(msg);
} }
/** /**
@ -369,24 +313,21 @@ err_t
pppapi_close(ppp_pcb *pcb, u8_t nocarrier) pppapi_close(ppp_pcb *pcb, u8_t nocarrier)
{ {
struct pppapi_msg msg; struct pppapi_msg msg;
msg.function = pppapi_do_ppp_close;
msg.msg.ppp = pcb; msg.msg.ppp = pcb;
msg.msg.msg.close.nocarrier = nocarrier; msg.msg.msg.close.nocarrier = nocarrier;
TCPIP_PPPAPI(&msg); return tcpip_api_call(pppapi_do_ppp_close, &msg.call);
return msg.msg.err;
} }
/** /**
* Call ppp_free() inside the tcpip_thread context. * Call ppp_free() inside the tcpip_thread context.
*/ */
static void static err_t
pppapi_do_ppp_free(void *m) pppapi_do_ppp_free(struct tcpip_api_call *m)
{ {
struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m; struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m;
msg->err = ppp_free(msg->ppp); return ppp_free(msg->ppp);
TCPIP_PPPAPI_ACK(msg);
} }
/** /**
@ -397,23 +338,20 @@ err_t
pppapi_free(ppp_pcb *pcb) pppapi_free(ppp_pcb *pcb)
{ {
struct pppapi_msg msg; struct pppapi_msg msg;
msg.function = pppapi_do_ppp_free;
msg.msg.ppp = pcb; msg.msg.ppp = pcb;
TCPIP_PPPAPI(&msg); return tcpip_api_call(pppapi_do_ppp_free, &msg.call);
return msg.msg.err;
} }
/** /**
* Call ppp_ioctl() inside the tcpip_thread context. * Call ppp_ioctl() inside the tcpip_thread context.
*/ */
static void static err_t
pppapi_do_ppp_ioctl(void *m) pppapi_do_ppp_ioctl(struct tcpip_api_call *m)
{ {
struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m; struct pppapi_msg_msg *msg = (struct pppapi_msg_msg *)m;
msg->err = ppp_ioctl(msg->ppp, msg->msg.ioctl.cmd, msg->msg.ioctl.arg); return ppp_ioctl(msg->ppp, msg->msg.ioctl.cmd, msg->msg.ioctl.arg);
TCPIP_PPPAPI_ACK(msg);
} }
/** /**
@ -424,13 +362,10 @@ err_t
pppapi_ioctl(ppp_pcb *pcb, u8_t cmd, void *arg) pppapi_ioctl(ppp_pcb *pcb, u8_t cmd, void *arg)
{ {
struct pppapi_msg msg; struct pppapi_msg msg;
msg.function = pppapi_do_ppp_ioctl;
msg.msg.ppp = pcb; msg.msg.ppp = pcb;
msg.msg.msg.ioctl.cmd = cmd; msg.msg.msg.ioctl.cmd = cmd;
msg.msg.msg.ioctl.arg = arg; msg.msg.msg.ioctl.arg = arg;
TCPIP_PPPAPI(&msg); return tcpip_api_call(pppapi_do_ppp_ioctl, &msg.call);
return msg.msg.err;
} }
#endif /* LWIP_PPP_API */ #endif /* LWIP_PPP_API */

7
src/include/lwip/pppapi.h
View File

@ -34,6 +34,7 @@
#include "lwip/sys.h" #include "lwip/sys.h"
#include "lwip/netif.h" #include "lwip/netif.h"
#include "lwip/priv/tcpip_priv.h"
#include "netif/ppp/ppp.h" #include "netif/ppp/ppp.h"
#if PPPOS_SUPPORT #if PPPOS_SUPPORT
#include "netif/ppp/pppos.h" #include "netif/ppp/pppos.h"
@ -44,10 +45,6 @@ extern "C" {
#endif #endif
struct pppapi_msg_msg { struct pppapi_msg_msg {
#if !LWIP_TCPIP_CORE_LOCKING
sys_sem_t sem;
#endif /* !LWIP_TCPIP_CORE_LOCKING */
err_t err;
ppp_pcb *ppp; ppp_pcb *ppp;
union { union {
struct { struct {
@ -111,7 +108,7 @@ struct pppapi_msg_msg {
}; };
struct pppapi_msg { struct pppapi_msg {
void (* function)(void *msg); struct tcpip_api_call call;
struct pppapi_msg_msg msg; struct pppapi_msg_msg msg;
}; };