.

wcfs/client/wcfs_watchlink.cpp

@@ -420,6 +420,10 @@ tuple<string, error> _WatchLink::_readline() {
         }
         nl_searchfrom = wlink._rxbuf.length();
 
+        // limit line length to avoid DoS
+        if (wlink._rxbuf.length() > 128)
+            return make_tuple("", fmt::errorf("line is too long"));
+
         int n;
         error err;
         //trace("\t_readline -> read ...\n");
@@ -427,9 +431,6 @@ tuple<string, error> _WatchLink::_readline() {
         //trace("\t_readline -> read: n=%d  err='%s'\n", n, v(err));
         if (n > 0) {
             wlink._rxbuf += string(buf, n);
-            // limit line length to avoid DoS
-            if (wlink._rxbuf.length() > 128) // XXX limit arbitrary
-                return make_tuple("", fmt::errorf("line is too long"));
             continue;
         }
         if (err == nil)