Package org.dcm4che3.net.pdu

Examples of org.dcm4che3.net.pdu.AAssociateRQ

317
318
319
320
321
322
323
324
325
326
327
                        "Move Destination: " + moveDest + " unknown");
            List<InstanceLocator> matches = DcmQRSCP.this.calculateMatches(keys);
            if (matches.isEmpty())
                return null;

            AAssociateRQ aarq = makeAAssociateRQ(as.getLocalAET(), moveDest, matches);
            Association storeas = openStoreAssociation(as, remote, aarq);
            BasicRetrieveTask retrieveTask = new BasicRetrieveTask(
                    Dimse.C_MOVE_RQ, as, pc, rq, matches, storeas);
            retrieveTask.setSendPendingRSPInterval(getSendPendingCMoveInterval());
            return retrieveTask;
View Full Code Here
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
            }
        }

        private AAssociateRQ makeAAssociateRQ(String callingAET,
                String calledAET, List<InstanceLocator> matches) {
            AAssociateRQ aarq = new AAssociateRQ();
            aarq.setCalledAET(calledAET);
            aarq.setCallingAET(callingAET);
            for (InstanceLocator match : matches) {
                if (aarq.addPresentationContextFor(match.cuid, match.tsuid)) {
                    if (!UID.ExplicitVRLittleEndian.equals(match.tsuid))
                        aarq.addPresentationContextFor(match.cuid, UID.ExplicitVRLittleEndian);
                    if (!UID.ImplicitVRLittleEndian.equals(match.tsuid))
                        aarq.addPresentationContextFor(match.cuid, UID.ImplicitVRLittleEndian);
                }
            }
            return aarq;
        }
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
    private int eventTypeId(Attributes eventInfo) {
        return eventInfo.containsValue(Tag.FailedSOPSequence) ? 2 : 1;
    }

    private AAssociateRQ makeAAssociateRQ() {
        AAssociateRQ aarq = new AAssociateRQ();
        aarq.setCallingAET(as.getLocalAET());
        aarq.setCalledAET(as.getRemoteAET());
        ApplicationEntity ae = as.getApplicationEntity();
        TransferCapability tc = ae.getTransferCapabilityFor(
                UID.StorageCommitmentPushModelSOPClass, TransferCapability.Role.SCP);
        aarq.addPresentationContext(
                        new PresentationContext(
                                1,
                                UID.StorageCommitmentPushModelSOPClass,
                                tc.getTransferSyntaxes()));
        aarq.addRoleSelection(
                new RoleSelection(UID.StorageCommitmentPushModelSOPClass, false, true));
        return aarq;
    }
View Full Code Here
164
165
166
167
168
169
170
171
172
173
174
        Association.LOG.trace("{} >> PDU[type={}, len={}]",
                new Object[] { as, pdutype, pdulen & 0xFFFFFFFFL });
        switch (pdutype) {
        case PDUType.A_ASSOCIATE_RQ:
            readPDU();
            as.onAAssociateRQ((AAssociateRQ) decode(new AAssociateRQ()));
            return;
        case PDUType.A_ASSOCIATE_AC:
            readPDU();
            as.onAAssociateAC((AAssociateAC) decode(new AAssociateAC()));
            return;
View Full Code Here
595
596
597
598
599
600
601
602
603
604
605
        instance.rq.setCallingAET(ae.getAETitle());
        instance.rq.setCalledAET(probedAET);
        // now start sending 128 each
        for (ArrayList<PresentationContext> subList : lst) {
            instance.rq = new AAssociateRQ();
            instance.rq.setCallingAET(ae.getAETitle());
            instance.rq.setCalledAET(probedAET);
            for (PresentationContext pc : subList)
                instance.rq.addPresentationContext(pc);
            try {
View Full Code Here
268
269
270
271
272
273
274
275
276
277
278
279
280
281
        this.status = status;
    }

    public void setTransferSyntaxes(String[] tss) {
        rq.addPresentationContext(
                new PresentationContext(1, UID.VerificationSOPClass,
                        UID.ImplicitVRLittleEndian));
        rq.addPresentationContext(
                new PresentationContext(2,
                        UID.StorageCommitmentPushModelSOPClass,
                        tss));
        ae.addTransferCapability(
                new TransferCapability(null,
                        UID.VerificationSOPClass,
View Full Code Here
167
168
169
170
171
172
173
174
175
            LOG.warn("{}: M-DELETE {} failed!", as, file);
    }

    private DicomServiceRegistry createServiceRegistry() {
        DicomServiceRegistry serviceRegistry = new DicomServiceRegistry();
        serviceRegistry.addDicomService(new BasicCEchoSCP());
        serviceRegistry.addDicomService(cstoreSCP);
        return serviceRegistry;
    }
View Full Code Here
139
140
141
142
143
144
145
146
147
    public StgCmtSCU(ApplicationEntity ae) throws IOException {
        this.remote = new Connection();
        this.ae = ae;
        DicomServiceRegistry serviceRegistry = new DicomServiceRegistry();
        serviceRegistry.addDicomService(new BasicCEchoSCP());
        serviceRegistry.addDicomService(stgcmtResultHandler);
        ae.setDimseRQHandler(serviceRegistry);
    }
View Full Code Here
452
453
454
455
456
457
458
459
460
461
462
                    Attributes.createFileMetaInformation(iuid, cuid,
                            UID.ExplicitVRLittleEndian),
                    eventInfo);
        } catch (IOException e) {
            LOG.warn(as + ": Failed to store Storage Commitment Result:", e);
            throw new DicomServiceException(Status.ProcessingFailure, e);
        } finally {
            SafeClose.close(out);
        }
        return null;
    }
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
    @Override
    public void process(Exchange exchange) throws Exception {
        DicomMessage in = exchange.getIn(DicomMessage.class);
        Dimse dimse = in.getHeader("dimse", Dimse.class);
        if (dimse != Dimse.C_ECHO_RQ)
            throw new DicomServiceException(Status.UnrecognizedOperation);
        DicomMessage out = new DicomMessage(
                Dimse.C_ECHO_RSP,
                Commands.mkEchoRSP(in.getCommand(), Status.Success));
        exchange.setOut(out);
    }
View Full Code Here
TOP

Related Classes of org.dcm4che3.net.pdu.AAssociateRQ

  • org.apache.camel.Exchange
  • org.apache.commons.cli.CommandLine
  • org.apache.commons.cli.OptionGroup
  • org.apache.commons.cli.Options
  • org.dcm4che3.audit.AuditMessages
  • org.dcm4che3.audit.AuditMessageTest
  • org.dcm4che3.camel.DicomConsumer$EndpointDimseRQHandlerAsyncCallback
  • org.dcm4che3.camel.test.EchoSCP
  • org.dcm4che3.conf.api.AttributeCoercion
  • org.dcm4che3.conf.api.AttributeCoercionsTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.