2024年Clojure状态调查中分享您的看法!

欢迎!有关如何工作的更多信息,请参阅关于页面。

+5
REPL
已关闭

在预解析会话中,Clojure警告保留在缓冲区,如果没有从客户端显式刷新,则不会发送给客户端。

以下是一个示例预解析会话,使用了netcat(以;;开头的行表示来自预解析服务器的响应)

$ clojure -X clojure.core.server/start-server :name prepl :port 5555 :accept clojure.core.server/io-prepl :server-daemon false &
$ nc localhost 5555

(set! *warn-on-reflection* true)
;; {:tag :ret, :val "true", :ns "user", :ms 2, :form "(set! *warn-on-reflection* true)"}

(.toString (identity "foo"))
;; {:tag :ret, :val "\"foo\"", :ns "user", :ms 4, :form "(.toString (identity \"foo\"))"}
(binding [*out* *err*] (flush))
;; {:tag :err, :val "Reflection warning, NO_SOURCE_PATH:2:1 - reference to field toString can't be resolved.\n"}
;; {:tag :ret, :val "nil", :ns "user", :ms 4, :form "(binding [*out* *err*] (flush))"}

(defn identity [x] x)
;; {:tag :ret, :val "#'user/identity", :ns "user", :ms 3, :form "(defn identity [x] x)"}
(binding [*out* *err*] (flush))
;; {:tag :err, :val "WARNING: identity already refers to: #'clojure.core/identity in namespace: user, being replaced by: #'user/identity\n"}
;; {:tag :ret, :val "nil", :ns "user", :ms 2, :form "(binding [*out* *err*] (flush))"}

这似乎是由预解析的*err* PrintWriter 没有启用autoFlush以及大多数Clojure警告未被显式刷新导致的。

这是否是一个需要解决的问题?或者这是一种预期的行为,客户端的责任是及时刷新错误流?

附注已关闭: 在Clojure 1.12.0-beta1中发布

4 答案

+2

这是一个补丁。我没有其他方式来提交这个补丁。

From 52fe3111bf0f8f769121bdc2c383a3f11aac695f Mon Sep 17 00:00:00 2001
From: Ray McDermott <[email protected]>
Date: Tue, 26 Apr 2022 21:52:21 +0200
Subject: [PATCH] Fix for #CLJ-2645

---
 src/clj/clojure/core/server.clj |  4 ++--
 src/clj/clojure/core_print.clj  | 41 ++++++++++++++++++---------------
 2 files changed, 24 insertions(+), 21 deletions(-)

