Pass the correct number of entries to writeData (#305)

* Change signature of write function to consider size_t

* Implement return type for all CouplingDataUsers

* Read relevant buffer part only

* Indentation with clang-format 11

CHT/HeatFlux.C

@@ -18,7 +18,7 @@ preciceAdapter::CHT::HeatFlux::HeatFlux(
     dataType_ = scalar;
 }
 
-void preciceAdapter::CHT::HeatFlux::write(double* buffer, bool meshConnectivity, const unsigned int dim)
+std::size_t preciceAdapter::CHT::HeatFlux::write(double* buffer, bool meshConnectivity, const unsigned int dim)
 {
     int bufferIndex = 0;
 
@@ -68,6 +68,7 @@ void preciceAdapter::CHT::HeatFlux::write(double* buffer, bool meshConnectivity,
             }
         }
     }
+    return bufferIndex;
 }
 
 void preciceAdapter::CHT::HeatFlux::read(double* buffer, const unsigned int dim)

CHT/HeatFlux.H

@@ -33,7 +33,7 @@ public:
 
     //- Compute heat flux values from the temperature field
     //  and write them into the buffer
-    void write(double* buffer, bool meshConnectivity, const unsigned int dim) final;
+    std::size_t write(double* buffer, bool meshConnectivity, const unsigned int dim) final;
 
     //- Read heat flux values from the buffer and assign them to
     //  the gradient of the temperature field

CHT/HeatTransferCoefficient.C

@@ -20,7 +20,7 @@ preciceAdapter::CHT::HeatTransferCoefficient::HeatTransferCoefficient(
 }
 
 
-void preciceAdapter::CHT::HeatTransferCoefficient::write(double* buffer, bool meshConnectivity, const unsigned int dim)
+std::size_t preciceAdapter::CHT::HeatTransferCoefficient::write(double* buffer, bool meshConnectivity, const unsigned int dim)
 {
     int bufferIndex = 0;
 
@@ -69,6 +69,7 @@ void preciceAdapter::CHT::HeatTransferCoefficient::write(double* buffer, bool me
             }
         }
     }
+    return bufferIndex;
 }
 
 

CHT/HeatTransferCoefficient.H

@@ -35,7 +35,7 @@ public:
         const std::string nameT);
 
     //- Write the heat transfer coefficient values into the buffer
-    void write(double* buffer, bool meshConnectivity, const unsigned int dim) final;
+    std::size_t write(double* buffer, bool meshConnectivity, const unsigned int dim) final;
 
     //- Read the heat transfer coefficient values from the buffer
     void read(double* buffer, const unsigned int dim) final;

CHT/SinkTemperature.C

@@ -14,7 +14,7 @@ preciceAdapter::CHT::SinkTemperature::SinkTemperature(
     dataType_ = scalar;
 }
 
-void preciceAdapter::CHT::SinkTemperature::write(double* buffer, bool meshConnectivity, const unsigned int dim)
+std::size_t preciceAdapter::CHT::SinkTemperature::write(double* buffer, bool meshConnectivity, const unsigned int dim)
 {
     int bufferIndex = 0;
 
@@ -63,6 +63,7 @@ void preciceAdapter::CHT::SinkTemperature::write(double* buffer, bool meshConnec
         // Clear the temporary internal field object
         patchInternalFieldTmp.clear();
     }
+    return bufferIndex;
 }
 
 void preciceAdapter::CHT::SinkTemperature::read(double* buffer, const unsigned int dim)

CHT/SinkTemperature.H

@@ -26,7 +26,7 @@ public:
         const std::string nameT);
 
     //- Write the sink temperature values into the buffer
-    void write(double* buffer, bool meshConnectivity, const unsigned int dim);
+    std::size_t write(double* buffer, bool meshConnectivity, const unsigned int dim);
 
     //- Read the sink temperature values from the buffer
     void read(double* buffer, const unsigned int dim);

CHT/Temperature.C

@@ -15,7 +15,7 @@ preciceAdapter::CHT::Temperature::Temperature(
     dataType_ = scalar;
 }
 
-void preciceAdapter::CHT::Temperature::write(double* buffer, bool meshConnectivity, const unsigned int dim)
+std::size_t preciceAdapter::CHT::Temperature::write(double* buffer, bool meshConnectivity, const unsigned int dim)
 {
     int bufferIndex = 0;
 
@@ -79,6 +79,7 @@ void preciceAdapter::CHT::Temperature::write(double* buffer, bool meshConnectivi
             }
         }
     }
+    return bufferIndex;
 }
 
 void preciceAdapter::CHT::Temperature::read(double* buffer, const unsigned int dim)

