File dos2unix_control_m.patch of Package libtaobao

Index: libtaobao-0.1/tbsys-0.1/test/testqueuethread.cpp
===================================================================
--- libtaobao-0.1.orig/tbsys-0.1/test/testqueuethread.cpp
+++ libtaobao-0.1/tbsys-0.1/test/testqueuethread.cpp
@@ -13,53 +13,53 @@
  *
  */
 
-#include <tbsys.h>
-
-using namespace tbsys;
-
-int mWriteCount = 1000;
-atomic_t mReadCount;
-CQueueThread *mQueueThread = NULL;
-
-class CMyHandler : public IQueueHandler
-{
-public:
-bool handleQueue (void *data, int len, int threadIndex, void *arg)
-{
-//    printf("TEST==> read_thread: %lu(%d) %d (%s)\n", pthread_self(), threadIndex, len, (char*)data);
-//    fflush(stdout);
-    if (mWriteCount == atomic_add_return(1, &mReadCount) && mQueueThread) {
-        mQueueThread->stop();
-        mQueueThread = NULL;
-    }
-    return 0; 
-}
-};
-
-int main(int argc, char *argv[])
-{
-    if (argc>1) {
-        mWriteCount = atoi(argv[1]);
-    }
-    CMyHandler handler;
-    CQueueThread queueThread(3, &handler, NULL);
-    mQueueThread = &queueThread;
-    queueThread.start();
-    char data[1024];
-    for(int i=1; i<=mWriteCount; i++) {
-        int len = sprintf(data, "data_%05d", i);
-        queueThread.writeData(data, len+1);
-//        printf("TEST==> writeData: %d, (%s)\n", i, data);
-//        fflush(stdout);
-        //if (rand() % 111 == 0) {
-            //usleep(100000);
-        //}
-    }
-    queueThread.wait(); 
-
-    printf("mReadCount: %d\n", atomic_read(&mReadCount));
-    printf("OK\n");
-
-    return 0;
-}
-
+#include <tbsys.h>
+
+using namespace tbsys;
+
+int mWriteCount = 1000;
+atomic_t mReadCount;
+CQueueThread *mQueueThread = NULL;
+
+class CMyHandler : public IQueueHandler
+{
+public:
+bool handleQueue (void *data, int len, int threadIndex, void *arg)
+{
+//    printf("TEST==> read_thread: %lu(%d) %d (%s)\n", pthread_self(), threadIndex, len, (char*)data);
+//    fflush(stdout);
+    if (mWriteCount == atomic_add_return(1, &mReadCount) && mQueueThread) {
+        mQueueThread->stop();
+        mQueueThread = NULL;
+    }
+    return 0;
+}
+};
+
+int main(int argc, char *argv[])
+{
+    if (argc>1) {
+        mWriteCount = atoi(argv[1]);
+    }
+    CMyHandler handler;
+    CQueueThread queueThread(3, &handler, NULL);
+    mQueueThread = &queueThread;
+    queueThread.start();
+    char data[1024];
+    for(int i=1; i<=mWriteCount; i++) {
+        int len = sprintf(data, "data_%05d", i);
+        queueThread.writeData(data, len+1);
+//        printf("TEST==> writeData: %d, (%s)\n", i, data);
+//        fflush(stdout);
+        //if (rand() % 111 == 0) {
+            //usleep(100000);
+        //}
+    }
+    queueThread.wait();
+
+    printf("mReadCount: %d\n", atomic_read(&mReadCount));
+    printf("OK\n");
+
+    return 0;
+}
+
Index: libtaobao-0.1/tbsys-0.1/test/testfilequeue.cpp
===================================================================
--- libtaobao-0.1.orig/tbsys-0.1/test/testfilequeue.cpp
+++ libtaobao-0.1/tbsys-0.1/test/testfilequeue.cpp
@@ -13,56 +13,56 @@
  *
  */
 
-#include <tbsys.h>
-
-using namespace tbsys;
-
-int mWriteCount = 1000;
-atomic_t mReadCount;
-CFileQueueThread *mQueueThread = NULL;
-
-class CMyHandler : public IQueueHandler
-{
-public:
-bool handleQueue(void *data, int len, int threadIndex, void *arg)
-{
-    //printf("TEST==> read_thread: %lu(%d) %d (%s)\n", pthread_self(), threadIndex, len, (char*)data);
-    fflush(stdout);
-    if (mWriteCount == atomic_add_return(1, &mReadCount) && mQueueThread) {
-        mQueueThread->stop();
-        mQueueThread = NULL;
-    }
-    return 0; 
-}
-};
-
-int main(int argc, char *argv[])
-{
-    atomic_set(&mReadCount, 0);
-    char testqueue[64];
-    
-    if (argc>1) {
-        mWriteCount = atoi(argv[1]);
-    }
-    sprintf(testqueue, "q_%d_%d", getpid(), rand());
-    CFileQueue queue("/tmp/queue", testqueue);
-    CMyHandler handler;
-    CFileQueueThread queueThread(&queue, 3, &handler, NULL);
-    mQueueThread = &queueThread;
-    queueThread.start();
-    char data[1024];
-    for(int i=1; i<=mWriteCount; i++) {
-        int len = sprintf(data, "data_%05d", i);
-        queueThread.writeData(data, len+1);
-        //printf("TEST==> writeData: %d, (%s)\n", i, data);
-        fflush(stdout);
-        //if (rand() % 111 == 0) {
-            //usleep(100000);
-        //}
-    }
-    queueThread.wait();
-    printf("mReadCount: %d\n", atomic_read(&mReadCount));
-    printf("OK\n");
-    return 0;
-}
-
+#include <tbsys.h>
+
+using namespace tbsys;
+
+int mWriteCount = 1000;
+atomic_t mReadCount;
+CFileQueueThread *mQueueThread = NULL;
+
+class CMyHandler : public IQueueHandler
+{
+public:
+bool handleQueue(void *data, int len, int threadIndex, void *arg)
+{
+    //printf("TEST==> read_thread: %lu(%d) %d (%s)\n", pthread_self(), threadIndex, len, (char*)data);
+    fflush(stdout);
+    if (mWriteCount == atomic_add_return(1, &mReadCount) && mQueueThread) {
+        mQueueThread->stop();
+        mQueueThread = NULL;
+    }
+    return 0;
+}
+};
+
+int main(int argc, char *argv[])
+{
+    atomic_set(&mReadCount, 0);
+    char testqueue[64];
+
+    if (argc>1) {
+        mWriteCount = atoi(argv[1]);
+    }
+    sprintf(testqueue, "q_%d_%d", getpid(), rand());
+    CFileQueue queue("/tmp/queue", testqueue);
+    CMyHandler handler;
+    CFileQueueThread queueThread(&queue, 3, &handler, NULL);
+    mQueueThread = &queueThread;
+    queueThread.start();
+    char data[1024];
+    for(int i=1; i<=mWriteCount; i++) {
+        int len = sprintf(data, "data_%05d", i);
+        queueThread.writeData(data, len+1);
+        //printf("TEST==> writeData: %d, (%s)\n", i, data);
+        fflush(stdout);
+        //if (rand() % 111 == 0) {
+            //usleep(100000);
+        //}
+    }
+    queueThread.wait();
+    printf("mReadCount: %d\n", atomic_read(&mReadCount));
+    printf("OK\n");
+    return 0;
+}
+