Class: OrigenLink::Server::Sequencer

Inherits:
Object
  • Object
show all
Defined in:
lib/origen_link/server/sequencer.rb

Overview

OrigenLink::Server::Sequencer Class

This class processes messages targeted for
pin sequencer interface (vector pattern
execution).

Supported messages:
  pin_assign (create pin mapping)
    ex: "pin_assign:tck,3,extal,23,tdo,5"

  pin_patternorder (define vector pin order)
    ex: "pin_patternorder:tdo,extal,tck"

  pin_cycle (execute vector data)
    ex: "pin_cycle:H11"

  pin_clear (clear all setup information)
    ex: "pin_clear:"

  pin_format (setup a pin with return format)
    first argument is the timeset
    ex: "pin_format:1,tck,rl"

  pin_timing (define when pin events happen)
    timing is stored in a timeset hash
    first argument is the timeset key
    ex: "pin_timing:1,tdi,0,tdo,1,tms,0

  version (check version of app server is
    running)
    ex: "version:"
    response ex: "P:0.2.0.pre0"

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Sequencer

initialize method

Create empty pinmap, pattern pin index
and pattern order instance variables


104
105
106
107
108
109
110
 
# File 'lib/origen_link/server/sequencer.rb', line 104

def initialize
  @pinmap = Hash.new(-1)
  @patternpinindex = Hash.new(-1)
  @patternorder = []
  @cycletiming = Hash.new(-1)
  @version = ''
end

Instance Attribute Details

#cycletiming ⇒ Object (readonly)

hash holding programmed time set information



95
96
97
 
# File 'lib/origen_link/server/sequencer.rb', line 95

def cycletiming
  @cycletiming
end

#patternorder ⇒ Object (readonly)

array of pin names in pattern order



93
94
95
 
# File 'lib/origen_link/server/sequencer.rb', line 93

def patternorder
  @patternorder
end

#patternpinindex ⇒ Object (readonly)

hash holding pin pattern order ('name' => index)



97
98
99
 
# File 'lib/origen_link/server/sequencer.rb', line 97

def patternpinindex
  @patternpinindex
end

#pinmap ⇒ Object (readonly)

hash holding the pinmap ('name' => pin object)



91
92
93
 
# File 'lib/origen_link/server/sequencer.rb', line 91

def pinmap
  @pinmap
end

#version ⇒ Object

code version of the server (populated by start_link_server)



89
90
91
 
# File 'lib/origen_link/server/sequencer.rb', line 89

def version
  @version
end

Instance Method Details

#new_timeset(tset) ⇒ Object

new_timeset(tset)

creates a new empty timeset hash

timing format:
  ['events'] = [0, 5, 10, 35]
  ['drive_event_data'] = {
        0: ['data']
       10: ['data','0']
       35: ['0']
      }
  ['drive_event_pins'] = {
        0: [[pin_obj1, pin_obj2]]
       10: [[pin1,pin2], [pin3]]
        etc.
      }


255
256
257
258
259
260
261
262
 
# File 'lib/origen_link/server/sequencer.rb', line 255

def new_timeset(tset)
  @cycletiming[tset] = {}
  @cycletiming[tset]['events'] = []
  @cycletiming[tset]['drive_event_data'] = {}
  @cycletiming[tset]['drive_event_pins'] = {}
  @cycletiming[tset]['compare_event_data'] = {}
  @cycletiming[tset]['compare_event_pins'] = {}
end

#pin_assign(args) ⇒ Object

pin_assign method

arguments: <args> from the message request
  see "processmessage" method
returns: "P:" or error message

This method creates a pin instance for each
pin in the pin map and builds the pinmap
hash.  Before the pinmap is created, any
information from a previous pattern run is
cleared.


160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
 
# File 'lib/origen_link/server/sequencer.rb', line 160

def pin_assign(args)
  pin_clear
  success = true
  fail_message = ''
  argarr = args.split(',')
  0.step(argarr.length - 2, 2) do |index|
    @pinmap[argarr[index]] = Pin.new(argarr[index + 1])
    unless @pinmap[argarr[index]].gpio_valid
      success = false
      fail_message = fail_message + 'pin ' + argarr[index] + ' gpio' + argarr[index + 1] + ' is invalid'
    end
  end
  if success
    'P:'
  else
    'F:' + fail_message
  end
end

#pin_clear ⇒ Object

pin_clear method

This method clears all storage objects.  It
is called by the "pin_assign" method


459
460
461
462
463
464
465
466
 
# File 'lib/origen_link/server/sequencer.rb', line 459

def pin_clear
  @pinmap.each { |pin_name, pin| pin.destroy }
  @pinmap.clear
  @patternpinindex.clear
  @patternorder.delete_if { true }
  @cycletiming.clear
  'P:'
end

#pin_cycle(args) ⇒ Object

pin_cycle method

