Search code examples
pythonsocketsdeque

Empty string is appended to the deque


I have a deque on a host. Each String that is received through TCP socket is appended to this deque. When each data is received, I print the data and the deque. Here is the code:

from __future__ import print_function
import commands
import socket
import select
from collections import deque

host = commands.getoutput("hostname -I")
port = 5005
backlog = 5
BUFSIZE = 4096
BUFFER_SIZE = 1024
q = deque()

def read_tcp(s):
    conn, addr = s.accept()
    print('Connected with', *addr)
    while 1:
        data = conn.recv(BUFFER_SIZE)
        if not data: break
        print("received data:", data)
        conn.send(data)  # echo
    if (data == 'sample.jpg'):
        print("start processing")
        #processP(q)
    else:
        print("appended")
        q.append(data)
        print(q)
    conn.close()

def read_udp(s):
    data,addr = s.recvfrom(1024)
    print("received message:", data)

def run():
    # create tcp socket
    tcp = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    tcp.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    try:
        tcp.bind((host,port))
    except socket.error as err:
        print('Bind failed', err)
        return
    tcp.listen(1)
    # create udp socket
    udp = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) # UDP
    udp.bind((host,port))
    print('***Socket now listening at***:', host, port)
    input = [tcp,udp]
    try:
        while True:
            #print("select.select")
            inputready,outputready,exceptready = select.select(input,[],[], 0.1)
            for s in inputready:
                if s == tcp:
                    read_tcp(s)
                elif s == udp:
                    read_udp(s)
                else:
                    print("unknown socket:", s)
    # Hit Break / Ctrl-C to exit
    except KeyboardInterrupt:
        print('\nClosing')
        raise
    tcp.close()
    udp.close()

if __name__ == '__main__':
    run()

The problem is that when I print the received data and deque in these lines print("received data:", data) and print(q), the received data is print correctly, but the deque content is printed like these in each step:

deque([''])
deque(['',''])
deque(['','',''])

What's wrong? Here is the sender code which doesn't seem to have any problem:

from __future__ import print_function
import socket
from struct import pack
import commands
import select

#HOST = '10.0.0.2'
PORT = 5005
BUFSIZE = 4096

def tcp_send(s, ip):
    TCP_IP = ip
    BUFFER_SIZE = 1024
    MESSAGE = s
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.connect((TCP_IP, PORT))
    s.send(MESSAGE)
    data = s.recv(BUFFER_SIZE)
    s.close()
    print ("sent data:", data)

fnames = [
    '90.jpg','91.jpg','92.jpg','93.jpg','94.jpg','95.jpg','96.jpg','97.jpg','98.jpg','99.jpg','100.jpg','sample.jpg'
    ]

def main():
    for fname1 in fnames:
        tcp_send(fname1,'10.0.0.2')

if __name__ == '__main__':
    main()

Solution

  • replace your read_tcp(s) with

    def read_tcp(s):
    conn, addr = s.accept()
    print('Connected with', *addr)
    while 1:
        data = conn.recv(BUFFER_SIZE)
        if not data: break
        print("received data:", data)
        conn.send(data)  # echo
        print(data)
        if (data == 'sample.jpg'):
            print("start processing")
            #processP(q)
        else:
            print("appended", data)
            q.append(data)
            print(q)
    conn.close()
    

    you are trying to access data outside while that's why it is empty