Skip to content
This repository

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse code

Fix Thread issue, Fix config issue

  • Loading branch information...
commit 6fad7ca01c6dd0cd6895aed8a81c70c301bbaa5d 1 parent dc7fe00
Nick Verbeck authored

Showing 1 changed file with 4 additions and 2 deletions. Show diff stats Hide diff stats

  1. +4 2 couchbase/couchbaseclient.py
6 couchbase/couchbaseclient.py
@@ -632,7 +632,7 @@ class VBucketAwareCouchbaseClient(object):
632 632 @param server: Server config. In the form of a URL, Dict, or List/Tuple
633 633 @param bucket: Couchbase bucket you wish to manage
634 634 @param password: Password for the REST API to Admin bucket
635   - @param verbose: Enable loggign
  635 + @param verbose: Enable logging
636 636
637 637 Examples:
638 638 client = VBucketAwareCouchbaseClient("http://127.0.0.1:8092", "default")
@@ -684,7 +684,7 @@ def __init__(self, server, bucket, password="", verbose=False):
684 684
685 685 self.servers = servers
686 686 self.servers_lock = Lock()
687   - self.rest = RestConnection(server)
  687 + self.rest = RestConnection(servers[0])
688 688 self.reconfig_vbucket_map()
689 689 self.init_vbucket_connections()
690 690
@@ -712,6 +712,7 @@ def parse_url(self, url):
712 712 if srv.password is not None:
713 713 server["password"] = srv.password
714 714 self.rest_password = srv.password
  715 + return server
715 716
716 717 def _start_streaming(self):
717 718 # this will dynamically update vBucketMap, vBucketMapFastForward, servers
@@ -980,6 +981,7 @@ class CommandDispatcher(Thread):
980 981 #this class contains a queue where request
981 982
982 983 def __init__(self, vbaware, verbose=False):
  984 + Thread.__init__(self)
983 985 #have a queue , in case of not my vbucket error
984 986 #let's reinitialize the config/memcached socket connections ?
985 987 self.queue = Queue(10000)

0 comments on commit 6fad7ca

Please sign in to comment.
Something went wrong with that request. Please try again.