Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorEugene Tarassov2012-08-29 19:22:57 +0000
committerEugene Tarassov2012-08-29 19:22:57 +0000
commitb518111e3b3b99e832e3861cd5f6fe70ca18b2b2 (patch)
tree0929edc98fb031f37f69c750b918a60b153d6cc9 /agent/tcf/services/streamsservice.c
parent8b64a8e8da146c09d36e3f206deafc95358ccd26 (diff)
downloadorg.eclipse.tcf.agent-b518111e3b3b99e832e3861cd5f6fe70ca18b2b2.tar.gz
org.eclipse.tcf.agent-b518111e3b3b99e832e3861cd5f6fe70ca18b2b2.tar.xz
org.eclipse.tcf.agent-b518111e3b3b99e832e3861cd5f6fe70ca18b2b2.zip
TCF Agent: code cleanup: TAB -> spaces
Diffstat (limited to 'agent/tcf/services/streamsservice.c')
-rw-r--r--agent/tcf/services/streamsservice.c48
1 files changed, 24 insertions, 24 deletions
diff --git a/agent/tcf/services/streamsservice.c b/agent/tcf/services/streamsservice.c
index f295ccdf..12869b0c 100644
--- a/agent/tcf/services/streamsservice.c
+++ b/agent/tcf/services/streamsservice.c
@@ -42,7 +42,7 @@ typedef struct Subscription Subscription;
#define STREAM_MAGIC 0x29465398
#ifndef STREAM_BASE_ID
-#define STREAM_BASE_ID "VS"
+#define STREAM_BASE_ID "VS"
#endif
struct VirtualStream {
@@ -124,7 +124,7 @@ static int str2id(char * s, unsigned * id) {
const char * stream_base_id = STREAM_BASE_ID;
char * p = NULL;
while (*stream_base_id != 0) {
- if (*s++ != *stream_base_id++) return 0;
+ if (*s++ != *stream_base_id++) return 0;
}
*id = (unsigned)strtoul(s, &p, 10);
return *p == 0;
@@ -673,7 +673,7 @@ int virtual_stream_read (Channel * c, char * token, char * id, size_t size) {
}
}
else errno = err;
-
+
return err == 0 ? 0 : -1;
}
@@ -691,10 +691,10 @@ static void command_read(char * token, Channel * c) {
if (virtual_stream_read (c, token, id, size) < 0) err = errno;
if (err != 0) {
- /*
- * Handle reply with an error. If none error was detected, the reply
- * was sent back by virtual_stream_read() or delayed.
- */
+ /*
+ * Handle reply with an error. If none error was detected, the reply
+ * was sent back by virtual_stream_read() or delayed.
+ */
write_stringz(&c->out, "R");
write_stringz(&c->out, token);
@@ -768,7 +768,7 @@ int virtual_stream_write (Channel * c, char * token, char * id, size_t size, Inp
if (err != 0) errno = err;
- return err == 0 ? 0 : -1;
+ return err == 0 ? 0 : -1;
}
static void command_write(char * token, Channel * c) {
@@ -786,15 +786,15 @@ static void command_write(char * token, Channel * c) {
json_test_char(&c->inp, MARKER_EOM);
if (err != 0) {
- /*
- * Handle reply with an error. If none error was detected, the reply
- * was sent back by virtual_stream_write() or delayed.
- */
+ /*
+ * Handle reply with an error. If none error was detected, the reply
+ * was sent back by virtual_stream_write() or delayed.
+ */
- write_stringz(&c->out, "R");
- write_stringz(&c->out, token);
- write_errno(&c->out, err);
- write_stream(&c->out, MARKER_EOM);
+ write_stringz(&c->out, "R");
+ write_stringz(&c->out, token);
+ write_errno(&c->out, err);
+ write_stream(&c->out, MARKER_EOM);
}
}
@@ -839,14 +839,14 @@ static void command_eos(char * token, Channel * c) {
if (virtual_stream_eos(c, token, id) < 0) err = errno;
if (err != 0) {
- /*
- * Handle reply with an error. If none error was detected, the reply
- * was sent back by virtual_stream_eos() or delayed.
- */
- write_stringz(&c->out, "R");
- write_stringz(&c->out, token);
- write_errno(&c->out, err);
- write_stream(&c->out, MARKER_EOM);
+ /*
+ * Handle reply with an error. If none error was detected, the reply
+ * was sent back by virtual_stream_eos() or delayed.
+ */
+ write_stringz(&c->out, "R");
+ write_stringz(&c->out, token);
+ write_errno(&c->out, err);
+ write_stream(&c->out, MARKER_EOM);
}
}

Back to the top