From 8e202ccd825052d351eaa3a9fba6dbc86e7180c7 Mon Sep 17 00:00:00 2001
From: Sage Weil <sage@newdream.net>
Date: Thu, 3 Sep 2009 16:08:52 -0700
Subject: [PATCH] mon: use client_t

---
 src/messages/MClientMountAck.h | 4 ++--
 src/mon/ClientMap.h            | 2 +-
 src/mon/ClientMonitor.cc       | 8 +++++---
 src/mon/ClientMonitor.h        | 6 +++---
 src/mon/MonClient.cc           | 2 +-
 5 files changed, 12 insertions(+), 10 deletions(-)

diff --git a/src/messages/MClientMountAck.h b/src/messages/MClientMountAck.h
index a526f0e331732..eeca95351be27 100644
--- a/src/messages/MClientMountAck.h
+++ b/src/messages/MClientMountAck.h
@@ -18,12 +18,12 @@
 #include "msg/Message.h"
 
 struct MClientMountAck : public Message {
-  __s64 client;
+  client_t client;
   __s32 result;
   cstring result_msg;
   bufferlist monmap_bl;
 
-  MClientMountAck(__s64 c = -1, int r = 0, const char *msg = 0) :
+  MClientMountAck(client_t c = -1, int r = 0, const char *msg = 0) :
     Message(CEPH_MSG_CLIENT_MOUNT_ACK),
     client(c), result(r),
     result_msg(msg) { }
diff --git a/src/mon/ClientMap.h b/src/mon/ClientMap.h
index ddb8b87f56c87..1307fd4cb468c 100644
--- a/src/mon/ClientMap.h
+++ b/src/mon/ClientMap.h
@@ -29,7 +29,7 @@ using namespace std;
 class ClientMap {
 public:
   version_t version;
-  __u64 next_client;
+  client_t next_client;
 
   ClientMap() : version(0), next_client(0) {}
 
diff --git a/src/mon/ClientMonitor.cc b/src/mon/ClientMonitor.cc
index d60b9e9741e8a..49c514491d711 100644
--- a/src/mon/ClientMonitor.cc
+++ b/src/mon/ClientMonitor.cc
@@ -144,7 +144,9 @@ bool ClientMonitor::prepare_update(PaxosServiceMessage *m)
   case CEPH_MSG_CLIENT_MOUNT:
     {
       entity_addr_t addr = m->get_orig_source_addr();
-      __s64 client = ++pending_map.next_client;
+      client_t client = pending_map.next_client;
+      pending_map.next_client.v++;
+
       dout(10) << "mount: assigned client" << client << " to " << addr << dendl;
 
       paxos->wait_for_commit(new C_Mounted(this, client, (MClientMount*)m));
@@ -225,11 +227,11 @@ bool ClientMonitor::prepare_command(MMonCommand *m)
 // MOUNT
 
 
-void ClientMonitor::_mounted(__s64 client, MClientMount *m)
+void ClientMonitor::_mounted(client_t client, MClientMount *m)
 {
   entity_inst_t to;
   to.addr = m->get_orig_source_addr();
-  to.name = entity_name_t::CLIENT(client);
+  to.name = entity_name_t::CLIENT(client.v);
 
   dout(10) << "_mounted client" << client << " at " << to << dendl;
   
diff --git a/src/mon/ClientMonitor.h b/src/mon/ClientMonitor.h
index e4e40e94f108a..270d812311d69 100644
--- a/src/mon/ClientMonitor.h
+++ b/src/mon/ClientMonitor.h
@@ -43,10 +43,10 @@ public:
 
   class C_Mounted : public Context {
     ClientMonitor *cmon;
-    __s64 client;
+    client_t client;
     MClientMount *m;
   public:
-    C_Mounted(ClientMonitor *cm, __s64 c, MClientMount *m_) : 
+    C_Mounted(ClientMonitor *cm, client_t c, MClientMount *m_) : 
       cmon(cm), client(c), m(m_) {}
     void finish(int r) {
       if (r >= 0)
@@ -69,7 +69,7 @@ private:
   void committed();
 
   bool check_mount(MClientMount *m);
-  void _mounted(__s64 c, MClientMount *m);
+  void _mounted(client_t c, MClientMount *m);
  
   bool preprocess_query(PaxosServiceMessage *m);  // true if processed.
   bool prepare_update(PaxosServiceMessage *m);
diff --git a/src/mon/MonClient.cc b/src/mon/MonClient.cc
index e1d6d5e59bb55..67dbd6d61b6dd 100644
--- a/src/mon/MonClient.cc
+++ b/src/mon/MonClient.cc
@@ -246,7 +246,7 @@ void MonClient::handle_mount_ack(MClientMountAck* m)
   bufferlist::iterator p = m->monmap_bl.begin();
   ::decode(monmap, p);
 
-  messenger->set_myname(entity_name_t::CLIENT(m->client));
+  messenger->set_myname(entity_name_t::CLIENT(m->client.v));
 
   // finish.
   timer.cancel_event(mount_timeout_event);
-- 
2.39.5