CHT/Temperature.H

@@ -27,7 +27,7 @@ public:
         const std::string nameT);
 
     //- Write the temperature values into the buffer
-    void write(double* buffer, bool meshConnectivity, const unsigned int dim);
+    std::size_t write(double* buffer, bool meshConnectivity, const unsigned int dim);
 
     //- Read the temperature values from the buffer
     void read(double* buffer, const unsigned int dim);

CouplingDataUser.H

@@ -74,7 +74,8 @@ public:
     virtual void initialize();
 
     //- Write the coupling data to the buffer
-    virtual void write(double* dataBuffer, bool meshConnectivity, const unsigned int dim) = 0;
+    // Returns the number of entries that were filles in the buffer (nComp * vertices)
+    virtual std::size_t write(double* dataBuffer, bool meshConnectivity, const unsigned int dim) = 0;
 
     //- Read the coupling data from the buffer
     virtual void read(double* dataBuffer, const unsigned int dim) = 0;

FF/Pressure.C

@@ -13,7 +13,7 @@ preciceAdapter::FF::Pressure::Pressure(
     dataType_ = scalar;
 }
 
-void preciceAdapter::FF::Pressure::write(double* buffer, bool meshConnectivity, const unsigned int dim)
+std::size_t preciceAdapter::FF::Pressure::write(double* buffer, bool meshConnectivity, const unsigned int dim)
 {
     int bufferIndex = 0;
 
@@ -55,6 +55,7 @@ void preciceAdapter::FF::Pressure::write(double* buffer, bool meshConnectivity,
                 p_->boundaryFieldRef()[patchID][i];
         }
     }
+    return bufferIndex;
 }
 
 void preciceAdapter::FF::Pressure::read(double* buffer, const unsigned int dim)

FF/Pressure.H

@@ -26,7 +26,7 @@ public:
         const std::string nameP);
 
     //- Write the pressure values into the buffer
-    void write(double* buffer, bool meshConnectivity, const unsigned int dim);
+    std::size_t write(double* buffer, bool meshConnectivity, const unsigned int dim);
 
     //- Read the pressure values from the buffer
     void read(double* buffer, const unsigned int dim);

FF/PressureGradient.C

@@ -12,7 +12,7 @@ preciceAdapter::FF::PressureGradient::PressureGradient(
     dataType_ = scalar;
 }
 
-void preciceAdapter::FF::PressureGradient::write(double* buffer, bool meshConnectivity, const unsigned int dim)
+std::size_t preciceAdapter::FF::PressureGradient::write(double* buffer, bool meshConnectivity, const unsigned int dim)
 {
     int bufferIndex = 0;
 
@@ -33,6 +33,7 @@ void preciceAdapter::FF::PressureGradient::write(double* buffer, bool meshConnec
                 -gradientPatch[i];
         }
     }
+    return bufferIndex;
 }
 
 void preciceAdapter::FF::PressureGradient::read(double* buffer, const unsigned int dim)

FF/PressureGradient.H

@@ -25,7 +25,7 @@ public:
         const std::string nameP);
 
     //- Write the pressure gradient values into the buffer
-    void write(double* buffer, bool meshConnectivity, const unsigned int dim);
+    std::size_t write(double* buffer, bool meshConnectivity, const unsigned int dim);
 
     //- Read the pressure gradient values from the buffer
     void read(double* buffer, const unsigned int dim);

FF/Temperature.C

@@ -12,7 +12,7 @@ preciceAdapter::FF::Temperature::Temperature(
     dataType_ = scalar;
 }
 
-void preciceAdapter::FF::Temperature::write(double* buffer, bool meshConnectivity, const unsigned int dim)
+std::size_t preciceAdapter::FF::Temperature::write(double* buffer, bool meshConnectivity, const unsigned int dim)
 {
     int bufferIndex = 0;
 
@@ -31,6 +31,7 @@ void preciceAdapter::FF::Temperature::write(double* buffer, bool meshConnectivit
                 T_->boundaryFieldRef()[patchID][i];
         }
     }
+    return bufferIndex;
 }
 
 void preciceAdapter::FF::Temperature::read(double* buffer, const unsigned int dim)

FF/Temperature.H

@@ -25,7 +25,7 @@ public:
         const std::string nameT);
 
     //- Write the temperature values into the buffer
-    void write(double* buffer, bool meshConnectivity, const unsigned int dim);
+    std::size_t write(double* buffer, bool meshConnectivity, const unsigned int dim);
 
     //- Read the temperature values from the buffer
     void read(double* buffer, const unsigned int dim);

