This is an automated email from the ASF dual-hosted git repository.
gmurthy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git
The following commit(s) were added to refs/heads/master by this push:
new d1ae913 DISPATCH-1274 - Missed out removing immediate.c from the
previous commit. Removed it now
d1ae913 is described below
commit d1ae9134dfd9918088d0afbbbc344a1eef2cb2d0
Author: Ganesh Murthy <gmur...@redhat.com>
AuthorDate: Mon Mar 25 11:42:55 2019 -0400
DISPATCH-1274 - Missed out removing immediate.c from the previous commit.
Removed it now
---
src/immediate.c | 96 ---------------------------------------------------------
1 file changed, 96 deletions(-)
diff --git a/src/immediate.c b/src/immediate.c
deleted file mode 100644
index 5b1cab9..0000000
--- a/src/immediate.c
+++ /dev/null
@@ -1,96 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-#include "immediate_private.h"
-#include "server_private.h"
-
-#include <qpid/dispatch/threading.h>
-#include <assert.h>
-
-struct qd_immediate_t {
- qd_server_t *server;
- void (*handler)(void* context);
- void *context;
- bool armed;
-};
-
-/* Array rather than list for fast access and cache-coherence */
-static qd_immediate_t immediates[256] = {{0}};
-static size_t count = 0;
-static sys_mutex_t *lock = NULL;
-
-void qd_immediate_initialize(void) {
- lock = sys_mutex();
-}
-
-void qd_immediate_finalize(void) {
- sys_mutex_free(lock);
- lock = 0;
-}
-
-qd_immediate_t *qd_immediate(qd_dispatch_t *qd, void (*handler)(void*), void*
context) {
- sys_mutex_lock(lock);
- if (count >= sizeof(immediates)/sizeof(immediates[0])) {
- assert("exceeded max number of qd_immediate_t objects" == 0);
- return 0;
- }
- qd_immediate_t *i = &immediates[count++];
- i->server = qd ? qd->server : NULL;
- i->handler = handler;
- i->context = context;
- i->armed = false;
- sys_mutex_unlock(lock);
- return i;
-}
-
-void qd_immediate_arm(qd_immediate_t *i) {
- bool interrupt = false;
- sys_mutex_lock(lock);
- if (!i->armed) {
- interrupt = i->armed = true;
- }
- sys_mutex_unlock(lock);
- if (interrupt && i->server) {
- qd_server_interrupt(i->server);
- }
-}
-
-void qd_immediate_disarm(qd_immediate_t *i) {
- sys_mutex_lock(lock);
- i->armed = false;
- sys_mutex_unlock(lock);
-}
-
-void qd_immediate_free(qd_immediate_t *i) {
- /* Just disarm, its harmless to leave it in place. */
- qd_immediate_disarm(i);
-}
-
-void qd_immediate_visit() {
- sys_mutex_lock(lock);
- for (qd_immediate_t *i = immediates; i < immediates + count; ++i) {
- if (i->armed) {
- i->armed = false;
- sys_mutex_unlock(lock);
- i->handler(i->context);
- sys_mutex_lock(lock);
- }
- }
- sys_mutex_unlock(lock);
-}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