diff --git a/src/clj/clojure/core/server.clj b/src/clj/clojure/core/server.clj
index 3cda4d1f74..c774cab3b5 100644
--- a/src/clj/clojure/core/server.clj
+++ b/src/clj/clojure/core/server.clj
@@ -220,8 +220,8 @@
     (m/with-bindings
       (in-ns 'user)
       (binding [*in* (or stdin in-reader)
-                *out* (PrintWriter-on #(out-fn {:tag :out :val %1}) nil)
-                *err* (PrintWriter-on #(out-fn {:tag :err :val %1}) nil)]
+                *out* (PrintWriter-on #(out-fn {:tag :out :val %1}) nil true)
+                *err* (PrintWriter-on #(out-fn {:tag :err :val %1}) nil true)]
         (try
           (add-tap tapfn)
           (loop []
diff --git a/src/clj/clojure/core_print.clj b/src/clj/clojure/core_print.clj
index 18c5101c1d..4f10b780a1 100644
--- a/src/clj/clojure/core_print.clj
+++ b/src/clj/clojure/core_print.clj
@@ -559,23 +559,26 @@
 (defn ^java.io.PrintWriter PrintWriter-on
   "implements java.io.PrintWriter given flush-fn, which will be called
   when .flush() is called, with a string built up since the last call to .flush().
-  if not nil, close-fn will be called with no arguments when .close is called"
+  if not nil, close-fn will be called with no arguments when .close is called.
+  autoflush? determines if the PrintWriter will autoflush, false by default."
   {:added "1.10"}
-  [flush-fn close-fn]
-  (let [sb (StringBuilder.)]
-    (-> (proxy [Writer] []
-          (flush []
-                 (when (pos? (.length sb))
-                   (flush-fn (.toString sb)))
-                 (.setLength sb 0))
-          (close []
-                 (.flush ^Writer this)
-                 (when close-fn (close-fn))
-                 nil)
-          (write [str-cbuf off len]
-                 (when (pos? len)
-                   (if (instance? String str-cbuf)
-                     (.append sb ^String str-cbuf ^int off ^int len)
-                     (.append sb ^chars str-cbuf ^int off ^int len)))))
-        java.io.BufferedWriter.
-        java.io.PrintWriter.)))
+  ([flush-fn close-fn]
+   (PrintWriter-on flush-fn close-fn false))
+  ([flush-fn close-fn autoflush?]
+   (let [sb (StringBuilder.)]
+     (-> (proxy [Writer] []
+           (flush []
+             (when (pos? (.length sb))
+               (flush-fn (.toString sb)))
+             (.setLength sb 0))
+           (close []
+             (.flush ^Writer this)
+             (when close-fn (close-fn))
+             nil)
+           (write [str-cbuf off len]
+             (when (pos? len)
+               (if (instance? String str-cbuf)
+                 (.append sb ^String str-cbuf ^int off ^int len)
+                 (.append sb ^chars str-cbuf ^int off ^int len)))))
+         java.io.BufferedWriter.
+         (java.io.PrintWriter. ^boolean autoflush?)))))
已添加到JIRA问题中
我们已将其添加到1.12候选名单,并将尽快跟进。感谢您的贡献!
谢谢你的鼓励 :)
0

此问题似乎已作为CLJ-2645提交到JIRA。

0

我们最近在Clojurian Slack上讨论了这个话题,@alex 希望在这里得到跟进。

客户端进行flush操作的问题在于消息可能会出现乱序。

对flush的需求没有进行文档化——尽管它应该有。

然而,在io-prepl的情况下,这是一个位于同一ns中维护的prepl客户端,io-prepl或其客户端不能强制做flush,因此错误信息会丢失。

prepl 的文档字符串说明将恰好有一个 :ret

我假设一旦接收到一个 :ret 标签,执行就完成了。我不确定预先程序客户端程序还有其他如何理解执行完成的方法。

代码表明,它旨在是最后一条消息,但我知道它可能会改变。无论如何,如果它不是那个,则需要某种完成信号的指示。

Slack用户 @flowthing提出了一个类似于你展示的修复方案,用于修复 prepl

(when-not (= :repl/quit ret)
  (set! *3 *2)

被替换为

(when-not (= :repl/quit ret)
  (binding [*out* *err*] (flush)) ; this is the only difference to the original
  (set! *3 *2)

这是一个简单的修复,确保所有 prepl 客户端都能及时、正确地(即在进行 :ret 之前)收到错误信息。

在没有这项核心修复的情况下,我不得不克隆 prepl 和 io-prepl,因为从外部代码来看没有其他明显的解决方法。

0

这里的基本问题是 *err* 没有得到控制状的清除。

为了完成这个话题,Slack 用户 @flowthing 还提出了一个想法,即在 PrintWriter-on 或其他 PrintWriter 包装器中添加一个选项,以使底层 Writer 自动刷新。

这也将有效,因为预先程序将 outerr 绑定到 PrintWriter-on

客户端必须将 outfn 传递给 prepl,而通过 io-prepl 传递的函数将 *flush-on-newline* 绑定到 true,这被 prn(每次调用值时调用)所尊重。

因此,对 prn 的调用确保 out 总是刷新。

*err* 使用的与 prn 类似的机制,该机制观察到 *flush-on-newline* 也可能提供解决方案所需的各个部分。

通过比较这两种选项并进行一些测试后,我发现通过新名称添加自动刷新选项到 `PrinteWriter-on` 是一个更干净的解决方案。

尽管如此,我不想也分叉核心功能,因此我现在将坚持使用 `binding` 修复。

如果得到一些鼓励,我会很高兴提供补丁。
Go Raft Raft! 你可以做到的!:)
没想到是这样的。好的!
补丁已完成。我在那天签署了CCA,但没有JIRA账户
...