arguments: <args> from the message request
returns: "P:" or "F:" followed by results

This method executes one cycle of pin vector
data.  The vector data is decomposed and
sequenced.  Each pin object and pin data
is passed to the "process_pindata" method
for decoding and execution


394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
 
# File 'lib/origen_link/server/sequencer.rb', line 394

def pin_cycle(args)
  # set default repeats and timeset
  repeat_count = 1
  tset = 0
  if args =~ /,/
    parsedargs = args.split(',')
    args = parsedargs.pop
    parsedargs.each do |arg|
      if arg =~ /repeat/
        repeat_count = arg.sub(/repeat/, '').to_i
      elsif arg =~ /tset/
        tset = arg.sub(/tset/, '').to_i
      end
    end
  end

  message = ''
  # load pattern cycle data into pin objects
  @pinmap.each_value { |p| p.load_pattern_data(args) }
  cycle_failure = false

  0.upto(repeat_count - 1) do |count|
    # process timing events
    @cycletiming[tset]['events'].each do |event|
      # process drive events
      if @cycletiming[tset]['drive_event_pins'].key?(event)
        @cycletiming[tset]['drive_event_pins'][event].each_index do |i|
          @cycletiming[tset]['drive_event_pins'][event][i].each do |p|
            p.process_event(:drive, @cycletiming[tset]['drive_event_data'][event][i])
          end
        end
      end

      # process compare events
      if @cycletiming[tset]['compare_event_pins'].key?(event)
        @cycletiming[tset]['compare_event_pins'][event].each_index do |i|
          @cycletiming[tset]['compare_event_pins'][event][i].each do |p|
            p.process_event(:compare, @cycletiming[tset]['compare_event_data'][event][i])
          end
        end
      end
    end # event

    # build response message
    message += ' ' unless count == 0

    @patternorder.each do |p|
      message += @pinmap[p].response
      cycle_failure = true if @pinmap[p].cycle_failure
    end
  end # count
  if cycle_failure
    rtnmsg = 'F:' + message + '    Expected:' + args
  else
    rtnmsg = 'P:' + message
  end
  rtnmsg
end

#pin_format(args) ⇒ Object

pin_format method

arguments: <args> from the message request
  Should be <timeset>,<pin>,rl or rh
  multi-clock not currently supported


271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
 
# File 'lib/origen_link/server/sequencer.rb', line 271

def pin_format(args)
  argarr = args.split(',')
  tset_key = argarr.delete_at(0).to_i
  new_timeset(tset_key) unless @cycletiming.key?(tset_key)
  @cycletiming[tset_key]['events'] += [1, 3]
  @cycletiming[tset_key]['events'].sort!
  [1, 3].each do |event|
    @cycletiming[tset_key]['drive_event_pins'][event] = [[]]
  end
  @cycletiming[tset_key]['compare_event_data'][1] = ['data']
  0.step(argarr.length - 2, 2) do |index|
    drive_type = argarr[index + 1]
    pin_name = argarr[index]
    @cycletiming[tset_key]['drive_event_data'][1] = ['data']
    @cycletiming[tset_key]['drive_event_pins'][1][0] << @pinmap[pin_name]
    @cycletiming[tset_key]['drive_event_pins'][3][0] << @pinmap[pin_name]
    @cycletiming[tset_key]['compare_event_pins'][1] = [[@pinmap[pin_name]]]
    if drive_type == 'rl'
      @cycletiming[tset_key]['drive_event_data'][3] = ['0']
    else
      @cycletiming[tset_key]['drive_event_data'][3] = ['1']
    end
  end
  'P:'
end

#pin_patternorder(args) ⇒ Object

pin_patternorder method

arguments: <args> from the message request
returns: "P:" or error message

This method is used to define the order
for pin vector data.


362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
 
# File 'lib/origen_link/server/sequencer.rb', line 362

def pin_patternorder(args)
  argarr = args.split(',')
  index = 0
  new_timeset(0)
  argarr.each do |pin|
    @patternorder << pin
    @pinmap[pin].pattern_index = index	# pattern index stored in pin object now
    @patternpinindex[pin] = index		# to be removed

    # define default timing
    @cycletiming[0]['events'] << index
    @cycletiming[0]['drive_event_data'][index] = ['data']
    @cycletiming[0]['drive_event_pins'][index] = [[@pinmap[pin]]]
    @cycletiming[0]['compare_event_data'][index] = ['data']
    @cycletiming[0]['compare_event_pins'][index] = [[@pinmap[pin]]]
    index += 1
  end
  'P:'
end

#pin_timing(args) ⇒ Object

pin_timing method

