Changeset 59c31da for lib/trace.c
- Timestamp:
- 10/26/04 07:57:30 (18 years ago)
- 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:
- a22c979
- Parents:
- 7e55902
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
lib/trace.c
r7e55902 r59c31da 139 139 double start_ts; 140 140 }; 141 142 #define RP_BUFSIZE 65536 141 143 142 144 #define URI_PROTO_LINE 16 … … 446 448 static int trace_read(struct libtrace_t *libtrace, void *buffer, size_t len) { 447 449 int numbytes; 448 static unsigned bottom = 0, top, diff, curr , scan;450 static unsigned bottom = 0, top, diff, curr = 0, scan; 449 451 static short lctr = 0; 450 452 struct dag_record_t *recptr = 0; … … 477 479 switch(libtrace->format) { 478 480 case DAG: 481 479 482 top = dag_offset(libtrace->input.fd, 480 483 &bottom, 481 484 0); 482 485 diff = top - bottom; 483 errno = 0;484 curr = 0;485 486 486 recptr = (dag_record_t *) ((void *)libtrace->buf + (bottom + curr)); 487 488 memcpy(buffer,libtrace->buf + (bottom + curr),diff); 487 //recptr = (dag_record_t *) ((void *)libtrace->buf + (bottom + curr)); 488 //rlen = ntohs(recptr->rlen); 489 490 491 memcpy(buffer,(void *)(libtrace->buf + (bottom + curr)),diff); 489 492 490 493 //buffer=libtrace->buf + (bottom + curr); 491 494 492 495 numbytes=diff; 493 496 bottom=top; 494 497 495 498 break; … … 524 527 * 525 528 */ 526 #define RP_BUFSIZE 65536527 529 int trace_read_packet(struct libtrace_t *libtrace, struct libtrace_packet_t *packet) { 528 530 int numbytes; … … 593 595 return numbytes; 594 596 } 597 assert(libtrace->fifo); 595 598 fifo_write(libtrace->fifo,buf,numbytes); 596 599
Note: See TracChangeset
for help on using the changeset viewer.