Changeset 3 for trunk


Ignore:
Timestamp:
02/02/11 22:37:40 (9 years ago)
Author:
mmamonski
Message:

try to be resistant to torque restarts - avoid double disconnect == double free

Location:
trunk/pbs_drmaa
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • trunk/pbs_drmaa/job.c

    r1 r3  
    201201                                case PBSE_PROTOCOL: 
    202202                                case PBSE_EXPIRED: 
    203                                         pbs_disconnect( session->pbs_conn ); 
     203                                        if ( session->pbs_conn >= 0 ) 
     204                                                pbs_disconnect( session->pbs_conn ); 
    204205                                        sleep(1); 
    205206                                        session->pbs_conn = pbs_connect( session->super.contact ); 
  • trunk/pbs_drmaa/session.c

    r1 r3  
    288288                        if (pbs_errno == PBSE_PROTOCOL || pbs_errno == PBSE_EXPIRED) 
    289289                         { 
    290                                 pbs_disconnect( pbsself->pbs_conn ); 
     290                                if ( pbsself->pbs_conn >= 0) 
     291                                        pbs_disconnect( pbsself->pbs_conn ); 
    291292                                sleep(1); 
    292293                                pbsself->pbs_conn = pbs_connect( pbsself->super.contact ); 
  • trunk/pbs_drmaa/submit.c

    r1 r3  
    183183                         { 
    184184                                pbsdrmaa_session_t *pbsself = (pbsdrmaa_session_t*)self->session; 
    185                                 pbs_disconnect( pbsself->pbs_conn ); 
     185                                if (pbsself->pbs_conn >= 0 ) 
     186                                        pbs_disconnect( pbsself->pbs_conn ); 
    186187                                sleep(1); 
    187188                                pbsself->pbs_conn = pbs_connect( pbsself->super.contact ); 
Note: See TracChangeset for help on using the changeset viewer.