[tor-commits] [tor/master] Merge remote-tracking branch 'origin/maint-0.2.3' into maint-0.2.4

nickm at torproject.org nickm at torproject.org
Fri Nov 15 20:35:37 UTC 2013


commit 59f50c80d443a7e148f85cfed493e3e703cc4386
Merge: a82b18f 9e90707
Author: Nick Mathewson <nickm at torproject.org>
Date:   Fri Nov 15 15:29:24 2013 -0500

    Merge remote-tracking branch 'origin/maint-0.2.3' into maint-0.2.4
    
    Conflicts:
    	src/or/or.h
    	src/or/relay.c
    
    Conflicts were simple to resolve.  More fixes were needed for
    compilation, including: reinstating the tv_to_msec function, and renaming
    *_conn_cells to *_chan_cells.

 changes/bug9093      |    7 +++++++
 src/common/util.c    |   12 +++++++++++
 src/common/util.h    |    1 +
 src/or/circuitlist.c |   56 +++++++++++++++++++++++++++++++++++++++++---------
 src/or/or.h          |    5 +++++
 src/or/relay.c       |    8 ++++++--
 6 files changed, 77 insertions(+), 12 deletions(-)

diff --cc src/common/util.c
index ae385e1,b16afa1..5eb0f9a
--- a/src/common/util.c
+++ b/src/common/util.c
@@@ -1232,6 -1322,6 +1232,18 @@@ tv_mdiff(const struct timeval *start, c
    return mdiff;
  }
  
++/**
++ * Converts timeval to milliseconds.
++ */
++int64_t
++tv_to_msec(const struct timeval *tv)
++{
++  int64_t conv = ((int64_t)tv->tv_sec)*1000L;
++  /* Round ghetto-style */
++  conv += ((int64_t)tv->tv_usec+500)/1000L;
++  return conv;
++}
++
  /** Yield true iff <b>y</b> is a leap-year. */
  #define IS_LEAPYEAR(y) (!(y % 4) && ((y % 100) || !(y % 400)))
  /** Helper: Return the number of leap-days between Jan 1, y1 and Jan 1, y2. */
diff --cc src/common/util.h
index 96a02dd,8977d27..73daa6e
--- a/src/common/util.h
+++ b/src/common/util.h
@@@ -251,8 -239,11 +251,9 @@@ void base16_encode(char *dest, size_t d
  int base16_decode(char *dest, size_t destlen, const char *src, size_t srclen);
  
  /* Time helpers */
 -double tv_to_double(const struct timeval *tv);
 -int64_t tv_to_msec(const struct timeval *tv);
 -int64_t tv_to_usec(const struct timeval *tv);
  long tv_udiff(const struct timeval *start, const struct timeval *end);
  long tv_mdiff(const struct timeval *start, const struct timeval *end);
++int64_t tv_to_msec(const struct timeval *tv);
  int tor_timegm(const struct tm *tm, time_t *time_out);
  #define RFC1123_TIME_LEN 29
  void format_rfc1123_time(char *buf, time_t t);
diff --cc src/or/circuitlist.c
index daeaa37,6250c11..b0e24a5
--- a/src/or/circuitlist.c
+++ b/src/or/circuitlist.c
@@@ -1525,10 -1383,41 +1525,41 @@@ n_cells_in_circ_queues(const circuit_t 
    return n;
  }
  
- /** helper to sort a list of circuit_q by total queue lengths, in descending
-  * order. */
+ /**
+  * Return the age of the oldest cell queued on <b>c</b>, in milliseconds.
+  * Return 0 if there are no cells queued on c.  Requires that <b>now</b> be
+  * the current time in milliseconds since the epoch, truncated.
+  *
+  * This function will return incorrect results if the oldest cell queued on
+  * the circuit is older than 2**32 msec (about 49 days) old.
+  */
+ static uint32_t
+ circuit_max_queued_cell_age(const circuit_t *c, uint32_t now)
+ {
+   uint32_t age = 0;
 -  if (c->n_conn_cells.head)
 -    age = now - c->n_conn_cells.head->inserted_time;
++  if (c->n_chan_cells.head)
++    age = now - c->n_chan_cells.head->inserted_time;
+ 
+   if (! CIRCUIT_IS_ORIGIN(c)) {
+     const or_circuit_t *orcirc = TO_OR_CIRCUIT((circuit_t*)c);
 -    if (orcirc->p_conn_cells.head) {
 -      uint32_t age2 = now - orcirc->p_conn_cells.head->inserted_time;
++    if (orcirc->p_chan_cells.head) {
++      uint32_t age2 = now - orcirc->p_chan_cells.head->inserted_time;
+       if (age2 > age)
+         return age2;
+     }
+   }
+   return age;
+ }
+ 
+ /** Temporary variable for circuits_compare_by_oldest_queued_cell_ This is a
+  * kludge to work around the fact that qsort doesn't provide a way for
+  * comparison functions to take an extra argument. */
+ static uint32_t circcomp_now_tmp;
+ 
+ /** Helper to sort a list of circuit_t by age of oldest cell, in descending
+  * order. Requires that circcomp_now_tmp is set correctly. */
  static int
- circuits_compare_by_queue_len_(const void **a_, const void **b_)
+ circuits_compare_by_oldest_queued_cell_(const void **a_, const void **b_)
  {
    const circuit_t *a = *a_;
    const circuit_t *b = *b_;
diff --cc src/or/or.h
index eff5a6d,4622391..5318b0f
--- a/src/or/or.h
+++ b/src/or/or.h
@@@ -1076,9 -911,14 +1076,14 @@@ typedef struct var_cell_t 
  /** A cell as packed for writing to the network. */
  typedef struct packed_cell_t {
    struct packed_cell_t *next; /**< Next cell queued on this circuit. */
 -  char body[CELL_NETWORK_SIZE]; /**< Cell as packed for network. */
 +  char body[CELL_MAX_NETWORK_SIZE]; /**< Cell as packed for network. */
+   uint32_t inserted_time; /**< Time (in milliseconds since epoch, with high
+                            * bits truncated) when this cell was inserted. */
  } packed_cell_t;
  
+ /* XXXX This next structure may be obsoleted by inserted_time in
+  * packed_cell_t */
+ 
  /** Number of cells added to a circuit queue including their insertion
   * time on 10 millisecond detail; used for buffer statistics. */
  typedef struct insertion_time_elem_t {
diff --cc src/or/relay.c
index 29dc361,a193ad8..63119cb
--- a/src/or/relay.c
+++ b/src/or/relay.c
@@@ -2146,13 -1902,16 +2146,17 @@@ cell_queue_append(cell_queue_t *queue, 
  
  /** Append a newly allocated copy of <b>cell</b> to the end of <b>queue</b> */
  void
 -cell_queue_append_packed_copy(cell_queue_t *queue, const cell_t *cell)
 +cell_queue_append_packed_copy(cell_queue_t *queue, const cell_t *cell,
 +                              int wide_circ_ids)
  {
+   struct timeval now;
 -  packed_cell_t *copy = packed_cell_copy(cell);
 +  packed_cell_t *copy = packed_cell_copy(cell, wide_circ_ids);
+   tor_gettimeofday_cached(&now);
+   copy->inserted_time = (uint32_t)tv_to_msec(&now);
+ 
    /* Remember the time when this cell was put in the queue. */
+   /*XXXX This may be obsoleted by inserted_time */
    if (get_options()->CellStatistics) {
-     struct timeval now;
      uint32_t added;
      insertion_time_queue_t *it_queue = queue->insertion_times;
      if (!it_pool)





More information about the tor-commits mailing list