Lint

Also, this commit disables an assertion causing a failure in
consumer client.

Dockerfile

@@ -143,13 +143,13 @@ COPY --from=builder \
  /usr/lib/x86_64-linux-gnu/libcrypto* \
  /usr/lib/x86_64-linux-gnu/
 
-RUN ldd /usr/local/lib/libkera.so \
- && ldd /opt/kera/install/bin/coordinator \
- && ldd /opt/kera/install/bin/server
-
 RUN mkdir /logs
 
 ENV LD_LIBRARY_PATH="/usr/local/lib/:$LD_LIBRARY_PATH"
 
+RUN ldd /usr/local/lib/libkera.so \
+ && ldd /opt/kera/install/bin/coordinator \
+ && ldd /opt/kera/install/bin/server
+
 COPY ./docker-entrypoint.sh /
 ENTRYPOINT ["/docker-entrypoint.sh"]

clients/producer-1/Producer.cc

@@ -26,7 +26,7 @@
 #define BATCH_SIZE 2000
 #define KEY_SIZE 10
 #define RECORD_SIZE 100
-#define RECORD_COUNT 100000
+#define RECORD_COUNT 1000000
 #define PRODID 1
 
 int main(int argc, char *argv[]) {
@@ -94,7 +94,6 @@ int main(int argc, char *argv[]) {
     batch->reset(keyHash, STREAMLET_ID);
 
     for (uint64_t i = 0; i < RECORD_COUNT; i++) {
-        std::cout << "Record: " << i << " (totalRecords: " << totalRecords << ", totalBatches: " << totalBatches << ")" << std::endl;
         /*
         if (KEY_SIZE > 0) {
             memset(keyv + tslength, 0, KEY_SIZE - tslength);
@@ -156,12 +155,14 @@ int main(int argc, char *argv[]) {
             
             while (!batchRequest.isReady()) {
                 ramcloud->poll();
-                //KerA::Cycles::sleep(1000000);
+                KerA::Cycles::sleep(1000);  // 1 ms
             }
 
             totalBatches++;
             totalRecords += batch->numberObjectsAppended;
 
+            std::cout << ">>> record " << i << " total_records " << totalRecords << " total_batches " << totalBatches << std::endl;
+
             batch->reset(keyHash, STREAMLET_ID);
         }
     }