Class: Jp::JobPoolInstrumented::Processor

Inherits:
Jp::JobPool::Processor show all
Includes:
Thrift::Processor
Defined in:
lib/rb/jp/gen-rb/job_pool_instrumented.rb

Instance Method Summary collapse

Methods inherited from Jp::JobPool::Processor

#process_acquire, #process_add, #process_purge

Methods inherited from FacebookService::Processor

#process_aliveSince, #process_getCounter, #process_getCounters, #process_getCpuProfile, #process_getName, #process_getOption, #process_getOptions, #process_getStatus, #process_getStatusDetails, #process_getVersion, #process_reinitialize, #process_setOption, #process_shutdown

Instance Method Details

#process_acquire_count(seqid, iprot, oprot) ⇒ Object 



140
141
142
143
144
145
146
147
148
149
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 140

def process_acquire_count(seqid, iprot, oprot)
  args = read_args(iprot, Acquire_count_args)
  result = Acquire_count_result.new()
  begin
    result.success = @handler.acquire_count(args.pool_name)
  rescue Jp::NoSuchPool => nsp
    result.nsp = nsp
  end
  write_result(result, oprot, 'acquire_count', seqid)
end

#process_add_count(seqid, iprot, oprot) ⇒ Object 



129
130
131
132
133
134
135
136
137
138
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 129

def process_add_count(seqid, iprot, oprot)
  args = read_args(iprot, Add_count_args)
  result = Add_count_result.new()
  begin
    result.success = @handler.add_count(args.pool_name)
  rescue Jp::NoSuchPool => nsp
    result.nsp = nsp
  end
  write_result(result, oprot, 'add_count', seqid)
end

#process_empty_count(seqid, iprot, oprot) ⇒ Object 



151
152
153
154
155
156
157
158
159
160
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 151

def process_empty_count(seqid, iprot, oprot)
  args = read_args(iprot, Empty_count_args)
  result = Empty_count_result.new()
  begin
    result.success = @handler.empty_count(args.pool_name)
  rescue Jp::NoSuchPool => nsp
    result.nsp = nsp
  end
  write_result(result, oprot, 'empty_count', seqid)
end

#process_pools(seqid, iprot, oprot) ⇒ Object 



115
116
117
118
119
120
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 115

def process_pools(seqid, iprot, oprot)
  args = read_args(iprot, Pools_args)
  result = Pools_result.new()
  result.success = @handler.pools()
  write_result(result, oprot, 'pools', seqid)
end

#process_purge_count(seqid, iprot, oprot) ⇒ Object 



162
163
164
165
166
167
168
169
170
171
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 162

def process_purge_count(seqid, iprot, oprot)
  args = read_args(iprot, Purge_count_args)
  result = Purge_count_result.new()
  begin
    result.success = @handler.purge_count(args.pool_name)
  rescue Jp::NoSuchPool => nsp
    result.nsp = nsp
  end
  write_result(result, oprot, 'purge_count', seqid)
end

#process_start_time(seqid, iprot, oprot) ⇒ Object 



122
123
124
125
126
127
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 122

def process_start_time(seqid, iprot, oprot)
  args = read_args(iprot, Start_time_args)
  result = Start_time_result.new()
  result.success = @handler.start_time()
  write_result(result, oprot, 'start_time', seqid)
end