equal
deleted
inserted
replaced
360 */ |
360 */ |
361 |
361 |
362 void ec_eoe_state_rx_fetch(ec_eoe_t *eoe /**< EoE handler */) |
362 void ec_eoe_state_rx_fetch(ec_eoe_t *eoe /**< EoE handler */) |
363 { |
363 { |
364 size_t rec_size, data_size; |
364 size_t rec_size, data_size; |
365 uint8_t *data, frame_type, last_fragment, time_appended, mbox_type; |
365 uint8_t *data, frame_type, last_fragment, time_appended, mbox_prot; |
366 uint8_t frame_number, fragment_offset, fragment_number; |
366 uint8_t frame_number, fragment_offset, fragment_number; |
367 off_t offset; |
367 off_t offset; |
368 #if EOE_DEBUG_LEVEL > 1 |
368 #if EOE_DEBUG_LEVEL > 1 |
369 unsigned int i; |
369 unsigned int i; |
370 #endif |
370 #endif |
374 eoe->state = ec_eoe_state_tx_start; |
374 eoe->state = ec_eoe_state_tx_start; |
375 return; |
375 return; |
376 } |
376 } |
377 |
377 |
378 if (!(data = ec_slave_mbox_fetch(eoe->slave, &eoe->datagram, |
378 if (!(data = ec_slave_mbox_fetch(eoe->slave, &eoe->datagram, |
379 &mbox_type, &rec_size))) { |
379 &mbox_prot, &rec_size))) { |
380 eoe->stats.rx_errors++; |
380 eoe->stats.rx_errors++; |
381 eoe->state = ec_eoe_state_tx_start; |
381 eoe->state = ec_eoe_state_tx_start; |
382 return; |
382 return; |
383 } |
383 } |
384 |
384 |
385 if (mbox_type != 0x02) { |
385 if (mbox_prot != 0x02) { // EoE |
386 eoe->stats.rx_errors++; |
386 eoe->stats.rx_errors++; |
387 eoe->state = ec_eoe_state_tx_start; |
387 eoe->state = ec_eoe_state_tx_start; |
388 return; |
388 return; |
389 } |
389 } |
390 |
390 |