35
35
import diskCacheV111 .vehicles .PoolMoverKillMessage ;
36
36
import diskCacheV111 .vehicles .PoolPassiveIoFileMessage ;
37
37
38
+ import dmg .cells .nucleus .CDC ;
38
39
import dmg .cells .nucleus .CellMessage ;
39
40
import dmg .cells .nucleus .CellPath ;
40
41
import dmg .cells .services .login .LoginManagerChildrenInfo ;
81
82
import org .dcache .chimera .nfs .vfs .Inode ;
82
83
import org .dcache .chimera .nfs .vfs .VirtualFileSystem ;
83
84
import org .dcache .chimera .nfsv41 .mover .NFS4ProtocolInfo ;
85
+ import org .dcache .commons .util .NDC ;
84
86
import org .dcache .util .RedirectedTransfer ;
85
87
import org .dcache .util .Transfer ;
86
88
import org .dcache .util .TransferRetryPolicy ;
@@ -130,7 +132,8 @@ public class NFSv41Door extends AbstractCellComponent implements
130
132
*/
131
133
private CellStub _poolManagerStub ;
132
134
private CellStub _billingStub ;
133
-
135
+ private String _cellName ;
136
+ private String _domainName ;
134
137
private PnfsHandler _pnfsHandler ;
135
138
136
139
private String _ioQueue ;
@@ -206,6 +209,8 @@ public void setEnableV3(boolean enable) {
206
209
207
210
public void init () throws Exception {
208
211
212
+ _cellName = getCellName ();
213
+ _domainName = getCellDomainName ();
209
214
final NFSv41DeviceManager _dm = this ;
210
215
211
216
_rpcService = new OncRpcSvc (_port , IpProtocolType .TCP , true );
@@ -339,7 +344,9 @@ public Layout layoutGet(CompoundContext context, Inode nfsInode, int ioMode, sta
339
344
throws IOException {
340
345
341
346
FsInode inode = _fileFileSystemProvider .inodeFromBytes (nfsInode .getFileId ());
342
- try {
347
+ try (CDC cdc = CDC .reset (_cellName , _domainName )) {
348
+ NDC .push ("pnfsid=" + inode );
349
+ NDC .push ("client=" + context .getRpcCall ().getTransport ().getRemoteSocketAddress ());
343
350
deviceid4 deviceid ;
344
351
if (inode .type () != FsInodeType .INODE || inode .getLevel () != 0 ) {
345
352
/*
@@ -349,6 +356,7 @@ public Layout layoutGet(CompoundContext context, Inode nfsInode, int ioMode, sta
349
356
} else {
350
357
InetSocketAddress remote = context .getRpcCall ().getTransport ().getRemoteSocketAddress ();
351
358
PnfsId pnfsId = new PnfsId (inode .toString ());
359
+ Transfer .initSession ();
352
360
NfsTransfer transfer = new NfsTransfer (_pnfsHandler , Subjects .ROOT , new FsPath ("/" ),
353
361
remote , stateid );
354
362
0 commit comments