全局变量的问题

figofifa

下面的多进程能够执行了，但提示NameError: global name 'connection' is not defined，是什么原因，我已经声明全局变量了。
def send_proc():
    global connection
    print '111111111111111111'
    activeTestSequence = 0
    while True:
        print '22222222222222222'
        print '【CMPP服务端】:发送链路检测消息'.decode('utf-8')
        activeTestCommandLength = 13
        activeTestCommand = 8
        activeTestSequence = activeTestSequence + 1

        MessageHeader = copy.deepcopy(MessageHeader_CMPP)
        MessageHeader[0].append(activeTestCommandLength)
        MessageHeader[1].append(activeTestCommand)
        MessageHeader[2].append(activeTestSequence)
        connection.send(packBody(MessageHeader))
        print '33333333333333333333333333333333'


def recv_proc():
    global connection
    print '4444444444444444444444444'
    while True:
        print '5555555555555555555555'
        total_length_rsp = connection.recv(4)
        print '66666666666666666666666666666666'
        (total_length_rsp,) = struct.unpack('>i', total_length_rsp)
        print total_length_rsp, '-----------------------'
        data_rsp = ''
        data_rsp = connection.recv(total_length_rsp - 4)
        thread_Command_id = decomplieCommandId(data_rsp)
        #如果是链路检测消息，需要解包sequence，放到链路检测队列中去
        if thread_Command_id == 2147483656:
            print '【CMPP服务端端】:收到链路检测消息'.decode('utf-8')


def fork_proc():
    print 'aaaaaaaaaaaaaaaaa'
    reader = multiprocessing.Process(target = send_proc)
    reader.start()
    time.sleep(5)
    print 'bbbbbbbbbbbbbbbbbb'
    recever = multiprocessing.Process(target = recv_proc)
    recever.start()



commandLength = 12 + 1 + 16 + 1
command_id = 2147483649
sequence_number = 2

status = '0'
#加密
m = hashlib.md5()
m.update(status + '\0' * 15)
authenticatorismg = m.digest()
#组包
struct.pack('16s', authenticatorismg)
version = 32

MessageHeader = copy.deepcopy(MessageHeader_CMPP)
CMPP_CONNECT = copy.deepcopy(CMPP_CONNECT_CMPP)

MessageHeader[0].append(commandLength)
MessageHeader[1].append(command_id)
MessageHeader[2].append(sequence_number)
CMPP_CONNECT_RESP_CMPP[0].append(int(status))
CMPP_CONNECT_RESP_CMPP[1].append(authenticatorismg)
CMPP_CONNECT_RESP_CMPP[2].append(version)
CMPP_CONNECT_RESP_CMPP[2].append(version)

if __name__=='__main__':

    myHost = 'xx.xx.xx.xxx'
    myPort = 8013
    sock1 = socket(AF_INET, SOCK_STREAM)
    sock1.bind((myHost, myPort))
    sock1.listen(1)


#while True:
#    print 'hhhhhhhhhhhh--------------------'
    connection, address = sock1.accept()
#    sock1.setblocking(0)
    print 'zzzzzzzzzzzzzzzz--------------------'
    print 'Server connected by', address
    while True:
        print 'hhhhhhhhhafasdfasdf'
        total_length_rsp = connection.recv(4)
        print 'hhhhhhhhhvvvvvvvvvvvvvvvvvvvv'
        (total_length_rsp,) = struct.unpack('>i', total_length_rsp)
        print total_length_rsp
        data_rsp = ''
        data_rsp = connection.recv(total_length_rsp - 4)
        thread_Command_id = decomplieCommandId(data_rsp)
        print thread_Command_id
        #如果是登陆请求连接
        if thread_Command_id == 1:
            connection.send(packBody(MessageHeader + CMPP_CONNECT_RESP_CMPP))
            print "okkgggggggg"
            #break
            fork_proc()
            time.sleep(11)
        #connection.close()

q1208c

要给个值吧 ? 哪怕是 None 也行.

openspace

只声明没有定义？

Jpython

你只是声明个全局变量，没赋值。