@@ -504,6 +504,29 @@ def test_dump_inmemory_log_on_missed_internal_heartbeats(self):
504504 return
505505 self .assertTrue (False , "Failed to dump in-memory logs during missed internal heartbeat" )
506506
507+ def _session_client_ls (self , cmd ):
508+ mount_a_client_id = self .mount_a .get_global_id ()
509+ info = self .fs .rank_asok (cmd )
510+ mount_a_mountpoint = self .mount_a .mountpoint
511+ mount_b_mountpoint = self .mount_b .mountpoint
512+ self .assertIsNotNone (info )
513+ for i in range (0 , len (info )):
514+ self .assertIn (info [i ]["client_metadata" ]["mount_point" ],
515+ [mount_a_mountpoint , mount_b_mountpoint ])
516+ info = self .fs .rank_asok (cmd + [f"id={ mount_a_client_id } " ])
517+ self .assertEqual (len (info ), 1 )
518+ self .assertEqual (info [0 ]["id" ], mount_a_client_id )
519+ self .assertEqual (info [0 ]["client_metadata" ]["mount_point" ], mount_a_mountpoint )
520+ info = self .fs .rank_asok (cmd + ['--cap_dump' ])
521+ for i in range (0 , len (info )):
522+ self .assertIn ("caps" , info [i ])
523+
524+ def test_session_ls (self ):
525+ self ._session_client_ls (['session' , 'ls' ])
526+
527+ def test_client_ls (self ):
528+ self ._session_client_ls (['client' , 'ls' ])
529+
507530class TestCacheDrop (CephFSTestCase ):
508531 CLIENTS_REQUIRED = 1
509532
0 commit comments