Changeset c1db742


Ignore:
Timestamp:
02/22/06 16:44:31 (15 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:
f0d19d4
Parents:
fe76c55
Message:

rename PACKET/EXTERNAL to TRACE_CTRL_ to avoid symbol clashes on windows.
fix some c++ style comments that have snuck in somewhere along the lines

Location:
lib
Files:
7 edited

Legend:

Unmodified
Added
Removed
  • lib/format_erf.c

    rfe76c55 rc1db742  
    353353        int rlen;
    354354
    355         if (packet->buf_control == PACKET) {
    356                 packet->buf_control = EXTERNAL;
     355        if (packet->buf_control == TRACE_CTRL_PACKET) {
     356                packet->buf_control = TRACE_CTRL_EXTERNAL;
    357357                free(packet->buffer);
    358358                packet->buffer = 0;
     
    395395        int rlen;
    396396
    397         if (!packet->buffer) {
     397        if (!packet->buffer || packet->buf_control == TRACE_CTRL_EXTERNAL) {
    398398                packet->buffer = malloc(LIBTRACE_PACKET_BUFSIZE);
    399                 packet->buf_control = PACKET;
     399                packet->buf_control = TRACE_CTRL_PACKET;
    400400        }
    401401
     
    441441        int numbytes;
    442442
    443         if (buffer == 0)
    444                 buffer = malloc(len);
    445443        while(1) {
    446444#ifndef MSG_NOSIGNAL
     
    479477        packet->trace = libtrace;
    480478
    481         if (packet->buf_control == EXTERNAL) {
    482                 packet->buf_control = PACKET;
     479        if (packet->buf_control == TRACE_CTRL_EXTERNAL || !packet->buffer) {
     480                packet->buf_control = TRACE_CTRL_PACKET;
    483481                packet->buffer = malloc(LIBTRACE_PACKET_BUFSIZE);
    484482        }
  • lib/format_legacy.c

    r9ff68ff rc1db742  
    148148static int legacy_read_packet(struct libtrace_t *libtrace, struct libtrace_packet_t *packet) {
    149149        int numbytes;
    150         void *buffer = packet->buffer;
     150        void *buffer;
     151
     152        if (!packet->buffer || packet->buf_control == TRACE_CTRL_EXTERNAL) {
     153                packet->buf_control = TRACE_CTRL_PACKET;
     154                packet->buffer=malloc(LIBTRACE_PACKET_BUFSIZE);
     155        }
     156        buffer = packet->buffer;
    151157       
    152158        if ((numbytes=LIBTRACE_READ(INPUT.file,
  • lib/format_pcap.c

    rfe76c55 rc1db742  
    254254        numbytes = pcaphdr->len;
    255255
    256         packet->buf_control = PACKET;
    257         if (!packet->buffer) {
     256        if (!packet->buffer || packet->buf_control==TRACE_CTRL_EXTERNAL) {
    258257                /* We only need struct pcap_pkthdr, but we have no way
    259258                 * to say how much we malloc'd so that formats can determine
     
    261260                 * malloc 64k
    262261                 */
     262                packet->buf_control = TRACE_CTRL_PACKET;
    263263                packet->buffer=malloc(65536);
    264264        }
  • lib/format_rt.c

    r9ff68ff rc1db742  
    152152                        return 0;
    153153                case RT_HELLO:
    154                         // do something with options
     154                        /* do something with options */
    155155                        printf("Hello\n");     
    156156                        if (recv(RT_INFO->input_fd, &hello_opts,
     
    216216        printf("Sending start - len: %d\n", start_msg.length);
    217217       
    218         // Need to send start message to server
     218        /* Need to send start message to server */
    219219        if (send(RT_INFO->input_fd, &start_msg, sizeof(rt_header_t), 0) != sizeof(rt_header_t)) {
    220220                printf("Failed to send start message to server\n");
     
    231231        close_msg.length = sizeof(rt_close_t);
    232232       
    233         // Send a close message to the server
     233        /* Send a close message to the server */
    234234        if (send(RT_INFO->input_fd, &close_msg, sizeof(rt_header_t), 0) != sizeof(rt_header_t)) {
    235235                printf("Failed to send close message to server\n");
     
    251251        int numbytes;
    252252
    253         if (buffer == 0)
    254                 buffer = malloc(len);
    255253        while(1) {
    256254#ifndef MSG_NOSIGNAL
     
    262260                                                MSG_NOSIGNAL)) == -1) {
    263261                        if (errno == EINTR) {
    264                                 //ignore EINTR in case
    265                                 // a caller is using signals
     262                                /* ignore EINTR in case
     263                                 * a caller is using signals
     264                                 */
    266265                                continue;
    267266                        }
     
    392391        packet->trace = libtrace;
    393392
    394         if (packet->buf_control == EXTERNAL) {
    395                 packet->buf_control = PACKET;
     393        if (packet->buf_control == TRACE_CTRL_EXTERNAL || !packet->buffer) {
     394                packet->buf_control = TRACE_CTRL_PACKET;
    396395                packet->buffer = malloc(LIBTRACE_PACKET_BUFSIZE);
    397         } else {
    398                 if (!packet->buffer)
    399                         packet->buffer = malloc(LIBTRACE_PACKET_BUFSIZE);
    400         }
     396        }
    401397
    402398        buffer = packet->buffer;
     
    413409                        read_required = 0;
    414410                }
    415                 // Read rt header
     411                /* Read rt header */
    416412                if (tracefifo_out_read(libtrace->fifo,
    417413                                &pkt_hdr, sizeof(rt_header_t)) == 0) {
     
    441437                                        break;
    442438                                }
    443                                 // set packet->trace
     439                                /* set packet->trace */
    444440                                if (rt_set_format(libtrace, packet,
    445441                                                        data_hdr.format) < 0) {
    446442                                        return -1;
    447443                                }
    448                                 // set packet->payload
     444                                /* set packet->payload */
    449445                                rt_set_payload(packet, data_hdr.format);
    450446                               
    451447                                if (reliability > 0) {
    452                                         // send ack
     448                                        /* send ack */
    453449                                        if (rt_send_ack(libtrace, packet,
    454450                                                                data_hdr.sequence)
     
    479475
    480476                        case RT_END_DATA:
    481                                 // need to do something sensible here
     477                                /* need to do something sensible here */
    482478                                return 0;       
    483479
    484480                        case RT_PAUSE_ACK:
    485                                 // Check if we asked for a pause
    486                                
     481                                /* Check if we asked for a pause */
    487482                               
    488483                                break;
    489484
    490485                        case RT_OPTION:
    491                                 // Server is requesting some option?
     486                                /* Server is requesting some option? */
    492487
    493488                                break;
     
    502497                               
    503498               
    504                 // got in our whole packet, so...
     499                /* got in our whole packet, so... */
    505500                tracefifo_out_update(libtrace->fifo,packet->size - sizeof(rt_header_t));
    506501
  • lib/format_wag.c

    rfe76c55 rc1db742  
    280280        int numbytes;
    281281       
    282         if (packet->buf_control == EXTERNAL || !packet->buffer) {
    283                 packet->buf_control = PACKET;
     282        if (packet->buf_control == TRACE_CTRL_EXTERNAL || !packet->buffer) {
     283                packet->buf_control = TRACE_CTRL_PACKET;
    284284                packet->buffer = malloc(LIBTRACE_PACKET_BUFSIZE);
    285285        }
     
    307307        int size;
    308308
    309         if (packet->buf_control == EXTERNAL || !packet->buffer) {
    310                 packet->buf_control = PACKET;
     309        if (packet->buf_control == TRACE_CTRL_EXTERNAL || !packet->buffer) {
     310                packet->buf_control = TRACE_CTRL_PACKET;
    311311                packet->buffer = malloc(LIBTRACE_PACKET_BUFSIZE);
    312312        }
  • lib/libtrace.h

    r9ff68ff rc1db742  
    8989 * wasn't created properly
    9090 */
    91 typedef enum {PACKET='p', EXTERNAL='e' } buf_control_t;
     91typedef enum {TRACE_CTRL_PACKET='p', TRACE_CTRL_EXTERNAL='e' } buf_control_t;
    9292/** Structure holding information about a packet */
    9393#define LIBTRACE_PACKET_BUFSIZE 65536
  • lib/trace.c

    rfe76c55 rc1db742  
    519519libtrace_packet_t *trace_create_packet() {
    520520        libtrace_packet_t *packet = calloc(1,sizeof(libtrace_packet_t));
    521         packet->buf_control=PACKET;
     521        packet->buf_control=TRACE_CTRL_PACKET;
    522522        return packet;
    523523}
     
    547547        assert(libtrace->started && "BUG: You must call libtrace_start() before trace_read_packet()\n");
    548548        assert(packet);
    549         assert((packet->buf_control==PACKET || packet->buf_control==EXTERNAL)&&
     549        assert((packet->buf_control==TRACE_CTRL_PACKET || packet->buf_control==TRACE_CTRL_EXTERNAL)&&
    550550                "BUG: You must allocate a packet using packet_create()");
    551551     
Note: See TracChangeset for help on using the changeset viewer.