Changeset 961

Timestamp:

10/22/06 16:47:37 (7 years ago)

Author:

leo

Message:

 

Location:

sandbox/trunk/pdp/src

Files:

• N-body.cpp (modified) (1 diff)
• Replication.cpp (modified) (7 diffs)

sandbox/trunk/pdp/src/N-body.cpp

@@ -93 +93 @@
         for(size_t step=0; step<times; ++step)
         {
-                XERIAL_DEBUG(_logger, "step " << step);
+                XERIAL_INFO(_logger, "step " << step);
                 naiveUpdate(dt);
                 XERIAL_DEBUG(_logger, "\n" << StringUtil::join(_particle, "\n"));

sandbox/trunk/pdp/src/Replication.cpp

@@ -72 +72 @@
                 opt.add(Option(OPT_VERBOSE, "v", "verbose", "display vorbose log messages"));
                 opt.add(OptionWithArgument(OPT_REPLICATION_MODE, "m", "replication", "MODE", " 0 (default) : one to N replication, 1 : chain replication"));
-                opt.add(OptionWithArgument(OPT_BUFFERSIZE, "b", "buffer", "MBYTES", "buffer size (default: 16M)"));
+                opt.add(OptionWithArgument(OPT_BUFFERSIZE, "b", "buffer", "MBYTES", "buffer size (default: 2M)"));
                 opt.add(OptionWithArgument(OPT_LOGLEVEL, "w", "loglevel", "LOGLEVEL", "0:all, 1:trace, 2:debug, 3:info, 4:warn, 5:error, 6:fatal, 7:off)"));
                 opt.add(OptionWithArgument(OPT_OUTPUTDIR, "d", "dir", "PATH", "output folder"));
@@ -100 +100 @@
                 string fileName = opt.getArgument(0);
                 int replicationMode = Integer::parseInt(opt.getValue(OPT_REPLICATION_MODE, "0"));
-                size_t bufferSize = Integer::parseInt(opt.getValue(OPT_BUFFERSIZE, "16"));
+                size_t bufferSize = Integer::parseInt(opt.getValue(OPT_BUFFERSIZE, "2"));
 
                 ReplicationProcess rp(fileName, outputDir, bufferSize);
@@ -217 +217 @@
                                 MPI::BYTE.Pack(&(fileBuffer[0]), readBytes, &(packedDataBuffer[0]), maximumPackedDataSize, sendBufferPosition, comm);
 
-                                XERIAL_TRACE(_logger, "broad casting data");
-
+                                XERIAL_TRACE(_logger, "broad casting data: size = " << sendBufferPosition);
                                 comm.Bcast(&(packedDataBuffer[0]), sendBufferPosition, MPI::PACKED, serverProcess);
                                 sendBytes += readBytes;
                                 XERIAL_DEBUG(_logger, "send bytes = " << sendBytes);
-                                comm.Barrier();
                         }
                 }
@@ -244 +242 @@
                         XERIAL_THROW(Exception, "cannot open file " << outputFileName);
 
-
-
                 uint64 recievedBytes = 0;
                 while(recievedBytes < fileSize)
@@ -251 +247 @@
                         XERIAL_TRACE(_logger, "braad cast wait");
                         comm.Bcast(&(packedDataBuffer[0]), maximumPackedDataSize, MPI::PACKED, serverProcess);
+                        XERIAL_TRACE(_logger, "receirved broad cast data");
                         int incomingDataSize = 0;
                         int packedBufferPosition = 0;
@@ -263 +260 @@
                         recievedBytes += incomingDataSize;
                         XERIAL_DEBUG(_logger, "recieved bytes = " << recievedBytes);
-                        comm.Barrier();
-                }
+                }
+
         }
 
@@ -276 +273 @@
         }
 }
-