Changeset 11070 for trunk/FACT++/dim/src

Timestamp:

06/18/11 23:10:31 (13 years ago)

Author:

tbretz

Message:

Updated from v19r20 to v19r21

Location:

trunk/FACT++/dim/src

Files:

• diccpp.cxx (modified) (5 diffs)
• examples/rpc_client.cxx (modified) (1 diff)

trunk/FACT++/dim/src/diccpp.cxx

@@ -452 +452 @@
         {
                 t->stop();
+//dim_print_date_time();
+//printf("DIM RPC: Stopped Timer, Data Received for %s\n", t->getName());
                 if(DimClient::getNoDataCopy() == 0)
                         memcpy(t->itsData, buf, size);
@@ -504 +506 @@
                         itsData = buf;
                 itsSize = size;
+//dim_print_date_time();
+//printf("DIM RPC: Timer fired, No Data Received for %s\n", itsName);
                 wakeUp = 1;
                 if(itsInit)
@@ -618 +622 @@
                 dim_wait();
         itsWaiting = 1;
+        if(itsTimeout)
+                start(itsTimeout);
+//dim_print_date_time();
+//printf("DIM RPC: Started Timer for %s - %d secs\n", itsName, itsTimeout);
         ret = DimClient::sendCommand(itsNameOut, itsDataOut, size); 
         if(!ret)
         {
+                if(itsTimeout)
+                        stop();
+//dim_print_date_time();
+//printf("DIM RPC: Stopped Timer, Command failed for %s\n", itsName);
 //              rpc_user_routine((int *)&itsTagId, itsNolinkBuf, &itsNolinkSize);
                 rpc_user_routine((long *)&itsHandler, itsNolinkBuf, &itsNolinkSize);
         }
+/*
         else
         {
@@ -629 +642 @@
                         start(itsTimeout);
         }
+*/
 }
 
@@ -655 +669 @@
 //      if(itsTagId)
 //              id_free(itsTagId, SRC_DIC);
+//dim_print_date_time();
+//printf("DIM RPC: Deleting RPC and Timer for %s\n", itsName);
         if(itsId)
                 dic_release_service(itsId);

trunk/FACT++/dim/src/examples/rpc_client.cxx

@@ -87 +87 @@
 
         dim_init();
-        DimClient::setNoDataCopy();
+//      DimClient::setNoDataCopy();
 
-        for(i = 0; i < 10; i++)
+        for(i = 0; i < 1; i++)
         {
                 dim_start_thread(do_work,(void *)i);