2 * Copyright (c) 2013 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.openflowplugin.openflow.md.queue;
10 import java.util.ArrayList;
11 import java.util.Collection;
12 import java.util.List;
15 import org.opendaylight.openflowplugin.openflow.md.core.ConnectionConductor;
16 import org.opendaylight.openflowplugin.openflow.md.core.IMDMessageTranslator;
17 import org.opendaylight.openflowplugin.openflow.md.core.SwitchConnectionDistinguisher;
18 import org.opendaylight.openflowplugin.openflow.md.core.TranslatorKey;
19 import org.slf4j.Logger;
20 import org.slf4j.LoggerFactory;
26 public class TicketProcessorFactory<IN, OUT> {
28 protected static final Logger LOG = LoggerFactory
29 .getLogger(TicketProcessorFactory.class);
31 protected VersionExtractor<IN> versionExtractor;
32 protected RegisteredTypeExtractor<IN> registeredTypeExtractor;
33 protected Map<TranslatorKey, Collection<IMDMessageTranslator<IN, List<OUT>>>> translatorMapping;
34 protected MessageSpy<IN, OUT> spy;
37 * @param versionExtractor the versionExtractor to set
39 public void setVersionExtractor(VersionExtractor<IN> versionExtractor) {
40 this.versionExtractor = versionExtractor;
44 * @param registeredTypeExtractor the registeredTypeExtractor to set
46 public void setRegisteredTypeExtractor(
47 RegisteredTypeExtractor<IN> registeredTypeExtractor) {
48 this.registeredTypeExtractor = registeredTypeExtractor;
52 * @param translatorMapping the translatorMapping to set
54 public void setTranslatorMapping(
55 Map<TranslatorKey, Collection<IMDMessageTranslator<IN, List<OUT>>>> translatorMapping) {
56 this.translatorMapping = translatorMapping;
60 * @param spy the spy to set
62 public void setSpy(MessageSpy<IN, OUT> spy) {
69 * @return runnable ticket processor
71 public Runnable createProcessor(final Ticket<IN, OUT> ticket) {
73 Runnable ticketProcessor = new Runnable() {
76 LOG.debug("message received, type: {}", registeredTypeExtractor.extractRegisteredType(
77 ticket.getMessage()).getSimpleName());
80 translate = translate();
81 ticket.getResult().set(translate);
84 spy.spyIn(ticket.getMessage());
85 spy.spyOut(ticket.getResult().get());
87 } catch (Exception e) {
88 LOG.error("translation problem: {}", e.getMessage());
89 ticket.getResult().setException(e);
91 LOG.debug("message processing done (type: {}, ticket: {})",
92 registeredTypeExtractor.extractRegisteredType(ticket.getMessage()).getSimpleName(),
93 System.identityHashCode(ticket));
99 private List<OUT> translate() {
100 List<OUT> result = new ArrayList<>();
102 IN message = ticket.getMessage();
103 Class<? extends IN> messageType = registeredTypeExtractor.extractRegisteredType(ticket.getMessage());
104 ConnectionConductor conductor = ticket.getConductor();
105 Collection<IMDMessageTranslator<IN, List<OUT>>> translators = null;
106 LOG.debug("translating ticket: {}, ticket: {}", messageType.getSimpleName(), System.identityHashCode(ticket));
108 Short version = versionExtractor.extractVersion(message);
109 if (version == null) {
110 throw new IllegalArgumentException("version is NULL");
112 TranslatorKey tKey = new TranslatorKey(version, messageType.getName());
113 translators = translatorMapping.get(tKey);
115 LOG.debug("translatorKey: {} + {}", version, messageType.getName());
117 if (translators != null) {
118 for (IMDMessageTranslator<IN, List<OUT>> translator : translators) {
119 SwitchConnectionDistinguisher cookie = null;
120 // Pass cookie only for PACKT_IN
121 if (messageType.equals("PacketInMessage.class")) {
122 cookie = conductor.getAuxiliaryKey();
124 long start = System.nanoTime();
125 List<OUT> translatorOutput = translator.translate(cookie, conductor.getSessionContext(), message);
126 long end = System.nanoTime();
127 LOG.debug("translator: {} elapsed time {} ns",translator,end-start);
128 if(translatorOutput != null && !translatorOutput.isEmpty()) {
129 result.addAll(translatorOutput);
133 LOG.warn("No translators for this message Type: {}", messageType);
139 return ticketProcessor;