@@ -128,12 +128,16 @@ int workend(mcomm *c)

   if(moption.commpass && !c->authchk){

     m = "password: \x1b]E";

   }else{

-    m = "\n> ";

     if(c->logover && strcmp("dsync", c->parse[0][0])){

       if(cprintf(0, c, "[error] Log lost: %d lines\n", c->logover) == 0){

         c->logover = 0;

       }

     }

+    if(c->logfail){

+      m = "\n> ";

+    }else{

+      m = "> ";

+    }

   }

   if(cprintf(0, c, m) == 0){

     c->working = 0;

@@ -201,6 +201,7 @@ typedef struct

   int isalive;

   int logflag;

   int logover;

+  int logfail;

   char cmdline[2][MAKUO_BUFFER_SIZE];

   char parse[2][8][MAKUO_BUFFER_SIZE];

   char readbuff[2][MAKUO_BUFFER_SIZE];

@@ -294,6 +294,7 @@ int mexec_close(mcomm *c, int n)

     c->logflag  = 0;

     c->logover  = 0;

     c->loglevel = 0;

+    c->logfail  = 0;

     c->isalive  = 0;

     if(c->cpid){

       kill(c->cpid, SIGTERM);

@@ -195,12 +195,15 @@ int cprintf(int l, mcomm *c, char *fmt, ...)

   va_start(arg, fmt);

   vsnprintf(m, sizeof(m), fmt, arg);

   va_end(arg);

+  m[sizeof(m) - 2] = '\n';

   m[sizeof(m) - 1] = 0;

   n = strlen(m);

   if(write(c->fd[0], m, n) == n){

     fsync(c->fd[0]);

+    c->logfail = 0;

   }else{

     c->logover++;

+    c->logfail = 1;

     lprintf(0, "[error] %s: Resource temporarily unavailable: %s", __func__, m);

     return(-1);

   }