Changeset 77


Ignore:
Timestamp:
06/30/09 11:09:39 (15 years ago)
Author:
rissim
Message:
trigger: gui added, interface modified
Location:
trigger
Files:
18 added
1 deleted
11 edited

Legend:

Unmodified
Added
Removed

  • trigger/CommSocket.py

    r52 r77  
    2020import time
    2121BUFSIZ = 1024
    22 
    23 
     22class Sender(threading.Thread):
     23    """ Sends the messages """
     24    outputs = []
     25    oldmessage=''
     26     
     27    def run(self):
     28        running = 1
     29        while running:
     30            time.sleep(0.001)
     31            if(self.oldmessage!=GlobalVariables.ServerMessage):
     32                self.oldmessage=GlobalVariables.ServerMessage
     33             
     34                for o in self.outputs:
     35                    # o.send(msg)
     36                    #print "sending (glob): ",GlobalVariables.ServerMessage,"\n"
     37                    send(o,GlobalVariables.ServerMessage )
     38                if(GlobalVariables.UserInput[1:]=='exit' or GlobalVariables.UserInput[1:]=='EXIT'):
     39                    running=0
     40             
     41
     42
     43         
    2444class CommServer(threading.Thread):
    2545    """ Simple  server using select """
    26    
     46    oldmessage=''
     47    sender=Sender()
    2748    def __init__(self, port=3490, backlog=5):
    2849        self.clients = 0
    … …  
    3657        print 'SERVER: Listening to port',port,'...'
    3758        self.server.listen(backlog)
     59        self.sender.start()
    3860        # Trap keyboard interrupts
    3961        #signal.signal(signal.SIGINT, self.sighandler)
    4062        threading.Thread.__init__(self)
    4163    #def sighandler(self, signum, frame):
    42     #    if(GlobalVariables.UserInput=='exit' or GlobalVariables.UserInput=='EXIT'):
     64    #    if(GlobalVariables.UserInput[1:]=='exit' or GlobalVariables.UserInput[1:]=='EXIT'):
    4365    #        running=0
    4466    #        for o in self.outputs:
    … …  
    7193
    7294        while running:
    73             time.sleep(0.01)
    74             if(GlobalVariables.UserInput=='exit' or GlobalVariables.UserInput=='EXIT'):
     95            time.sleep(0.001)
     96            #if(self.oldmessage!=GlobalVariables.ServerMessage):
     97            #    self.oldmessage=GlobalVariables.ServerMessage
     98            #    for o in self.outputs:
     99            #        # o.send(msg)
     100            #        #print "sending (glob): ",GlobalVariables.ServerMessage,"\n"
     101            #        send(o,GlobalVariables.ServerMessage )
     102            if(GlobalVariables.UserInput[1:]=='exit' or GlobalVariables.UserInput[1:]=='EXIT'):
    75103                running=0
    76104           
    … …  
    87115                    # handle the server socket
    88116                    client, address = self.server.accept()
    89                     print 'SERVER: got connection %d from %s' % (client.fileno(), address)
     117                    #print 'SERVER: got connection %d from %s' % (client.fileno(), address)
     118                    GlobalVariables.ServerMessage = 'SERVER: got connection %d from %s' %( client.fileno(), address)+"\n"
    90119                    # Read the login name
    91                     cname = receive(client).split('NAME: ')[1]
    92                    
     120                    cname="TESTUSER"
     121                    #cname = receive(client).split('NAME: ')[1]
     122                    #print cname
    93123                    # Compute client name and send back
    94124                    self.clients += 1
    95                     send(client, 'FROM SERVER: CLIENT: ' + str(address[0]))
     125                    #send(client, 'FROM SERVER: CLIENT: ' + str(address[0]))
     126                    #send(client,"test");
     127                    #send(client,"test2");
     128                   
    96129                    inputs.append(client)
    97130
    … …  
    99132                    # Send joining information to other clients
    100133                    msg = '\nFROM SERVER: (Connected: New client (%d) from %s)' % (self.clients, self.getname(client))
    101                     for o in self.outputs:
    102                         # o.send(msg)
    103                         send(o, msg)
    104                    
     134                    GlobalVariables.ServerMessage=msg;
     135                    time.sleep(0.001)
     136                    #print "appending ", client
    105137                    self.outputs.append(client)
    106 
     138                    self.sender.outputs=self.outputs
    107139                #elif s == sys.stdin:
    108140                    # handle standard input
    … …  
    119151                    # handle all other sockets
    120152                    try:
    121                         # data = s.recv(BUFSIZ)
    122                         data = receive(s)
     153                        data = s.recv(BUFSIZ)
     154                       
     155                        #data = receive(s)
     156                        #print data
    123157                        if data:
     158                            GlobalVariables.counter += 1
     159                            GlobalVariables.counter %= 10
     160                            data = str(GlobalVariables.counter)+data
    124161                            # Send as new client's message...
    125162                            msg = 'SERVER: You sent: >> ' + data
     163                            msg+="\n"
    126164                            GlobalVariables.UserInput=data
    127                             print "SERVER: recv data: "+data
    128                             for o in self.outputs:
    129                                 send(o, msg)
    130                             if(GlobalVariables.UserInput=='exit' or GlobalVariables.UserInput=='EXIT'):
     165                            #print "SERVER: recv data: "+data
     166                            #print "msg is: ",msg
     167
     168                            #for o in self.outputs:
     169                                #msg="TSTSTS"
     170                             #   print "sending ",msg," to ",o
     171                               
     172                              #  send(o, msg)
     173                            if(GlobalVariables.UserInput[1:]=='exit' or GlobalVariables.UserInput[1:]=='EXIT'):
    131174                                running=0
    132175                                # Send data to all except ourselves
    133176                                                           
    134177                        else:
    135                             print 'SERVER: %d hung up' % s.fileno()
     178                            GlobalVariables.ServerMessage ='SERVER: %d hung up' % s.fileno()
    136179                            self.clients -= 1
    137180                            s.close()
    138181                            inputs.remove(s)
    139182                            self.outputs.remove(s)
    140 
     183                            self.sender.outputs=self.outputs
    141184                            # Send client leaving information to others
    142185                            msg = 'SERVER: \n(Hung up: Client from %s)' % self.getname(s)
    143                             for o in self.outputs:
     186                            #for o in self.outputs:
    144187                                # o.send(msg)
    145                                 send(o, msg)
     188                                # send(o, msg)
    146189                               
    147190                    except socket.error, e:
    … …  
    151194                       
    152195
    153         print 'SERVER: Shutting down server...'
     196        GlobalVariables.ServerMessage ='SERVER: Shutting down server...'
     197       
    154198        # Close existing client sockets
    155199        for o in self.outputs:

  • trigger/CommunicateWithVME.py

    r52 r77  
    1818    _VME.V560_Clear_Scales( module)
    1919    beginCounter=_VME. V560_Read_Counter( module,  channel)
    20     print "Evaluating rates (2 seconds)..."
     20    GlobalVariables.ServerMessage = "Evaluating rates (2 seconds)..."
    2121    time.sleep(2)
    2222    endCounter = _VME. V560_Read_Counter( module,  channel)
    … …  
    3333                   0,0,0,0,
    3434                   0,0,0,0]
    35     rates      =  [0,0,0,0,
     35    rates      =  ["rates",
     36                   0,0,0,0,
    3637                   0,0,0,0,
    3738                   0,0,0,0,
    … …  
    4041    for i in range(0,16):
    4142        beginCounter[i]=_VME. V560_Read_Counter( module,  i)
    42         print beginCounter[i]
    43     print "Evaluating rates..."
     43        #GlobalVariables.ServerMessage = str(beginCounter[i])
     44    #GlobalVariables.ServerMessage = "Evaluating rates..."
    4445    time.sleep(2)
    4546    for i in range(0,16):
    4647        endCounter[i] = _VME. V560_Read_Counter( module,  i)
    47         print endCounter[i]
    48         rates[i] =(endCounter[i]-beginCounter[i])/2000.
     48        #GlobalVariables.ServerMessage = str(endCounter[i])
     49        rates[i+1] =(endCounter[i]-beginCounter[i])/2000.
    4950    return rates
    50    
     51
     52class GimmeRates(threading.Thread):
     53    rates=["rates",
     54        0,0,0,0,
     55           0,0,0,0,
     56           0,0,0,0,
     57           0,0,0,0]
     58    module = 1
     59    def run(self):
     60        oldcommand=GlobalVariables.UserInput
     61        while(GlobalVariables.UserInput[1:]!="exit" and GlobalVariables.UserInput[1:] != "EXIT"):
     62            time.sleep(0.001)
     63            newrates = GetRates(self.module)
     64            self.rates=newrates
     65
    5166class ParseUserInput(threading.Thread):
     67    gimmeRates=GimmeRates()
    5268    def Parse(self,Command):
    53         print "PARSING: ",Command
     69        Command = Command[1:]
     70        #GlobalVariables.ServerMessage = "PARSING: " + Command
    5471        sCommand=Command.split()
    5572        error_code=0
    … …  
    5774        try:
    5875            VMEModule=sCommand[0]
    59             if(VMEModule == "help"): print "please use \'<V812|V560|Triggerboard> help\' "
     76            if(VMEModule == "help"):
     77                GlobalVariables.ServerMessage = "please use \'<V812|V560|Triggerboard> help\' "
     78                #GlobalVariables.ServerMessage="please use \'<V812|V560|Triggerboard> help\' "
    6079           
    6180            # now do the stuff for the V560:
    … …  
    6382                V560Command=sCommand[1]
    6483                if(V560Command=="help"):
    65                     print "available functions are: "
    66                     print "V560 GetRate <module#> <channel#>"
    67                     print "V560 GetRates <module#> "
     84                    GlobalVariables.ServerMessage = "available functions are: \n"
     85                    GlobalVariables.ServerMessage += "V560 GetRate <module#> <channel#>\n"
     86                    GlobalVariables.ServerMessage += "V560 GetRates <module#\n "
     87                    time.sleep(0.05)
    6888                   
    6989                if(V560Command=="GetRate"):
    70                     print "trying to get rate"
    71                     try:
    72                         module = sCommand[2]
    73                         channel= sCommand[3]
    74                         print GetRate(int(module),int(channel))
    75                     except:
    76                         print "Syntax Error (GetRate)"
     90                    #GlobalVariables.ServerMessage = "trying to get rate"
     91                    #time.sleep(0.05)
     92                   
     93
     94                    try:
     95                        module = int(sCommand[2])
     96                        channel= int(sCommand[3])
     97                        if(module!= self.gimmeRates.module):
     98                            self.gimmeRates.module=module
     99                            GlobalVariables.ServerMessage = "please wait... (5sec)"
     100                            time.sleep(5)
     101                       
     102                        GlobalVariables.ServerMessage = str(self.gimmeRates.rates[channel])
     103                        time.sleep(0.01)
     104                    except:
     105                        GlobalVariables.ServerMessage = "Syntax Error (GetRate)"
     106                        time.sleep(0.01)
    77107                    #GlobalVariables.Rates[int(channel)] = GetRates(int(module),int(channel))
    78108
    79                 if(V560Command=="GetRates"):
    80                     print "trying to get rates"
    81                     try:
    82                         module = sCommand[2]
    83 
    84                         print GetRates(int(module))
    85                     except:
    86                         print "Syntax Error (GetRates)"
     109                if(V560Command=="GetRates" or V560Command=="GR"):
     110                    GlobalVariables.ServerMessage = "trying to get rates"
     111                    time.sleep(0.01)
     112                    try:
     113                        module = int(sCommand[2])
     114                        if(module!= self.gimmeRates.module):
     115                            self.gimmeRates.module=module
     116                            GlobalVariables.ServerMessage = "please wait... (5sec)"
     117                            time.sleep(5)
     118                        #GlobalVariables.ServerMessage = "RATES:"
     119                        GlobalVariables.ServerMessage = str(self.gimmeRates.rates)
     120                        time.sleep(0.01)
     121                    except:
     122                        GlobalVariables.ServerMessage = "Syntax Error (GetRates)"
     123                        time.sleep(0.05)
    87124                    #GlobalVariables.Rates[int(channel)] = GetRates(int(module),int(channel))
    88125       
    … …  
    92129                V812Command=sCommand[1]
    93130                if(V812Command=="help"):
    94                     print "available functions are: "
    95                     print "V812 SetHexPat <module#[1-10]> <HexPattern[0x0000-0xFFFF>"
    96                     print "V812 SetThresh <module#[1-10]> <channel#[0-15]> <thresh[0-255]>"
    97                     print "V812 SetMajLevel <module#[1-10]> <MajLev[1-20]>"
    98                     print "V812 SetMajThresh <module#[1-10]> <MajThr[0-255]>"
    99                     print "V812 SetDeadTime <module#[1-10]> <Block [0-1]> <DeadTime[0-255]>"
    100 
     131                    GlobalVariables.ServerMessage  = "available functions are: \n"
     132                    GlobalVariables.ServerMessage += "V812 SetHexPat <module#[1-10]> <HexPattern[0x0000-0xFFFF>\n"
     133                    GlobalVariables.ServerMessage += "V812 SetThresh <module#[1-10]> <channel#[0-15]> <thresh[0-255]>\n"
     134                    GlobalVariables.ServerMessage += "V812 SetAllThresh <module#[1-10]>  <thresh[0-255]>\n"
     135                    GlobalVariables.ServerMessage += "V812 SetMajLevel <module#[1-10]> <MajLev[1-20]>\n"
     136                    GlobalVariables.ServerMessage += "V812 SetMajThresh <module#[1-10]> <MajThr[0-255]>\n"
     137                    GlobalVariables.ServerMessage += "V812 SetDeadTime <module#[1-10]> <Block [0-1]> <DeadTime[0-255]>\n"
     138                    time.sleep(0.05)
    101139                #set the hexpattern:
    102140                elif(V812Command=="SetHexPat"):
    103                     print "trying to set the hexpattern:"
     141                    GlobalVariables.ServerMessage = "trying to set the hexpattern:"
     142                    time.sleep(0.05)
    104143                    try:
    105144                        module = int(sCommand[2])
    106145                        hexpat = int(sCommand[3],16)
    107                         #hexpat="ddd"
    108                         print "setting module ",module," to hexpat: ",hex(hexpat)
     146                        #print hexpat
     147                        # hexpat="ddd"
     148                        GlobalVariables.ServerMessage = "setting module "+str(module)+" to hexpat: "+str(hex(hexpat))
     149                        time.sleep(0.05)
    109150                        try:
     151                            print "setting it now..."
    110152                            error_code=_VME.V812_Set_Pattern_Inhibit_Hex(module, hexpat)
    111                             print "success! "
     153                            GlobalVariables.ServerMessage = "success! "
     154                            time.sleep(0.05)
    112155                           
    113156                        except:
    114157                            VME_ErrorPrint(error_code)
    115                     except:
    116                         print "Syntax error (SetHexPat)"
    117 
    118 
     158                            print "FAILED"
     159                    except:
     160                        GlobalVariables.ServerMessage = "Syntax error (SetHexPat)"
     161
     162                       
     163                        time.sleep(0.05)
     164                elif(V812Command=="SetAllThresh"):
     165                    print "trying to set all the threshold:"
     166                    try:
     167                        module  = int(sCommand[2])
     168                        thresh  = int(sCommand[3])
     169                        GlobalVariables.ServerMessage="Setting all thresholds...\n"
     170                        for channel in range(0,16):
     171                            GlobalVariables.ServerMessage += "setting threshold of channel: "+str(channel)+ " in module "+str(module)+" to: "+str(thresh)+"\n"
     172                            GlobalVariables.ServerMessage += "success: "+str(_VME.V812_Set_Threshold(module, channel,  thresh))+"\n"
     173                        time.sleep(0.05)
     174                           
     175                           
     176                    except:
     177                        print "Syntax error (SetAllThresh) "
    119178                elif(V812Command=="SetThresh"):
    120                     print "trying to set the threshold:"
     179                    GlobalVariables.ServerMessage = "trying to set the threshold:"
     180                    time.sleep(0.05)
    121181                    try:
    122182                        module  = int(sCommand[2])
    123183                        channel = int(sCommand[3])
    124184                        thresh  = int(sCommand[4])
    125                         print "setting threshold of channel: ",channel, " in module ",module," to: ",thresh
    126                         print "success: ",_VME.V812_Set_Threshold(module, channel,  thresh)
    127                     except:
    128                         print "Syntax error (SetThresh) "
    129                        
     185                        GlobalVariables.ServerMessage = "setting threshold of channel: "+str(channel)+ " in module "+str(module)+" to: "+str(thresh)
     186                        GlobalVariables.ServerMessage += "success: "+str(_VME.V812_Set_Threshold(module, channel,  thresh))
     187                        time.sleep(0.05)
     188                    except:
     189                        GlobalVariables.ServerMessage = "Syntax error (SetThresh) "
     190                        time.sleep(0.05)
    130191                elif(V812Command=="SetMajLevel"):
    131                     print "trying to set the majority level:"
     192                    GlobalVariables.ServerMessage = "trying to set the majority level:"
     193                    time.sleep(0.05)
    132194                    try:
    133195                        module  = int(sCommand[2])
    134196                        level   = int(sCommand[3])
    135                         print "setting maj. level of module ",module," to: ",level
    136                         print "success: ",_VME.V812_Set_Majority_Level(module,level)
    137                     except:
    138                         print "Syntax error (SetMajLevel)"
     197                        GlobalVariables.ServerMessage = "setting maj. level of module "+str(module)+" to: "+str(level)
     198                        GlobalVariables.ServerMessage += "success: "+str(_VME.V812_Set_Majority_Level(module,level))
     199                        time.sleep(0.05)
     200                    except:
     201                        GlobalVariables.ServerMessage = "Syntax error (SetMajLevel)"
     202                        time.sleep(0.05)
    139203
    140204                elif(V812Command=="SetMajThresh"):
    141                     print "trying to set the majority threshold:"
     205                    GlobalVariables.ServerMessage = "trying to set the majority threshold:"
     206                    time.sleep(0.05)
    142207                    try:
    143208                        module  = int(sCommand[2])
    144209                        thresh  = int(sCommand[3])
    145                         print "setting maj. level of module ",module," to: ",thresh
    146                         print "success: ",_VME.V812_Set_Majority_Threshold(module,  thresh)
    147                     except:
    148                         print "Syntax error (SetMajThresh)"
     210                        GlobalVariables.ServerMessage = "setting maj. level of module "+str(module)+" to: "+str(thresh)
     211                        GlobalVariables.ServerMessage += "success: "+str(_VME.V812_Set_Majority_Threshold(module,  thresh))
     212                        time.sleep(0.05)
     213                    except:
     214                        GlobalVariables.ServerMessage = "Syntax error (SetMajThresh)"
     215                        time.sleep(0.05)
    149216
    150217                elif(V812Command=="SetDeadTime"):
    151                     print "trying to set the majority threshold:"
     218                    GlobalVariables.ServerMessage = "trying to set the majority threshold:"
     219                    time.sleep(0.05)
    152220                    try:
    153221                        module  = int(sCommand[2])
    154222                        block  = int(sCommand[3])
    155223                        deadtime= int(sCommand[4])
    156                         print "setting deadtime of module ",module," block: ",block, " to: ",deadtime
    157                         print "success: ",_VME.V812_Set_Dead_Time(module, block, deadtime);
    158                     except:
    159                         print "Syntax error (SetMajThresh)"
     224                        GlobalVariables.ServerMessage = "setting deadtime of module "+str(module)+" block: "+str(block)+ " to: "+str(deadtime)
     225                        GlobalVariables.ServerMessage += "success: "+str(_VME.V812_Set_Dead_Time(module, block, deadtime))
     226                        time.sleep(0.05)
     227                    except:
     228                        GlobalVariables.ServerMessage = "Syntax error (SetMajThresh)"
     229                        time.sleep(0.05)
    160230
    161231                else:
    162                     print "Syntax Error (V812)"
     232                    GlobalVariables.ServerMessage = "Syntax Error (V812)"
     233                    time.sleep(0.05)
    163234                       
    164235        except:
    165             print "syntax error"
     236            GlobalVariables.ServerMessage = "syntax error"
     237            time.sleep(0.05)
    166238        #_VME.V812_Set_Threshold(1, 0,  255)
    167239   
    … …  
    169241        threading.Thread.__init__(self)
    170242    def run(self):
     243        self.gimmeRates.start()
    171244        oldcommand=GlobalVariables.UserInput
    172         while(GlobalVariables.UserInput!="exit" and GlobalVariables.UserInput != "EXIT"):
     245        while(GlobalVariables.UserInput[1:]!="exit" and GlobalVariables.UserInput[1:] != "EXIT"):
    173246            CommandToParse=GlobalVariables.UserInput
    174247            if(oldcommand!=CommandToParse):
    … …  
    179252
    180253           
    181         print "EXITING PARSER...press <enter> to exit"
     254        GlobalVariables.ServerMessage = "EXITING PARSER...press <enter> to exit"
     255        time.sleep(0.05)
    182256           

  • trigger/GlobalVariables.py

    r52 r77  
    77UserInput =''
    88Rates = [16]
     9ServerMessage=''
     10Flag=1
     11counter = 0

  • trigger/Main.py

    r52 r77  
    1919import GlobalVariables
    2020import CommunicateWithVME
     21import ListenToArduino
    2122import time
    2223#connecting to the crates:
    … …  
    4748parseUserInput.start()
    4849
    49 while(GlobalVariables.UserInput!="exit" and GlobalVariables.UserInput != "EXIT"):
     50print "listening to Arduino..."
     51listenToArduino = ListenToArduino.ListenToArduino()
     52listenToArduino.start()
     53while(GlobalVariables.UserInput[1:]!="exit" and GlobalVariables.UserInput[1:] != "EXIT"):
    5054    time.sleep(0.1)
    5155    #do something

  • trigger/PythonShell.py

    r52 r77  
    1212
    1313    def run (self):
    14         #outputShell= OutputShell()
    15         #OutputShell.start(outputShell)
     14        outputShell= OutputShell()
     15        OutputShell.start(outputShell)
    1616       
    17         while(GlobalVariables.UserInput!="exit" and GlobalVariables.UserInput != "EXIT"):
     17        while(GlobalVariables.UserInput[1:]!="exit" and GlobalVariables.UserInput[1:] != "EXIT"):
    1818            dummy=raw_input("SHELL>>> ")
    19             if(GlobalVariables.UserInput!="exit" and GlobalVariables.UserInput != "EXIT"):
    20                 GlobalVariables.UserInput = dummy
     19            if(GlobalVariables.UserInput[1:]!="exit" and GlobalVariables.UserInput[1:] != "EXIT"):
     20                GlobalVariables.counter +=1
     21                GlobalVariables.counter%=10
     22                GlobalVariables.UserInput = str(GlobalVariables.counter)+dummy
     23
    2124            else:
    2225                break
    … …  
    3134    def run (self):
    3235        while(GlobalVariables.UserInput!="exit" and GlobalVariables.UserInput != "EXIT"):
    33             if(GlobalVariables.UserInput!=self.lastvar):
    34                 print "\n(SHELL) You entered:",GlobalVariables.UserInput
     36            time.sleep(0.001)
     37            if(GlobalVariables.ServerMessage!=self.lastvar):
     38                #print "\n(SHELL) You entered:",GlobalVariables.ServerMessage
    3539                #sys.stdout.write( "SHELL2 >>>")
    36                 self.lastvar=GlobalVariables.UserInput
     40                print GlobalVariables.ServerMessage
     41                self.lastvar=GlobalVariables.ServerMessage
     42             
    3743        print "EXITING OUTPUTSHELL...press <enter> to exit "
    3844        #sys.exit(0)

  • trigger/TestClient3.py

    r52 r77  
    3737            send(self.sock,'NAME: ' + self.name)
    3838            data = receive(self.sock)
     39            print data
    3940            # Contains client address, set it
    4041            addr = data.split('CLIENT: ')[1]

  • trigger/VME.i

    r52 r77  
    2828int V812_Set_Threshold(short module, short channel, short threshold);
    2929int V812_Set_Pattern_Inhibit(short module, char channel[16]);
    30 int V812_Set_Pattern_Inhibit_Hex(short module, short pattern);
     30int V812_Set_Pattern_Inhibit_Hex(short module, int pattern);
    3131int V812_Set_Output_Width(short module, char channel_block, short width);
    3232int V812_Set_Dead_Time(short module, short channel_block, short dead_time);

  • trigger/VME_wrap.c

    r52 r77  
    991991    PyObject *resultobj;
    992992    short arg1 ;
    993     short arg2 ;
    994     int result;
    995    
    996     if(!PyArg_ParseTuple(args,(char *)"hh:V812_Set_Pattern_Inhibit_Hex",&arg1,&arg2)) goto fail;
     993    int arg2 ;
     994    int result;
     995   
     996    if(!PyArg_ParseTuple(args,(char *)"hi:V812_Set_Pattern_Inhibit_Hex",&arg1,&arg2)) goto fail;
    997997    result = (int)V812_Set_Pattern_Inhibit_Hex(arg1,arg2);
    998998   

  • trigger/communication.py

    r52 r77  
    99unmarshall = cPickle.loads
    1010
    11 def send(channel, *args):
    12     buf = marshall(args)
    13     value = socket.htonl(len(buf))
    14     size = struct.pack("L",value)
    15     channel.send(size)
     11def send(channel, args):
     12    #print "will send: ", args
     13    args+="\n"
     14    buf = args #marshall(args)
     15    #value = socket.htonl(len(buf))
     16    value = str(len(buf))
     17    #size = struct.pack("i",value)
     18    print "length: ",len(buf)
     19    #print "SIZE: ",repr(size)
     20    #channel.send(value)
     21    buf+="\0"
    1622    channel.send(buf)
    17 
     23    #print 'sending: ',buf
     24    #print 'sent'
    1825def receive(channel):
    1926
    2027    size = struct.calcsize("L")
    2128    size = channel.recv(size)
     29    print "rec size: ",size
    2230    try:
    23         size = socket.ntohl(struct.unpack("L", size)[0])
     31        size = socket.ntohl(struct.unpack("i", size)[0])
     32        #print "unpacked: ",size
    2433    except struct.error, e:
    2534        return ''

  • trigger/v812.c

    r52 r77  
    162162        return 0;
    163163}
    164 int V812_Set_Pattern_Inhibit_Hex(short module, short pattern)
     164int V812_Set_Pattern_Inhibit_Hex(short module, int pattern)
    165165{
    166166        //return values

  • trigger/v812.h

    r52 r77  
    6666int V812_Test_Pulse(short module);
    6767int V812_Print_Info(void);
    68 int V812_Set_Pattern_Inhibit_Hex(short module, short pattern);
     68int V812_Set_Pattern_Inhibit_Hex(short module, int pattern);
    6969VME_ErrorCode_t V812_Close(void);
    7070
Note: See TracChangeset for help on using the changeset viewer.