1

asyncoreディスパッチャー（以下のコード）を使用して、パケットソケットを介してsend/recvのプロトタイプを作成しようとしています。私のhandle_writeメソッドはすぐに呼び出されますが、handle_readメソッドが呼び出されていないようです。loop（）は読み取り可能なメソッドを頻繁に呼び出しますが、何も受信できません。単純なtcpdumpが着信パケットを表示するため、eth0で受信されたパケットがあることを知っています。私は何かが足りないのですか？



#!/usr/bin/python

import asyncore, socket, IN, struct

class packet_socket(asyncore.dispatcher):

    def __init__(self):
        asyncore.dispatcher.__init__(self)
        self.create_socket(socket.AF_PACKET, socket.SOCK_RAW)
        self.buffer = '0180C20034350012545900040060078910'
        self.socket.setsockopt(socket.SOL_SOCKET,IN.SO_BINDTODEVICE,struct.pack("%ds" % (len("eth0")+1,), "eth0"))

    def handle_close(self):
        self.close()

    def handle_connect(self):
        pass

    def handle_read(self):
        print "handle_read() called"
        data,addr=self.recvfrom(1024)
        print data
        print addr

    def readable(self):
        print "Checking read flag"
        return True

    def writable(self):
        return (len(self.buffer) > 0)

    def handle_write(self):
        print "Writing buffer data to the socket"
        sent = self.sendto(self.buffer,("eth0",0xFFFF))
        self.buffer = self.buffer[sent:]

c = packet_socket()

asyncore.loop()

前もって感謝します。

4

1 に答える 1

1

同僚の助けを借りて、ようやくこれを機能させることができました。これは、プロトコル引数をメソッドに渡すことに関係していますcreate_socket()。残念ながらcreate_socket() 、ディスパッチャーは 3 番目の引数を取りません。そのため、コンストラクターを変更して、protocol as (または受信したいプロトコルの種類) をpacket_socket()持つ事前に作成されたソケットを引数として受け取る必要がありました。ETH_P_ALL以下の編集されたコード：



#!/usr/bin/python

import asyncore, socket, IN, struct

proto=3
s = socket.socket(socket.AF_PACKET, socket.SOCK_RAW, socket.htons(3))
s.bind(("eth0",proto))

class packet_socket(asyncore.dispatcher):

    def __init__(self,sock):
        asyncore.dispatcher.__init__(self,sock)
        #self.create_socket(socket.AF_PACKET, socket.SOCK_RAW,socket.htons(3))
        self.buffer = '0180C20034350012545900040060078910'
        self.socket.setsockopt(socket.SOL_SOCKET,IN.SO_BINDTODEVICE,struct.pack("%ds" % (len("eth0")+1,), "eth0"))

    def handle_close(self):
        self.close()

    def handle_connect(self):
        pass

    def handle_read(self):
        print "handle_read() called" 
    data,addr=self.recvfrom(1024)
        print data
        print addr

    def readable(self):
        print "Checking read flag" 
    return True

    def writable(self):
        return (len(self.buffer) > 0)

    def handle_write(self):
        print "Writing buffer data to the socket" 
    sent = self.sendto(self.buffer,("eth0",0xFFFF))
        self.buffer = self.buffer[sent:]

c = packet_socket(s)

asyncore.loop()

ありがとう、

于 2009-04-06T20:22:06.743 に答える