FF/TemperatureGradient.C

@@ -13,7 +13,7 @@ preciceAdapter::FF::TemperatureGradient::TemperatureGradient(
     dataType_ = scalar;
 }
 
-void preciceAdapter::FF::TemperatureGradient::write(double* buffer, bool meshConnectivity, const unsigned int dim)
+std::size_t preciceAdapter::FF::TemperatureGradient::write(double* buffer, bool meshConnectivity, const unsigned int dim)
 {
     int bufferIndex = 0;
 
@@ -34,6 +34,7 @@ void preciceAdapter::FF::TemperatureGradient::write(double* buffer, bool meshCon
                 gradientPatch[i];
         }
     }
+    return bufferIndex;
 }
 
 void preciceAdapter::FF::TemperatureGradient::read(double* buffer, const unsigned int dim)

FF/TemperatureGradient.H

@@ -25,7 +25,7 @@ public:
         const std::string nameT);
 
     //- Write the Temperature gradient values into the buffer
-    void write(double* buffer, bool meshConnectivity, const unsigned int dim);
+    std::size_t write(double* buffer, bool meshConnectivity, const unsigned int dim);
 
     //- Read the Temperature gradient values from the buffer
     void read(double* buffer, const unsigned int dim);

FF/Velocity.C

@@ -34,7 +34,7 @@ preciceAdapter::FF::Velocity::Velocity(
     dataType_ = vector;
 }
 
-void preciceAdapter::FF::Velocity::write(double* buffer, bool meshConnectivity, const unsigned int dim)
+std::size_t preciceAdapter::FF::Velocity::write(double* buffer, bool meshConnectivity, const unsigned int dim)
 {
     int bufferIndex = 0;
 
@@ -118,6 +118,7 @@ void preciceAdapter::FF::Velocity::write(double* buffer, bool meshConnectivity,
             }
         }
     }
+    return bufferIndex;
 }
 
 void preciceAdapter::FF::Velocity::read(double* buffer, const unsigned int dim)

FF/Velocity.H

@@ -32,7 +32,7 @@ public:
         bool fluxCorrection = false);
 
     //- Write the velocity values into the buffer
-    void write(double* buffer, bool meshConnectivity, const unsigned int dim);
+    std::size_t write(double* buffer, bool meshConnectivity, const unsigned int dim);
 
     //- Read the velocity values from the buffer
     void read(double* buffer, const unsigned int dim);

FF/VelocityGradient.C

@@ -13,7 +13,7 @@ preciceAdapter::FF::VelocityGradient::VelocityGradient(
     dataType_ = vector;
 }
 
-void preciceAdapter::FF::VelocityGradient::write(double* buffer, bool meshConnectivity, const unsigned int dim)
+std::size_t preciceAdapter::FF::VelocityGradient::write(double* buffer, bool meshConnectivity, const unsigned int dim)
 {
     int bufferIndex = 0;
 
@@ -46,6 +46,7 @@ void preciceAdapter::FF::VelocityGradient::write(double* buffer, bool meshConnec
             }
         }
     }
+    return bufferIndex;
 }
 
 void preciceAdapter::FF::VelocityGradient::read(double* buffer, const unsigned int dim)

FF/VelocityGradient.H

@@ -25,7 +25,7 @@ public:
         const std::string nameU);
 
     //- Write the velocity gradient values into the buffer
-    void write(double* buffer, bool meshConnectivity, const unsigned int dim) final;
+    std::size_t write(double* buffer, bool meshConnectivity, const unsigned int dim) final;
 
     //- Read the velocity gradient values from the buffer
     void read(double* buffer, const unsigned int dim) final;

FSI/Displacement.C

@@ -36,7 +36,7 @@ void preciceAdapter::FSI::Displacement::initialize()
 }
 
 
