RemoteEditor/emacs: redit-client-sm.el comparison

comparison redit-client-sm.el @ 48:8d73102deff6

*** empty log message ***

author	gongo
date	Sat, 23 Aug 2008 18:11:26 +0900
parents	991526bc3f16
children	563a0c8c5706

comparison

equal deleted inserted replaced

-:1d131b6064ae
+:8d73102deff6
 (defvar redit-process-filter-resume nil
 "String of the unprocessing in redit-client-process-filter")
 ;; REP が使用する文字コード
-(defconst rep-string-encoding 'utf-8)
+(defconst redit-string-coding 'utf-8)
 ;; port
 (defconst redit-process-port 8766)
 ;; REP command header size
 (defconst redit-deregister-command     51) ;; obsolete
 (defconst redit-deregister-ack-command 52) ;; obsolete
 (defconst redit-quit-command           53)
 (defconst redit-quit-ack-command       54)
 ;;;;;;;;;;;;;;;;;;
 ;; Queue struct ;;
 ;;;;;;;;;;;;;;;;;;
 (defstruct Queue (front nil) (rear nil))
 (defun redit-set-session-info-to-sid-table (sid sinfo)
 (setf (gethash sid sid-to-session-table) sinfo))
 (defun redit-get-session-info-from-sid-table (sid)
 (gethash sid sid-to-session-table))
 ;;;;;;;;;;;;;;;;;;;
 ;; pack / unpack ;;
 ;;;;;;;;;;;;;;;;;;;
 (defun redit-pack-int-loop (num count)
 (if (> count 0)
 (defun redit-unpack-int (pkt pos)
 (redit-unpack-int-loop pkt (* pos 4) 4))
+;; binary この時点では、pkt は binary 形式なので
+;; substring でも抽出できる。。。ってことかな(何
+;; utf-8 とかで decode されていれば多分出来ないはず
+;; (length "あいうえお") => 5
+;; (string-bytes "あいうえお") => 15 (utf-8の場合)
+(defun redit-unpack-str (pkt pos length)
+(substring pkt (* pos 4) (+ (* pos 4) length)))
+(defun redit-make-packet (cmd sid eid seq lno siz text)
+(concat (redit-pack cmd sid eid seq lno siz) text))
+(defun redit-get-command-from-pkt (pkt)
+(redit-unpack-int pkt 1))
+(defun redit-get-session-id-from-pkt (pkt)
+(redit-unpack-int pkt 2))
+(defun redit-get-editor-id-from-pkt (pkt)
+(redit-unpack-int pkt 3))
+(defun redit-get-sequence-id-from-pkt (pkt)
+(redit-unpack-int pkt 4))
+(defun redit-get-line-number-from-pkt (pkt)
+(redit-unpack-int pkt 5))
+(defun redit-get-text-size-from-pkt (pkt)
+(redit-unpack-int pkt 6))
+;; text のサイズが指定されていればそれを使い、
+;; そうでなければ、get-text-size-from-pkt を実行する
+(defun redit-get-text-from-pkt (pkt &optional _siz)
+(let (size)
+(setq size (if (null _siz) (redit-get-text-size-from-pkt pkt) _siz))
+(decode-coding-string (redit-unpack-str pkt 6 size) redit-string-coding)))
 ;;;;;;;;;;;;;;;;;;
 ;; User Command ;;
 ;;;;;;;;;;;;;;;;;;
 (defun redit-join-command ()
 "Allow this Emacs process to be a remote-edit session manager for client processes."
 (interactive)
 (let (bufname)
 (setq bufname (encode-coding-string
 		   (buffer-name)
-		   rep-string-encoding))
+		   redit-string-coding))
 (if redit-client-process
 	(progn
 	  (set-process-sentinel redit-client-process nil)
 	  (condition-case () ;;
 (set-process-sentinel redit-client-process 'redit-client-sentinel)
 ;; called when the process receive packet
 (set-process-filter redit-client-process 'redit-client-process-filter)
-;; //Code of the process input/output buffer is rep-string-encoding
+;; //Code of the process input/output buffer is redit-string-coding
-;; //(set-process-coding-system redit-client-process rep-string-encoding rep-string-encoding)
+;; //(set-process-coding-system redit-client-process redit-string-coding redit-string-coding)
 ;; 送受信するデータはバイナリで貰わないといけない。
 ;; utf-8 じゃなくてずれる可能性があるので
 (set-process-coding-system redit-client-process 'binary 'binary)
 ;; プロセスが生きてるとき、 emacs を終了しようとすると
 		   (progn (goto-line linenum) (beginning-of-line) (point)))
 	     (setq endp
 		   (progn (goto-line linenum) (end-of-line) (point)))
 	     (setq text
 		   (encode-coding-string
-		    (buffer-substring beginp endp) rep-string-encoding))
+		    (buffer-substring beginp endp) redit-string-coding))
 	     (setq length (string-bytes text))
 	     ;;(setq packet (concat (redit-pack redit-insert-command
 		;;			      redit-client-session-id
 			;;		      redit-client-editor-id
 (block loop
 ;; process-filter が受け取れるのは1024byteまで。
 ;; なので、string に入っているパケットが途中で切れてる可能性がある
 (while (> allsize redit-command-header-size)
-	(setq command (rep-get-command-from-pkt string))
+	(setq command (redit-get-command-from-pkt string))
-	(setq textsize (rep-get-text-size-from-pkt string))
+	(setq textsize (redit-get-text-size-from-pkt string))
 	;; ヘッダ (redit-command-header-size) + テキストサイズ
 	(setq cursize (+ redit-command-header-size textsize))
 	;; パケットが 1024 byte の壁で途切れてる場合、
 	;; テキストが読めないので、ループを抜ける
 	(if (> cursize allsize) (return-from loop))
-	(let ((command (rep-get-command-from-pkt string)))
+	(let ((command (redit-get-command-from-pkt string)))
 	  ;; command がどの命令かを判断し、対応した処理をする。case みたい
 	  (cond
 	   ;; FIXME
 	   ;;((if (= command redit-open-ack)
-	   ;;(if (/= redit-client-editor-id (rep-get-editor-id-from-pkt string))
+	   ;;(if (/= redit-client-editor-id (redit-get-editor-id-from-pkt string))
 	   ;;(redit-client-exec-open-ack string))))
 	   ((if (= command redit-read-ack)
-		(if (= redit-client-editor-id (rep-get-editor-id-from-pkt string))
+		(if (= redit-client-editor-id (redit-get-editor-id-from-pkt string))
 		    (redit-client-exec-read-ack string))))
 	   ((if (= command redit-insert-ack)
-		(if (= redit-client-editor-id (rep-get-editor-id-from-pkt string))
+		(if (= redit-client-editor-id (redit-get-editor-id-from-pkt string))
 		    (redit-client-exec-insert-ack string))))
 	   ((if (= command redit-delete-line-ack)
-		(if (= redit-client-editor-id (rep-get-editor-id-from-pkt string))
+		(if (= redit-client-editor-id (redit-get-editor-id-from-pkt string))
 		    (redit-client-exec-delete-line-ack string))))
 	   ((if (= command redit-close-ack)
-		(if (= redit-client-editor-id (rep-get-editor-id-from-pkt string))
+		(if (= redit-client-editor-id (redit-get-editor-id-from-pkt string))
 		    (redit-client-exec-close-ack string))))
 	   ((if (= command redit-insert-command)
-		(if (/= redit-client-editor-id (rep-get-editor-id-from-pkt string))
+		(if (/= redit-client-editor-id (redit-get-editor-id-from-pkt string))
 		    (redit-client-exec-insert-line string))))
 	   ;; from Session Manager
 	   ;; join ack (editor id)
 	   ((if (= command redit-join-ack-command)
 	   ((if (= command redit-put-ack-command)
 		(redit-client-exec-put string)))
 	   ;; delete line
 	   ((if (= command redit-delete-line-command)
-		(if (/= redit-client-editor-id (rep-get-editor-id-from-pkt string))
+		(if (/= redit-client-editor-id (redit-get-editor-id-from-pkt string))
 		    (redit-client-exec-delete-line string))))
 	   )
 	  (setq allsize (- allsize cursize))
 	  ;; string の分割
 (setq redit-client-previous-edited-line endl)))
 ;; 引き数で与えられた string (line_num + text_data) から
 ;; 指定された行を削除し、そこに text_data を挿入する
 (defun redit-client-exec-insert-line (string)
-(let ((linenum (rep-get-line-number-from-pkt string)) ;; 行番号
+(let ((linenum (redit-get-line-number-from-pkt string)) ;; 行番号
-	(text (rep-get-text-from-pkt string))) ;; テキストデータ
+	(text (redit-get-text-from-pkt string))) ;; テキストデータ
 (if (< (real-count-lines (point-max)) linenum)
 	(progn
 	  (call-interactively 'end-of-buffer) (newline)))
 (goto-line linenum)
 (delete-region (progn (beginning-of-line) (point)) ;; 行の頭から
 (insert text) ;; テキストデータを挿入
 ))
 ;; 引き数 string (line_num + text_data) で指定された行を削除する
 (defun redit-client-exec-delete-line (string)
-(let ((linenum (rep-get-line-number-from-pkt string)))
+(let ((linenum (redit-get-line-number-from-pkt string)))
 (goto-line linenum)
 ;; 行頭から末尾までのテキストを削除
 (delete-region (progn (beginning-of-line) (point))
 		   (progn (end-of-line) (point)))
 ;; 指定された行自体を削除
 ;; 何用？相手が開いてるファイルを取得するのかな？
 ;; read みたいなもん？
 ;; 引き数 string (buf_num + line_num + text_data)
 ;;(defun redit-client-exec-open-ack (string)
 ;;  (save-excursion
-;;    (let ((bufnum (rep-get-editor-id-from-pkt string))
+;;    (let ((bufnum (redit-get-editor-id-from-pkt string))
-;;	  (linenum (rep-get-line-number-from-pkt string)))
+;;	  (linenum (redit-get-line-number-from-pkt string)))
 ;;      (make-variable-buffer-local 'redit-client-buffer-name)
 ;;      (make-variable-buffer-local 'redit-client-editor-id)
 ;;      (setq redit-client-buffer-name
-;;	    (rep-get-text-from-pkt string))
+;;	    (redit-get-text-from-pkt string))
 ;;      (setq redit-client-buffer (get-buffer-create redit-client-buffer-name))
 ;;      ;; プロセスとバッファを関連づける
 ;;      (set-process-buffer redit-client-process redit-client-buffer)
 ;;      (switch-to-buffer redit-client-buffer) ;; windowのバッファを変更する
 ;;      (make-variable-buffer-local 'redit-client-previous-edited-line)
 ;; string (line_num + text_data) で指定された行に
 ;; text_data を挿入する
 (defun redit-client-exec-read-ack (string)
 (save-excursion
-(let ((lines (rep-get-line-number-from-pkt string)))
+(let ((lines (redit-get-line-number-from-pkt string)))
 ;; redit-client-buffer をカレントバッファにする
 (set-buffer redit-client-buffer)
 (goto-line lines)
 (beginning-of-line) ;; 行の始めへ移動
 ;;      (delete-region (progn (beginning-of-line) (point))
 ;; 		     (progn (end-of-line) (point)))
-(insert (rep-get-text-from-pkt string))))) ;; テキストデータを挿入
+(insert (redit-get-text-from-pkt string))))) ;; テキストデータを挿入
 ;; redit-client-line-max-in-server に行番号を入れてる(だけ)
 (defun redit-client-exec-insert-ack (string)
 (save-excursion
 (set-buffer redit-client-buffer)
-(let ((linenum (rep-get-line-number-from-pkt string )))
+(let ((linenum (redit-get-line-number-from-pkt string )))
 (setq redit-client-line-max-in-server linenum))))
 (defun redit-client-exec-delete-line-ack (string)
 (save-excursion
 (set-buffer redit-client-buffer)
-(let ((linenum (rep-get-line-number-from-pkt string)))
+(let ((linenum (redit-get-line-number-from-pkt string)))
 (setq redit-client-line-max-in-server linenum))))
 ;; プロセスとバッファ、ローカル変数を削除する
 (defun redit-client-exec-close-ack (string)
 (if redit-client-process
 (kill-all-local-variables))
 ;; 引き数で与えられた string から Editor IDを取得する
 (defun redit-client-exec-join (string)
 (let (sinfo)
-(setq redit-client-editor-id (rep-get-editor-id-from-pkt string))
+(setq redit-client-editor-id (redit-get-editor-id-from-pkt string))
-(setq redit-client-session-id (rep-get-session-id-from-pkt string))
+(setq redit-client-session-id (redit-get-session-id-from-pkt string))
 (setq sinfo (redit-create-session-info redit-client-editor-id))
 (redit-set-session-info-to-sid-table redit-client-session-id sinfo)
 (redit-set-sid-to-bufname-table "test.c" redit-client-session-id)
 ;; //引き数で与えられた string から Session IDを取得する
 ;; 新仕様で、(put = ファイル有りjoin) ってことになって
 ;; editor id を返すことになったので、sid と共に eid もセーブする
 (defun redit-client-exec-put (string)
 (let (sinfo)
-(setq redit-client-editor-id (rep-get-editor-id-from-pkt string))
+(setq redit-client-editor-id (redit-get-editor-id-from-pkt string))
-(setq redit-client-session-id (rep-get-session-id-from-pkt string))
+(setq redit-client-session-id (redit-get-session-id-from-pkt string))
 (setq sinfo (redit-create-session-info redit-client-editor-id))
 (redit-set-session-info-to-sid-table redit-client-session-id sinfo)
 (redit-set-sid-to-bufname-table "test.c" redit-client-session-id)
 	 (message "Client subprocess killed"))))
 (defun gen-seqno ()
 "generate editor local sequence number."
 (setq redit-client-seqno (+ redit-client-seqno 1)))
-(defun redit-make-packet (cmd sid eid seq lno siz text)
-(concat (redit-pack cmd sid eid seq lno siz) text))
-(defun rep-get-command-from-pkt (pkt)
-(redit-unpack-int pkt 1))
-(defun rep-get-session-id-from-pkt (pkt)
-(redit-unpack-int pkt 2))
-(defun rep-get-editor-id-from-pkt (pkt)
-(redit-unpack-int pkt 3))
-(defun rep-get-sequence-id-from-pkt (pkt)
-(redit-unpack-int pkt 4))
-(defun rep-get-line-number-from-pkt (pkt)
-(redit-unpack-int pkt 5))
-(defun rep-get-text-size-from-pkt (pkt)
-(redit-unpack-int pkt 6))
-;; コマンド後ろにあるテキストは
-;;   (substring packet 24)
-;; でとれるので、text-size は要らない、とうれしい。
-;; が、(通信テストまだなので)例えば連続してパケットが送られて来たとき
-;; そのパケットが繋がってしまうと駄目。
-;; もし、process-filter が、一つのパケットの処理が終わるまで
-;; 後続のパケットを止めててくれるならこれでいけるが。
-;; 念のため、受け取った text-size と比較して
-;; 同じならおk、だめならそのサイズ分だけ取る、って所か。
-;; 最初からサイズ分だけでいいんじゃね？と思ったりもするが。
-;; あと、現時点ではサイズが違う(失敗)時の処理いれてない。
-(defun rep-get-text-from-pkt (pkt)
-(let ((size) (text))
-(setq size (rep-get-text-size-from-pkt pkt))
-(setq text (substring pkt 24))
-(decode-coding-string text rep-string-encoding)))
-;;(if (= size (string-bytes text)) text
-;;(decode-coding-string (apply 'concat (split-string text "\xe3"))
-;;rep-string-encoding))))
 (defun redit-line-translate-out (cque rque)
 "redit line translate for output"
 (let ((cc) (rc) (xcc) (xrc) (ccc) (crc) (cignore 0) (rignore 0))
 (setq xcc 0)

Mercurial > hg > RemoteEditor > emacs

comparison redit-client-sm.el @ 48:8d73102deff6