arguments: <args> from the message request
  Should be '1,pin,-1,pin2,0,pin3,1'
  First integer is timeset number
  If argument is '', default timing is created
  Default timeset number is 0, this is used
  if no timeset is explicitly defined

  cycle arg:  0   1   2
  waveform : ___/***\___

returns "P:" or error message

This method sets up a time set.  All retrun
format pins are driven between 0 and 1 and
return between 1 and 2.  Non-return pins are
acted upon during the 0, 1 or 2 time period.


317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
 
# File 'lib/origen_link/server/sequencer.rb', line 317

def pin_timing(args)
  argarr = args.split(',')
  tset_key = argarr.delete_at(0).to_i
  new_timeset(tset_key) unless @cycletiming.key?(tset_key)
  [0, 2, 4].each do |event|
    @cycletiming[tset_key]['drive_event_pins'][event] = [[]]
    @cycletiming[tset_key]['compare_event_pins'][event] = [[]]
  end

  # process the information received
  0.step(argarr.length - 2, 2) do |index|
    event = argarr[index + 1].to_i
    # reorder event number to allow rising/falling edges
    event *= 2
    pin_name = argarr[index]
    @cycletiming[tset_key]['events'] << event
    @cycletiming[tset_key]['drive_event_data'][event] = ['data']
    @cycletiming[tset_key]['drive_event_pins'][event][0] << @pinmap[pin_name]
    @cycletiming[tset_key]['compare_event_data'][event] = ['data']
    @cycletiming[tset_key]['compare_event_pins'][event][0] << @pinmap[pin_name]
  end

  # remove events with no associated pins
  @cycletiming[tset_key]['events'].uniq!
  @cycletiming[tset_key]['events'].sort!
  [0, 2, 4].each do |event|
    if @cycletiming[tset_key]['drive_event_pins'][event][0].size == 0
      @cycletiming[tset_key]['events'] -= [event]
      @cycletiming[tset_key]['drive_event_data'].delete(event)
      @cycletiming[tset_key]['drive_event_pins'].delete(event)
      @cycletiming[tset_key]['compare_event_data'].delete(event)
      @cycletiming[tset_key]['compare_event_pins'].delete(event)
    end
  end
  'P:'
end

#pin_timingv2(args) ⇒ Object

pin_timingv2 method

arguments: <args> from the message request
  Should be '1,drive,5,pin,10,pin2,|compare,0,pin3'
  First integer is timeset number

returns "P:" or error message

This method sets up a time set.  Any arbitrary
waveform can be generated


191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
 
# File 'lib/origen_link/server/sequencer.rb', line 191

def pin_timingv2(args)
  # get the tset number
  argarr = args.split(',')
  tset_key = argarr.delete_at(0).to_i
  new_timeset(tset_key)
  args = argarr.join(',')

  invalid_pins = []

  # process and load the timeset
  waves = args.split('|')
  waves.each do |w|
    argarr = w.split(',')
    wave_type = argarr.delete_at(0)
    event_data_key = wave_type + '_event_data'
    event_pins_key = wave_type + '_event_pins'
    w = argarr.join(',')
    events = w.split(';')
    events.each do |e|
      argarr = e.split(',')
      event_key = argarr.delete_at(0).to_f
      @cycletiming[tset_key]['events'] << event_key
      @cycletiming[tset_key][event_data_key][event_key] = [] unless @cycletiming[tset_key][event_data_key].key?(event_key)
      @cycletiming[tset_key][event_data_key][event_key] << argarr.delete_at(0)
      # now load the pins for this event
      @cycletiming[tset_key][event_pins_key][event_key] = [] unless @cycletiming[tset_key][event_pins_key].key?(event_key)
      @cycletiming[tset_key][event_pins_key][event_key] << []
      argarr.each do |pin|
        if @pinmap.key?(pin)
          @cycletiming[tset_key][event_pins_key][event_key].last << @pinmap[pin]
        else
          invalid_pins << pin
        end
      end # of argarr.each
    end # of events.each
  end # of waves.each
  @cycletiming[tset_key]['events'].uniq!
  @cycletiming[tset_key]['events'].sort!

  # return result
  if invalid_pins.size > 0
    'F:Invalid pins (not in pinmap): ' + invalid_pins.join(', ')
  else
    'P:'
  end
end

#processmessage(message) ⇒ Object

processmessage method

arguments: message
  message format is <group>_<command>:<args>
returns: message response

This method splits a message into it's
command and arguments and passes this
information to the method that performs
the requested command


123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
 
# File 'lib/origen_link/server/sequencer.rb', line 123

def processmessage(message)
  command = message.split(':')

  case command[0]
  when 'pin_assign'
    pin_assign(command[1])
  when 'pin_patternorder'
    pin_patternorder(command[1])
  when 'pin_cycle'
    pin_cycle(command[1])
  when 'pin_clear'
    pin_clear
  when 'pin_format'
    pin_format(command[1])
  when 'pin_timing'
    pin_timing(command[1])
  when 'pin_timingv2'
    pin_timingv2(command[1])
  when 'version'
    "P:#{@version}"
  else
    'Error Invalid command: ' + command[0].to_s
  end
end