<commit_before># Echo client program
import six
if six.PY3:
    from queue import LifoQueue
    from urllib.request import urlopen
else:
    from Queue import LifoQueue
    from urllib2 import urlopen
import socket
import threading
import time
import re
import json
from struct import unpack, unpack_from
import logging

SSDP_ADDR = "192.168.3.11"  # The remote host
SSDP_PORT = 1900    # The same port as used by the server
SSDP_MX = 1
SSDP_ST = "urn:schemas-sony-com:service:ScalarWebAPI:1"
SSDP_TIMEOUT = 10000  #msec
PACKET_BUFFER_SIZE = 1024

# Find all available cameras using uPNP
# Improved with code from 'https://github.com/storborg/sonypy' under MIT license.

class ControlPoint(object):
    def __init__(self):
        sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        sock.settimeout(0.1)
        # Set the socket to broadcast mode.
        sock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL , 2)
        self.__udp_socket = sock

    def discover(self, duration=1):
        msg = '\r\n'.join(["M-SEARCH * HTTP/1.1",
                           "HOST: 192.168.3.11:1900",<commit_msg>FIX: defined module logger instance<commit_after># Echo client program
import six
if six.PY3:
    from queue import LifoQueue
    from urllib.request import urlopen
else:
    from Queue import LifoQueue
    from urllib2 import urlopen
import socket
import threading
import time
import re
import json
from struct import unpack, unpack_from
import logging

SSDP_ADDR = "192.168.3.11"  # The remote host
SSDP_PORT = 1900    # The same port as used by the server
SSDP_MX = 1
SSDP_ST = "urn:schemas-sony-com:service:ScalarWebAPI:1"
SSDP_TIMEOUT = 10000  #msec
PACKET_BUFFER_SIZE = 1024

logger = logging.getLogger('pysony')


# Find all available cameras using uPNP
# Improved with code from 'https://github.com/storborg/sonypy' under MIT license.

class ControlPoint(object):
    def __init__(self):
        sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        sock.settimeout(0.1)
        # Set the socket to broadcast mode.
        sock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL , 2)
        self.__udp_socket = sock

    def discover(self, duration=1):
        msg = '\r\n'.join(["M-SEARCH * HTTP/1.1",
                           "HOST: 192.168.3.11:1900",
{'fraction_non_alphanumeric': 0.08845315904139434, 'fraction_numerical': 0.0392156862745098, 'mean_word_length': 3.291588785046729, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 2, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 4, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '1622125', 'n_tokens_mistral': 826, 'n_tokens_neox': 746, 'n_words': 219}