Skip to content
This repository has been archived by the owner on May 22, 2019. It is now read-only.

Commit

Permalink
use list_all convention
Browse files Browse the repository at this point in the history
  • Loading branch information
Kyle Maxwell committed Dec 16, 2010
1 parent b98f566 commit 4fc0516
Show file tree
Hide file tree
Showing 3 changed files with 17 additions and 8 deletions.
Expand Up @@ -33,11 +33,11 @@ class ShardManagerService[S <: shards.Shard, J <: JsonJob](nameServer: NameServe
nameServer.listHostnames.toJavaList nameServer.listHostnames.toJavaList
} }


def list_shards() = wrapWithThriftExceptions { def list_all_shards() = wrapWithThriftExceptions {
nameServer.listShards.map(_.toThrift).toJavaList nameServer.listShards.map(_.toThrift).toJavaList
} }


def list_links() = wrapWithThriftExceptions { def list_all_links() = wrapWithThriftExceptions {
nameServer.listLinks.map(_.toThrift).toJavaList nameServer.listLinks.map(_.toThrift).toJavaList
} }


Expand Down Expand Up @@ -96,6 +96,7 @@ class ShardManagerService[S <: shards.Shard, J <: JsonJob](nameServer: NameServe
def get_forwardings(): java.util.List[Forwarding] = wrapWithThriftExceptions { def get_forwardings(): java.util.List[Forwarding] = wrapWithThriftExceptions {
nameServer.getForwardings().map(_.toThrift).toJavaList nameServer.getForwardings().map(_.toThrift).toJavaList
} }
def list_all_forwardings = get_forwardings


def reload_forwardings() = wrapWithThriftExceptions { def reload_forwardings() = wrapWithThriftExceptions {
log.info("Reloading forwardings...") log.info("Reloading forwardings...")
Expand Down
5 changes: 3 additions & 2 deletions src/main/thrift/ShardManager.thrift
Expand Up @@ -41,8 +41,9 @@ service ShardManager {
list<LinkInfo> list_upward_links(1: ShardId id) throws(1: ShardException ex) list<LinkInfo> list_upward_links(1: ShardId id) throws(1: ShardException ex)
list<LinkInfo> list_downward_links(1: ShardId id) throws(1: ShardException ex) list<LinkInfo> list_downward_links(1: ShardId id) throws(1: ShardException ex)


list<LinkInfo> list_links() throws(1: ShardException ex) list<LinkInfo> list_all_links() throws(1: ShardException ex)
list<ShardInfo> list_shards() throws(1: ShardException ex) list<ShardInfo> list_all_shards() throws(1: ShardException ex)
list<Forwarding> list_all_forwardings() throws(1: ShardException ex)


list<ShardInfo> get_child_shards_of_class(1: ShardId parent_id, 2: string class_name) throws(1: ShardException ex) list<ShardInfo> get_child_shards_of_class(1: ShardId parent_id, 2: string class_name) throws(1: ShardException ex)


Expand Down
Expand Up @@ -60,18 +60,25 @@ object ShardManagerServiceSpec extends ConfiguredSpecification with JMocker with
manager.create_shard(thriftShardInfo1) manager.create_shard(thriftShardInfo1)
} }


"list_links" in { "list_all_links" in {
expect { expect {
one(nameServer).listLinks() willReturn List(shards.LinkInfo(shardInfo1.id, shardInfo2.id, 1)) one(nameServer).listLinks() willReturn List(shards.LinkInfo(shardInfo1.id, shardInfo2.id, 1))
} }
manager.list_links() mustEqual List(new thrift.LinkInfo(thriftShardInfo1.id, thriftShardInfo2.id, 1)).toJavaList manager.list_all_links() mustEqual List(new thrift.LinkInfo(thriftShardInfo1.id, thriftShardInfo2.id, 1)).toJavaList
} }


"list_shards" in { "list_all_shards" in {
expect { expect {
one(nameServer).listShards() willReturn List(shardInfo1) one(nameServer).listShards() willReturn List(shardInfo1)
} }
manager.list_shards mustEqual List(thriftShardInfo1).toJavaList manager.list_all_shards() mustEqual List(thriftShardInfo1).toJavaList
}

"list_all_forwardings" in {
expect {
one(nameServer).getForwardings() willReturn List(forwarding)
}
manager.list_all_forwardings() mustEqual List(thriftForwarding).toJavaList
} }


"get_shard" in { "get_shard" in {
Expand Down

0 comments on commit 4fc0516

Please sign in to comment.