s4z / plumd

        """Request and read stats from memcache socket."""

        stats = {}

        if not self.socket and not self.connect():

            return {}

        try:

            if PY3:

                self.socket.sendall(bytes(Memcache.STAT_CMD, 'utf8'))

            else:

                self.socket.sendall(Memcache.STAT_CMD)

            st_str = self.socket.recv(Memcache.RECV_SIZE)

            self.log.debug("Memcached: read: {0}".format(st_str))

            for line in st_str.split("\n"):

                vals = line.split()

                if len(vals) != 3:

                    continue

                stype, sname, sval = vals

                if stype == "STAT":

                    msg = "Memcached: {0} = {1}"

                    self.log.debug(msg.format(sname, sval))

                    stats[sname] = sval

        except Exception as e:

            msg = "Memcached: {0}: poll: exception: {1}"

            self.log.error(msg.format(self.addr, e))

            self.disconnect()

        return stats

    def connect(self):

        """Connect to memcached, returns True if sucessful, False otherwise.

        :rtype: bool

        """

            sname = slave_str.format(i)

            if sname not in stats:

                break

            try:

                vals = stats[sname].split(",")

                smetrics = dict((k,v) for k,v in (v.split('=') for v in vals))

                sip = smetrics['ip'].replace(".", "_")

                smname = "{0}_{1}".format(sip, smetrics['port'])

                # record offset and lag

                mname = "{0}.slave.{1}.offset".format(name, sname)

                soffset = moffset - int(smetrics['offset'])

                result.add(plumd.Int(mname, soffset))

                mname = "{0}.slave.{1}.lag".format(name, sname)

                result.add(plumd.Int(mname, smetrics['lag']))

                # if slave is online set online = 1, otherwise 0

                sonline = 1 if smetrics['state'] == "online" else 0

                mname = "{0}.slave.{1}.online".format(name, sname)

                result.add(plumd.Int(mname, sonline))

            except(TypeError, KeyError, ValueError) as e:

                self.log.error("Redis: invalid slave entry: {0}".format(sname))

    def get_metrics(self):

        """Request and read stats from Redis socket."""

        stats = {}

        if not self.socket and not self.connect():

            return {}

        try:

            if PY3:

                self.socket.sendall(bytes(Redis.INFO_CMD, 'utf8'))

            else:

                self.socket.sendall(Redis.INFO_CMD)