Changeset d3b2234 for lib/format_erf.c


Ignore:
Timestamp:
02/23/06 15:22:40 (16 years ago)
Author:
Perry Lorier <perry@…>
Branches:
4.0.1-hotfixes, cachetimestamps, develop, dpdk-ndag, etsilive, getfragoff, help, libtrace4, master, ndag_format, pfring, rc-4.0.1, rc-4.0.2, rc-4.0.3, rc-4.0.4, ringdecrementfix, ringperformance, ringtimestampfixes
Children:
9836f12
Parents:
b7d2de5
Message:

depacket->sizeification

File:
1 edited

Legend:

Unmodified
Added
Removed
  • lib/format_erf.c

    r52f8fc2 rd3b2234  
    381381        }
    382382
    383         packet->size = size;
    384383        DAG.offset += size;
    385384        DAG.diff -= size;
     
    431430                return -1;
    432431        }
    433         packet->size = rlen;
    434432        if (((dag_record_t *)packet->buffer)->flags.rxerror == 1) {
    435433                packet->payload = NULL;
     
    485483        do {
    486484                struct libtrace_packet_status status;
    487                 if (tracefifo_out_available(libtrace->fifo) == 0 || read_required) {
     485                int size;
     486                if (tracefifo_out_available(libtrace->fifo) == 0
     487                                || read_required) {
    488488                        if ((numbytes = rtclient_read(
    489489                                        libtrace,buf,RP_BUFSIZE))<=0) {
     
    502502                /* Read in packet size */
    503503                if (tracefifo_out_read(libtrace->fifo,
    504                                 &packet->size, sizeof(uint32_t)) == 0) {
     504                                &size, sizeof(uint32_t)) == 0) {
    505505                        tracefifo_out_reset(libtrace->fifo);
    506506                        read_required = 1;
     
    511511                if (status.type == 2 /* RT_MSG */) {
    512512                        /* Need to skip this packet as it is a message packet */
    513                         tracefifo_out_update(libtrace->fifo, packet->size);
    514                         tracefifo_ack_update(libtrace->fifo, packet->size +
     513                        tracefifo_out_update(libtrace->fifo, size);
     514                        tracefifo_ack_update(libtrace->fifo, size +
    515515                                        sizeof(uint32_t) +
    516516                                        sizeof(libtrace_packet_status_t));
     
    520520                /* read in the full packet */
    521521                if ((numbytes = tracefifo_out_read(libtrace->fifo,
    522                                                 buffer, packet->size)) == 0) {
     522                                                buffer, size)) == 0) {
    523523                        tracefifo_out_reset(libtrace->fifo);
    524524                        read_required = 1;
     
    527527
    528528                /* got in our whole packet, so... */
    529                 tracefifo_out_update(libtrace->fifo,packet->size);
    530 
    531                 tracefifo_ack_update(libtrace->fifo,packet->size +
     529                tracefifo_out_update(libtrace->fifo,size);
     530
     531                tracefifo_ack_update(libtrace->fifo,size +
    532532                                sizeof(uint32_t) +
    533533                                sizeof(libtrace_packet_status_t));
     
    666666        dag_record_t *erfptr = 0;
    667667        assert(packet);
    668         if((size + erf_get_framing_length(packet)) > packet->size) {
     668        if(size  > trace_get_capture_length(packet)) {
    669669                /* can't make a packet larger */
    670                 return (packet->size - erf_get_framing_length(packet));
     670                return trace_get_capture_length(packet);
    671671        }
    672672        erfptr = (dag_record_t *)packet->header;
    673673        erfptr->rlen = htons(size + erf_get_framing_length(packet));
    674         packet->size = size + erf_get_framing_length(packet);
    675         return packet->size;
     674        return trace_get_capture_length(packet);
    676675}
    677676
Note: See TracChangeset for help on using the changeset viewer.