record Q_entryM: int; // the applic

record Q_entry
M: int; // the application message
tag: int; // unique message identifier sender_id: int; // sender of the message timestamp: int; // tentative timestamp assigned to message deliverable: boolean; // whether message is ready for delivery
(local variables)
queue of Q_entry: temp_Q, delivery_Q
int: clock // Used as a variant of Lamport’s scalar clock
int: priority // Used to track the highest proposed timestamp (message types)
REVISE_TS(M, i, tag, ts)
// Phase 1 message sent by Pi, with initial timestamp ts
PROPOSED_TS(j, i, tag, ts)
// Phase 2 message sent by Pj , with revised timestamp, to Pi
FINAL_TS(i, tag, ts) // Phase 3 message sent by Pi, with final timestamp
(1) When process Pi wants to multicast a message M with a tag tag: (1a) clock ← clock + 1;
(1b) send REVISE_TS(M, i, tag, clock) to all processes; (1c) temp_ts ← 0;
(1d) await PROPOSED_TS(j, i, tag, tsj) from each process Pj ; (1e) ∀j ∈ N , do temp_ts ← max(temp_ts, tsj);
(1f) send FINAL_TS(i, tag, temp_ts) to all processes; (1g) clock ← max(clock, temp_ts).
(2) When REVISE_TS(M, j, tag, clk) arrives from Pj : (2a) priority ← max(priority + 1, clk);
(2b) insert (M, tag, j, priority, undeliverable) in temp_Q;
// at end of queue
(2c) send PROPOSED_TS(i, j, tag, priority) to Pj .
(3) When FINAL_TS(j, x, clk) arrives from Pj :
(3a) Identify entry Q_e in temp_Q, where Q_e.tag = x;
(3b) mark Q_e.deliverable as true;
(3c) Update Q_e.timestamp to clk and re-sort temp_Q based on the
timestamp field;
(3d) if (head(temp_Q)).tag = Q_e.tag then
(3e) move Q_e from temp_Q to delivery_Q; (3f) while (head(temp_Q)).deliverable is true do
(3g) dequeue head(temp_Q) and insert in delivery_Q.
(4) When Pi removes a message (M, tag, j, ts, deliverable) from
head(delivery_Qi):
(4a) clock ← max(clock, ts) + 1.

Kết quả (Việt) 1:

ghi Q_entryM: int; ứng dụng thưtừ khóa: int; thông báo duy nhất định danh sender_id: int; người gửi của thư dấu thời gian: int; dấu thời gian dự kiến được gán cho thư deliverable: boolean; cho dù thư đã sẵn sàng cho việc phân phối(địa phương biến)hàng đợi Q_entry: temp_Q, delivery_QINT: đồng hồ / / sử dụng như là một biến thể của Lamport của vô hướng đồng hồINT: ưu tiên / / sử dụng để theo dõi dấu thời gian đề nghị cao nhất (loại thư)REVISE_TS (M, tôi, từ khóa, ts)Giai đoạn 1 thư được gửi bởi Pi, với dấu thời gian ban đầu tsPROPOSED_TS (j, tôi, từ khóa, ts)Giai đoạn 2 thư được gửi bởi Pj, với sửa đổi dấu thời gian nhất, phải PiFINAL_TS (tôi, từ khóa, ts) / / giai đoạn 3 thư gửi bởi Pi, với dấu thời gian cuối cùng(1) khi quá trình Pi muốn phát đa hướng đến một tin nhắn M với một từ khóa từ khóa: (1a) đồng hồ đồng hồ ← + 1;(1b) gửi REVISE_TS (M, tôi, từ khóa, giờ) để tất cả quá trình; (1c) temp_ts ← 0;(1d) đang chờ đợi PROPOSED_TS (j, tôi, từ khóa, tsj) từ mỗi quá trình Pj; (1e) ∀j ∈ N, làm temp_ts ← max (temp_ts, tsj);(1f) gửi FINAL_TS (tôi, từ khóa, temp_ts) đến tất cả các quy trình; (1g) đồng hồ ← tối đa (đồng hồ, temp_ts).(2) khi REVISE_TS (M, j, từ khóa, clk) đến từ Pj: (2a) ưu tiên ← tối đa (ưu tiên + 1, clk);chèn (2b) (M, từ khóa, j, ưu tiên, không thể gửi) trong temp_Q;cuối hàng đợi(2c) gửi PROPOSED_TS (i, j, từ khóa, ưu tiên) để Pj.(3) khi FINAL_TS (j, x, clk) đến từ Pj:(3a) xác định nhập cảnh Q_e ở temp_Q, nơi Q_e.tag = x;(3b) mark Q_e.deliverable là đúng;(3c) Cập Nhật Q_e.timestamp để temp_Q clk và tái sắp xếp dựa trên cácthời gian hiển thị trường;Nếu (3d) (head(temp_Q)) .tag = Q_e.tag sau đódi chuyển (3e) Q_e từ temp_Q đến delivery_Q; (3f) trong khi (head(temp_Q)) .deliverable là làm đúng(3g) dequeue head(temp_Q) và đưa vào delivery_Q.(4) khi Pi loại bỏ một tin nhắn (M, từ khóa, j, ts, deliverable) từHead(delivery_Qi):(4a) đồng hồ ← tối đa (đồng hồ, ts) + 1.

