Lines Matching refs:protocol
27 import protocol
41 qt2n = protocol.qid_type2name
329 self.iproto = protocol.p9_version(version)
336 self.fidalloc = numalloc.NumAlloc(0, protocol.td.NOFID - 1)
599 resp = protocol.plain.unpack(pkt)
600 except protocol.SequenceError as err:
605 except protocol.SequenceError:
678 if isinstance(resp, protocol.rrd.Rlerror):
680 if isinstance(resp, protocol.rrd.Rerror):
734 req = protocol.rrd.Tversion(tag=tag, msize=maxio,
738 if not isinstance(resp, protocol.rrd.Rversion):
740 if isinstance(resp, protocol.rrd.Rerror):
775 afid = protocol.td.NOFID
781 n_uname = protocol.td.NONUNAME
789 if not isinstance(resp, protocol.rrd.Rattach):
820 if not isinstance(resp, protocol.rrd.Rwalk):
854 if not isinstance(resp, protocol.rrd.Rwalk):
895 if not isinstance(resp, protocol.rrd.Rstat):
906 if not isinstance(resp, protocol.rrd.Rclunk):
918 if not isinstance(resp, protocol.rrd.Rremove):
952 'dir': protocol.td.DMDIR,
953 'symlink': protocol.td.DMSYMLINK,
954 'device': protocol.td.DMDEVICE,
955 'fifo': protocol.td.DMNAMEDPIPE,
956 'socket': protocol.td.DMSOCKET,
962 if not isinstance(resp, protocol.rrd.Rcreate):
965 if resp.qid.type == protocol.td.QTFILE:
977 if not isinstance(resp, protocol.rrd.Ropen):
987 if not isinstance(resp, protocol.rrd.Rlopen):
997 if not isinstance(resp, protocol.rrd.Rread):
1010 if not isinstance(resp, protocol.rrd.Rwrite):
1026 statobj = protocol.td.stat()
1037 if self.proto == protocol.plain:
1044 'qid': protocol.td.qid(0, 0, 0),
1076 if not isinstance(resp, protocol.rrd.Rwstat):
1097 if not isinstance(resp, protocol.rrd.Rreaddir):
1109 if not isinstance(resp, protocol.rrd.Rrename):
1124 if not isinstance(resp, protocol.rrd.Rrenameat):
1139 if not isinstance(resp, protocol.rrd.Runlinkat):
1179 if not isinstance(resp, protocol.rrd.Rlcreate):
1194 if not isinstance(resp, protocol.rrd.Rmkdir):
1200 def Tgetattr(self, fid, request_mask=protocol.td.GETATTR_ALL):
1206 if not isinstance(resp, protocol.rrd.Rgetattr):
1213 bit = getattr(protocol.td, 'GETATTR_' + name.upper())
1218 bit = getattr(protocol.td, 'GETATTR_' + name.upper())
1226 if resp.valid & protocol.td.GETATTR_INO:
1250 attrobj = protocol.rrd.Tsetattr()
1269 bit = getattr(protocol.td, bitname)
1303 bit = getattr(protocol.td, bitname + '_SET')
1307 valid |= protocol.td.SETATTR_CTIME
1319 if not isinstance(resp, protocol.rrd.Rsetattr):
1331 if not isinstance(resp, protocol.rrd.Rxattrwalk):
1378 'dir': protocol.td.QTDIR,
1379 None: protocol.td.QTFILE,
1420 if isinstance(resp, protocol.rrd.Rwalk):
1466 if not isinstance(resp, protocol.rrd.Rwalk):
1488 if self.supports_all(protocol.td.Tlcreate, protocol.td.Tmkdir):
1501 perm = protocol.td.DMDIR | 0o777
1503 perm |= protocol.td.DMDIR
1534 if self.supports(protocol.td.Tmkdir):
1538 protocol.td.DMDIR | perm,
1539 protocol.td.OREAD)
1558 if qid.type != protocol.td.QTDIR:
1563 if not self.supports_all(protocol.td.Tlopen, protocol.td.Treaddir):
1592 if qid.type != protocol.td.QTDIR:
1610 qid, iounit = self.open(fid, protocol.td.OREAD)
1612 if qid.type == protocol.td.QTDIR:
1633 qid, iounit = self.lopen(fid, protocol.td.OREAD |
1634 protocol.td.L_O_DIRECTORY)
1670 if qid.type == protocol.td.QTDIR:
1705 if self.supports(protocol.td.Tunlinkat):
1712 self.unsupported(protocol.td.Tunlinkat)
1735 if self.supports_all(protocol.td.Tlopen, protocol.td.Treaddir):
1741 attrs = self.Tgetattr(fid, protocol.td.GETATTR_MODE)
1756 if statobj.qid.type == protocol.td.QTDIR:
1763 if qid.type == protocol.td.QTDIR:
1772 os.O_CREAT: protocol.td.L_O_CREAT,
1773 os.O_EXCL: protocol.td.L_O_EXCL,
1774 os.O_NOCTTY: protocol.td.L_O_NOCTTY,
1775 os.O_TRUNC: protocol.td.L_O_TRUNC,
1776 os.O_APPEND: protocol.td.L_O_APPEND,
1777 os.O_DIRECTORY: protocol.td.L_O_DIRECTORY,