-void preciceAdapter::FSI::Displacement::write(double* buffer, bool meshConnectivity, const unsigned int dim)
+std::size_t preciceAdapter::FSI::Displacement::write(double* buffer, bool meshConnectivity, const unsigned int dim)
 {
     /* TODO: Implement
      * We need two nested for-loops for each patch,
@@ -46,9 +46,9 @@ void preciceAdapter::FSI::Displacement::write(double* buffer, bool meshConnectiv
 
     // Copy the displacement field from OpenFOAM to the buffer
 
+    int bufferIndex = 0;
     if (this->locationType_ == LocationType::faceCenters)
     {
-        int bufferIndex = 0;
         // For every boundary patch of the interface
         for (const label patchID : patchIDs_)
         {
@@ -70,7 +70,6 @@ void preciceAdapter::FSI::Displacement::write(double* buffer, bool meshConnectiv
             "See https://github.com/precice/openfoam-adapter/issues/153.",
             "warning"));
 
-        int bufferIndex = 0;
         // For every boundary patch of the interface
         for (const label patchID : patchIDs_)
         {
@@ -87,6 +86,7 @@ void preciceAdapter::FSI::Displacement::write(double* buffer, bool meshConnectiv
             }
         }
     }
+    return bufferIndex;
 }
 
 

FSI/Displacement.H

@@ -36,7 +36,7 @@ public:
         const std::string nameCellDisplacement);
 
     //- Write the displacement values into the buffer
-    void write(double* buffer, bool meshConnectivity, const unsigned int dim) final;
+    std::size_t write(double* buffer, bool meshConnectivity, const unsigned int dim) final;
 
     //- Read the displacement values from the buffer
     void read(double* buffer, const unsigned int dim) final;

FSI/DisplacementDelta.C

@@ -34,7 +34,7 @@ void preciceAdapter::FSI::DisplacementDelta::initialize()
 }
 
 
-void preciceAdapter::FSI::DisplacementDelta::write(double* buffer, bool meshConnectivity, const unsigned int dim)
+std::size_t preciceAdapter::FSI::DisplacementDelta::write(double* buffer, bool meshConnectivity, const unsigned int dim)
 {
     /* TODO: Implement
      * We need two nested for-loops for each patch,
@@ -44,6 +44,7 @@ void preciceAdapter::FSI::DisplacementDelta::write(double* buffer, bool meshConn
     FatalErrorInFunction
         << "Writing displacementDeltas is not supported."
         << exit(FatalError);
+    return 0;
 }
 
 // return the displacement to use later in the velocity?

FSI/DisplacementDelta.H

@@ -36,7 +36,7 @@ public:
         const std::string nameCellDisplacement);
 
     //- Write the displacementDelta values into the buffer
-    void write(double* buffer, bool meshConnectivity, const unsigned int dim) final;
+    std::size_t write(double* buffer, bool meshConnectivity, const unsigned int dim) final;
 
     //- Read the displacementDelta values from the buffer
     void read(double* buffer, const unsigned int dim) final;

FSI/Force.C

@@ -36,9 +36,9 @@ preciceAdapter::FSI::Force::Force(
     }
 }
 
-void preciceAdapter::FSI::Force::write(double* buffer, bool meshConnectivity, const unsigned int dim)
+std::size_t preciceAdapter::FSI::Force::write(double* buffer, bool meshConnectivity, const unsigned int dim)
 {
-    this->writeToBuffer(buffer, *Force_, dim);
+    return this->writeToBuffer(buffer, *Force_, dim);
 }
 
 void preciceAdapter::FSI::Force::read(double* buffer, const unsigned int dim)

FSI/Force.H

@@ -26,7 +26,7 @@ public:
         const std::string nameForce);
 
     //- Write the forces values into the buffer
-    void write(double* buffer, bool meshConnectivity, const unsigned int dim) final;
+    std::size_t write(double* buffer, bool meshConnectivity, const unsigned int dim) final;
 
     //- Read the forces values from the buffer
     void read(double* buffer, const unsigned int dim) final;

FSI/ForceBase.C

@@ -130,9 +130,9 @@ Foam::tmp<Foam::volScalarField> preciceAdapter::FSI::ForceBase::mu() const
     }
 }
 
-void preciceAdapter::FSI::ForceBase::writeToBuffer(double* buffer,
-                                                   volVectorField& forceField,
-                                                   const unsigned int dim) const
+std::size_t preciceAdapter::FSI::ForceBase::writeToBuffer(double* buffer,
+                                                          volVectorField& forceField,
+                                                          const unsigned int dim) const
 {
     // Compute forces. See the Forces function object.
     // Stress tensor boundary field
@@ -188,6 +188,7 @@ void preciceAdapter::FSI::ForceBase::writeToBuffer(double* buffer,
                     forceField.boundaryField()[patchID][i][d];
         }
     }
+    return bufferIndex;
 }
 
 void preciceAdapter::FSI::ForceBase::readFromBuffer(double* buffer) const

FSI/ForceBase.H

@@ -39,9 +39,9 @@ public:
         const Foam::fvMesh& mesh,
         const std::string solverType);
 
-    void writeToBuffer(double* buffer,
-                       Foam::volVectorField& forceField,
-                       const unsigned int dim) const;
+    std::size_t writeToBuffer(double* buffer,
+                              Foam::volVectorField& forceField,
+                              const unsigned int dim) const;
 
     void readFromBuffer(double* buffer) const;