Kết quả (Việt) 2:

kỷ lục Q_entry
M: int; // Thông điệp ứng dụng
tag: int; // Định danh độc đáo sender_id nhắn: int; // Người gửi tin nhắn timestamp: int; // Dấu thời gian dự kiến giao cho thông điệp chuyển giao: boolean; // Liệu tin nhắn đã sẵn sàng cho giao hàng
(biến cục bộ)
hàng đợi của Q_entry: temp_Q, delivery_Q
int: đồng hồ // Được sử dụng như là một biến thể của vô hướng đồng hồ Lamport của
int: ưu tiên // Được sử dụng để theo dõi các dấu thời gian được đề xuất cao nhất (các loại tin nhắn)
REVISE_TS ( M, i, tag, ts)
// Giai đoạn 1 tin nhắn gửi bởi Pi, với ts dấu thời gian ban đầu
PROPOSED_TS (j, i, tag, ts)
// Giai đoạn 2 nhắn gửi bởi Pj, với dấu thời gian sửa đổi, để Pi
FINAL_TS (i, tag, ts) // Giai đoạn 3 nhắn gửi bởi Pi, với dấu thời gian thức
(1) Khi quá trình Pi muốn multicast nhắn M với một thẻ tag: (1a) đồng hồ ← đồng hồ + 1;
(1b) gửi REVISE_TS (M, i, tag, đồng hồ) cho tất cả các quy trình; (1c) temp_ts ← 0;
(1d) đang chờ đợi PROPOSED_TS (j, i, tag, tsj) từ mỗi quá trình Pj; (1e) ∀j ∈ N, đừng temp_ts ← max (temp_ts, tsj);
(1f) gửi FINAL_TS (i, tag, temp_ts) cho tất cả các quy trình; . (1g) đồng hồ ← max (đồng hồ, temp_ts)
(2) Khi REVISE_TS (M, j, tag, CLK) đến từ Pj: (2a) ưu tiên ← max (ưu tiên + 1, CLK);
(2b) chèn (M , tag, j, ưu tiên, không gửi được) trong temp_Q;
// vào cuối hàng đợi
(2c) gửi PROPOSED_TS (i, j, tag, ưu tiên) để Pj.
(3) Khi FINAL_TS (j, x, CLK) đến từ Pj :
(3a) Xác định mục Q_e trong temp_Q, nơi Q_e.tag = x;
(3b) đánh dấu Q_e.deliverable là đúng sự thật;
(3c) Update Q_e.timestamp để CLK và tái phân loại temp_Q dựa trên các
lĩnh vực dấu thời gian;
(3d) if (đầu (temp_Q)) tag = Q_e.tag sau đó.
(3e) di chuyển từ Q_e temp_Q để delivery_Q; (3f) trong khi (đầu (temp_Q)). Phân bổ là làm đúng
(3g) đầu dequeue (temp_Q) và chèn vào delivery_Q.
(4) Khi Pi xoá thư (M, tag, j, ts, chuyển giao) từ
đầu ( delivery_Qi):
(4a) đồng hồ ← max (đồng hồ, ts) + 1.