diff options
| author | Peter Stephenson <pws@users.sourceforge.net> | 2004-01-06 13:56:12 +0000 |
|---|---|---|
| committer | Peter Stephenson <pws@users.sourceforge.net> | 2004-01-06 13:56:12 +0000 |
| commit | a892f5e24c60a5a77fc375aedca501152da0686c (patch) | |
| tree | 03da6ba80dedcde37ad928d9cf10b52da6c80288 /Functions | |
| parent | 66329cbe4c9842e6515d8a1b07b83b2ef3bcae35 (diff) | |
| download | zsh-a892f5e24c60a5a77fc375aedca501152da0686c.tar.gz zsh-a892f5e24c60a5a77fc375aedca501152da0686c.tar.xz zsh-a892f5e24c60a5a77fc375aedca501152da0686c.zip | |
19339: minor TCP function suite additions
Diffstat (limited to 'Functions')
| -rw-r--r-- | Functions/TCP/tcp_fd_handler | 1 | ||||
| -rw-r--r-- | Functions/TCP/tcp_read | 38 |
2 files changed, 22 insertions, 17 deletions
diff --git a/Functions/TCP/tcp_fd_handler b/Functions/TCP/tcp_fd_handler index 33f553536..8774a2666 100644 --- a/Functions/TCP/tcp_fd_handler +++ b/Functions/TCP/tcp_fd_handler @@ -1,4 +1,5 @@ local line name=${tcp_by_fd[$1]} +local TCP_HANDLER_ACTIVE=1 if [[ -n $name ]] then local TCP_INVALIDATE_ZLE diff --git a/Functions/TCP/tcp_read b/Functions/TCP/tcp_read index f70bd798c..cf1b99441 100644 --- a/Functions/TCP/tcp_read +++ b/Functions/TCP/tcp_read @@ -60,7 +60,7 @@ setopt extendedglob cbases zmodload -i zsh/mathfunc -local opt drain line quiet block read_fd all sess key val +local opt drain line quiet block read_fd all sess key val noprint local -A read_fds read_fds=() float timeout timeout_all endtime @@ -140,10 +140,10 @@ local helper_stat=2 skip tpat reply REPLY float newtimeout if [[ ${(t)SECONDS} != float* ]]; then - # If called from another function, don't override - typeset -F TCP_SECONDS_START=$SECONDS - # Get extra accuracy by making SECONDS floating point locally - typeset -F SECONDS + # If called from another function, don't override + typeset -F TCP_SECONDS_START=$SECONDS + # Get extra accuracy by making SECONDS floating point locally + typeset -F SECONDS fi if (( timeout_all )); then @@ -198,23 +198,27 @@ while (( ${#read_fds} )); do helper_stat=0 sess=${tcp_by_fd[$read_fd]} - tcp_output -P "${TCP_PROMPT=<-[%s] }" -S $sess -F $read_fd \ - ${TCP_SILENT:+-q} "$line" - # REPLY is now set to the line with an appropriate prompt. - tcp_lines+=($REPLY) - TCP_LINE=$REPLY TCP_LINE_FD=$read_fd # Handle user-defined triggers + noprint=${TCP_SILENT:+-q} if (( ${+tcp_on_read} )); then - # Call the function given in the key for each matching value. - # It is this way round because function names must be - # unique, while patterns do not need to be. Furthermore, - # this keeps the use of subscripting under control. - for key val in ${(kv)tcp_on_read}; do - [[ $line = ${~val} ]] && $key "$sess" "$line" - done + # Call the function given in the key for each matching value. + # It is this way round because function names must be + # unique, while patterns do not need to be. Furthermore, + # this keeps the use of subscripting under control. + for key val in ${(kv)tcp_on_read}; do + if [[ $line = ${~val} ]]; then + $key "$sess" "$line" || noprint=-q + fi + done fi + tcp_output -P "${TCP_PROMPT=<-[%s] }" -S $sess -F $read_fd \ + $noprint "$line" + # REPLY is now set to the line with an appropriate prompt. + tcp_lines+=($REPLY) + TCP_LINE=$REPLY TCP_LINE_FD=$read_fd + # Only handle one line from one device at a time unless draining. [[ -z $drain ]] && return $stat done |