Changeset c1db742 for lib/format_rt.c


Ignore:
Timestamp:
02/22/06 16:44:31 (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:
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

File:
1 edited

Legend:

Unmodified
Added
Removed
  • 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
Note: See TracChangeset for help on using the changeset viewer.