RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-01 07:52:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

test/fio/fio_ceph_messenger: make exec multi client on the same host.

Browse Source 
When create Messenger, for client we should give different nonce to
make multi clients on the same host can work. Otherwise, server only
accept one connection.

Signed-off-by: Jianpeng Ma <jianpeng.ma@intel.com>
This commit is contained in:
Jianpeng Ma 2019-06-11 15:21:39 +08:00
parent 9296d783d0
commit c7979833ca
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/test/fio/fio_ceph_messenger.cc
View File

@ -300,8 +300,10 @@ static Messenger *create_messenger(struct ceph_msgr_options *o)
ceph_msgr_types[o->ms_type] :
g_ceph_context->_conf.get_val<std::string>("ms_type");
/* o->td__>pid doesn't set value, so use getpid() instead*/
auto nonce = o->is_receiver ? 0 : (getpid() + o->td__->thread_number);
Messenger *msgr = Messenger::create(g_ceph_context, ms_type.c_str(),
ename, lname, 0, flags);
ename, lname, nonce, flags);
if (o->is_receiver) {
msgr->set_default_policy(Messenger::Policy::stateless_server(0));
msgr->bind(hostname_to_addr(o));
@ -385,6 +387,7 @@ static void put_messenger(struct ceph_msgr_data *data)
static int fio_ceph_msgr_setup(struct thread_data *td)
{
struct ceph_msgr_options *o = (decltype(o))td->eo;
o->td__ = td;
ceph_msgr_data *data;
/* We have to manage global resources so we use threads */