]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
kclient: send osd, ping messages in lossless mode
authorSage Weil <sage@newdream.net>
Thu, 16 Oct 2008 02:50:03 +0000 (19:50 -0700)
committerSage Weil <sage@newdream.net>
Thu, 16 Oct 2008 02:50:03 +0000 (19:50 -0700)
This is what they should have been doing all along.  Oops.

src/kernel/messenger.c
src/kernel/osd_client.c

index 03cacd6fd1d1ada3e1ce57a58fa416f725648a71..c78eb88d8c33490eb25354fcd9f9161961d373bb 100644 (file)
@@ -2195,5 +2195,5 @@ void ceph_ping(struct ceph_messenger *msgr, struct ceph_entity_name name,
        memset(m->front.iov_base, 0, m->front.iov_len);
        m->hdr.dst.name = name;
        m->hdr.dst.addr = *addr;
-       ceph_msg_send(msgr, m, 0);
+       ceph_msg_send(msgr, m, BASE_DELAY_INTERVAL);
 }
index 9ce758b284e7aba30bfecb87dfafbb006a7dbb65..ae894e2ffd816384bbdaea8aabf519773e67df29 100644 (file)
@@ -276,7 +276,8 @@ static int send_request(struct ceph_osd_client *osdc,
        req->r_last_stamp = jiffies;
 
        ceph_msg_get(req->r_request); /* send consumes a ref */
-       rc = ceph_msg_send(osdc->client->msgr, req->r_request, 0);
+       rc = ceph_msg_send(osdc->client->msgr, req->r_request,
+                          BASE_DELAY_INTERVAL);
 
        return rc;
 }