2012/01/12 13:14
TAG
'Language'에 해당되는 글 35건
- 2012/01/12 CString FAQ
- 2011/09/05 Eclipse의 Color Theme적용하는 Plug-in
- 2011/08/24 scapy :: sniff 예제
- 2011/07/21 scapy :: Custom Protocol 추가
- 2011/07/13 scapy :: pcap 파일 읽기
- 2011/04/04 scapy on windows
- 2011/03/27 Python으로 급하게 만들어 사용한 UDP Server 예제
- 2011/03/16 Windows에서 시간측정 관련 자료 링크
- 2010/12/14 C Macro 활용
- 2010/11/21 파이썬 링크 모음
2011/09/05 16:17
http://marketplace.eclipse.org/content/eclipse-color-theme
Preferences >> General >> Appearance >> Color Theme 에서 변경가능하다.
Preferences >> General >> Appearance >> Color Theme 에서 변경가능하다.
TAG
2011/08/24 11:05
특정 UDP 포트로 들어오는 데이터를 캡처하여 sequential하게 증가하는 특정값을 모니터링하는 소프트웨어이다.
import socket
import struct
import time
from threading import Thread
from scapy.all import *
DATA_FMT = "!IHHH%ds"
UDP_PORT = 8080
captured_list = []
start_msginx = -1
expected_msginx = -1
missing_cnt = 0
captured_cnt = 0
def pkg_callback(pkg):
global start_msginx
global missing_cnt
global expected_msginx
global captured_cnt
udp_layer = pkg.getlayer("UDP")
if udp_layer.dport != UDP_PORT:
return
captured_cnt = captured_cnt + 1
udp_size = udp_layer.len
dl_payload_size = udp_size - 8 - 10
dl_timestamp, dl_bport, dl_msginx, dl_crc, dl_payload = struct.unpack(DATA_FMT%dl_payload_size, str(udp_layer.payload))
if start_msginx == -1:
start_msginx = dl_msginx
print "DL MsgInx Start from %d" % ( start_msginx )
expected_msginx = start_msginx + 1
expected_msginx = expected_msginx % 0x10000
return
if expected_msginx != dl_msginx:
print "Expected MsgInx ( %d ), Received MsgInx ( %d )" % (expected_msginx, dl_msginx)
temp_missing_cnt = 0
if dl_msginx < expected_msginx:
temp_missing_cnt = 0xffff + dl_msginx - expected_msginx
else:
temp_missing_cnt = dl_msginx - expected_msginx
missing_cnt = missing_cnt + temp_missing_cnt
expected_msginx = dl_msginx + 1
expected_msginx = expected_msginx % 0x10000
class UDP_SNIFFER(Thread):
def __init__(self):
Thread.__init__(self)
def run(self):
while 1:
choice = raw_input("menu> ")
if choice.strip() == "":
continue
if choice.strip() == "exit":
break
if choice.strip() == "start":
print "Start to capture packets..."
self.startCapture()
continue
print "Exiting..."
def startCapture(self):
global captured_list
global start_msginx
global missing_cnt
global expected_msginx
global captured_cnt
# initialize all variables.
captured_list = []
start_msginx = -1
expected_msginx = -1
missing_cnt = 0
captured_cnt = 0
# try to capture N packets.
start_time = time.time()
sniff(prn=pkg_callback, filter="udp and port %d" % (UDP_PORT), count=10000)
end_time = time.time()
gap = end_time - start_time
# print result
print "Sniffing is done. Result ( %d / %d ) during %f" % ( missing_cnt, captured_cnt, gap )
if __name__ == "__main__":
upr = UDP_SNIFFER()
upr.start()
upr.join()
exit(0)
import struct
import time
from threading import Thread
from scapy.all import *
DATA_FMT = "!IHHH%ds"
UDP_PORT = 8080
captured_list = []
start_msginx = -1
expected_msginx = -1
missing_cnt = 0
captured_cnt = 0
def pkg_callback(pkg):
global start_msginx
global missing_cnt
global expected_msginx
global captured_cnt
udp_layer = pkg.getlayer("UDP")
if udp_layer.dport != UDP_PORT:
return
captured_cnt = captured_cnt + 1
udp_size = udp_layer.len
dl_payload_size = udp_size - 8 - 10
dl_timestamp, dl_bport, dl_msginx, dl_crc, dl_payload = struct.unpack(DATA_FMT%dl_payload_size, str(udp_layer.payload))
if start_msginx == -1:
start_msginx = dl_msginx
print "DL MsgInx Start from %d" % ( start_msginx )
expected_msginx = start_msginx + 1
expected_msginx = expected_msginx % 0x10000
return
if expected_msginx != dl_msginx:
print "Expected MsgInx ( %d ), Received MsgInx ( %d )" % (expected_msginx, dl_msginx)
temp_missing_cnt = 0
if dl_msginx < expected_msginx:
temp_missing_cnt = 0xffff + dl_msginx - expected_msginx
else:
temp_missing_cnt = dl_msginx - expected_msginx
missing_cnt = missing_cnt + temp_missing_cnt
expected_msginx = dl_msginx + 1
expected_msginx = expected_msginx % 0x10000
class UDP_SNIFFER(Thread):
def __init__(self):
Thread.__init__(self)
def run(self):
while 1:
choice = raw_input("menu> ")
if choice.strip() == "":
continue
if choice.strip() == "exit":
break
if choice.strip() == "start":
print "Start to capture packets..."
self.startCapture()
continue
print "Exiting..."
def startCapture(self):
global captured_list
global start_msginx
global missing_cnt
global expected_msginx
global captured_cnt
# initialize all variables.
captured_list = []
start_msginx = -1
expected_msginx = -1
missing_cnt = 0
captured_cnt = 0
# try to capture N packets.
start_time = time.time()
sniff(prn=pkg_callback, filter="udp and port %d" % (UDP_PORT), count=10000)
end_time = time.time()
gap = end_time - start_time
# print result
print "Sniffing is done. Result ( %d / %d ) during %f" % ( missing_cnt, captured_cnt, gap )
if __name__ == "__main__":
upr = UDP_SNIFFER()
upr.start()
upr.join()
exit(0)
2011/07/21 11:22
http://www.secdev.org/projects/scapy/doc/build_dissect.html#adding-new-protocols
IP / UDP / CUSTOM_DL_HDR / CUSTOM_HDR 과 같은 네트워크 스택이 있다고 가정한다. CUSTOM_DL_HDR의 Destination UDP Port는 50481이며, 바로 뒤에 CUSTOM_HDR이 따라 오도록 한다.
CUSTOM_DL_HDR는 [4 bytes] [2 bytes] [2 bytes] [2 bytes]로 구성되어 있다.
CUSTOM_HDR는 [1 byte] [1 byte] [2 bytes]로 구성되어 있다.
CUSTOM_DL_HDR과 CUSTOM_HDR Protocol 을 등록하기 위한 코드는 아래와 같다.
CUSTOM_Packet을 임포트하기 전의 pcap의 내용
CUSTOM_Packet을 임포트한 후의 pcap의 내용 : 851번 패킷의 경우, CUSTOM_Packet을 임포트한 이후에는 해당 프로토콜이 해석되어 전시되는 것을 볼수가 있다.
851번 패킷의 내용을 자세히 분석한 결과이다.
IP / UDP / CUSTOM_DL_HDR / CUSTOM_HDR 과 같은 네트워크 스택이 있다고 가정한다. CUSTOM_DL_HDR의 Destination UDP Port는 50481이며, 바로 뒤에 CUSTOM_HDR이 따라 오도록 한다.
CUSTOM_DL_HDR는 [4 bytes] [2 bytes] [2 bytes] [2 bytes]로 구성되어 있다.
CUSTOM_HDR는 [1 byte] [1 byte] [2 bytes]로 구성되어 있다.
CUSTOM_DL_HDR과 CUSTOM_HDR Protocol 을 등록하기 위한 코드는 아래와 같다.
from scapy.all import *
class CUSTOM_HDR(Packet):
name = "Custom Header"
fields_desc = [ XByteField("Custom1", 0),
XByteField("Custom2", 0),
ShortField("Custom3", 0) ]
class CUSTOM_DL_HDR(Packet):
name = "Custom Datalink Header"
fields_desc = [ XIntField("CustomDl1", 0),
ShortField("CustomDl2", 0),
ShortField("CustomDl3", 0),
ShortField("CustomDl4", 0) ]
def guess_payload_class(self, payload):
return CUSTOM_HDR
bind_layers(UDP, CUSTOM_DL_HDR, dport=50481)
class CUSTOM_HDR(Packet):
name = "Custom Header"
fields_desc = [ XByteField("Custom1", 0),
XByteField("Custom2", 0),
ShortField("Custom3", 0) ]
class CUSTOM_DL_HDR(Packet):
name = "Custom Datalink Header"
fields_desc = [ XIntField("CustomDl1", 0),
ShortField("CustomDl2", 0),
ShortField("CustomDl3", 0),
ShortField("CustomDl4", 0) ]
def guess_payload_class(self, payload):
return CUSTOM_HDR
bind_layers(UDP, CUSTOM_DL_HDR, dport=50481)
CUSTOM_Packet을 임포트하기 전의 pcap의 내용
CUSTOM_Packet을 임포트한 후의 pcap의 내용 : 851번 패킷의 경우, CUSTOM_Packet을 임포트한 이후에는 해당 프로토콜이 해석되어 전시되는 것을 볼수가 있다.
851번 패킷의 내용을 자세히 분석한 결과이다.
2011/07/13 16:16
scapy 모듈을 활용하여 pcap 파일을 읽는 예제이다.
간단히 모든 패킷을 읽어들여 ARP 패킷 개수를 세는 프로그램이다.
간단히 모든 패킷을 읽어들여 ARP 패킷 개수를 세는 프로그램이다.
pcap_rd.py
from scapy.all import *
arps = []
pcap_data = rdpcap("test_arp.pcap")
n_total = 0
for pkg in pcap_data:
ip_layer = pkg.getlayer("ARP")
n_total = n_total + 1
if ip_layer == None:
# print "No ARP"
continue
arps.append(pkg)
print "%02d / %02d ARP packets found. " % (len(arps), n_total)
arps = []
pcap_data = rdpcap("test_arp.pcap")
n_total = 0
for pkg in pcap_data:
ip_layer = pkg.getlayer("ARP")
n_total = n_total + 1
if ip_layer == None:
# print "No ARP"
continue
arps.append(pkg)
print "%02d / %02d ARP packets found. " % (len(arps), n_total)
2011/03/27 13:09
프로젝트 진행간에 테스트 용도로 급하게 만들어 보았다. 역시 이럴때는 Python 만한게 없다. :)
import socket
if __name__ == '__main__':
rcv_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
try:
rcv_sock.bind(("10.100.10.90", 8889))
except:
print "Error at Binding"
while 1:
print "Listening..."
data, addr = rcv_sock.recvfrom(65535)
print "Got %s" % data
if __name__ == '__main__':
rcv_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
try:
rcv_sock.bind(("10.100.10.90", 8889))
except:
print "Error at Binding"
while 1:
print "Listening..."
data, addr = rcv_sock.recvfrom(65535)
print "Got %s" % data
2011/03/16 15:03
2010/12/14 23:44
다음에 참고하기 위해 쓴다.
사용예
#define DebugRtiData(name) do { \
for (int i = 0; i < data_seq.length(); ++i) { \
if (info_seq[i].valid_data) { \
name##TypeSupport::print_data(&data_seq[i]); \
} \
} \
} while ( 0 )
for (int i = 0; i < data_seq.length(); ++i) { \
if (info_seq[i].valid_data) { \
name##TypeSupport::print_data(&data_seq[i]); \
} \
} \
} while ( 0 )
사용예
DebugRtiData(FCE_AIDLC_CTRL);
2010/11/21 21:28