196 |
List.iter (print_peer buf) peers |
List.iter (print_peer buf) peers |
197 |
| OvernetPublished target -> |
| OvernetPublished target -> |
198 |
Printf.bprintf buf "OvernetPublished %s\n" (Md4.to_string target) |
Printf.bprintf buf "OvernetPublished %s\n" (Md4.to_string target) |
199 |
|
| OvernetPeerNotFound p -> |
200 |
|
Printf.bprintf buf "OvernetPeerNotFound\n"; |
201 |
|
print_peer buf p |
202 |
|
| OvernetUnknown21 p -> |
203 |
|
Printf.bprintf buf "OvernetUnknown21\n"; |
204 |
|
print_peer buf p |
205 |
| _ -> |
| _ -> |
206 |
Buffer.add_string buf "unknown\n" |
Buffer.add_string buf "unknown\n" |
207 |
end; |
end; |
1078 |
| _ -> () |
| _ -> () |
1079 |
end |
end |
1080 |
|
|
1081 |
|
| OvernetFirewallConnectionACK(md4) -> |
1082 |
|
if !verbose_overnet && debug_client other_ip then |
1083 |
|
lprintf_nl () "FIREWALL ACK for md4=%s" (Md4.to_string md4) |
1084 |
|
|
1085 |
|
| OvernetFirewallConnectionNACK(md4) -> |
1086 |
|
if !verbose_overnet && debug_client other_ip then |
1087 |
|
lprintf_nl () "FIREWALL NACK for md4=%s" (Md4.to_string md4) |
1088 |
|
|
1089 |
|
(* send the answer *) |
1090 |
|
| OvernetGetMyIP other_port -> |
1091 |
|
if !verbose_overnet && debug_client other_ip then |
1092 |
|
lprintf_nl () "GET MY IP (port=%d)\n" other_port; |
1093 |
|
(* FIXME : should be able to flush the UDP buffer*) |
1094 |
|
udp_send_direct other_ip other_port (OvernetGetMyIPResult other_ip); |
1095 |
|
udp_send_direct other_ip other_port OvernetGetMyIPDone |
1096 |
|
|
1097 |
|
| OvernetGetMyIPResult(ip) -> |
1098 |
|
if !verbose_overnet && debug_client other_ip then |
1099 |
|
lprintf_nl () "GET MY IP RESULT (%s)\n" (Ip.to_string ip) |
1100 |
|
|
1101 |
|
| OvernetGetMyIPDone -> |
1102 |
|
if !verbose_overnet && debug_client other_ip then |
1103 |
|
lprintf_nl () "GET MY IP DONE\n" |
1104 |
|
|
1105 |
|
| OvernetPeerNotFound peer -> |
1106 |
|
begin |
1107 |
|
if !verbose_overnet && debug_client other_ip then |
1108 |
|
lprintf_nl () "Peer NOT FOUND %s (%s:%d) kind: %d (msg 33)" |
1109 |
|
(Md4.to_string peer.peer_md4) (Ip.to_string peer.peer_ip) |
1110 |
|
peer.peer_port peer.peer_kind; |
1111 |
|
let key = (peer.peer_ip, peer.peer_port) in |
1112 |
|
if Hashtbl.mem known_peers key |
1113 |
|
then begin |
1114 |
|
Hashtbl.remove known_peers key; |
1115 |
|
end |
1116 |
|
end |
1117 |
|
|
1118 |
|
| OvernetUnknown21 peer -> |
1119 |
|
if !verbose_overnet && debug_client other_ip then begin |
1120 |
|
lprintf_nl () "Unknown 21 message ..."; |
1121 |
|
lprintf_nl () "From peer: %s ip: %s:%d kind: %d" |
1122 |
|
(Md4.to_string peer.peer_md4) (Ip.to_string peer.peer_ip) peer.peer_port peer.peer_kind |
1123 |
|
end |
1124 |
|
|
1125 |
| _ -> failwith "Message not understood" |
| _ -> failwith "Message not understood" |
1126 |
|
|
1127 |
let query_next_peers () = |
let query_next_peers () = |