Как я могу добавить код в тестовую программу libnodave (testiso TCP simplified), который защищает процедуру чтения от сбоя?

Я начну с того, что скажу, что я студент колледжа с небольшим опытом работы на c++. Сколько раз вы слышали это правильно? Я работаю с тестовой программой testISO_TCP (упрощенная версия) из библиотеки libnodave. Эта программа выполняет простое считывание значений флагов и блоков данных, когда она подключена к ПЛК seimens 300. Программа не вызывает никаких ошибок как таковых. То, что я пытаюсь сделать, - это, надеюсь, добавить в эту программу некоторый код, который защитит чтение от любого сбоя. Позволь я объясню немного лучше. Скажем, например, у меня есть много чтений, реализованных в коде. На данный момент есть только два чтения. В конце концов я буду запускать этот код с большим количеством других чтений. Теперь скажите, что я запускаю тестовую программу и по какой-то причине теряю связь с ПЛК. Я хотел бы, чтобы программа сделала одну из двух вещей: 1) Как только соединение потеряно, повторите попытку подключения определенное количество раз, а когда она закончится, закройте ее. или 2) как-то продолжать читать с ПЛК пока они все не закончат.

Я надеюсь, что этой информации достаточно, чтобы получить некоторую помощь. Я опубликую код, который я так долго искал, не имея ни малейшего представления о том, как это сделать эффективно. Спасибо всем заранее.

#define PLAY_WITH_KEEPALIVE

#include <stdlib.h>

#include <stdio.h>

#include "nodavesimple.h"

#include "openSocket.h"





#ifdef PLAY_WITH_KEEPALIVE

#include <winsock.h>

#endif





int main(int argc, char **argv) {

    int a,b,c,res, doRun, doStop, doRead, doreadFlag, useProtocol, useSlot;

#ifdef PLAY_WITH_KEEPALIVE      

    int opt;

#endif    

    float d;

    daveInterface * di;

    daveConnection * dc;

    _daveOSserialType fds;

    doRun=0;

    doStop=0;

    doRead=0;

    doreadFlag=0;

    useProtocol=daveProtoISOTCP;

    useSlot=2;





 fds.rfd=openSocket(102, argv[1]);

    #ifdef PLAY_WITH_KEEPALIVE

    errno=0;    

    opt=1;

   //res=setsockopt(fds.rfd, SOL_SOCKET, SO_KEEPALIVE, &opt, 4);

   //LOG3("setsockopt %s %dn", strerror(errno),res);

    #endif

 fds.wfd=fds.rfd;



    if (fds.rfd>0) 

        { 

        di =daveNewInterface(fds,"IF1",0, daveProtoISOTCP, daveSpeed187k);

        daveSetTimeout(di,5000000);

        dc =daveNewConnection(di,2,0, 2);  // insert your rack and slot here







            if (0==daveConnectPLC(dc)) 

                {

                    printf("Connected.n");



                res=daveReadBytes(dc,daveFlags,0,0,16,NULL);

                if (0==res)  

                { 

                        a=daveGetU32(dc);

                        b=daveGetU32(dc);

                        c=daveGetU32(dc);

                        d=daveGetFloat(dc);

                    printf("FD0: %dn",a);

                    printf("FD4: %dn",b);

                    printf("FD8: %dn",c);

                    printf("FD12: %fn",d);

                }//end 0==res



                }//end daveConnectPLC





            else 



            {

        printf("Couldn't connect to PLC.n Please make sure you use the -2 option with a CP243 but not with CPs 343 or 443.n");    

        //closeSocket(fds.rfd);

        //return -2;

            }



    }//end fds.rfd







    fds.rfd=openSocket(102, argv[1]);

    fds.wfd=fds.rfd;



    if (fds.rfd>0) 

        { 

        di =daveNewInterface(fds,"IF1",0, daveProtoISOTCP, daveSpeed187k);

        daveSetTimeout(di,5000000);

        dc =daveNewConnection(di,2,0, 2);  // insert your rack and slot here





            if (0==daveConnectPLC(dc)) 

                {

                    printf("Connected.n");



                res=daveReadBytes(dc,daveDB,1,0,64,NULL);

                if (0==res) 

                { 



                    a=daveGetU16(dc);

                    printf("DB1:DW0: %dn",a);

                    a=daveGetU16(dc);

                    printf("DB1:DW1: %dn...n",a);

                    a=daveGetU16At(dc,62);

                    printf("DB1:DW32: %dn",a);





                }//end 0==res



                    return 0;



                }//end daveConnectPLC

            else 



            {

        printf("Couldn't connect to PLC.n Please make sure you use the -2 option with a CP243 but not with CPs 343 or 443.n");    

        closeSocket(fds.rfd);

        return -2;

            }



    }//end fds.rfd













    else 

    {

    printf("Couldn't open TCP port. nPlease make sure a CP is connected and the IP address is ok. n");    

        return -1;

    }    







}// end main