6

停止して待機するアルゴリズムを実装しようとしています。送信側でのタイムアウトの実装に問題があります。受信者からの ACK を待っている間、recvfrom() 関数を使用しています。ただし、これによりプログラムがアイドル状態になり、タイムアウトに従って再送信できません。

ここに私のコードがあります: 

import socket

import time

mysocket=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)


while True:


   ACK= " "

    userIn=raw_input()
    if not userIn : break
    mysocket.sendto(userIn, ('127.0.0.01', 88))     
    ACK, address = mysocket.recvfrom(1024)    #the prog. is idle waiting for ACK
    future=time.time()+0.5   
    while True:
            if time.time() > future:
                    mysocket.sendto(userIn, ('127.0.0.01', 88))
                    future=time.time()+0.5
            if (ACK!=" "):
                    print ACK
                    break 
mysocket.close()
4

1 に答える 1

3

ソケットはデフォルトでブロックします。この動作を制御するには、ソケット関数 setblocking() または settimeout() を使用します。

あなた自身のタイミングをしたい場合。

mysocket.setblocking(0)
ACK, address = mysocket.recvfrom(1024)

しかし、私は次のようなことをします

import socket

mysocket = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
mysocket.settimeout(0.5)
dest = ('127.0.0.01', 88)

user_input = raw_input()

while user_input:
    mysocket.sendto(user_input, dest)     
    acknowledged = False
    # spam dest until they acknowledge me (sounds like my kids)
    while not acknowledged:
        try:
            ACK, address = mysocket.recvfrom(1024)
            acknowledged = True
        except socket.timeout:
            mysocket.sendto(user_input, dest)
    print ACK
    user_input = raw_input()

mysocket.close()
于 2013-04-09T19:15:11.333 に答える