Changeset 92
- Timestamp:
- 07/11/06 23:59:22 (2 years ago)
- Files:
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
streamservice/trunk/src-python/streamservice/clientapi.py
r86 r92 90 90 lnitem = [tag, body, 91 91 type('linemeta',(),dict( 92 client_tag=client_tag, 92 93 lineno=lineno+linenumberoffset, 93 remainder=len(ln)>2 and l n[2]or ''))]94 remainder=len(ln)>2 and lineitemsep.join(ln[2:]) or ''))] 94 95 parsedlines.append(lnitem) 95 96 dispatch_tag += 1 … … 198 199 else: 199 200 logger( 200 " NOTIFICATION:%s:%s <= %s" % (201 "INFO:%s:%s <= %s" % ( 201 202 replytag, querymap[replytag], 202 203 replydata)) … … 208 209 else: 209 210 logger ( 210 " NOTIFICATION:serverquery (%s,%s)" % (t,b))211 "INFO:serverquery (%s,%s)" % (t,b)) 211 212 serverqueries.append((t,b)) 212 213 if not replypending: 213 logger('SUCCESS: %s completed' % len(querymap.keys()))214 logger('SUCCESS:%s completed' % len(querymap.keys())) 214 215 break 215 logger(' NOTIFICATION:%s pending' % len(replypending.keys()))216 logger('INFO:%s pending' % len(replypending.keys())) 216 217 sleep(pollinterval) 217 218 qp[idispatchparam]=(dispatch_param, emptydispatchvalue)