Lines Matching refs:tag
389 tag = 65535
391 tag = self.tagalloc.alloc()
392 if tag is None:
394 self.tagstate[tag] = True # ie, in use, still waiting
395 return tag
397 def set_tag(self, tag, reply): argument
399 assert tag >= 0 and tag < 65536
402 state = self.tagstate.get(tag)
404 self.tagstate[tag] = reply # i.e., here's the answer
412 self, tag, reply)
413 self.retire_tag_locked(tag)
420 self, tag, reply, tag)
425 self, tag, reply, tag, state)
428 def retire_tag(self, tag): argument
430 if tag == 65535:
432 assert tag >= 0 and tag < 65535
434 self.retire_tag_locked(tag)
436 def retire_tag_locked(self, tag): argument
440 if tag in self.tagstate:
441 del self.tagstate[tag]
442 self.tagalloc.free(tag)
621 self.logger.log(logging.DEBUG, "read_resp: tag %d resp %r", resp.tag, resp)
622 self.set_tag(resp.tag, resp)
624 def wait_for(self, tag): argument
634 self.logger.log(logging.DEBUG, "wait_for: tag %d", tag)
644 resp = self.tagstate.get(tag, None)
654 if tag in self.tagstate:
655 self.tagstate[tag] = False
666 self.tagalloc.free(tag)
667 del self.tagstate[tag]
733 tag = self.get_tag(for_Tversion=True)
734 req = protocol.rrd.Tversion(tag=tag, msize=maxio,
737 resp = self.wait_for(tag)
782 tag = self.get_tag()
784 pkt = self.proto.Tattach(tag=tag, fid=fid, afid=afid,
788 resp = self.wait_for(tag)
814 tag = self.get_tag()
816 pkt = self.proto.Twalk(tag=tag, fid=fid, newfid=newfid, nwname=0,
819 resp = self.wait_for(tag)
847 tag = self.get_tag()
850 pkt = self.proto.Twalk(tag=tag, fid=fid, newfid=newfid,
853 resp = self.wait_for(tag)
891 tag = self.get_tag()
892 pkt = self.proto.Tstat(tag=tag, fid=rfid)
894 resp = self.wait_for(tag)
902 tag = self.get_tag()
903 pkt = self.proto.Tclunk(tag=tag, fid=fid)
905 resp = self.wait_for(tag)
914 tag = self.get_tag()
915 pkt = self.proto.Tremove(tag=tag, fid=fid)
917 resp = self.wait_for(tag)
949 tag = self.get_tag()
958 pkt = self.proto.Tcreate(tag=tag, fid=fid, name=name,
961 resp = self.wait_for(tag)
973 tag = self.get_tag()
974 pkt = self.proto.Topen(tag=tag, fid=fid, mode=mode)
976 resp = self.wait_for(tag)
983 tag = self.get_tag()
984 pkt = self.proto.Tlopen(tag=tag, fid=fid, flags=flags)
986 resp = self.wait_for(tag)
993 tag = self.get_tag()
994 pkt = self.proto.Tread(tag=tag, fid=fid, offset=offset, count=count)
996 resp = self.wait_for(tag)
1005 tag = self.get_tag()
1006 pkt = self.proto.Twrite(tag=tag, fid=fid, offset=offset,
1009 resp = self.wait_for(tag)
1072 tag = self.get_tag()
1073 pkt = self.proto.Twstat(tag=tag, fid=fid, data=data)
1075 resp = self.wait_for(tag)
1093 tag = self.get_tag()
1094 pkt = self.proto.Treaddir(tag=tag, fid=fid, offset=offset, count=count)
1096 resp = self.wait_for(tag)
1105 tag = self.get_tag()
1106 pkt = self.proto.Trename(tag=tag, fid=fid, dfid=dfid, name=name)
1108 resp = self.wait_for(tag)
1118 tag = self.get_tag()
1119 pkt = self.proto.Trenameat(tag=tag,
1123 resp = self.wait_for(tag)
1134 tag = self.get_tag()
1135 pkt = self.proto.Tunlinkat(tag=tag, dirfd=dirfd,
1138 resp = self.wait_for(tag)
1174 tag = self.get_tag()
1175 pkt = self.proto.Tlcreate(tag=tag, fid=fid, name=name,
1178 resp = self.wait_for(tag)
1189 tag = self.get_tag()
1190 pkt = self.proto.Tmkdir(tag=tag, dfid=dfid, name=name,
1193 resp = self.wait_for(tag)
1202 tag = self.get_tag()
1203 pkt = self.proto.Tgetattr(tag=tag, fid=fid, request_mask=request_mask)
1205 resp = self.wait_for(tag)
1312 tag = self.get_tag()
1314 attrobj.tag = tag
1318 resp = self.wait_for(tag)
1325 tag = self.get_tag()
1327 pkt = self.proto.Txattrwalk(tag=tag, fid=fid, newfid=newfid,
1330 resp = self.wait_for(tag)
1415 tag = self.get_tag()
1416 pkt = self.proto.Twalk(tag=tag, fid=startdir, newfid=fid,
1419 resp = self.wait_for(tag)
1461 tag = self.get_tag()
1462 pkt = self.proto.Twalk(tag=tag, fid=startdir, newfid=fid,
1465 resp = self.wait_for(tag)