• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Python scalaris.ScalarisVM类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Python中scalaris.ScalarisVM的典型用法代码示例。如果您正苦于以下问题:Python ScalarisVM类的具体用法?Python ScalarisVM怎么用?Python ScalarisVM使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



在下文中一共展示了ScalarisVM类的18个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。

示例1: testGetNumberOfNodes1

 def testGetNumberOfNodes1(self):
     """Test method for ScalarisVM.getVersion()."""
     vm = ScalarisVM()
     number = vm.getNumberOfNodes()
     self.assertTrue(isinstance(number, int), msg = number)
     self.assertTrue(number >= 0)
     vm.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:7,代码来源:scalaris_test.py


示例2: testGetVersion1

 def testGetVersion1(self):
     """Test method for ScalarisVM.getVersion()."""
     vm = ScalarisVM()
     version = vm.getVersion()
     self.assertTrue(isinstance(version, basestring), msg = version)
     self.assertTrue(len(version) > 0)
     vm.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:7,代码来源:scalaris_test.py


示例3: testGetNodes1

 def testGetNodes1(self):
     """Test method for ScalarisVM.getNodes()."""
     vm = ScalarisVM()
     nodes = vm.getNodes()
     self.assertTrue(isinstance(nodes, list), msg = nodes)
     self.assertTrue(len(nodes) >= 0)
     self.assertEqual(len(nodes), vm.getNumberOfNodes())
     vm.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:8,代码来源:scalaris_test.py


示例4: _testGetOtherVMs

 def _testGetOtherVMs(self, maxVMs):
     """Test method for ScalarisVM.getOtherVMs()."""
     vm = ScalarisVM()
     otherVMs = vm.getOtherVMs(maxVMs)
     self.assertTrue(len(otherVMs) <= maxVMs, "list too long: " + str(otherVMs))
     for otherVMUrl in otherVMs:
         otherVM = ScalarisVM(JSONConnection(otherVMUrl))
         otherVM.getInfo()
         otherVM.close_connection()
     vm.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:10,代码来源:scalaris_test.py


示例5: _testDeleteNode

 def _testDeleteNode(self, action):
     """Test method for ScalarisVM.shutdownNode() and ScalarisVM.killNode()."""
     vm = ScalarisVM()
     size = vm.getNumberOfNodes();
     (ok, _failed) = vm.addNodes(1)
     name = ok[0]
     self.assertEqual(size + 1, vm.getNumberOfNodes())
     if action == 'shutdown':
         result = vm.shutdownNode(name)
     elif action == 'kill':
         result = vm.killNode(name)
     self.assertTrue(result)
     self.assertEqual(size, vm.getNumberOfNodes())
     nodes = vm.getNodes()
     self.assertTrue(not name in nodes, str(nodes) + " should not contain " + name)
     vm.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:16,代码来源:scalaris_test.py


示例6: _testAddNodes

 def _testAddNodes(self, nodesToAdd):
     """Test method for ScalarisVM.addNodes(nodesToAdd)."""
     vm = ScalarisVM()
     size = vm.getNumberOfNodes();
     (ok, failed) = vm.addNodes(nodesToAdd)
     size = size + nodesToAdd
     self.assertEqual(nodesToAdd, len(ok))
     self.assertEqual(len(failed), 0)
     self.assertEqual(size, vm.getNumberOfNodes())
     nodes = vm.getNodes()
     for name in ok:
         self.assertTrue(name in nodes, str(nodes) + " should contain " + name)
     for name in ok:
         vm.killNode(name)
     size = size - nodesToAdd
     self.assertEqual(size, vm.getNumberOfNodes())
     vm.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:17,代码来源:scalaris_test.py


示例7: _testKillVM_NotConnected

 def _testKillVM_NotConnected(self):
     """Test method for ScalarisVM.killVM() with a closed connection."""
     vm = ScalarisVM()
     vm.close_connection()
     #self.assertRaises(scalaris.ConnectionError, vm.killVM())
     vm.killVM()
     vm.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:7,代码来源:scalaris_test.py


示例8: testShutdownNodes_NotConnected

 def testShutdownNodes_NotConnected(self):
     """Test method for ScalarisVM.shutdownNodes() with a closed connection."""
     vm = ScalarisVM()
     vm.close_connection()
     #self.assertRaises(scalaris.ConnectionError, vm.shutdownNodes(0))
     vm.shutdownNodes(0)
     vm.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:7,代码来源:scalaris_test.py


示例9: testGetNumberOfNodes_NotConnected

 def testGetNumberOfNodes_NotConnected(self):
     """Test method for ScalarisVM.getNumberOfNodes() with a closed connection."""
     vm = ScalarisVM()
     vm.close_connection()
     #self.assertRaises(scalaris.ConnectionError, vm.getNumberOfNodes())
     vm.getNumberOfNodes()
     vm.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:7,代码来源:scalaris_test.py


示例10: testKillNodesByName_NotConnected

 def testKillNodesByName_NotConnected(self):
     """Test method for ScalarisVM.killNodesByName() with a closed connection."""
     vm = ScalarisVM()
     vm.close_connection()
     #self.assertRaises(scalaris.ConnectionError, vm.killNodesByName(["test"]))
     vm.killNodesByName(["test"])
     vm.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:7,代码来源:scalaris_test.py


