rename into ioriot

1 files changed, 0 insertions, 85 deletions

diff --git a/ioreplay/src/generate/gwriter.c b/ioreplay/src/generate/gwriter.c
deleted file mode 100644
index e0d448e..0000000
--- a/ioreplay/src/generate/gwriter.c
+++ /dev/null
@@ -1,85 +0,0 @@
-// Copyright 2018 Mimecast Ltd.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-//      http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-#include "gwriter.h"
-
-#include "gtask.h"
-#include "generate.h"
-#include "gioop.h"
-#include "../opcodes.h"
-
-void* gwriter_pthread_start(void *data)
-{
-    gwriter_s *w = data;
-    generate_s *g = w->generate;
-    gtask_s *t = NULL;
-
-    do {
-        while (NULL != (t = rbuffer_get_next(w->queue))) {
-#ifdef LOG_FILTERED
-            // Logging filtered lines
-            if (SUCCESS != gioop_run(w, t)) {
-                fprintf(g->replay_fd, "#FILTERED @%ld %s", t->lineno,
-                        t->original_line);
-            }
-#else
-            gioop_run(w, t);
-#endif
-            rbuffer_insert(g->reuse_queue, t);
-        }
-        usleep(100);
-    } while (!w->terminate);
-
-    while (NULL != (t = rbuffer_get_next(w->queue))) {
-#ifdef LOG_FILTERED
-        if (SUCCESS != gioop_run(w, t)) {
-            fprintf(g->replay_fd, "#FILTERED @%ld %s\n", t->lineno,
-                    t->original_line);
-        }
-#else
-        gioop_run(w, t);
-#endif
-        rbuffer_insert(g->reuse_queue, t);
-    }
-
-    return NULL;
-}
-
-gwriter_s* gwriter_new(generate_s *g)
-{
-    gwriter_s *w = Malloc(gwriter_s);
-
-    w->generate = g;
-    w->terminate = false;
-    w->queue = rbuffer_new(1024);
-
-    return w;
-}
-
-void gwriter_start(gwriter_s *w)
-{
-    start_pthread(&w->pthread, gwriter_pthread_start, (void*)w);
-}
-
-void gwriter_destroy(gwriter_s *w)
-{
-    rbuffer_destroy(w->queue);
-    free(w);
-}
-
-void gwriter_terminate(gwriter_s *w)
-{
-    w->terminate = true;
-    pthread_join(w->pthread, NULL);
-}