Changeset 87 for trunk/pbs_drmaa/pbs_conn.c

Timestamp:

02/11/13 14:10:39 (11 years ago)

Author:

mmamonski

Message:

BUMP version 1.0.13

File:

• trunk/pbs_drmaa/pbs_conn.c (modified) (8 diffs)

trunk/pbs_drmaa/pbs_conn.c

@@ -53 +53 @@
 static void pbsdrmaa_pbs_holdjob( pbsdrmaa_pbs_conn_t *self,  char *job_id );
 
-static void pbsdrmaa_pbs_connection_autoclose_thread_loop( pbsdrmaa_pbs_conn_t *self, bool reconnect);
+/* static void pbsdrmaa_pbs_connection_autoclose_thread_loop( pbsdrmaa_pbs_conn_t *self, bool reconnect); */
 
 
@@ -111 +111 @@
 
                         if (self->connection_fd != -1)
+                          {
+                                fsd_log_info(( "pbs_disconnect(%d)", self->connection_fd ));
                                 pbs_disconnect(self->connection_fd);
+                          }
                   }
                         
@@ -132 +135 @@
                 if(self != NULL)
                 {
+                        if (self->connection_fd != -1)
+                          {
+                                fsd_log_info(( "pbs_disconnect(%d)", self->connection_fd ));
+                                pbs_disconnect(self->connection_fd);
+
+                          }
                         fsd_free(self->server);
                         fsd_free(self); 
-
-                        if (self->connection_fd != -1)
-                                pbs_disconnect(self->connection_fd);
                 }
         }
@@ -220 +226 @@
                 status = pbs_statjob(self->connection_fd, job_id, attrib, NULL);
 
-                fsd_log_info(( "pbs_statjob( fd=%d, job_id=%s, attribs={...} ) =%p", self->connection_fd, job_id, (void*)status));
+                fsd_log_info(( "pbs_statjob( fd=%d, job_id=%s, attribs={...} ) = %p", self->connection_fd, job_id, (void*)status));
 
                 if(status == NULL)
@@ -230 +236 @@
                         else if (IS_TRANSIENT_ERROR && first_try)
                          {
-                                fsd_log_error(( "pbs_statjob failed, pbs_errno = %d", pbs_errno ));
+                                fsd_log_info(( "pbs_statjob failed, pbs_errno = %d, retrying", pbs_errno ));
                                 check_reconnect(self, true);
                                 first_try = false;
@@ -344 +350 @@
                 if(rc != PBSE_NONE)
                  {
-                        fsd_log_error(( "pbs_deljob failed, rc = %d, pbs_errno = %d", rc, pbs_errno ));
                         if (IS_TRANSIENT_ERROR && first_try)
                          {
+                                fsd_log_info(( "pbs_deljob failed, rc = %d, pbs_errno = %d. Retrying...", rc, pbs_errno ));
                                 check_reconnect(self, true);
                                 first_try = false;
@@ -491 +497 @@
                 else
                  {
-                        stop_autoclose_thread(self);
+                        fsd_log_info(( "pbs_disconnect(%d)", self->connection_fd ));
                         pbs_disconnect(self->connection_fd);
                         self->connection_fd = -1;
@@ -501 +507 @@
 retry_connect: /* Life... */
         self->connection_fd = pbs_connect( self->server );
-        fsd_log_info(( "pbs_connect(%s) =%d", self->server, self->connection_fd ));
+        fsd_log_info(( "pbs_connect(%s) = %d", self->server, self->connection_fd ));
         if( self->connection_fd < 0 && tries_left-- )
           {