pop

diff --git a/meta b/meta
index 478ddddeb3c066ff9e513cd52194486170437354..da70fddc0bfff75c572b519452aebc8ce71baf8c 100644 (file)
--- a/meta
+++ b/meta
@@ -1,6 +1,6 @@
 Version: 1
-Previous: 837397a8d7effc32d3f6080ed1df1333572d151e
-Head: 94e4650160dd8b32efd7e1befe3b179487bd7cac
+Previous: a86087efcfd056aaecfce09a7a778bbd7a0f75d2
+Head: aaca54f9c8fbc522a62c8abd86cc7fc28a551389
 Applied:
   destroy_cqs: 66410c265b2661e16b7f6126bcc4ea5c7e1af1bd
   conn-err: ac46465ae6061b06f005ba9b49b371c9eb0d2325
@@ -15,9 +15,9 @@ Applied:
   acm-init: 666fa02d8f18ac2e98008cd3d57a90a864203548
   pre-socket: 659f605c2d6bdba067651138aa5ffc01f14465d6
   rs-states: 94e4650160dd8b32efd7e1befe3b179487bd7cac
+  rs-recv-hang: aaca54f9c8fbc522a62c8abd86cc7fc28a551389
 Unapplied:
   rs-1sge: 85e4c4a0da0b501b60a1035d7a003ee20a749511
   rs-def-inline: 6ad70d3b80178e40fea97f662a6b31e51cddc0af
-  rs-recv-hang: 7f62ace0f6bae5cc302bd58dd24ef5455229e1cb
   rstream-opt: e7db81a741c83da0739c078351abcc730465404a
 Hidden:

diff --git a/patches/rs-recv-hang b/patches/rs-recv-hang
index 7b072f8d42d265c126629a3e53308fe2fe8a1711..a12453bb2cba5772d3a7f051f57d553b4ab1bfbc 100644 (file)
--- a/patches/rs-recv-hang
+++ b/patches/rs-recv-hang
@@ -1,5 +1,5 @@
-Bottom: 58e892deadb121454026692a0c778cbb9d22e540
-Top:    18e2adc2e12c49c653badf14585eaed48bfce64f
+Bottom: 82e13151ae7719d96c8c400a99918961bc514175
+Top:    fdfaeba03cd72a5fb2f57a5316f270c905d4dc15
 Author: Sean Hefty <sean.hefty@intel.com>
 Date:   2012-05-25 17:24:08 -0700
 
@@ -18,10 +18,10 @@ Signed-off-by: Sean Hefty <sean.hefty@intel.com>
 ---
 
 diff --git a/src/rsocket.c b/src/rsocket.c
-index 8cbd425..1fcc4af 100644
+index 9ce58d5..c111797 100644
 --- a/src/rsocket.c
 +++ b/src/rsocket.c
-@@ -937,6 +937,11 @@ static int rs_can_send(struct rsocket *rs)
+@@ -954,6 +954,11 @@ static int rs_can_send(struct rsocket *rs)
               (rs->target_sgl[rs->target_sge].length != 0);
  }
  
@@ -33,7 +33,7 @@ index 8cbd425..1fcc4af 100644
  static int rs_can_send_ctrl(struct rsocket *rs)
  {
        return rs->ctrl_avail;
-@@ -947,6 +952,11 @@ static int rs_have_rdata(struct rsocket *rs)
+@@ -964,6 +969,11 @@ static int rs_have_rdata(struct rsocket *rs)
        return (rs->rmsg_head != rs->rmsg_tail);
  }
  
@@ -45,7 +45,7 @@ index 8cbd425..1fcc4af 100644
  static int rs_all_sends_done(struct rsocket *rs)
  {
        return (rs->sqe_avail + rs->ctrl_avail) == rs->sq_size;
-@@ -1007,7 +1017,7 @@ ssize_t rrecv(int socket, void *buf, size_t len, int flags)
+@@ -1024,7 +1034,7 @@ ssize_t rrecv(int socket, void *buf, size_t len, int flags)
        }
        fastlock_acquire(&rs->rlock);
        if (!rs_have_rdata(rs)) {
@@ -54,7 +54,7 @@ index 8cbd425..1fcc4af 100644
                if (ret && errno != ECONNRESET)
                        goto out;
        }
-@@ -1111,9 +1121,14 @@ ssize_t rsend(int socket, const void *buf, size_t len, int flags)
+@@ -1128,9 +1138,14 @@ ssize_t rsend(int socket, const void *buf, size_t len, int flags)
        fastlock_acquire(&rs->slock);
        for (left = len; left; left -= xfer_size, buf += xfer_size) {
                if (!rs_can_send(rs)) {
@@ -70,7 +70,7 @@ index 8cbd425..1fcc4af 100644
                }
  
                if (olen < left) {
-@@ -1208,9 +1223,14 @@ static ssize_t rsendv(int socket, const struct iovec *iov, int iovcnt, int flags
+@@ -1237,9 +1252,14 @@ static ssize_t rsendv(int socket, const struct iovec *iov, int iovcnt, int flags
        fastlock_acquire(&rs->slock);
        for (left = len; left; left -= xfer_size) {
                if (!rs_can_send(rs)) {