-import "C"
-
-// OptTPacketVersion is the version of TPacket to use.
-// It can be passed into NewTPacket.
-type OptTPacketVersion int
-
-// String returns a string representation of the version, generally of the form V#.
-func (t OptTPacketVersion) String() string {
- switch t {
- case TPacketVersion1:
- return "V1"
- case TPacketVersion2:
- return "V2"
- case TPacketVersion3:
- return "V3"
- case TPacketVersionHighestAvailable:
- return "HighestAvailable"
- }
- return "InvalidVersion"
-}
-
-// OptSocketType is the socket type used to open the TPacket socket.
-type OptSocketType int
-
-func (t OptSocketType) String() string {
- switch t {
- case SocketRaw:
- return "SOCK_RAW"
- case SocketDgram:
- return "SOCK_DGRAM"
- }
- return "UnknownSocketType"
-}
-
-// TPacket version numbers for use with NewHandle.
-const (
- // TPacketVersionHighestAvailable tells NewHandle to use the highest available version of tpacket the kernel has available.
- // This is the default, should a version number not be given in NewHandle's options.
- TPacketVersionHighestAvailable = OptTPacketVersion(-1)
- TPacketVersion1 = OptTPacketVersion(C.TPACKET_V1)
- TPacketVersion2 = OptTPacketVersion(C.TPACKET_V2)
- TPacketVersion3 = OptTPacketVersion(C.TPACKET_V3)
- tpacketVersionMax = TPacketVersion3
- tpacketVersionMin = -1
- // SocketRaw is the default socket type. It returns packet data
- // including the link layer (ethernet headers, etc).
- SocketRaw = OptSocketType(C.SOCK_RAW)
- // SocketDgram strips off the link layer when reading packets, and adds
- // the link layer back automatically on packet writes (coming soon...)
- SocketDgram = OptSocketType(C.SOCK_DGRAM)
-)
-
-// OptInterface is the specific interface to bind to.
-// It can be passed into NewTPacket.
-type OptInterface string
-
-// OptFrameSize is TPacket's tp_frame_size
-// It can be passed into NewTPacket.
-type OptFrameSize int
-
-// OptBlockSize is TPacket's tp_block_size
-// It can be passed into NewTPacket.
-type OptBlockSize int
-
-// OptNumBlocks is TPacket's tp_block_nr
-// It can be passed into NewTPacket.
-type OptNumBlocks int
-
-// OptBlockTimeout is TPacket v3's tp_retire_blk_tov. Note that it has only millisecond granularity, so must be >= 1 ms.
-// It can be passed into NewTPacket.
-type OptBlockTimeout time.Duration
-
-// OptPollTimeout is the number of milliseconds that poll() should block waiting for a file
-// descriptor to become ready. Specifying a negative value in timeâ€out means an infinite timeout.
-type OptPollTimeout time.Duration
-
-// Default constants used by options.
-const (
- DefaultFrameSize = 4096 // Default value for OptFrameSize.
- DefaultBlockSize = DefaultFrameSize * 128 // Default value for OptBlockSize.
- DefaultNumBlocks = 128 // Default value for OptNumBlocks.
- DefaultBlockTimeout = 64 * time.Millisecond // Default value for OptBlockTimeout.
- DefaultPollTimeout = -1 * time.Millisecond // Default value for OptPollTimeout. This blocks forever.
-)
-
-type options struct {
- frameSize int
- framesPerBlock int
- blockSize int
- numBlocks int
- blockTimeout time.Duration
- pollTimeout time.Duration
- version OptTPacketVersion
- socktype OptSocketType
- iface string
-}
-
-var defaultOpts = options{
- frameSize: DefaultFrameSize,
- blockSize: DefaultBlockSize,
- numBlocks: DefaultNumBlocks,
- blockTimeout: DefaultBlockTimeout,
- pollTimeout: DefaultPollTimeout,
- version: TPacketVersionHighestAvailable,
- socktype: SocketRaw,
-}
-
-func parseOptions(opts ...interface{}) (ret options, err error) {
- ret = defaultOpts
- for _, opt := range opts {
- switch v := opt.(type) {
- case OptFrameSize:
- ret.frameSize = int(v)
- case OptBlockSize:
- ret.blockSize = int(v)
- case OptNumBlocks:
- ret.numBlocks = int(v)
- case OptBlockTimeout:
- ret.blockTimeout = time.Duration(v)
- case OptPollTimeout:
- ret.pollTimeout = time.Duration(v)
- case OptTPacketVersion:
- ret.version = v
- case OptInterface:
- ret.iface = string(v)
- case OptSocketType:
- ret.socktype = v
- default:
- err = errors.New("unknown type in options")
- return
- }
- }
- if err = ret.check(); err != nil {
- return
- }
- ret.framesPerBlock = ret.blockSize / ret.frameSize
- return
-}
-func (o options) check() error {
- switch {
- case o.blockSize%pageSize != 0:
- return fmt.Errorf("block size %d must be divisible by page size %d", o.blockSize, pageSize)
- case o.blockSize%o.frameSize != 0:
- return fmt.Errorf("block size %d must be divisible by frame size %d", o.blockSize, o.frameSize)
- case o.numBlocks < 1:
- return fmt.Errorf("num blocks %d must be >= 1", o.numBlocks)
- case o.blockTimeout < time.Millisecond:
- return fmt.Errorf("block timeout %v must be > %v", o.blockTimeout, time.Millisecond)
- case o.version < tpacketVersionMin || o.version > tpacketVersionMax:
- return fmt.Errorf("tpacket version %v is invalid", o.version)
- }
- return nil
-}
diff --git a/vendor/github.com/google/gopacket/afpacket/sockopt_linux.go b/vendor/github.com/google/gopacket/afpacket/sockopt_linux.go
deleted file mode 100644
index c53e1cce..00000000
--- a/vendor/github.com/google/gopacket/afpacket/sockopt_linux.go
+++ /dev/null
@@ -1,58 +0,0 @@
-// Copyright 2012 Google, Inc. All rights reserved.
-//
-// Use of this source code is governed by a BSD-style license
-// that can be found in the LICENSE file in the root of the source
-// tree.
-
-// +build linux
-
-package afpacket
-
-import (
- "unsafe"
-
- "golang.org/x/sys/unix"
-)
-
-// setsockopt provides access to the setsockopt syscall.
-func setsockopt(fd, level, name int, val unsafe.Pointer, vallen uintptr) error {
- _, _, errno := unix.Syscall6(
- unix.SYS_SETSOCKOPT,
- uintptr(fd),
- uintptr(level),
- uintptr(name),
- uintptr(val),
- vallen,
- 0,
- )
- if errno != 0 {
- return error(errno)
- }
-
- return nil
-}
-
-// getsockopt provides access to the getsockopt syscall.
-func getsockopt(fd, level, name int, val unsafe.Pointer, vallen uintptr) error {
- _, _, errno := unix.Syscall6(
- unix.SYS_GETSOCKOPT,
- uintptr(fd),
- uintptr(level),
- uintptr(name),
- uintptr(val),
- vallen,
- 0,
- )
- if errno != 0 {
- return error(errno)
- }
-
- return nil
-}
-
-// htons converts a short (uint16) from host-to-network byte order.
-// Thanks to mikioh for this neat trick:
-// https://github.com/mikioh/-stdyng/blob/master/afpacket.go
-func htons(i uint16) uint16 {
- return (i<<8)&0xff00 | i>>8
-}
diff --git a/vendor/github.com/google/gopacket/afpacket/sockopt_linux_386.go b/vendor/github.com/google/gopacket/afpacket/sockopt_linux_386.go
deleted file mode 100644
index 8c3eb424..00000000
--- a/vendor/github.com/google/gopacket/afpacket/sockopt_linux_386.go
+++ /dev/null
@@ -1,57 +0,0 @@
-// Copyright 2012 Google, Inc. All rights reserved.
-//
-// Use of this source code is governed by a BSD-style license
-// that can be found in the LICENSE file in the root of the source
-// tree.
-
-// +build linux,386
-
-package afpacket
-
-import (
- "unsafe"
-
- "golang.org/x/sys/unix"
-)
-
-const (
- sysSETSOCKOPT = 0xe
- sysGETSOCKOPT = 0xf
-)
-
-func socketcall(call int, a0, a1, a2, a3, a4, a5 uintptr) (int, unix.Errno)
-
-// setsockopt provides access to the setsockopt syscall.
-func setsockopt(fd, level, name int, v unsafe.Pointer, l uintptr) error {
- _, errno := socketcall(
- sysSETSOCKOPT,
- uintptr(fd),
- uintptr(level),
- uintptr(name),
- uintptr(v),
- l,
- 0,
- )
- if errno != 0 {
- return error(errno)
- }
-
- return nil
-}
-
-func getsockopt(fd, level, name int, v unsafe.Pointer, l uintptr) error {
- _, errno := socketcall(
- sysGETSOCKOPT,
- uintptr(fd),
- uintptr(level),
- uintptr(name),
- uintptr(v),
- l,
- 0,
- )
- if errno != 0 {
- return error(errno)
- }
-
- return nil
-}
diff --git a/vendor/github.com/google/gopacket/afpacket/sockopt_linux_386.s b/vendor/github.com/google/gopacket/afpacket/sockopt_linux_386.s
deleted file mode 100644
index 7d0336a1..00000000
--- a/vendor/github.com/google/gopacket/afpacket/sockopt_linux_386.s
+++ /dev/null
@@ -1,8 +0,0 @@
-// Copyright 2012 Google, Inc. All rights reserved.
-//
-// Use of this source code is governed by a BSD-style license
-// that can be found in the LICENSE file in the root of the source
-// tree.
-
-TEXT ·socketcall(SB),4,$0-36
- JMP syscall·socketcall(SB)
\ No newline at end of file
diff --git a/vendor/github.com/google/gopacket/benchmark_test.go b/vendor/github.com/google/gopacket/benchmark_test.go
deleted file mode 100644
index 74a1d28d..00000000
--- a/vendor/github.com/google/gopacket/benchmark_test.go
+++ /dev/null
@@ -1,194 +0,0 @@
-// Copyright 2012, Google, Inc. All rights reserved.
-//
-// Use of this source code is governed by a BSD-style license
-// that can be found in the LICENSE file in the root of the source
-// tree.
-
-package gopacket
-
-import (
- "runtime"
- "testing"
-)
-
-// A few benchmarks for figuring out exactly how fast some underlying Go
-// things are.
-
-type testError struct{}
-
-func (t *testError) Error() string { return "abc" }
-
-func BenchmarkTypeAssertion(b *testing.B) {
- var e error = &testError{}
- for i := 0; i < b.N; i++ {
- _, _ = e.(*testError)
- }
-}
-
-func BenchmarkMapLookup(b *testing.B) {
- m := map[LayerType]bool{
- LayerTypePayload: true,
- }
- for i := 0; i < b.N; i++ {
- _ = m[LayerTypePayload]
- }
-}
-
-func BenchmarkNilMapLookup(b *testing.B) {
- var m map[LayerType]bool
- for i := 0; i < b.N; i++ {
- _ = m[LayerTypePayload]
- }
-}
-
-func BenchmarkNilMapLookupWithNilCheck(b *testing.B) {
- var m map[LayerType]bool
- for i := 0; i < b.N; i++ {
- if m != nil {
- _ = m[LayerTypePayload]
- }
- }
-}
-
-func BenchmarkArrayLookup(b *testing.B) {
- m := make([]bool, 100)
- for i := 0; i < b.N; i++ {
- _ = m[LayerTypePayload]
- }
-}
-
-var testError1 = &testError{}
-var testError2 error = testError1
-
-func BenchmarkTypeToInterface1(b *testing.B) {
- var e error
- for i := 0; i < b.N; i++ {
- e = testError1
- }
- // Have to do someting with 'e' or the compiler complains about an unused
- // variable.
- testError2 = e
-}
-func BenchmarkTypeToInterface2(b *testing.B) {
- var e error
- for i := 0; i < b.N; i++ {
- e = testError2
- }
- // Have to do someting with 'e' or the compiler complains about an unused
- // variable.
- testError2 = e
-}
-
-var decodeOpts DecodeOptions
-
-func decodeOptsByValue(_ DecodeOptions) {}
-func decodeOptsByPointer(_ *DecodeOptions) {}
-func BenchmarkPassDecodeOptionsByValue(b *testing.B) {
- for i := 0; i < b.N; i++ {
- decodeOptsByValue(decodeOpts)
- }
-}
-func BenchmarkPassDecodeOptionsByPointer(b *testing.B) {
- for i := 0; i < b.N; i++ {
- decodeOptsByPointer(&decodeOpts)
- }
-}
-
-func BenchmarkLockOSThread(b *testing.B) {
- for i := 0; i < b.N; i++ {
- runtime.LockOSThread()
- }
-}
-func BenchmarkUnlockOSThread(b *testing.B) {
- for i := 0; i < b.N; i++ {
- runtime.UnlockOSThread()
- }
-}
-func lockUnlock() {
- runtime.LockOSThread()
- runtime.UnlockOSThread()
-}
-func lockDeferUnlock() {
- runtime.LockOSThread()
- defer runtime.UnlockOSThread()
-}
-func BenchmarkLockUnlockOSThread(b *testing.B) {
- for i := 0; i < b.N; i++ {
- lockUnlock()
- }
-}
-func BenchmarkLockDeferUnlockOSThread(b *testing.B) {
- for i := 0; i < b.N; i++ {
- lockDeferUnlock()
- }
-}
-
-func BenchmarkUnbufferedChannel(b *testing.B) {
- ca := make(chan bool)
- cb := make(chan bool)
- defer close(ca)
- go func() {
- defer close(cb)
- for _ = range ca {
- cb <- true
- }
- }()
- for i := 0; i < b.N; i++ {
- ca <- true
- <-cb
- }
-}
-func BenchmarkSmallBufferedChannel(b *testing.B) {
- ca := make(chan bool, 1)
- cb := make(chan bool, 1)
- defer close(ca)
- go func() {
- defer close(cb)
- for _ = range ca {
- cb <- true
- }
- }()
- for i := 0; i < b.N; i++ {
- ca <- true
- <-cb
- }
-}
-func BenchmarkLargeBufferedChannel(b *testing.B) {
- ca := make(chan bool, 1000)
- cb := make(chan bool, 1000)
- defer close(ca)
- go func() {
- defer close(cb)
- for _ = range ca {
- cb <- true
- }
- }()
- for i := 0; i < b.N; i++ {
- ca <- true
- <-cb
- }
-}
-func BenchmarkEndpointFastHashShort(b *testing.B) {
- e := Endpoint{typ: 1, len: 2}
- for i := 0; i < b.N; i++ {
- e.FastHash()
- }
-}
-func BenchmarkEndpointFastHashLong(b *testing.B) {
- e := Endpoint{typ: 1, len: 16}
- for i := 0; i < b.N; i++ {
- e.FastHash()
- }
-}
-func BenchmarkFlowFastHashShort(b *testing.B) {
- e := Flow{typ: 1, slen: 2, dlen: 2}
- for i := 0; i < b.N; i++ {
- e.FastHash()
- }
-}
-func BenchmarkFlowFastHashLong(b *testing.B) {
- e := Flow{typ: 1, slen: 16, dlen: 16}
- for i := 0; i < b.N; i++ {
- e.FastHash()
- }
-}
diff --git a/vendor/github.com/google/gopacket/bsdbpf/bsd_bpf_sniffer.go b/vendor/github.com/google/gopacket/bsdbpf/bsd_bpf_sniffer.go
deleted file mode 100644
index 3e1da0b9..00000000
--- a/vendor/github.com/google/gopacket/bsdbpf/bsd_bpf_sniffer.go
+++ /dev/null
@@ -1,215 +0,0 @@
-// Copyright 2012 Google, Inc. All rights reserved.
-//
-// Use of this source code is governed by a BSD-style license
-// that can be found in the LICENSE file in the root of the source
-// tree.
-
-// +build darwin dragonfly freebsd netbsd openbsd
-
-package bsdbpf
-
-import (
- "errors"
- "fmt"
- "syscall"
- "time"
- "unsafe"
-
- "github.com/google/gopacket"
- "golang.org/x/sys/unix"
-)
-
-const wordSize = int(unsafe.Sizeof(uintptr(0)))
-
-func bpfWordAlign(x int) int {
- return (((x) + (wordSize - 1)) &^ (wordSize - 1))
-}
-
-// Options is used to configure various properties of the BPF sniffer.
-// Default values are used when a nil Options pointer is passed to NewBPFSniffer.
-type Options struct {
- // BPFDeviceName is name of the bpf device to use for sniffing
- // the network device. The default value of BPFDeviceName is empty string
- // which causes the first available BPF device file /dev/bpfX to be used.
- BPFDeviceName string
- // ReadBufLen specifies the size of the buffer used to read packets
- // off the wire such that multiple packets are buffered with each read syscall.
- // Note that an individual packet larger than the buffer size is necessarily truncated.
- // A larger buffer should increase performance because fewer read syscalls would be made.
- // If zero is used, the system's default buffer length will be used which depending on the
- // system may default to 4096 bytes which is not big enough to accomodate some link layers
- // such as WLAN (802.11).
- // ReadBufLen defaults to 32767... however typical BSD manual pages for BPF indicate that
- // if the requested buffer size cannot be accommodated, the closest allowable size will be
- // set and returned... hence our GetReadBufLen method.
- ReadBufLen int
- // Timeout is the length of time to wait before timing out on a read request.
- // Timeout defaults to nil which means no timeout is used.
- Timeout *syscall.Timeval
- // Promisc is set to true for promiscuous mode ethernet sniffing.
- // Promisc defaults to true.
- Promisc bool
- // Immediate is set to true to make our read requests return as soon as a packet becomes available.
- // Otherwise, a read will block until either the kernel buffer becomes full or a timeout occurs.
- // The default is true.
- Immediate bool
- // PreserveLinkAddr is set to false if the link level source address should be filled in automatically
- // by the interface output routine. Set to true if the link level source address will be written,
- // as provided, to the wire.
- // The default is true.
- PreserveLinkAddr bool
-}
-
-var defaultOptions = Options{
- BPFDeviceName: "",
- ReadBufLen: 32767,
- Timeout: nil,
- Promisc: true,
- Immediate: true,
- PreserveLinkAddr: true,
-}
-
-// BPFSniffer is a struct used to track state of a BSD BPF ethernet sniffer
-// such that gopacket's PacketDataSource interface is implemented.
-type BPFSniffer struct {
- options *Options
- sniffDeviceName string
- fd int
- readBuffer []byte
- lastReadLen int
- readBytesConsumed int
-}
-
-// NewBPFSniffer is used to create BSD-only BPF ethernet sniffer
-// iface is the network interface device name that you wish to sniff
-// options can set to nil in order to utilize default values for everything.
-// Each field of Options also have a default setting if left unspecified by
-// the user's custome Options struct.
-func NewBPFSniffer(iface string, options *Options) (*BPFSniffer, error) {
- var err error
- enable := 1
- sniffer := BPFSniffer{
- sniffDeviceName: iface,
- }
- if options == nil {
- sniffer.options = &defaultOptions
- } else {
- sniffer.options = options
- }
-
- if sniffer.options.BPFDeviceName == "" {
- sniffer.pickBpfDevice()
- }
-
- // setup our read buffer
- if sniffer.options.ReadBufLen == 0 {
- sniffer.options.ReadBufLen, err = syscall.BpfBuflen(sniffer.fd)
- if err != nil {
- return nil, err
- }
- } else {
- sniffer.options.ReadBufLen, err = syscall.SetBpfBuflen(sniffer.fd, sniffer.options.ReadBufLen)
- if err != nil {
- return nil, err
- }
- }
- sniffer.readBuffer = make([]byte, sniffer.options.ReadBufLen)
-
- err = syscall.SetBpfInterface(sniffer.fd, sniffer.sniffDeviceName)
- if err != nil {
- return nil, err
- }
-
- if sniffer.options.Immediate {
- // turn immediate mode on. This makes the snffer non-blocking.
- err = syscall.SetBpfImmediate(sniffer.fd, enable)
- if err != nil {
- return nil, err
- }
- }
-
- // the above call to syscall.SetBpfImmediate needs to be made
- // before setting a timer otherwise the reads will block for the
- // entire timer duration even if there are packets to return.
- if sniffer.options.Timeout != nil {
- err = syscall.SetBpfTimeout(sniffer.fd, sniffer.options.Timeout)
- if err != nil {
- return nil, err
- }
- }
-
- if sniffer.options.PreserveLinkAddr {
- // preserves the link level source address...
- // higher level protocol analyzers will not need this
- err = syscall.SetBpfHeadercmpl(sniffer.fd, enable)
- if err != nil {
- return nil, err
- }
- }
-
- if sniffer.options.Promisc {
- // forces the interface into promiscuous mode
- err = syscall.SetBpfPromisc(sniffer.fd, enable)
- if err != nil {
- return nil, err
- }
- }
-
- return &sniffer, nil
-}
-
-// Close is used to close the file-descriptor of the BPF device file.
-func (b *BPFSniffer) Close() error {
- return syscall.Close(b.fd)
-}
-
-func (b *BPFSniffer) pickBpfDevice() {
- var err error
- b.options.BPFDeviceName = ""
- for i := 0; i < 99; i++ {
- b.options.BPFDeviceName = fmt.Sprintf("/dev/bpf%d", i)
- b.fd, err = syscall.Open(b.options.BPFDeviceName, syscall.O_RDWR, 0)
- if err == nil {
- return
- }
- }
- panic("failed to acquire a BPF device for read-write access")
-}
-
-func (b *BPFSniffer) ReadPacketData() ([]byte, gopacket.CaptureInfo, error) {
- var err error
- if b.readBytesConsumed >= b.lastReadLen {
- b.readBytesConsumed = 0
- b.readBuffer = make([]byte, b.options.ReadBufLen)
- b.lastReadLen, err = syscall.Read(b.fd, b.readBuffer)
- if err != nil {
- b.lastReadLen = 0
- return nil, gopacket.CaptureInfo{}, err
- }
- }
- hdr := (*unix.BpfHdr)(unsafe.Pointer(&b.readBuffer[b.readBytesConsumed]))
- frameStart := b.readBytesConsumed + int(hdr.Hdrlen)
- b.readBytesConsumed += bpfWordAlign(int(hdr.Hdrlen) + int(hdr.Caplen))
-
- if frameStart+int(hdr.Caplen) > len(b.readBuffer) {
- captureInfo := gopacket.CaptureInfo{
- Timestamp: time.Unix(int64(hdr.Tstamp.Sec), int64(hdr.Tstamp.Usec)*1000),
- CaptureLength: 0,
- Length: 0,
- }
- return nil, captureInfo, errors.New("BPF captured frame received with corrupted BpfHdr struct.")
- }
-
- rawFrame := b.readBuffer[frameStart : frameStart+int(hdr.Caplen)]
- captureInfo := gopacket.CaptureInfo{
- Timestamp: time.Unix(int64(hdr.Tstamp.Sec), int64(hdr.Tstamp.Usec)*1000),
- CaptureLength: len(rawFrame),
- Length: len(rawFrame),
- }
- return rawFrame, captureInfo, nil
-}
-
-// GetReadBufLen returns the BPF read buffer length
-func (b *BPFSniffer) GetReadBufLen() int {
- return b.options.ReadBufLen
-}
diff --git a/vendor/github.com/google/gopacket/bytediff/bytediff.go b/vendor/github.com/google/gopacket/bytediff/bytediff.go
deleted file mode 100644
index 63addd94..00000000
--- a/vendor/github.com/google/gopacket/bytediff/bytediff.go
+++ /dev/null
@@ -1,217 +0,0 @@
-// Copyright 2012 Google, Inc. All rights reserved.
-//
-// Use of this source code is governed by a BSD-style license
-// that can be found in the LICENSE file in the root of the source
-// tree.
-
-// Package bytediff provides a simple diff utility for looking at differences in byte
-// slices. It's slow, clunky, and not particularly good by any measure, but
-// it does provide very useful visualizations for diffs between small byte
-// slices.
-//
-// Our diff algorithm uses a dynamic programming implementation of longest common
-// substring to find matching parts of slices, then recursively calls itself on
-// the prefix/suffix of that matching part for each packet. This is a Bad Idea
-// (tm) for normal (especially large) input, but for packets where large portions
-// repeat frequently and we expect minor changes between results, it's actually
-// quite useful.
-package bytediff
-
-import (
- "bytes"
- "fmt"
-)
-
-// OutputFormat tells a Differences.String call how to format the set of
-// differences into a human-readable string. Its internals are currently
-// unexported because we may want to change them drastically in the future. For
-// the moment, please just use one of the provided OutputFormats that comes with
-// this library.
-type OutputFormat struct {
- start, finish, add, remove, change, reset string
-}
-
-var (
- // BashOutput uses bash escape sequences to color output.
- BashOutput = &OutputFormat{
- reset: "\033[0m",
- remove: "\033[32m",
- add: "\033[31m",
- change: "\033[33m",
- }
- // HTMLOutput uses a to wrap output, and s to color it.
- // HTMLOutput is pretty experimental, so use at your own risk ;)
- HTMLOutput = &OutputFormat{
- start: "",
- finish: "
",
- reset: "",
- remove: "",
- add: "",
- change: "",
- }
-)
-
-// longestCommonSubstring uses a O(MN) dynamic programming approach to find the
-// longest common substring in a set of slices. It returns the index in each
-// slice at which the substring begins, plus the length of the commonality.
-func longestCommonSubstring(strA, strB []byte) (indexA, indexB, length int) {
- lenA, lenB := len(strA), len(strB)
- if lenA == 0 || lenB == 0 {
- return 0, 0, 0
- }
- arr := make([][]int, lenA)
- for i := 0; i < lenA; i++ {
- arr[i] = make([]int, lenB)
- }
- var maxLength int
- var maxA, maxB int
- for a := 0; a < lenA; a++ {
- for b := 0; b < lenB; b++ {
- if strA[a] == strB[b] {
- length := 1
- if a > 0 && b > 0 {
- length = arr[a-1][b-1] + 1
- }
- arr[a][b] = length
- if length > maxLength {
- maxLength = length
- maxA = a
- maxB = b
- }
- }
- }
- }
- a, b := maxA, maxB
- for a >= 0 && b >= 0 && strA[a] == strB[b] {
- indexA = a
- indexB = b
- a--
- b--
- length++
- }
- return
-}
-
-func intMax(a, b int) int {
- if a > b {
- return a
- }
- return b
-}
-
-// Difference represents a single part of the data being diffed, containing
-// information about both the original and new values.
-// From and To are the sets of bytes in the original and the new byte slice.
-// !Replace implies From == To (no change)
-// len(To) == 0 implies From is being deleted
-// len(From) == 0 implies To is being inserted
-// else implies From is being replaced by To
-type Difference struct {
- Replace bool
- From, To []byte
-}
-
-// color returns the bash color for a given difference.
-func (c *OutputFormat) color(d Difference) string {
- switch {
- case !d.Replace:
- return ""
- case len(d.From) == 0:
- return c.remove
- case len(d.To) == 0:
- return c.add
- default:
- return c.change
- }
-}
-
-// Diff diffs strA and strB, returning a list of differences which
-// can be used to construct either the original or new string.
-//
-// Diff is optimized for comparing VERY SHORT slices. It's meant for comparing
-// things like packets off the wire, not large files or the like.
-// As such, its runtime can be catastrophic if large inputs are passed in.
-// You've been warned.
-func Diff(strA, strB []byte) Differences {
- if len(strA) == 0 && len(strB) == 0 {
- return nil
- }
- ia, ib, l := longestCommonSubstring(strA, strB)
- if l == 0 {
- return Differences{
- Difference{true, strA, strB},
- }
- }
- beforeA, match, afterA := strA[:ia], strA[ia:ia+l], strA[ia+l:]
- beforeB, afterB := strB[:ib], strB[ib+l:]
- var diffs Differences
- diffs = append(diffs, Diff(beforeA, beforeB)...)
- diffs = append(diffs, Difference{false, match, match})
- diffs = append(diffs, Diff(afterA, afterB)...)
- return diffs
-}
-
-// Differences is a set of differences for a given diff'd pair of byte slices.
-type Differences []Difference
-
-// String outputs a previously diff'd set of strings, showing differences
-// between them, highlighted by colors.
-//
-// The output format of this function is NOT guaranteed consistent, and may be
-// changed at any time by the library authors. It's meant solely for human
-// consumption.
-func (c *OutputFormat) String(diffs Differences) string {
- var buf bytes.Buffer
- count := 0
- fmt.Fprintf(&buf, "%s", c.start)
- fmt.Fprintf(&buf, "00000000 ")
- for i := 0; i < len(diffs); i++ {
- diff := diffs[i]
- color := c.color(diff)
- reset := ""
- if color != "" {
- reset = c.reset
- }
- fmt.Fprint(&buf, color)
- for _, b := range diff.From {
- fmt.Fprintf(&buf, " %02x", b)
- count++
- switch count % 16 {
- case 0:
- fmt.Fprintf(&buf, "%v\n%08x%v ", reset, count, color)
- case 8:
- fmt.Fprintf(&buf, " ")
- }
- }
- fmt.Fprint(&buf, reset)
- }
- fmt.Fprintf(&buf, "\n\n00000000 ")
- count = 0
- for i := 0; i < len(diffs); i++ {
- diff := diffs[i]
- str := diff.From
- if diff.Replace {
- str = diff.To
- }
- color := c.color(diff)
- reset := ""
- if color != "" {
- reset = c.reset
- }
- fmt.Fprint(&buf, color)
- for _, b := range str {
- fmt.Fprintf(&buf, " %02x", b)
- count++
- switch count % 16 {
- case 0:
- fmt.Fprintf(&buf, "%v\n%08x%v ", reset, count, color)
- case 8:
- fmt.Fprintf(&buf, " ")
- }
- }
- fmt.Fprint(&buf, reset)
- }
- fmt.Fprint(&buf, "\n")
- fmt.Fprintf(&buf, "%s", c.finish)
- return string(buf.Bytes())
-}
diff --git a/vendor/github.com/google/gopacket/bytediff/bytediff_test.go b/vendor/github.com/google/gopacket/bytediff/bytediff_test.go
deleted file mode 100644
index 022ad4bc..00000000
--- a/vendor/github.com/google/gopacket/bytediff/bytediff_test.go
+++ /dev/null
@@ -1,53 +0,0 @@
-// Copyright 2012 Google, Inc. All rights reserved.
-//
-// Use of this source code is governed by a BSD-style license
-// that can be found in the LICENSE file in the root of the source
-// tree.
-
-package bytediff
-
-import (
- "reflect"
- "testing"
-)
-
-func TestLCS(t *testing.T) {
- for i, test := range []struct {
- a, b []byte
- indexA, indexB, length int
- }{
- {[]byte{1, 2, 3}, []byte{1, 2, 3}, 0, 0, 3},
- {[]byte{0, 1, 2, 3}, []byte{1, 2, 3, 4}, 1, 0, 3},
- {[]byte{0, 1, 2, 3, 1, 2, 3, 4, 1, 2, 3}, []byte{1, 2, 3, 4}, 4, 0, 4},
- {[]byte{1, 2, 2, 3, 4}, []byte{1, 2, 3, 4}, 2, 1, 3},
- {[]byte{0, 1, 2, 3, 4}, []byte{1, 1, 2, 2, 3, 4}, 2, 3, 3},
- } {
- ia, ib, l := longestCommonSubstring(test.a, test.b)
- if ia != test.indexA || ib != test.indexB || l != test.length {
- t.Errorf("%d: want (%d %d %d) got (%d %d %d)", i, test.indexA, test.indexB, test.length, ia, ib, l)
- }
- }
-}
-
-func TestDiff(t *testing.T) {
- for i, test := range []struct {
- a, b []byte
- d Differences
- }{
- {
- []byte{0, 1, 2, 3, 4},
- []byte{1, 1, 2, 2, 3, 4},
- Differences{
- Difference{true, []byte{0}, []byte{}},
- Difference{false, []byte{1}, []byte{1}},
- Difference{true, []byte{}, []byte{1, 2}},
- Difference{false, []byte{2, 3, 4}, []byte{2, 3, 4}},
- },
- },
- } {
- diffs := Diff(test.a, test.b)
- if !reflect.DeepEqual(diffs, test.d) {
- t.Errorf("%d want %v got %v", i, test.d, diffs)
- }
- }
-}
diff --git a/vendor/github.com/google/gopacket/dumpcommand/tcpdump.go b/vendor/github.com/google/gopacket/dumpcommand/tcpdump.go
deleted file mode 100644
index 2d357220..00000000
--- a/vendor/github.com/google/gopacket/dumpcommand/tcpdump.go
+++ /dev/null
@@ -1,119 +0,0 @@
-// Copyright 2012 Google, Inc. All rights reserved.
-//
-// Use of this source code is governed by a BSD-style license
-// that can be found in the LICENSE file in the root of the source
-// tree.
-
-// Package dumpcommand implements a run function for pfdump and pcapdump
-// with many similar flags/features to tcpdump. This code is split out seperate
-// from data sources (pcap/pfring) so it can be used by both.
-package dumpcommand
-
-import (
- "flag"
- "fmt"
- "log"
- "os"
- "time"
-
- "github.com/google/gopacket"
- "github.com/google/gopacket/ip4defrag"
- "github.com/google/gopacket/layers" // pulls in all layers decoders
-)
-
-var (
- print = flag.Bool("print", true, "Print out packets, if false only prints out statistics")
- maxcount = flag.Int("c", -1, "Only grab this many packets, then exit")
- decoder = flag.String("decoder", "Ethernet", "Name of the decoder to use")
- dump = flag.Bool("X", false, "If true, dump very verbose info on each packet")
- statsevery = flag.Int("stats", 1000, "Output statistics every N packets")
- printErrors = flag.Bool("errors", false, "Print out packet dumps of decode errors, useful for checking decoders against live traffic")
- lazy = flag.Bool("lazy", false, "If true, do lazy decoding")
- defrag = flag.Bool("defrag", false, "If true, do IPv4 defrag")
-)
-
-func Run(src gopacket.PacketDataSource) {
- if !flag.Parsed() {
- log.Fatalln("Run called without flags.Parse() being called")
- }
- var dec gopacket.Decoder
- var ok bool
- if dec, ok = gopacket.DecodersByLayerName[*decoder]; !ok {
- log.Fatalln("No decoder named", *decoder)
- }
- source := gopacket.NewPacketSource(src, dec)
- source.Lazy = *lazy
- source.NoCopy = true
- source.DecodeStreamsAsDatagrams = true
- fmt.Fprintln(os.Stderr, "Starting to read packets")
- count := 0
- bytes := int64(0)
- start := time.Now()
- errors := 0
- truncated := 0
- layertypes := map[gopacket.LayerType]int{}
- defragger := ip4defrag.NewIPv4Defragmenter()
-
- for packet := range source.Packets() {
- count++
- bytes += int64(len(packet.Data()))
-
- // defrag the IPv4 packet if required
- if *defrag {
- ip4Layer := packet.Layer(layers.LayerTypeIPv4)
- if ip4Layer == nil {
- continue
- }
- ip4 := ip4Layer.(*layers.IPv4)
- l := ip4.Length
-
- newip4, err := defragger.DefragIPv4(ip4)
- if err != nil {
- log.Fatalln("Error while de-fragmenting", err)
- } else if newip4 == nil {
- continue // packet fragment, we don't have whole packet yet.
- }
- if newip4.Length != l {
- fmt.Printf("Decoding re-assembled packet: %s\n", newip4.NextLayerType())
- pb, ok := packet.(gopacket.PacketBuilder)
- if !ok {
- panic("Not a PacketBuilder")
- }
- nextDecoder := newip4.NextLayerType()
- nextDecoder.Decode(newip4.Payload, pb)
- }
- }
-
- if *dump {
- fmt.Println(packet.Dump())
- } else if *print {
- fmt.Println(packet)
- }
- if !*lazy || *print || *dump { // if we've already decoded all layers...
- for _, layer := range packet.Layers() {
- layertypes[layer.LayerType()]++
- }
- if packet.Metadata().Truncated {
- truncated++
- }
- if errLayer := packet.ErrorLayer(); errLayer != nil {
- errors++
- if *printErrors {
- fmt.Println("Error:", errLayer.Error())
- fmt.Println("--- Packet ---")
- fmt.Println(packet.Dump())
- }
- }
- }
- done := *maxcount > 0 && count >= *maxcount
- if count%*statsevery == 0 || done {
- fmt.Fprintf(os.Stderr, "Processed %v packets (%v bytes) in %v, %v errors and %v truncated packets\n", count, bytes, time.Since(start), errors, truncated)
- if len(layertypes) > 0 {
- fmt.Fprintf(os.Stderr, "Layer types seen: %+v\n", layertypes)
- }
- }
- if done {
- break
- }
- }
-}
diff --git a/vendor/github.com/google/gopacket/examples/arpscan/arpscan.go b/vendor/github.com/google/gopacket/examples/arpscan/arpscan.go
deleted file mode 100644
index 1a0e33e5..00000000
--- a/vendor/github.com/google/gopacket/examples/arpscan/arpscan.go
+++ /dev/null
@@ -1,188 +0,0 @@
-// Copyright 2012 Google, Inc. All rights reserved.
-//
-// Use of this source code is governed by a BSD-style license
-// that can be found in the LICENSE file in the root of the source
-// tree.
-
-// arpscan implements ARP scanning of all interfaces' local networks using
-// gopacket and its subpackages. This example shows, among other things:
-// * Generating and sending packet data
-// * Reading in packet data and interpreting it
-// * Use of the 'pcap' subpackage for reading/writing
-package main
-
-import (
- "bytes"
- "encoding/binary"
- "errors"
- "log"
- "net"
- "sync"
- "time"
-
- "github.com/google/gopacket"
- "github.com/google/gopacket/layers"
- "github.com/google/gopacket/pcap"
-)
-
-func main() {
- // Get a list of all interfaces.
- ifaces, err := net.Interfaces()
- if err != nil {
- panic(err)
- }
-
- var wg sync.WaitGroup
- for _, iface := range ifaces {
- wg.Add(1)
- // Start up a scan on each interface.
- go func(iface net.Interface) {
- defer wg.Done()
- if err := scan(&iface); err != nil {
- log.Printf("interface %v: %v", iface.Name, err)
- }
- }(iface)
- }
- // Wait for all interfaces' scans to complete. They'll try to run
- // forever, but will stop on an error, so if we get past this Wait
- // it means all attempts to write have failed.
- wg.Wait()
-}
-
-// scan scans an individual interface's local network for machines using ARP requests/replies.
-//
-// scan loops forever, sending packets out regularly. It returns an error if
-// it's ever unable to write a packet.
-func scan(iface *net.Interface) error {
- // We just look for IPv4 addresses, so try to find if the interface has one.
- var addr *net.IPNet
- if addrs, err := iface.Addrs(); err != nil {
- return err
- } else {
- for _, a := range addrs {
- if ipnet, ok := a.(*net.IPNet); ok {
- if ip4 := ipnet.IP.To4(); ip4 != nil {
- addr = &net.IPNet{
- IP: ip4,
- Mask: ipnet.Mask[len(ipnet.Mask)-4:],
- }
- break
- }
- }
- }
- }
- // Sanity-check that the interface has a good address.
- if addr == nil {
- return errors.New("no good IP network found")
- } else if addr.IP[0] == 127 {
- return errors.New("skipping localhost")
- } else if addr.Mask[0] != 0xff || addr.Mask[1] != 0xff {
- return errors.New("mask means network is too large")
- }
- log.Printf("Using network range %v for interface %v", addr, iface.Name)
-
- // Open up a pcap handle for packet reads/writes.
- handle, err := pcap.OpenLive(iface.Name, 65536, true, pcap.BlockForever)
- if err != nil {
- return err
- }
- defer handle.Close()
-
- // Start up a goroutine to read in packet data.
- stop := make(chan struct{})
- go readARP(handle, iface, stop)
- defer close(stop)
- for {
- // Write our scan packets out to the handle.
- if err := writeARP(handle, iface, addr); err != nil {
- log.Printf("error writing packets on %v: %v", iface.Name, err)
- return err
- }
- // We don't know exactly how long it'll take for packets to be
- // sent back to us, but 10 seconds should be more than enough
- // time ;)
- time.Sleep(10 * time.Second)
- }
-}
-
-// readARP watches a handle for incoming ARP responses we might care about, and prints them.
-//
-// readARP loops until 'stop' is closed.
-func readARP(handle *pcap.Handle, iface *net.Interface, stop chan struct{}) {
- src := gopacket.NewPacketSource(handle, layers.LayerTypeEthernet)
- in := src.Packets()
- for {
- var packet gopacket.Packet
- select {
- case <-stop:
- return
- case packet = <-in:
- arpLayer := packet.Layer(layers.LayerTypeARP)
- if arpLayer == nil {
- continue
- }
- arp := arpLayer.(*layers.ARP)
- if arp.Operation != layers.ARPReply || bytes.Equal([]byte(iface.HardwareAddr), arp.SourceHwAddress) {
- // This is a packet I sent.
- continue
- }
- // Note: we might get some packets here that aren't responses to ones we've sent,
- // if for example someone else sends US an ARP request. Doesn't much matter, though...
- // all information is good information :)
- log.Printf("IP %v is at %v", net.IP(arp.SourceProtAddress), net.HardwareAddr(arp.SourceHwAddress))
- }
- }
-}
-
-// writeARP writes an ARP request for each address on our local network to the
-// pcap handle.
-func writeARP(handle *pcap.Handle, iface *net.Interface, addr *net.IPNet) error {
- // Set up all the layers' fields we can.
- eth := layers.Ethernet{
- SrcMAC: iface.HardwareAddr,
- DstMAC: net.HardwareAddr{0xff, 0xff, 0xff, 0xff, 0xff, 0xff},
- EthernetType: layers.EthernetTypeARP,
- }
- arp := layers.ARP{
- AddrType: layers.LinkTypeEthernet,
- Protocol: layers.EthernetTypeIPv4,
- HwAddressSize: 6,
- ProtAddressSize: 4,
- Operation: layers.ARPRequest,
- SourceHwAddress: []byte(iface.HardwareAddr),
- SourceProtAddress: []byte(addr.IP),
- DstHwAddress: []byte{0, 0, 0, 0, 0, 0},
- }
- // Set up buffer and options for serialization.
- buf := gopacket.NewSerializeBuffer()
- opts := gopacket.SerializeOptions{
- FixLengths: true,
- ComputeChecksums: true,
- }
- // Send one packet for every address.
- for _, ip := range ips(addr) {
- arp.DstProtAddress = []byte(ip)
- gopacket.SerializeLayers(buf, opts, ð, &arp)
- if err := handle.WritePacketData(buf.Bytes()); err != nil {
- return err
- }
- }
- return nil
-}
-
-// ips is a simple and not very good method for getting all IPv4 addresses from a
-// net.IPNet. It returns all IPs it can over the channel it sends back, closing
-// the channel when done.
-func ips(n *net.IPNet) (out []net.IP) {
- num := binary.BigEndian.Uint32([]byte(n.IP))
- mask := binary.BigEndian.Uint32([]byte(n.Mask))
- num &= mask
- for mask < 0xffffffff {
- var buf [4]byte
- binary.BigEndian.PutUint32(buf[:], num)
- out = append(out, net.IP(buf[:]))
- mask += 1
- num += 1
- }
- return
-}
diff --git a/vendor/github.com/google/gopacket/examples/bidirectional/main.go b/vendor/github.com/google/gopacket/examples/bidirectional/main.go
deleted file mode 100644
index 4b0b240d..00000000
--- a/vendor/github.com/google/gopacket/examples/bidirectional/main.go
+++ /dev/null
@@ -1,192 +0,0 @@
-// Copyright 2012 Google, Inc. All rights reserved.
-//
-// Use of this source code is governed by a BSD-style license
-// that can be found in the LICENSE file in the root of the source
-// tree.
-
-// This binary provides an example of connecting up bidirectional streams from
-// the unidirectional streams provided by gopacket/tcpassembly.
-package main
-
-import (
- "flag"
- "fmt"
- "github.com/google/gopacket"
- "github.com/google/gopacket/examples/util"
- "github.com/google/gopacket/layers"
- "github.com/google/gopacket/pcap"
- "github.com/google/gopacket/tcpassembly"
- "log"
- "time"
-)
-
-var iface = flag.String("i", "eth0", "Interface to get packets from")
-var snaplen = flag.Int("s", 16<<10, "SnapLen for pcap packet capture")
-var filter = flag.String("f", "tcp", "BPF filter for pcap")
-var logAllPackets = flag.Bool("v", false, "Logs every packet in great detail")
-
-// key is used to map bidirectional streams to each other.
-type key struct {
- net, transport gopacket.Flow
-}
-
-// String prints out the key in a human-readable fashion.
-func (k key) String() string {
- return fmt.Sprintf("%v:%v", k.net, k.transport)
-}
-
-// timeout is the length of time to wait befor flushing connections and
-// bidirectional stream pairs.
-const timeout time.Duration = time.Minute * 5
-
-// myStream implements tcpassembly.Stream
-type myStream struct {
- bytes int64 // total bytes seen on this stream.
- bidi *bidi // maps to my bidirectional twin.
- done bool // if true, we've seen the last packet we're going to for this stream.
-}
-
-// bidi stores each unidirectional side of a bidirectional stream.
-//
-// When a new stream comes in, if we don't have an opposite stream, a bidi is
-// created with 'a' set to the new stream. If we DO have an opposite stream,
-// 'b' is set to the new stream.
-type bidi struct {
- key key // Key of the first stream, mostly for logging.
- a, b *myStream // the two bidirectional streams.
- lastPacketSeen time.Time // last time we saw a packet from either stream.
-}
-
-// myFactory implements tcpassmebly.StreamFactory
-type myFactory struct {
- // bidiMap maps keys to bidirectional stream pairs.
- bidiMap map[key]*bidi
-}
-
-// New handles creating a new tcpassembly.Stream.
-func (f *myFactory) New(netFlow, tcpFlow gopacket.Flow) tcpassembly.Stream {
- // Create a new stream.
- s := &myStream{}
-
- // Find the bidi bidirectional struct for this stream, creating a new one if
- // one doesn't already exist in the map.
- k := key{netFlow, tcpFlow}
- bd := f.bidiMap[k]
- if bd == nil {
- bd = &bidi{a: s, key: k}
- log.Printf("[%v] created first side of bidirectional stream", bd.key)
- // Register bidirectional with the reverse key, so the matching stream going
- // the other direction will find it.
- f.bidiMap[key{netFlow.Reverse(), tcpFlow.Reverse()}] = bd
- } else {
- log.Printf("[%v] found second side of bidirectional stream", bd.key)
- bd.b = s
- // Clear out the bidi we're using from the map, just in case.
- delete(f.bidiMap, k)
- }
- s.bidi = bd
- return s
-}
-
-// emptyStream is used to finish bidi that only have one stream, in
-// collectOldStreams.
-var emptyStream = &myStream{done: true}
-
-// collectOldStreams finds any streams that haven't received a packet within
-// 'timeout', and sets/finishes the 'b' stream inside them. The 'a' stream may
-// still receive packets after this.
-func (f *myFactory) collectOldStreams() {
- cutoff := time.Now().Add(-timeout)
- for k, bd := range f.bidiMap {
- if bd.lastPacketSeen.Before(cutoff) {
- log.Printf("[%v] timing out old stream", bd.key)
- bd.b = emptyStream // stub out b with an empty stream.
- delete(f.bidiMap, k) // remove it from our map.
- bd.maybeFinish() // if b was the last stream we were waiting for, finish up.
- }
- }
-}
-
-// Reassembled handles reassembled TCP stream data.
-func (s *myStream) Reassembled(rs []tcpassembly.Reassembly) {
- for _, r := range rs {
- // For now, we'll simply count the bytes on each side of the TCP stream.
- s.bytes += int64(len(r.Bytes))
- if r.Skip > 0 {
- s.bytes += int64(r.Skip)
- }
- // Mark that we've received new packet data.
- // We could just use time.Now, but by using r.Seen we handle the case
- // where packets are being read from a file and could be very old.
- if s.bidi.lastPacketSeen.After(r.Seen) {
- s.bidi.lastPacketSeen = r.Seen
- }
- }
-}
-
-// ReassemblyComplete marks this stream as finished.
-func (s *myStream) ReassemblyComplete() {
- s.done = true
- s.bidi.maybeFinish()
-}
-
-// maybeFinish will wait until both directions are complete, then print out
-// stats.
-func (bd *bidi) maybeFinish() {
- switch {
- case bd.a == nil:
- log.Fatalf("[%v] a should always be non-nil, since it's set when bidis are created", bd.key)
- case !bd.a.done:
- log.Printf("[%v] still waiting on first stream", bd.key)
- case bd.b == nil:
- log.Printf("[%v] no second stream yet", bd.key)
- case !bd.b.done:
- log.Printf("[%v] still waiting on second stream", bd.key)
- default:
- log.Printf("[%v] FINISHED, bytes: %d tx, %d rx", bd.key, bd.a.bytes, bd.b.bytes)
- }
-}
-
-func main() {
- defer util.Run()()
- log.Printf("starting capture on interface %q", *iface)
- // Set up pcap packet capture
- handle, err := pcap.OpenLive(*iface, int32(*snaplen), true, pcap.BlockForever)
- if err != nil {
- panic(err)
- }
- if err := handle.SetBPFFilter(*filter); err != nil {
- panic(err)
- }
-
- // Set up assembly
- streamFactory := &myFactory{bidiMap: make(map[key]*bidi)}
- streamPool := tcpassembly.NewStreamPool(streamFactory)
- assembler := tcpassembly.NewAssembler(streamPool)
-
- log.Println("reading in packets")
- // Read in packets, pass to assembler.
- packetSource := gopacket.NewPacketSource(handle, handle.LinkType())
- packets := packetSource.Packets()
- ticker := time.Tick(timeout / 4)
- for {
- select {
- case packet := <-packets:
- if *logAllPackets {
- log.Println(packet)
- }
- if packet.NetworkLayer() == nil || packet.TransportLayer() == nil || packet.TransportLayer().LayerType() != layers.LayerTypeTCP {
- log.Println("Unusable packet")
- continue
- }
- tcp := packet.TransportLayer().(*layers.TCP)
- assembler.AssembleWithTimestamp(packet.NetworkLayer().NetworkFlow(), tcp, packet.Metadata().Timestamp)
-
- case <-ticker:
- // Every minute, flush connections that haven't seen activity in the past minute.
- log.Println("---- FLUSHING ----")
- assembler.FlushOlderThan(time.Now().Add(-timeout))
- streamFactory.collectOldStreams()
- }
- }
-}
diff --git a/vendor/github.com/google/gopacket/examples/bytediff/bytediff.png b/vendor/github.com/google/gopacket/examples/bytediff/bytediff.png
deleted file mode 100644
index 5aa3c8a446797cb3491c6e8cbf47328062d4cf18..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001
literal 47462
zcmbTd2T)UOxGfx-6s3qXDFV`ajWj_J>4=oj2|Y+hO6VvNjnburA|fS(-a$Y}AWAj#
z4$=e+(m{$e!5jR(GymMV=ltj1!wl@%o8-x!o%KFtt@TD58fZ~du~Gp50BRlW2gU#Z
zi8}y5s!BmjxI#BA_ndGb@;BDH52zeqUn87QKGC-H2LNbaU;Yv?^`PK{i{t@14>ic=
zuP_3LMUuB}NfIvI4A8I$Q1|ijf_Mi2)cqh10T5@dAh!TlE-jshhUPFDW&nT-pz}Zt
z6#R7)6E+3WfPMq-tVOBXx#oV1eXBZZFE=NK9?A{(OM1{zJnZYZ#77k0F?^Tu?bREP
z_w@CDkCFO(k$WWGA;6>fg;^tqWlY}5nbc?~QcSMpWuY2ds-E2%ym4`B=Iq?}^GU*)
zaf|zS>DLc~C+D{=T;~@Z(%9vtJ{#<((J@b%ZwH^V+)GqKSzK)Ye<)ZB`ar
z0n-IF!pvPZshQfujEctIO-P{y&pTPG=esBB2YNgzT-&@RIwBfn1UBYI_tx$7&%#xY
zSy&mV-_cjOdp1g)3IPBV;bo71KWA_69uDfbpJ5stA=+_<(2454D$SO%8A5jF^WH)5
zB7VwvVh%Nrkcor}I{ez`m$`m4Bdba5RV>Hh8bkOLcx;+_G
zT*buZQ{+Vv@ceruTlODa(b=)fdsd8&?7r95D?Af;+Fo;Op%X}tv!>3SMU4uWqe9AK`n(_MGbMXlF<6&R3=lF3pK`iP`x6TJSwH
zbEHASl-KMJyY|>Owc^hE>CF!xiAtutH*Ufw|;KZazCbFmmezgFX2AvGbUXDHam!q#CYMqfj+*LId)n$;LjAA9hVH1`EBc+
zvgZYyc7Saoj31w{+yPx*%@1E1_|!TInq*A~5o*Bg8eq#r1A((L^q?4x*Qb4zVGAO4
z;nJ_tmACmELIIq
zZBX5Tw05q_u`FM76l4aXSqqNK9!=w{Hg$~#dxyj3ND8rqMdCw~IZ&lnsvI2?PbTl7
zO{sJ%#+N@H+_43liFkz^s6#7YT$;38;vYPzu)SVgQ}Eo*u`z}q+amav5CGuR_GfiG
zH8=ThrYbem&qVy)yWS~z)Flk%L{1Awj_N&p;TFGF|ABPDVsrl%ngq)&J9f(
zNAz{Tn=P&^v#=J5A}jX-)xYHb_-zfzrRLa)TnptPj(oQUY{fBe>#lnnAKRBCo9n{X
zH4<23>s{NK)GPI6`#R*pc^J=H9=^Z)D63C4KUl8=oHaOa#L3kR>ZDPEa%znmP4V~Z
zM2{u}d`N>Pze*G%9(DrP>24`?soH!eT~xYEodqnOHt?Li;OUQ!@T)iH-U(DYfZ5Yj
zRO>}`akDM~;<^nV>PPsW12>w>pyL>G!|xqW#e>xeB_o_P5oRc9n^5T3Pkxv(`3y0J#-Zi<@d7sR|j85#`cx)?1P(9rJ
zHjQL%P!6|KDL_W53VkBaq)?FQ5yAjaRXJc?P}B0M!ts8w_`$K&_=~JHspuoMna6weIo5T2
zvYTLF)-@pM;hm9*&S@iMDgc+rsnZ?5fcw;E9JppD)8p{yiF4@5tB0h4i}NDEx?I&Q
zHBP*}y}#~TyiXpNCX{iPhx`$l6Uuc~B9?fCxKABj#ZNwE6iEZ`Z(5jJ*0e_)V(-_?smC+68z&=
z17hCBtUp@Z7yC;0hdfe|kmRd<7FuoRvVtIu2p!|)dYEGs$C=5-t`s)ntA04E&6tsH
zW15U_WGbr_yXqa(I^JkqWkJ_@dTFyMw2VDVmx!?Ztpd=SZ|m5$&sz`hvTI6OUnx-jz5Ig4S>p)mM`SzqUcP?_q}O%o&sBa=tj)B3|HkBljz&)J{$
zQdQeo;M6|w#fP@N@CpzWK%aup3hl4-FAsQJB6v4)_xk0Lg7dOb`>#&`?t>Ba>~Ch)
zc%`JAt@ez+p!N>zgTCNzzoGz@S7`znMD)zQtM)#|=WI`U@-s~ZXS7Z2EwXC*4YOq1
zf_+kIyGbIYC^@ely=M%?Z1b1I<<>~Zj$)QH%H1JJVo_;RkE=~;0f%jFJYQROPuU0?dD4sEd=Y=GQjyxwa0!p7W|`+qlgsH5Umny^u$d6gRC_Gay=)(DORN{q)Ff
z;v!0@K(q)ooYkZrhw^igL>i2i
zg&9?Du1M=hKeR6Sx{j2|j1w(aX;g8H_Lv@aTqK_P;E+oa%%}jd{rSAKqyO&j@Y~(n
zA`l*2HySXcaT-6TmABl(?Y7(9{75&&>r{Mals+!JaK+I3=(YtZQ?eC1i8IYN3uh?I
z$Vvn62~7e{XbikIg(x0_CWJ&#VW8b+0T;8TexeZXYxzV9&Z@%Xq&kU-|t0Y(rINB(Cop7VUZ
zJrb`XpTpl^HNHQ|A5?P`tacCXRS-T|Nr1VmyJEN$N%Zxa<>No^Y3oXgc{@f
zZzApuDK_gDqQM}`lPSP{2bQ-
zamqikLw-~LIZJ!$wBY>FyR3q@7vRRsGH=o%V)sfkl*yym*4Z+!`HsHm(Ch6}6J|mX
z2H-zI9+cG!zR}Sl1*BkKdKjR;ZT|Shy5R9o^2Th`-{lMIO?O)b#(q;$Le%zTPD!Fv
zd9s7X7zrWrLsR>t7vly0n7J8or6f=Q_+OQjlsuj6m8=A3nSJaq-%vDgi92t~-?kT0
zo+uMu4gocO^&TSVCK;mEDXrq{Dn?mWwcG&mnhXv&2g5=
z;0St0t%@{yC~m>LU3=68;Z8wX>JwJIk@9802#`T~nqlvkPu|X)8mR^S#iyXTNde$O
znjfuzr$r#i&LLOL|8$rZIuuO5-2M0hd;76tdn)mGEIUuNYcK2KE!5J!u!AoMxJe8R
z$^rm*a~G!Om_t$Q$yCUs7VPe#g1hZ6KLwhnf$Ef9XLr3a^zFH~eVNO|CCNRC!&0Yy
zAmQKEIZ38zCyYY2;*K=#0wO(*U3Vh_{IY
zTd}u=CK@+Z>w7NmFp`y`-Q9JvzB_#cs9p=QCAoyK^PhiT5NsH>jl>r(>L+VH
zGYLwvI{pYj6y1LH+LYO~2Ci$nNIaLbhuM+u@IsT~oJ&1ct?g>jV;dqE>;wlE)$_c}
zk^acj#)Sm%bkT|1QShKwf!9(|Exiamw52MR^g?$vH_QCwXk9D3H{fajn*>ZcbDfni
zR-~neMxYonqDW-#D65rCLbF&{iLu{@Jl+9VFpeTAyk`&emQ5`4Sd?XB_WDKevr#)}
zr`I#VlprC4Cb%?PVV}qiSf+d=xYcuB%AcCZK7TdH{E%I-2^;1jwh`A#T*oos^c}Hh
ztUH}J8s>tcCRc->>OU^Z7KoH36Z&&+F8xq6J;$8deD&okbJ-BgqxC@x7~xi^Co*F
z?eSuV$Ft@b89Pv$^r3Ug$i?gMR98q+j(o^{?CeV#0DF}2HVgp9ttDc>8*9(5B?P+)$GGPO
zWV=rnTrdVEfe*)
z((Oz*p+-y%Svn^>pFG@*Y9*2JV=jhbwZ5sceCUyS%750%{TRk=S;l#T=gm6{dzwT1
z@wuf4K0c2dpwBQH@_!CnThelJTK~*ll{L#3=Vz3Edkbtdq21b?Y5X@A-z5wlmxyn~
z)=X|3oqhPBVr3BPrChQnxrO6&<*;87G<+iV;`F*lS{7~Rq-~gKCK#mV;$(VCl{)@f
zKmLuCSwLj!O8*1k`d2UImNrTJ4Y}8;k*#I$GSNRSAdBbT-Qniz68ev()3b@K;cxn73%iH&&NKc*k-Ji(u6~}1^3$ru!S1f{IJMrOE$BfBcD3}U+Cpjh
z%pnVl?TbO$5A;d~-^P%!Bowx~S7~x*UJEb4tlb_!S!4cw`U}w&Bhs7?2EkfY-qe;T
zLuN5}?-Vkg(leG;dln8Mq8kc=1dm0uDZk}5T1E>1Q-Hd&(JdKKIYj^CYz)S+U2O%!(HNglo%SkxEEBF
zU~Qg@zn%$nKID6I^8ytcBhZv?j{o+aMZGo@0TGcj-hX6f3(XlUBD|UV$q(QqV*gvV
z@}Cz(l3!waAg*8R%UBMs3>sj07lxD;8ALMKR4hU?GqJ-tC+@C)FwLr#Ti-2(77r0w
zs?dELX=TOfazMXCQFbi4!S<__hd41I|9WKMt^&SYS7Cw=4iCt+^9JEfpHqTiztjeP
zPTXuUBR(Im66$R;UiWP>{V8Z`9z%Kb(8)`vgFT>fI*JOJ%A
z;ICd}qd7kFJE6K)7l}*$PS3u|AzjXJRNH7Ow9KmHGVa-_kjDN|2!U-_oV04p9gPt8ulQqPMVuK&8cBTKHUDww
zBv4U@T^aP$%WA&(M+P_>P6pe?Z7@yisjFeri&VR{QJuP!jqv7Jm(_hom=RCU+NrCj
zm3nR^d^DVplxuf~=eGzUBqd`_$Y@KiGV}(F4SApkZF2Kpq>8_tLUvi?>b;Y#;Pz5{
z9y(e|9L-FGrTL#UAsx#TDZ;eRD}SpUuZ1Ee#a?j6xF}qh2TDJ|t95Xjn~YI1SgRY^
zFPp&byz@S_)J}@m+_GRTH&O(R+#YI-_$X%~ffvbf@9WjbJwJNxQCz<*Q7oEX-m`uQ
zpqgMxi#(){@)vr@S2C)Mz*ulNPhB&GPle#IN!zQSieDk0n~Ap&^xo|sbbTnkc*9KE
z-VQ#cE$}(>^QjhQ#p&nG_;k<}hf!fRfwutms#P_1w=krlDZEGCioXXG4^_Rq&d=>V
zvMOmjlmq)78$Ng$%_4)|2p>7dQbQ45Lj83gBs*{&1w
zyo4y2$6SuF3sYnU%CWjp2%(*0(EBW!A5U551ScAM;xVolY;r_g%6%&Ca8?hJ_b;!B
zFmQd+llXKK5RhQI+~VSZ;C;n=#Ejov`|@Gnx@PdEJop(Pp6txzxlWbahJw7Nsd}br
z4e+y5_lKl$x^MV>@uV0+zx@j}-*=S^v?Dhwpamtf!tsgJib?1?lfO^-
zzB&pWJzNM(O<^B=Ep?dV`6xC4-EbEuc6tZWd{IX`oi4sk44I$<#gwOsxtCX*2HAhw
z2ygY9Q>eaP@(f-+(|1)Pf!mNy4SuygRnNv*%@zP?*d5kREPj~jtTVo~Q<$9sqS?-z
zF!8gpw%5)@iW?fO)IVCU*F+T~=b0R3#le|gjME~#rVPblo=xYL_ca04?f(-Zu%~fU
zM_QP6xZ>_+qf~cSkuy$7g|A69fA4xGyBJ#`1IxB#VCH(z3)hgR=wIW(5(&ByAwoB2
z;Dr|lP)nJ~^;!8_>;T#J?$7ZSFTWMG=q%kb`x)ujD=%PXi|P60VERPEC)+I0gSU(U
z+Mu{E(>Df4LZP#a!f_v8W#U7s~Xz*}914rl9u<0qSp(
z$+ztm*i}{@<+XEUJvBU9Z`k9F*^$n~y**^%YPr*l_|zh5mK$CmTq)wWd1x{RbWOqE
zu4;y#Fy91xMJ*U%w0=m^2Y5k4$P&V>vasv#g(Z}(2s6nidN40p+aBtcFj(AtLw059
zr(<`Q@aWgyr7TJ~o3RH|OEyKNQ*Z=p+QL)ofMIPFTEcjcne6wgM!c$6*)w?4HSwd<
ztE)8|dKly65YXL4#73`z>xOtogj-8xD?E|*V%TwLv`IpvtY>NRE))ikteg!WrCz2}
z>6+P^oPt{IC2x`FF)5wKj38!R)fYs^L^M2}_MnW%`aOhdoA)xqK=#+RjO~QQS&zrF
zb&Jw#naLuzji+S}YV=k<`JN`dhl-@9jZ*I4@qXEX%>POUu)j9ds02u8Dh
z%uD%Fp@4J}^3TA&ZVjj7y8wOS|E%S&X#b>q*%}RDM<60s{$#v;d;6d6Uf_p3mrjjZA5kl#T7%OhiI0yiR1?K3u*ur89nTt2_VJqX!xr0CR?`OusZy^6h
zS*v9n&lzA)EFmldgbCT4ZVZFc={#w1W!@=Eim|$-?K;g+zE)=-02a&7RP52Nx(`nu
z5D8>xDOMEPp(c+ssPk=CBs_>UC7UWO(i;N8lXNYE{m#XCmDta#mC}~QDr(-ehki^J
zfx-w6MyPeb1+%KZ1`xnon6l^;0x+0R@&E%kmQigZG&Rh%?MGM$q+J(=95t%_oF?(m
zY~j7No9*G2uhg%Zms-U}N5wCW!@+Ib+pWT6R~m4Nl%z<2r1xc@gpvv}O@grV*9*X^
zR`^bY_578OCcd);tJc{u?Twgm#F#gI%gCPFOS-E&hjt_F${2_f<_(vtC_jstydDxF
z0nitXf@}~tAfbh5o-L3_uhGp4!ejge8}EPCF(kP^WmFzM)}Q*bFRKk3oO0BhBa4V-
zZ`#rDB`d5cSf>F1oB&~*Gu(f+r|6>+%BXMh2sB)WMzm75kwtbKtj_~Q!bbFyMUk)1
zOt#N!D^+he95xs<1>e`GZqX~un?nD(IWa-jC0NTurZt`zF%10vAs;SAC96`TX-#@6JRJjXw{xGncvpU%tf8v8Wenr(
zG&uVM;>~kob=xyRBaM=jFcCdoTObG7+K&@%`P=t15Qhn0zPlh@aiv2nF~<9wA;=i4
z-lBR&Cr;BdBAbu>WqR_u>fP@M+s!FySi;4Mg?pwffF&$V-1_JAhKe1V3R5AGW>}wo
z@~pre(Cr?@lXccoLC(uyGHT%V-IIpYTa1GmJk#9jIp#r|Ox9F{ZV~%tFnp!?{Ol-e
zdpqLYnVZ#cp5z<(z*-?C$4vP4VsH~yR@2qIy|@Oc1J!tZ5tw^M40zrD7WnwtNw3}7
zlVb}DYn@TD^jFPl6C?~rFi5_`9FrgzhD4Tl0wyXP#i+%IkzM-8&%KLJt;MYbc;A0#
zCpBw+=s^87NDVzg3+exa7b?6(WS?pm(aTnK(y`Fr-+x&1azZ=h2gv3%yglOJr4NM_
zv&BbX1syl_#iGYNsfGcQQW}r;r&zPGsic8VBJj!^u5L87nxp{3?r4Gc$LJr~$K%g1
zuuhK?Iu<8R3p3WV9Ajn+maflaG(o4YJWmo!^Mv|OSD&hyWVZCNO06u8Fes42*0ZWP
z$V!_8rT742KRwz`SK3ZDJQNkqEN%)wF%**A58fWG>2kf?CjkV!-M8Ianx3AvUG^xB
z5HS_e!TSzqoUr&tic0i~CROf9!w}XVnr|Dj3qvaNbP2L+?8>Mxlq^&kAKU=SR?V#A
z3p4_-2(+HIwT}60mTp>?Sm_8?iA|jQY|*598H>E3DD0N;;-J%Ge&Lc}XNJ3OR~cDkmBZ|H)8
z*i_g`>es{akl!Y+c9MS>^?&)C|N5j@`DoZr-+MzR
zo|(6plg&1y)f*4KZYv;Tu0mfNzNko5L&g9MkV{Sf90)|G*1HOpL7=d;{g{9|!6?>R
zv@=+jpqy8Xj2KJ1ApnxYi%3*mFK@}*d&MVXjdoa;eDuWJLNlw?6{niLKwvnc-lN!W
zuR+iCwmLZEP}6zR5R>`%wjsvUiWDcy&}K;lIAB$OHQZ7mt>c#%#-5W*W^BYG1KYDI
z?HV1ry%02S)R?wka=@PYh>&$%-bZ6o580|(GlEDX6;J0(BYul}Qrmp0Cl$9!Pf6E{aC4iAo*M3juUFI>(o!G#6JxtnB|8k=>Ve8;4H%5MR6
z4Ior`+Bg~ifL^thSz%u2rrvBm)LX?|)gX_%_-PI;CQ8uDq6Ut_M$h!|Oqzx0qEV+KG
z`m^Fw^}8Ynvk75-i^Kdiq5zPy5tGUiVbdB>&;IFvR7tWLJuPd$YyY!io-Ab`6XzSe
zl>Q<5d!4f9k9hM4&|M^N5kUtTjg?CTWUw+uZM!2g{l1==s}E&R__dptW{I**aCpg*KY<>uiG?
zmQ8LZh&w7QY9xS#zBqQ@1%k9Nt+RUEufyoGxFKS^NdPIT=0_^)w%5dNUF*17
zD^480|MGJ)T=(win}b6)pqE=yxe-m)#nw3^uYyAU@lA)gtau_odmed8%fUR4XY!Vl}=d-4U?i*KC
zX)+)7>&>xxQC^eS8%z8I}?v{aA}HN9ou*@15oY$tQD4?q@KJ@e%ltAd-ex@l|h?A
zPGgxzdcQO$FI)4QB;BA|d+H(Hk%?W^GsF%Cc3UBkrn~>3_y3hNWs|&hU$m9
zzRz&IRq||q$K?BOK&zVm+J1?<3@x2qXGWiQSQrF-%z0+v!n%d%GV`<~jA5&W_W^aM
zi1=1WXEnSMt|03VrG`j+;l9PUTNVuF1L!**TdZnbX*8!^$hr(A%%0=7<1U8r59UJU
zqaoUFrX}5r3A~&}V-1?QvxyhnDKAu!WGyo}VmQ05P8xb*>d8j1kJSWB$9%fCGMKZl
z<9ai|hnj{n*)(+iKJ6_h0}YNjXnTXEL{&J6`m5ro`ZP|(3G*i4-lQbjv@j%Mub;1!
zpqbfBH#uZWxwyDo4h?e#-AqnezI~w9eMM)vZaZ5lM3w!si
zXf|^hCy9+-*)gv?DcNgoh+nsRpAWO#DsxpQ^nXmE7DJp-jvdzIvMOwIpaw6Exu!MX
zYqL_R`u%U5i^QF#mI9LDQ)RKP5wW8C@mM(B4C^{8f1qb3oV&sp(*uF6&oBZ2n*q>Y
zQd0QDTf!|?NB!!}Gs@tu$Tu%5jDQ_Zd8gtcTCl}Cpqm#a-lDPY)JUnQ;#MAoQn+v!
zsYni$)cp`0Fdl3)OfX}mU2D8YuM+w~h$G_RV|OBTAuArv8~7@RiwK50qyUL4VVpT3
zE19-)VP23w$vVk+jp=hC#IW9wM;U{HyLLe(yj&PU+&L;~G#KpOOMAnj9fcEhf1NGn
zPffrwTx*RmgY&;qr%@
z%!rzAH~zjTJx~Jbkt(9Si(}Z{Kk*RUW>2OBH4YGP`Six5eD
ztgX@{QS@MHi0Msn$?EELX(#z2Z^$&~a79FB-)~^tB4|6w!}<!Y=LjcMqYxGkf_!`eWvPR^pD*fycx8hYxVpwjFI6acD4r^WfY
z&xWb$$xf3cev9uTR`)Oiz2b(s=w`T-aOe3oFDotiAgog}FS-+K&mH18uIuX)W945Y{_3ofCGrSP|9V`x
zV=V}!h9VVP%xXg>YO!>tqnn@N*NbE7-a~QBE^;%}xgw0OF>kg|&q9(EH8(9jj+;uo
zcX49_ba97!zFh1IukaodH++-S4CfyhGeGIv;Z3$ldL3xJmr4U{h?vWRCps0Qp1n9j
z$30a;f5b=9}&uiQE2?m#>Fn25*r>JmJ*U&zubm#fu&zvAOXKD2E}I}e?;cYrD6>m2
zBS907e{?dD-ojcN=3D17k#6L4R
zzkfcPY48ebtEsD=EuC~s<{Q6AJ(U-0O8j*04%S-yLduGg$=vYP^KYX!Y;^B{`_<>A
zJ8ir*H_O-Y2l)E%)H%R4t^l4q{*ufS79W9IjW^BY{TTE*X3|S&Kxy6f^Gv?#VUwI@YVJyEj8iYAab5G^7ts_oYh0CUlq&8A%a+Mg1
z#MNeJcxQf>+V%OM`KA@yt?2y{??9943YAB&B;u0hhh(tKv~*^r
z>q^2_JeedQZ_;ZA#dPGw@7Ni`j36KPg#2E!UaEMN%HB9)&7AQp;$ynV-N1LM%v%ql#`~=>kM%5j
z9dpPdzvTVZrcVtrzfXyE%`;hEH2Q?QD17EY_nc7l<+aYfG7d}PpnW4v&@6r!IFc}z`Im{m3@S!-7C9<)#bX{z2Wi;r@)
z5Jzk6Zx|cawc~RKLJWH748df_25txdmJD*l1D`w%2?JlzZ;`UP9kx
zK99Zg^zE4&v6tXPwLxxhnPV--cYx$m$+IaM^pN_b9g4p@z7tZANrG(}Dccm;PAceqCByBNvWo?fGcpql5eAv*%_JQS4oz^fh_AH{OS>YOAuUsV)@}%)u)mZ}ymIVW
zn)_VA{XeG1Fwv^r`H#NT15&rk!wvZjJ=MV;yiCQ`LV-Z%A{`}nmT|ZgyDBCP+Mo4I
z=8>oEv`M%k2_TuEAVUgt=-(mPst#694@ryvO!7|I3)$RFdxKeWZ&{IJR_VffTjKc#;^k9?M
z3By?~{zZI+tj%
zv&xFzRNraK)fTRKLBqmoNF7Yo{^STbs!$sbnXApqX9f!AIJo8u8WJk4r$uqADm7#v
zv*~YyvPCBWeua)2WN&!Z87}vX)YhIr{shu4SWGCemA28KW*=udY?zctbn`(q5?Oz1
z%>AgN`bn4>7QemE6^DA09<7lcf_;-3rui~L=yy
z$!R!0wHc-reOK5}eR_NGci0_*LzBQR8?mXdZcJYLl1wFV9Cv|Db|zNo)Mi&p1B!}j
zhg7(KqzI7J#`~F~LQF+P%c{1&5&&9=#-Iwys~Xs`;6e@R%=VTRSNMl(0DI1Fr)ia?
za|LfOyHd>tbNXUAp*_xuRM$k;BmpBI^7QSsyfQ}ajSq&=GR(w~#9^@7AK1siM7bOP
zlOZ%Ahad~D@0inFWw2LRF;7cBpS6eS&mqxZ;ZEf$TvUt5pt4!L1M<&<4|%8_De>fn
ztVuZ&W|(cVlagwa^8REsBaHn%4Z&lHTxPVcNzp$?`8&dDZ%sfp$C?WaxMVaRI94%8
zP>cQa@Z)jFMtF1^@c}rC3@Lp
zk+2ca3&}Rl_w=QSR233C5f<5eN-yglL~TubNH`M6nRn$=!xoR(ArT(gsz1M#0tLRh
z&SMwbeCJV~ww9>kNx!D6d`}055C3>p3^z%s>Z#W>xcypl8Sf)FNs^{&_P@()5*4fw
z?fsl_u0bxt7zsg#^8ea}+Y0pQ6WOIvr%5s*R^gPiogTHH1m}Ap>a>+)%EP$)9d%G>|6*E-1`t{|EgfW2=Bu}+k%HN
zYv-d3CBKx~62W;nE1Nq?#R<*oG26fx>G8HgOqg?O_3vmQqV8YO4J{6H11^2?6S{@QV
zd(xJpxO?Ru6sEbBx}%!tCz@_PUJyX2W-_7ibE~V27D6d;gB(@R?A)_#XhM{36LzZV
zFm3g&IyGeFp`}oWdj`KmXNcBZSiUvGRGLw}&$j3GDk}>W=;?RvyOVXhsicW>8V=O4#}}
zyl#Ds7m-0gaJ}
zi3T$eSoRr8sg!=HRTof6xS7Oh{K_GCH^#`0QkZX@spc9pwUcbICfn($rZj9FW(7Zl
zq+^@!0OG8V<-fM@S&)MM6h1IN(bhDS^Vz(;VHOi1ru58tLhxAx>ex5A6TZFDZ)aa%
zwzjmt<$h_69vXtQgbUCJiF8(*icD$j=lGCRoaXxxscKejA2!!M)5+w`Vojn1tvSpM
zlGjiSas!|_UnnGMn_AINGi}w6it1N%N57*g^E|(bK7$D#j!#^*;3u%M3Zp)o->A;@
zY76euDxF5%|FiKvT|TY!cld{L`0^ORNvC-@!yJ@l5%3!9T=jYgWy}ug+AVG_a=z2Y
zE0L)c;#O??y@8Z!Pxnt+@l@UAW*YUPH2yF1W$=R2z=Q3Qgp;q21eiqZjt(QeOQ5l$
zqcWOXMX5q{4%Q)V5noZkfE-q{oS5r6iN~C7Ote-49hntok*vUL^?8o33TK3gxYSme
z*3=|Uq34~e+2EJG_Q`zFPFk_56;r;E`c0=m$adqs7CRZ&VMBX|^qiBfgtW2~Qkpl<
zP-A)Gk_Dd%Ycw}+zY0qQw?ARyZ%IH*U5}g^28N3s2t~1#T_JpDvicv|m}Vs2h*4bI
zaYrT?*N_RrL!~r@g7y^?4z@1?6$D87MtSwJu4~X72_E%4a%tav{}5wJ9GQK^aj5P;
zyZ~%I=o%4Ps`hSu*Uh=H?m6~7`q{}@@9PZe`|rR~#wgw=plRxF+1p4ZkewB^m}ZiU
z4+3zbSA!WW`}+u=ZZ|(Msc-^M%zn+G73L)o0jHf1yL!r0XKX*WN-r+yY{;BGtYIHQ
ztTdx5^;6Eg*uvWPLIn=QJzASEf34NIQOe|I(q0PUqH$pCXdln8RSRa=ForJdJj%@zT(E|j%kCIx`-a4yhttQ??YF*Fs)wQFB
zE)N8uJ6O5|Vy2h=s?YPF@U`ia2I-DH~S^p(Hp$rTy
zc3z5j6Ole0yVz#JAFb5tTqc=D@~~buAj$1|hHAT+a3|Ovju^@3gm)*@`l0IK1oz@C
z#&*``HqRPk06+WmKqszf#OJw9v!{mFv8!%a1VON6?_O4+b^fAv&H?_lrk@SRdzmIk
zbCAJ3iXF?Qh-Io$Q=eKG_}xvN8GF_zB4Qppu^Yq1sH{85nx^|@fskC^5t3_!-X(G;
zdw8Fk4egXUe?L|*fD?C0k0-{h)l)+;W0+cyJ2#v}5XT^A3?(;Az4;}bf00W7@S5l!
zrzh`{NzQ5N4$sRLXLuMpS^hukqq!qqZeH*h3pq%N6>oM8=ykI0h94E{UDk(xMBYfj
ze>PbU-L#tB)BbDqAChuz5%|aGuLuvuNuEckEh6#q)2TXLCrq_Cp6(9@qGfmGnvAIJ
zVDUNxqD!Lz6oV9ONp`GhCipj1V_CUbuPCbWuY5R0r*p99>@}BbG%i$ca5b&+Jw!e5
zGm6wHe6nXSKzrq7VgmC*r-AfgP=dm|P?6t_bdA@9Rfcd~XHEdlfBnJNzxSDoiS2_i
zNWAa{T1BH&LSsJ$5p)nTjR{{TY^GIv85Xvr8@-qhxG}JbAIrSA$`bX9?JRY;%*ceF
z+C&|Wd5+a4*)Ql!Xhkfk+_-Towz!yK`%aArm`(*E`$
zQ9(1sNJ+l?q0zRx1u5>1eTmOZOfzktN_(EQvmJi4>b$eEO21EJ=KLLHEdbE;KlxBNzzca#Fd*D0Xvv!Nf06dqVQqE&wrHqOp+JQeCk0Azg1hzQ1zKo}
zySq2IL#RQE7K#)oR@~jaxVsYqh2Rh%KnRlDMf-mDIp1^l-ru?B@CWcDizQ^vpNu)i
zm;gq3lZ+jelUD!oS!RWBLZDXfVx)rJXNPrRdwDk%-vvKZdYyC}=0@>5=KN?1uG^po
z_W)orl>Y^N3M2>PQOB$vLOf9yxEW*<)UCzgEbb9(B3Bya5MOPOg1MdTdR7;=Ow*|(H^!N8)CB^MUt0`TAj`8u7X8l>ONI4Cvej(!;Z1>J;YioxLF<2wdi7m|{
z$t~c;O%#3!9JJ;@yeb@or!?DbKosRi--GfgzXb|(CIr?&fksQ=%UV%*
z1nhhpcF`u~y>u}4=3+7|&d|H(40nRZ^;<~^vF#n2m_YSupoyD04Zret`w0T7b#eOkCUp4Bzj?ypwV4f;js#i|%Nr|#hvw0@of
zovVbu$Z0`bz&#+k71nzwgL?OYL?P&4zr$SB#di77X*&X^QSkh2ntvfRV<6)Ed#f2m>4?1DT77FyVSp>D&WPykea)W&ri>r(9--hfq
z!MidA#wl;PjPTEn1Rz#4o(+2C-)
zZuJ7QT@2g(d9g+k>@ASB6S5wLiq&hru!5bwJwh}u?}|Z%I`6!D4*Z7^I8C#Dg#Ry8
zC=a=j??}lEol8GY=Qq73>`@r?Br&eu3~B0BO7V&e!p9#&AiNpH#$5ozM5vmg_eo+|t>bTz{qf%EJ9CL8i-
zaB$FnB^@T2a2Tv;=>N+lMeGFQh@7Qx!CF9hI(^rbq{_^?!sFxPq4VbheF%5iq;rpp
z)flN7Ow-tF1NQ|l2u~-C?_TSY=$enCk{MoXd;I?4IKVS5y8rZ>%5aiAYjNwxu5i}^5&lue15BxP}rQ_
zma}ggwIS>%NXmQ407K(C{A}&J%drn0jf!wNVF|a1LdL*IseNeqI_naRW7PbD?2@mv
zAzIBty5YP~<9wQPZNKK?(`4cphP6c?hjl#G=5RTlvGUsp!K-7&^EBAQc*wuwN8gi(
zS|6f{{U_LsF7mYMR-BivuNir^V(Tn6Y)`Zo#L0?LK#$9em79TX5ovlQlkc&Xn;3oKDiEjjX*kSK(DF+<%dEYc|-ljAXb?a)q|mY
z^o*_fH31B1
z+_vB%ff1|On2LwqVdgJBKJdLQ^#%EmS2O1NBX^wa0J~Ga3fda;7pf
z@TU#2Z2~XFgPypIn6D0GXy_(KVH+~PUkd&*U}>?}JQT2AGQmgnViA
zRRmJ!AK0qwIj$DR))a+?ct_G`FW~{V9y?g*P(33Oaau_Cy9znh8oA?k$CoOC5BZz0bG|{&Nm?
zLXvx_JeC_h%t_^z-oUu&ymb4RKiHY0^IZ&5Ys{U_L%p=G-4K-tx(A+Uae?+
zF?w(ZBk;aXt8r5UaXMMOsfxaEeL5txe9-+w?`ipV&;xrxTVFQw)izagom`DzeP-^z
zWz?EESRQFpA~HTFYVa$~e^TGHdu$#65c5pi>IPpuE-wT`u!EOK5CSp<&T@0on)_iYf#KP0Zt<&HH>KHc^G$!G@mzY5wE
zKImp7=lX{4HcJ$8@IG0TAu+6To#D1=yCBu~-e6LUr8!y|+_4*!G=rZW$+m$L@1iwUdmwPtg%ONg~0DOcbcKA2se&h7bHyViHu3*58LZ`X-dN%2i~Q(xN<
z5dD%xsYY~?Je|(|+rF!q;s}FaLwLQVg;WeLt2y0Y)nDE4#v+clp9$8dat&kR=wleh
zhVx@-r5Y-8BC)@c>WSM7)aRRAB@_$*NM^n|di{3jerzUyG_)icd0#*by^v6hcO&rZ
zRJi@l0lUXvoF(>9NKo4(OeK
z4dg+$a45Y5u}Uu89IT%-z+fRX!j6l;JvaV(7$b#>Qv*uj3f2S@)dAjYD&AarG9;jsI~8YtB{6+7+}N*3JGCG
zb*p5r&R-q!hos(v3lct6&^i6Mkl?)6e-J4aRS{O;tn>5plbjI_@B{6o
z8!j#`dV*4Q7U=Z%ct6vwDwEMc<|>r0X}uyBTOP^MBHd+{_@7)!6!(yqBAS*JXY?zf
zoR1N)%T||5x?-fjlCC=44?VBx;zipqX@Hi{L*nJG(uN^)AQ!l%rO$8ZNvq0APiG!UVrbjuW
zYC?u97T{vZ?vGf11b{>KDGbgN3!X5js~l#RlaXt#}_U~BO5JWNp5%h?GUno9EObZKt`4VP0p(T
zWI37f-Os+?t_GoB(l2oeJ(A{Z%e`5DEhf_huE0a(1MY&p6W2>2jb79%nl$U`6{3lg
zTQS8_Oo9OOAAQ1~Kl`dh!@X+r0nAS|RJA(u<@eklf#J3vw1TH+RO_tMy)0^lBxACN
zf@-WYsp!8t_5im*-T@d$asBdfCtZ_##~t;C$GsnxAhtU$Vjw1^I5vca;#nSW
zw}HG}uYsPwpSo?$t&hn?r5-tBX-RSs_NZx2!Q_chq-tmx7*mu@t||>Mwmr
z``GumE?p8r0BtkT0jLFsGcCL%jAA42!Koy-e2z=b-on#t3nD<2Spt%rr2ZqLFVm
zeGr8i&|FXYqXy3e?dR(~Q1Mm;hLz4Az1&Cl6O{DrLTfkk@Y{w)w%e==WahI&WBzBj(RP;`|VYtAgxoo
z%KPyhG55x!10x@d&w@m~6{3-vj)vpPykpy|e68a1B!m|R=7sW!5W{`&X@Vhua7Gxp
zo*v=g-$Ri>)_CT0GrzbA_!gIf`;p0v-%gK!g2j)z86#+Y
z`bSc5XG8sog!eT{!T1xm%x^TRfL;#ol^)toY#`V-VPV
z9r)CbH>Vm_KlUjRL5P0GcWKvf$<>^rt;wX5c{9w;oL%V5;c#0Qolk$0AD-^j8-V6@
zmuPqPXyx5?^o<9>Lgy)ogCc9&8+=2e_WQpie2$xd7K-}ZZ|UcCCGk?1y)!w@LVa8z
z)NkuNF4<$dR32Pqz28PEaTljS9P-;}a6|+xo8RQ#MjRp0WLt
z4@ycrzW@>wzgWG8rRC}*YTkV|w~vs1waM=+T;lj-W(K}B2|wCU@^fa{9Jf#`ZpNjg
z_nRL)*B-<_mLAoo{}ZUM-&n
zqnP9keMhi}I;5B$AYN!VDFM3j{oHI$*dcQwVXk5v7l0@kO;a
zX@o(D4Y?A)v-;sdxDT2d;kcsG1+?fc$Gh-y`JhuC3%kc
zgaq%+9s{u|s6eMU-itZeebz>v)=eLu`u-S&@YtX6T4Nx@O1Tl?!AJtXz3JKej{>piyG7(twzjdgT2j`b8El
zn7dT^$VB4{+**14{^MCzDM>2)tpinZ>svKpogzzFt}!7k1g`MTqO_5k{=e!h`+dI`N0?;SNgM)0!vCyYbm{2{Xdyh$JO@u;A#<
zoFEiY<#pKACeopz;&Z%RyOw;^e83L%1RnEa%I6IM_oj4m?aY_FlV0-i(uMa#Km64#
zAYmXem(5_r1Y`>p2sTDUTD;oEw@rndP7nM1ir*UTaz}Wn1K{(rtzfcn&)B|Z^}!T?
z(!umAZ9CA(n0LUX$L=Sh7P<;fA^Ufp#dl8Fb{W-mWzq8`ZC)8`XISFnaU0`a0@i=7
z&&LSW8p=(1n<;I8-h1+xXN@&|1iE{GUo-ju6};K{DzNigVIr8;A8D{!sC9n)4Ol%t
z(WMKR&m@l+uVrFDP?@QEj+7&EEi=Bl)epW
zi8NgHaWKi{(TOS;)4E4N-8BvPe;4nSt1Nw-d8X5}bfxdcyYZb@t_2WGw)qWAjTLQ?
z$*&q_$6hw4T8?Mg-f>a=1m;w;oI~_tpfBJ2%~1O5vr$YBy{7>`%QK8jRc7{Q+CKW(
z$2ZxpS%oXMA+tACY1hOiuGbZFicZE|u)b~SwHR9({P0dXE^YQl8oacFJ}Klt&J30Q
zi@ZrU;R6Q5N-Ld}Rxh2tkE|>Le0DQFL}YEWtzCOTZv<-J+USk)Lze~VBeh={Sh8QS
z2nPg9abmR*7@O~WhI)7T`|oP_ePlnCR=A;z88!Jfrjz2E*2ia%m6Zg955@L?Q09UTu_fmZ)w-7FDtuqtHW
zHlcw&y#e-bk6L0(q&wZ$!eNNX4faO08c!=jNTo(Sh8X_jp`aN@{MAc19tg}5wJv7~
zw;IF#dIv*Fb&i|VgEnFltDAN!i$zeGe!tL$C2r_+Aj%um7~=+$>K}3GHu%lO#>c~lV68)!
zS6XQF3FXnN78g9Z7!X1<*aEn>R^$4JJY9m{s*Typ259NdAxGm-KyP2!=o88j3w`&u
zO)q0Uu_@|_;fk0n?
z=j)yJ;;N1%SI>}@jfknn9<2h^MTv4YM!#iV%};3u^k27L7b@{8(hPf(X7GmtOq&_!-jemJ5VfFrHN#*1Rlj!Y$q+CGYM?}-hB5ez|I
zgg@Bc-qsm|h;FVg2X0N>0Q(N-!GJ%j~f;-PCbeUHyL&9_7sH$@evyL&aiz$Aj0ttw4Wm
zYlmW7lRQ1jj(s!kam2jRcjxE}7noQt9$ZOY%YK!ai%QRH?4ztHF%c+4GivD->3Gi*-|oZ9BR3485fw46Z?%0Z{)O9`$nrTe{~GB>4^d2;MA}Ua0q+~3bhK~J-3Xx{*;k%Zu=RX7+V)?*gP9r}p
z6`nQiBAqLiuHF7ePC<4W4ItD-4u>~Bh7TPyvw_1V{U)rnWF9MLoiAcyj1*!u?%&DO
zP5H=XyUwNDs2bWCH{}){77|#WQ&YCt%T&H(4xH)*DR>9|CgDjjDaSURn(kTeIIzsg
zQp`TE&k8BsqzXIm
zIsfI}H>|$EwhR+YrN2GXzr3q`ZNhr<4}{_QZzSHkL9KY;D+BQBzZqb*cmi(gLn&%cXL8SyMbGCPE)OUfhTi#kdr1qR
zB9UpIJfnYEAXX4GeJSX8EPG;2+A#V=0B0CWetGDJmOqNz|ENs=j|cqW5`q5w_>V{b
z#{>TDbbF~raoj>eLML70
zvB-1xc4yy+M&StTWKi5oB8J!faI}}bJ}0H5rafd68>rNw!4>FD*^4U|MLCpqt6Ye$
z91&i+S^v0^P-e_xcyl5qvW%N47G~&1uZ1iU?r^Rp;;^QGSce;!J7o$FHeb1P^>c-|
z(
add a note
- User Contributed Notes
- PHP Manual
- 
-
-
-
)
-
-
åé÷éàåô
-
-
-
