session: avoid rx notifications on accepting sessions

Type: fix

Signed-off-by: Florin Coras <fcoras@cisco.com>
Change-Id: Iba37e528e968104c3ba9c8324438ba695ddddfd1

1 files changed, 5 insertions, 0 deletions

diff --git a/src/vnet/session/session.c b/src/vnet/session/session.c
index a709302c8a7..027070436fd 100644
--- a/src/vnet/session/session.c
+++ b/src/vnet/session/session.c
@@ -624,6 +624,11 @@ session_enqueue_notify_inline (session_t * s)
   SESSION_EVT (SESSION_EVT_ENQ, s, svm_fifo_max_dequeue_prod (s->rx_fifo));
 
   s->flags &= ~SESSION_F_RX_EVT;
+
+  /* Application didn't confirm accept yet */
+  if (PREDICT_FALSE (s->session_state == SESSION_STATE_ACCEPTING))
+    return 0;
+
   if (PREDICT_FALSE (app_worker_lock_and_send_event (app_wrk, s,
 						     SESSION_IO_EVT_RX)))
     return -1;

path: root/src

locals {
  datacenters = join(",", var.datacenters)
  url = join("",
    [
      "https://github.com",
      "/prometheus/prometheus/releases/download/",
      "v${var.pm_version}/",
      "prometheus-${var.pm_version}.linux-amd64.tar.gz"
    ]
  )
}

resource "nomad_job" "nomad_job_prometheus" {
  jobspec = templatefile(
    "${path.module}/conf/nomad/prometheus.hcl.tftpl",
    {
      auto_promote              = var.auto_promote,
      auto_revert               = var.auto_revert,
      canary                    = var.canary,
      cpu                       = var.cpu,
      datacenters               = local.datacenters,
      group_count               = var.group_count,
      job_name                  = var.job_name,
      max_parallel              = var.max_parallel,
      memory                    = var.memory
      port                      = var.port,
      region                    = var.region,
      service_name              = var.service_name,
      url                       = local.url,
      use_canary                = var.use_canary,
      use_host_volume           = var.use_host_volume,
      use_vault_provider        = var.vault_secret.use_vault_provider,
      vault_kv_policy_name      = var.vault_secret.vault_kv_policy_name,
      vault_kv_path             = var.vault_secret.vault_kv_path,
      vault_kv_field_access_key = var.vault_secret.vault_kv_field_access_key,
      vault_kv_field_secret_key = var.vault_secret.vault_kv_field_secret_key,
      version                   = var.pm_version,
      volume_destination        = var.volume_destination,
      volume_source             = var.volume_source
  })
  detach = false
}