#define PPPINITFCS16 0xffff /* Initial FCS value */
#define PPPGOODFCS16 0xf0b8 /* Good final FCS value */
+struct frame_buffer {
+ gsize len;
+ guint8 bytes[0];
+};
+
static GList *packet_handlers = NULL;
void ppp_register_packet_handler(struct ppp_packet_handler *handler)
static void ppp_recv(GAtPPP *ppp)
{
GList *list;
- guint8 *frame;
+ struct frame_buffer *frame;
/* pop frames off of receive queue */
while ((frame = g_queue_pop_head(ppp->recv_queue))) {
- guint protocol = ppp_proto(frame);
- guint8 *packet = ppp_info(frame);
+ guint protocol = ppp_proto(frame->bytes);
+ guint8 *packet = ppp_info(frame->bytes);
struct ppp_packet_handler *h;
/*
if (list) {
h = list->data;
h->handler(h->priv, packet);
- }
+ } else
+ lcp_protocol_reject(ppp->lcp, frame->bytes, frame->len);
g_free(frame);
}
}
/* XXX - Implement PFC and ACFC */
-static guint8 *ppp_decode(GAtPPP *ppp, guint8 *frame)
+static struct frame_buffer *ppp_decode(GAtPPP *ppp, guint8 *frame)
{
guint8 *data;
guint pos = 0;
int i = 0;
int len;
guint16 fcs;
+ struct frame_buffer *fb;
- data = g_try_malloc0(ppp->mru + 10);
- if (!data)
+ fb = g_try_malloc0(sizeof(struct frame_buffer) + ppp->mru + 10);
+ if (!fb)
return NULL;
+ data = fb->bytes;
/* skip the first flag char */
pos++;
}
len = i;
+ fb->len = len;
/* see if we have a good FCS */
fcs = PPPINITFCS16;
fcs = ppp_fcs(fcs, data[i]);
if (fcs != PPPGOODFCS16) {
- g_free(data);
+ g_free(fb);
return NULL;
}
- return data;
+ return fb;
}
static void ppp_feed(GAtPPP *ppp, guint8 *data, gsize len)
{
guint pos = 0;
- guint8 *frame;
+ struct frame_buffer *frame;
/* collect bytes until we detect we have received a complete frame */
/* examine the data. If we are at the beginning of a new frame,
void lcp_close(struct pppcp_data *data);
void lcp_establish(struct pppcp_data *data);
void lcp_terminate(struct pppcp_data *data);
+void lcp_protocol_reject(struct pppcp_data *lcp, guint8 *packet, gsize len);
void auth_set_credentials(struct auth_data *data, const char *username,
const char *passwd);
void auth_set_proto(struct auth_data *data, guint16 proto, guint8 method);
return 0;
}
+void pppcp_send_protocol_reject(struct pppcp_data *data,
+ guint8 *rejected_packet, gsize len)
+{
+ struct pppcp_packet *packet;
+ struct ppp_header *ppp_packet = (struct ppp_header *) rejected_packet;
+
+ pppcp_trace(data);
+
+ /*
+ * Protocol-Reject can only be sent when we are in
+ * the OPENED state. If in any other state, silently discard.
+ */
+ if (data->state != OPENED) {
+ g_free(ppp_packet);
+ return;
+ }
+
+ /*
+ * info should contain the old packet info, plus the 16bit
+ * protocol number we are rejecting.
+ */
+ packet = pppcp_packet_new(data, PROTOCOL_REJECT, len);
+
+ /*
+ * Identifier must be changed for each Protocol-Reject sent
+ */
+ packet->identifier = new_identity(data, data->reject_identifier);
+
+ /*
+ * rejected packet should be copied in, but it should be
+ * truncated if it needs to be to comply with mtu requirement
+ */
+ memcpy(packet->data, rejected_packet,
+ (ntohs(packet->length) - CP_HEADER_SZ));
+
+ ppp_transmit(data->ppp, pppcp_to_ppp_packet(packet),
+ ntohs(packet->length));
+
+ pppcp_packet_free(packet);
+
+}
+
/*
* parse the packet and determine which event this packet caused
*/
enum pppcp_event_type event_type,
gpointer event_data, guint data_len);
void pppcp_process_packet(gpointer priv, guint8 *new_packet);
+void pppcp_send_protocol_reject(struct pppcp_data *data,
+ guint8 *rejected_packet, gsize len);
pppcp_free(lcp);
}
+void lcp_protocol_reject(struct pppcp_data *lcp, guint8 *packet, gsize len)
+{
+ pppcp_send_protocol_reject(lcp, packet, len);
+}
+
struct pppcp_data *lcp_new(GAtPPP *ppp)
{
struct pppcp_data *pppcp;