示例11: testGetInfo1

 def testGetInfo1(self):
     """Test method for ScalarisVM.getInfo()."""
     vm = ScalarisVM()
     info = vm.getInfo()
     self.assertTrue(isinstance(info.scalarisVersion, basestring), msg = info.scalarisVersion)
     self.assertTrue(len(info.scalarisVersion) > 0, msg = "scalaris_version (" + info.scalarisVersion + ") != \"\"");
     self.assertTrue(isinstance(info.erlangVersion, basestring), msg = info.erlangVersion)
     self.assertTrue(len(info.erlangVersion) > 0, msg = "erlang_version (" + info.erlangVersion + ") != \"\"");
     self.assertTrue(isinstance(info.memTotal, int), msg = info.memTotal)
     self.assertTrue(info.memTotal >= 0, msg = "mem_total (" + str(info.memTotal) + ") >= 0");
     self.assertTrue(isinstance(info.uptime, int), msg = info.uptime)
     self.assertTrue(info.uptime >= 0, msg = "uptime (" + str(info.uptime) + ") >= 0");
     self.assertTrue(isinstance(info.erlangNode, basestring), msg = info.erlangNode)
     self.assertTrue(len(info.erlangNode) > 0, msg = "erlang_node (" + info.erlangNode + ") != \"\"");
     self.assertTrue(isinstance(info.port, int), msg = info.port)
     self.assertTrue(info.port >= 0 and info.port <= 65535, msg = "0 <= port (" + str(info.port) + ") <= 65535");
     self.assertTrue(isinstance(info.yawsPort, int), msg = info.yawsPort)
     self.assertTrue(info.yawsPort >= 0 and info.yawsPort <= 65535, msg = "0 <= yaws_port (" + str(info.yawsPort) + ") <= 65535");
     vm.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:19,代码来源:scalaris_test.py


示例12: _testDeleteNodes

 def _testDeleteNodes(self, nodesToRemove, action):
     """Test method for ScalarisVM.shutdownNode() and ScalarisVM.killNode()."""
     vm = ScalarisVM()
     size = vm.getNumberOfNodes();
     if nodesToRemove >= 1:
         vm.addNodes(nodesToRemove)
         self.assertEqual(size + nodesToRemove, vm.getNumberOfNodes())
     if action == 'shutdown':
         result = vm.shutdownNodes(nodesToRemove)
     elif action == 'kill':
         result = vm.killNodes(nodesToRemove)
     self.assertEqual(nodesToRemove, len(result))
     self.assertEqual(size, vm.getNumberOfNodes())
     nodes = vm.getNodes()
     for name in result:
         self.assertTrue(not name in nodes, str(nodes) + " should not contain " + name)
     vm.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:17,代码来源:scalaris_test.py


示例13: _testDeleteNodesByName

 def _testDeleteNodesByName(self, nodesToRemove, action):
     """Test method for ScalarisVM.shutdownNode() and ScalarisVM.killNode()."""
     vm = ScalarisVM()
     size = vm.getNumberOfNodes();
     if nodesToRemove >= 1:
         vm.addNodes(nodesToRemove)
         self.assertEqual(size + nodesToRemove, vm.getNumberOfNodes())
     nodes = vm.getNodes()
     shuffle(nodes)
     removedNodes = nodes[:nodesToRemove]
     if action == 'shutdown':
         (ok, not_found) = vm.shutdownNodesByName(removedNodes)
     elif action == 'kill':
         (ok, not_found) = vm.killNodesByName(removedNodes)
     self.assertEqual(nodesToRemove, len(ok))
     self.assertEqual(nodesToRemove, len(not_found))
     list.sort(removedNodes)
     list.sort(ok)
     self.assertEqual(removedNodes, ok)
     self.assertEqual(size, vm.getNumberOfNodes())
     nodes = vm.getNodes()
     for name in ok:
         self.assertTrue(not name in nodes, str(nodes) + " should not contain " + name)
     vm.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:24,代码来源:scalaris_test.py


示例14: _testShutdownVM1

 def _testShutdownVM1(self):
     """Test method for ScalarisVM.shutdownVM()."""
     vm = ScalarisVM()
     vm.shutdownVM()
     vm.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:5,代码来源:scalaris_test.py


示例15: _testKillVM1

 def _testKillVM1(self):
     """Test method for ScalarisVM.killVM()."""
     vm = ScalarisVM()
     vm.killVM()
     vm.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:5,代码来源:scalaris_test.py


示例16: testScalarisVM1

 def testScalarisVM1(self):
     rdht = ScalarisVM()
     rdht.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:3,代码来源:scalaris_test.py


示例17: testScalarisVM2

 def testScalarisVM2(self):
     rdht = ScalarisVM(conn = scalaris.JSONConnection(url = scalaris.DEFAULT_URL))
     rdht.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:3,代码来源:scalaris_test.py


示例18: testDoubleClose

 def testDoubleClose(self):
     rdht = ScalarisVM()
     rdht.close_connection()
     rdht.close_connection()
开发者ID:gongyouliu,项目名称:scalaris,代码行数:4,代码来源:scalaris_test.py



注:本文中的scalaris.ScalarisVM类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Python bus.fire函数代码示例发布时间:2022-05-27
下一篇:
Python utils.myRaise函数代码示例发布时间:2022-05-27
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap