KaneAI - World’s First E2E Software Testing Agent.Book a Demo Join TestMu Conference

How to use _slave_hello method in autotest

Best Python code snippet using autotest_python

barrier.py

Source:barrier.py

...203                     name, addr[0], addr[1])204        # They seem to be valid record them.205        self._waiting[name] = connection206        self._seen += 1207    def _slave_hello(self, connection):208        (client, addr) = connection209        name = None210        client.settimeout(5)211        try:212            client.send(self._tag + " " + self._hostid)213            reply = client.recv(4)214            reply = reply.strip("\r\n")215            logging.info("master said: %s", reply)216            # Confirm the master accepted the connection.217            if reply != "wait":218                logging.warning("Bad connection request to master")219                client.close()220                return221        except socket.timeout:222            # This is nominally an error, but as we do not know223            # who that was we cannot do anything sane other224            # than report it and let the normal timeout kill225            # us when thats appropriate.226            logging.error("master handshake timeout: (%s:%d)",227                          addr[0], addr[1])228            client.close()229            return230        logging.info("slave now waiting: (%s:%d)", addr[0], addr[1])231        # They seem to be valid record them.232        self._waiting[self._hostid] = connection233        self._seen = 1234    def _master_release(self):235        # Check everyone is still there, that they have not236        # crashed or disconnected in the meantime.237        allpresent = True238        abort = self._abort239        for name in self._waiting:240            (client, addr) = self._waiting[name]241            logging.info("checking client present: %s", name)242            client.settimeout(5)243            reply = 'none'244            try:245                client.send("ping")246                reply = client.recv(1024)247            except socket.timeout:248                logging.warning("ping/pong timeout: %s", name)249                pass250            if reply == 'abrt':251                logging.warning("Client %s requested abort", name)252                abort = True253            elif reply != "pong":254                allpresent = False255        if not allpresent:256            raise error.BarrierError("master lost client")257        if abort:258            logging.info("Aborting the clients")259            msg = 'abrt'260        else:261            logging.info("Releasing clients")262            msg = 'rlse'263        # If every ones checks in then commit the release.264        for name in self._waiting:265            (client, addr) = self._waiting[name]266            client.settimeout(5)267            try:268                client.send(msg)269            except socket.timeout:270                logging.warning("release timeout: %s", name)271                pass272        if abort:273            raise BarrierAbortError("Client requested abort")274    def _waiting_close(self):275        # Either way, close out all the clients.  If we have276        # not released them then they know to abort.277        for name in self._waiting:278            (client, addr) = self._waiting[name]279            logging.info("closing client: %s", name)280            try:281                client.close()282            except:283                pass284    def _run_server(self, is_master):285        server = self._server or listen_server(port=self._port)286        failed = 0287        try:288            while True:289                try:290                    # Wait for callers welcoming each.291                    server.socket.settimeout(self._remaining())292                    connection = server.socket.accept()293                    if is_master:294                        self._master_welcome(connection)295                    else:296                        self._slave_hello(connection)297                except socket.timeout:298                    logging.warning("timeout waiting for remaining clients")299                    pass300                if is_master:301                    # Check if everyone is here.302                    logging.info("master seen %d of %d",303                                 self._seen, len(self._members))304                    if self._seen == len(self._members):305                        self._master_release()306                        break307                else:308                    # Check if master connected.309                    if self._seen:310                        logging.info("slave connected to master")311                        self._slave_wait()312                        break313        finally:314            self._waiting_close()315            # if we created the listening_server in the beginning of this316            # function then close the listening socket here317            if not self._server:318                server.close()319    def _run_client(self, is_master):320        while self._remaining() is None or self._remaining() > 0:321            try:322                remote = socket.socket(socket.AF_INET,323                        socket.SOCK_STREAM)324                remote.settimeout(30)325                if is_master:326                    # Connect to all slaves.327                    host = _get_host_from_id(self._members[self._seen])328                    logging.info("calling slave: %s", host)329                    connection = (remote, (host, self._port))330                    remote.connect(connection[1])331                    self._master_welcome(connection)332                else:333                    # Just connect to the master.334                    host = _get_host_from_id(self._masterid)335                    logging.info("calling master")336                    connection = (remote, (host, self._port))337                    remote.connect(connection[1])338                    self._slave_hello(connection)339            except socket.timeout:340                logging.warning("timeout calling host, retry")341                sleep(10)342                pass343            except socket.error, err:344                (code, str) = err345                if (code != errno.ECONNREFUSED and346                    code != errno.ETIMEDOUT):347                    raise348                sleep(10)349            if is_master:350                # Check if everyone is here.351                logging.info("master seen %d of %d",352                             self._seen, len(self._members))...

base_barrier.py

Source:base_barrier.py

...203                     name, addr[0], addr[1])204        # They seem to be valid record them.205        self._waiting[name] = connection206        self._seen += 1207    def _slave_hello(self, connection):208        (client, addr) = connection209        name = None210        client.settimeout(5)211        try:212            client.send(self._tag + " " + self._hostid)213            reply = client.recv(4)214            reply = reply.strip("\r\n")215            logging.info("master said: %s", reply)216            # Confirm the master accepted the connection.217            if reply != "wait":218                logging.warning("Bad connection request to master")219                client.close()220                return221        except socket.timeout:222            # This is nominally an error, but as we do not know223            # who that was we cannot do anything sane other224            # than report it and let the normal timeout kill225            # us when thats appropriate.226            logging.error("master handshake timeout: (%s:%d)",227                          addr[0], addr[1])228            client.close()229            return230        logging.info("slave now waiting: (%s:%d)", addr[0], addr[1])231        # They seem to be valid record them.232        self._waiting[self._hostid] = connection233        self._seen = 1234    def _master_release(self):235        # Check everyone is still there, that they have not236        # crashed or disconnected in the meantime.237        allpresent = True238        abort = self._abort239        for name in self._waiting:240            (client, addr) = self._waiting[name]241            logging.info("checking client present: %s", name)242            client.settimeout(5)243            reply = 'none'244            try:245                client.send("ping")246                reply = client.recv(1024)247            except socket.timeout:248                logging.warning("ping/pong timeout: %s", name)249                pass250            if reply == 'abrt':251                logging.warning("Client %s requested abort", name)252                abort = True253            elif reply != "pong":254                allpresent = False255        if not allpresent:256            raise error.BarrierError("master lost client")257        if abort:258            logging.info("Aborting the clients")259            msg = 'abrt'260        else:261            logging.info("Releasing clients")262            msg = 'rlse'263        # If every ones checks in then commit the release.264        for name in self._waiting:265            (client, addr) = self._waiting[name]266            client.settimeout(5)267            try:268                client.send(msg)269            except socket.timeout:270                logging.warning("release timeout: %s", name)271                pass272        if abort:273            raise BarrierAbortError("Client requested abort")274    def _waiting_close(self):275        # Either way, close out all the clients.  If we have276        # not released them then they know to abort.277        for name in self._waiting:278            (client, addr) = self._waiting[name]279            logging.info("closing client: %s", name)280            try:281                client.close()282            except:283                pass284    def _run_server(self, is_master):285        server = self._server or listen_server(port=self._port)286        failed = 0287        try:288            while True:289                try:290                    # Wait for callers welcoming each.291                    server.socket.settimeout(self._remaining())292                    connection = server.socket.accept()293                    if is_master:294                        self._master_welcome(connection)295                    else:296                        self._slave_hello(connection)297                except socket.timeout:298                    logging.warning("timeout waiting for remaining clients")299                    pass300                if is_master:301                    # Check if everyone is here.302                    logging.info("master seen %d of %d",303                                 self._seen, len(self._members))304                    if self._seen == len(self._members):305                        self._master_release()306                        break307                else:308                    # Check if master connected.309                    if self._seen:310                        logging.info("slave connected to master")311                        self._slave_wait()312                        break313        finally:314            self._waiting_close()315            # if we created the listening_server in the beginning of this316            # function then close the listening socket here317            if not self._server:318                server.close()319    def _run_client(self, is_master):320        while self._remaining() is None or self._remaining() > 0:321            try:322                remote = socket.socket(socket.AF_INET,323                        socket.SOCK_STREAM)324                remote.settimeout(30)325                if is_master:326                    # Connect to all slaves.327                    host = get_host_from_id(self._members[self._seen])328                    logging.info("calling slave: %s", host)329                    connection = (remote, (host, self._port))330                    remote.connect(connection[1])331                    self._master_welcome(connection)332                else:333                    # Just connect to the master.334                    host = get_host_from_id(self._masterid)335                    logging.info("calling master")336                    connection = (remote, (host, self._port))337                    remote.connect(connection[1])338                    self._slave_hello(connection)339            except socket.timeout:340                logging.warning("timeout calling host, retry")341                sleep(10)342                pass343            except socket.error, err:344                (code, str) = err345                if (code != errno.ECONNREFUSED):346                    raise347                sleep(10)348            if is_master:349                # Check if everyone is here.350                logging.info("master seen %d of %d",351                             self._seen, len(self._members))352                if self._seen == len(self._members):...

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.